Marown/yacy_search_server
1
0
Fork 0
mirror of https://github.com/yacy/yacy_search_server.git synced 2024-09-21 00:00:13 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

changed synchronization to fix 'contains loops' bug in kelondroTree

Browse Source 
git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@1208 6c8d7289-2bf4-0310-a012-ef5d649a1542
This commit is contained in:
orbiter 2005-12-13 11:58:55 +00:00
parent 5e2673e86c
commit 676e384b45
1 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
source/de/anomic/kelondro/kelondroTree.java
View File

@ -149,15 +149,16 @@ public class kelondroTree extends kelondroRecords implements Comparator, kelondr
public byte[][] get(byte[] key) throws IOException {
// System.out.println("kelondroTree.get " + new String(key) + " in " + filename);
byte[][] result = null;
//writeLock.stay(2000, 1000);
Search search = new Search();
search.process(key);
if (search.found()) {
result = search.getMatcher().getValues();
} else {
result = null;
// writeLock.stay(2000, 1000);
synchronized (writeSearchObj) {
writeSearchObj.process(key);
if (writeSearchObj.found()) {
result = writeSearchObj.getMatcher().getValues();
} else {
result = null;
}
}
//writeLock.release();
// writeLock.release();
return result;
}
@ -318,7 +319,7 @@ public class kelondroTree extends kelondroRecords implements Comparator, kelondr
return (lc.equals(childn.handle()));
}
public synchronized long[] putLong(byte[] key, long[] newlongs) throws IOException {
public long[] putLong(byte[] key, long[] newlongs) throws IOException {
byte[][] newrow = new byte[newlongs.length + 1][];
newrow[0] = key;
for (int i = 0; i < newlongs.length; i++) {
@ -598,7 +599,7 @@ public class kelondroTree extends kelondroRecords implements Comparator, kelondr
}
// Associates the specified value with the specified key in this map
public synchronized byte[] put(byte[] key, byte[] value) throws IOException {
public byte[] put(byte[] key, byte[] value) throws IOException {
byte[][] row = new byte[2][];
row[0] = key;
row[1] = value;