flush the compressor cache when a cleanup is done

yacy · Jun 7, 2012 · b0095c8 · b0095c8
1 parent a61f44f
commit b0095c8
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 2 deletions.
diff --git a/source/de/anomic/crawler/Cache.java b/source/de/anomic/crawler/Cache.java
@@ -143,6 +143,10 @@ public void run() {
         }
     }
 
+    public static void commit() {
+    	fileDB.flushAll();
+    }
+
     /**
      * clear the cache
      */

diff --git a/source/net/yacy/kelondro/blob/Compressor.java b/source/net/yacy/kelondro/blob/Compressor.java
@@ -335,7 +335,7 @@ private boolean flushOne() {
         }
     }
 
-    private void flushAll() {
+    public void flushAll() {
         while (!this.buffer.isEmpty()) {
             if (!flushOne()) break;
         }

diff --git a/source/net/yacy/search/Switchboard.java b/source/net/yacy/search/Switchboard.java
@@ -1892,7 +1892,7 @@ public indexingQueueEntry(
     }
 
     public int cleanupJobSize() {
-        int c = 0;
+        int c = 1; // "es gibt immer was zu tun"
         if ( (this.crawlQueues.delegatedURL.stackSize() > 1000) ) {
             c++;
         }
@@ -1909,6 +1909,9 @@ public int cleanupJobSize() {
 
     public boolean cleanupJob() {
         try {
+        	// flush the document compressor cache
+        	Cache.commit();
+
             // clear caches if necessary
             if ( !MemoryControl.request(8000000L, false) ) {
                 for ( final Segment indexSegment : this.indexSegments ) {