fixed bugs in last commit

git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@65 6c8d7289-2bf4-0310-a012-ef5d649a1542

source/de/anomic/plasma/plasmaCrawlWorker.java

@@ -104,7 +104,7 @@ public final class plasmaCrawlWorker extends Thread {
         this.log = log;
     }
 
-    public void execute(plasmaCrawlLoaderMessage theMsg) {
+    public synchronized void execute(plasmaCrawlLoaderMessage theMsg) {
         this.theMsg = theMsg;
         
         this.url = theMsg.url;

source/de/anomic/plasma/plasmaSearch.java

@@ -301,11 +301,16 @@ public class plasmaSearch {
 	Enumeration e = searchResult.elements(true);
 	plasmaWordIndexEntry entry;
         long startCreateTime = System.currentTimeMillis();
+	try {
 	    while ((e.hasMoreElements()) &&
 		   ((acc.sizeFetched() < minEntries) || (System.currentTimeMillis() - startCreateTime < maxTime))) {
 		entry = (plasmaWordIndexEntry) e.nextElement();
 		acc.addResult(entry);
 	    }
+	} catch (kelondroException ee) {
+	    serverLog.logError("PLASMA", "Database Failure during plasmaSearch.order: " + ee.getMessage());
+	    ee.printStackTrace();
+	}
         long startSortTime = System.currentTimeMillis();
         acc.sortResults();
         System.out.println("plasmaSearch.order: minEntries = " + minEntries + ", effectiveEntries = " + acc.sizeOrdered() + ", demanded Time = " + maxTime + ", effectiveTime = " + (System.currentTimeMillis() - startCreateTime) + ", createTime = " + (startSortTime - startCreateTime) + ", sortTime = " + (System.currentTimeMillis() - startSortTime));

source/de/anomic/plasma/plasmaSwitchboard.java

@@ -116,7 +116,7 @@ public class plasmaSwitchboard extends serverAbstractSwitch implements serverSwi
 
 
     // load slots
-    private static final int crawlSlots = 6;
+    private static final int crawlSlots = 8;
 
     // couloured list management
     public static TreeSet blueList = null;
@@ -411,8 +411,7 @@ public class plasmaSwitchboard extends serverAbstractSwitch implements serverSwi
     public boolean deQueue() {
 	// work off fresh entries from the proxy or from the crawler
 
-	synchronized (processStack) {
-	    if (processStack.size() == 0) return false; // noting to do
+	if (processStack.size() == 0) return false; // nothing to do
 	
 	// in case that the server is very busy we do not work off the queue too fast
 	if (serverJobs > 10) try {Thread.currentThread().sleep(10 * serverJobs);} catch (InterruptedException e) {}
@@ -423,7 +422,6 @@ public class plasmaSwitchboard extends serverAbstractSwitch implements serverSwi
 		     ", localStackSize=" + noticeURL.localStackSize() +
 		     ", remoteStackSize=" + noticeURL.remoteStackSize());
 	processResourceStack((plasmaHTCache.Entry) processStack.removeFirst());
-	}
 	return true;
     }
     

source/de/anomic/plasma/plasmaWordIndexRAMCache.java

@@ -171,15 +171,15 @@ public class plasmaWordIndexRAMCache extends Thread {
 	return flushKey(key, "flushSpecific");
     }
     
-    private synchronized int flushKey(String key, String caller) throws IOException {
-	Vector v = (Vector) cache.get(key);
-	if (v == null) {
-	    //serverLog.logDebug("PLASMA INDEXING", "flushKey: '" + caller + "' forced to flush non-existing key " + key);
-	    return 0;
-	}
-	pic.addEntriesToIndex(key, v);
+    private int flushKey(String key, String caller) throws IOException {
+	Vector v = null;
+	synchronized (cache) {
+	    v = (Vector) cache.get(key);
+	    if (v == null) return 0; // flushing of nonexisting key
 	    cache.remove(key);
 	    hashScore.deleteScore(key);
+	}
+	pic.addEntriesToIndex(key, v);
 	return v.size();
     }