mirror of
https://github.com/yacy/yacy_search_server.git
synced 2024-09-19 00:01:41 +02:00
fix for fixes from this afternoon
git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@6253 6c8d7289-2bf4-0310-a012-ef5d649a1542
This commit is contained in:
parent
cf739edc2e
commit
8e56c2ace6
|
@ -109,7 +109,7 @@ public final class LoaderDispatcher {
|
|||
final yacyURL url,
|
||||
final boolean forText,
|
||||
final boolean global
|
||||
) throws IOException {
|
||||
) {
|
||||
return new Request(
|
||||
sb.peers.mySeed().hash,
|
||||
url,
|
||||
|
|
|
@ -135,14 +135,16 @@ public class MapView {
|
|||
* @throws IOException
|
||||
*/
|
||||
public void put(String key, final Map<String, String> newMap) throws IOException {
|
||||
assert (key != null);
|
||||
assert (key.length() > 0);
|
||||
assert (newMap != null);
|
||||
assert key != null;
|
||||
assert key.length() > 0;
|
||||
assert newMap != null;
|
||||
key = normalizeKey(key);
|
||||
|
||||
assert blob != null;
|
||||
synchronized (this) {
|
||||
// write entry
|
||||
blob.put(key.getBytes("UTF-8"), map2string(newMap, "W" + DateFormatter.formatShortSecond() + " ").getBytes("UTF-8"));
|
||||
String s = map2string(newMap, "W" + DateFormatter.formatShortSecond() + " ");
|
||||
assert s != null;
|
||||
blob.put(key.getBytes("UTF-8"), s.getBytes("UTF-8"));
|
||||
|
||||
// write map to cache
|
||||
cache.put(key, newMap);
|
||||
|
|
|
@ -62,16 +62,18 @@ public class SimpleARC <K, V> {
|
|||
}
|
||||
|
||||
/**
|
||||
* put a value to the cache. The value may NOT exist before.
|
||||
* This restriction is used here to check possible algorithm logic error cases.
|
||||
* put a value to the cache.
|
||||
* @param s
|
||||
* @param v
|
||||
*/
|
||||
public void put(K s, V v) {
|
||||
assert this.levelA.get(s) == null;
|
||||
assert this.levelB.get(s) == null;
|
||||
this.levelA.put(s, v);
|
||||
assert (this.levelA.size() <= cacheSize); // the cache should shrink automatically
|
||||
if (this.levelB.containsKey(s)) {
|
||||
this.levelB.put(s, v);
|
||||
assert (this.levelB.size() <= cacheSize); // the cache should shrink automatically
|
||||
} else {
|
||||
this.levelA.put(s, v);
|
||||
assert (this.levelA.size() <= cacheSize); // the cache should shrink automatically
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
Loading…
Reference in New Issue
Block a user