From b33094e925448c55df59401a28c56daf3421f787 Mon Sep 17 00:00:00 2001
From: theli <theli@6c8d7289-2bf4-0310-a012-ef5d649a1542>
Date: Tue, 30 Aug 2005 09:07:42 +0000
Subject: [PATCH] *) Trying to solve "Too many open files bug" *) Temp.Bugfix
 for "Bug in Index Restore"    See:
 http://www.yacy-forum.de/viewtopic.php?p=8647#8647    Orbiter: Please take a
 look

git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@602 6c8d7289-2bf4-0310-a012-ef5d649a1542
---
 source/de/anomic/kelondro/kelondroFileRA.java | 56 +++++++++++++------
 .../anomic/plasma/plasmaWordIndexCache.java   | 14 ++++-
 2 files changed, 49 insertions(+), 21 deletions(-)

diff --git a/source/de/anomic/kelondro/kelondroFileRA.java b/source/de/anomic/kelondro/kelondroFileRA.java
index 5f987d3f2..258be8d7e 100644
--- a/source/de/anomic/kelondro/kelondroFileRA.java
+++ b/source/de/anomic/kelondro/kelondroFileRA.java
@@ -97,33 +97,53 @@ public class kelondroFileRA extends kelondroAbstractRA implements kelondroRA {
     
     // some static tools
     public static void writeProperties(File f, Properties props, String comment) throws IOException {
-	File fp = f.getParentFile();
-	if (fp != null) fp.mkdirs();
-	kelondroRA kra = new kelondroFileRA(f);
-	kra.writeProperties(props, comment);
-	kra.close();
+        File fp = f.getParentFile();
+        if (fp != null) fp.mkdirs();
+        kelondroRA kra = null;
+        try {
+            kra = new kelondroFileRA(f);
+            kra.writeProperties(props, comment);
+            kra.close();
+        } finally {
+            if (kra != null) try {kra.close();}catch(Exception e){}
+        }
     }
 
     public static Properties readProperties(File f) throws IOException {
-	kelondroRA kra = new kelondroFileRA(f);
-	Properties props = kra.readProperties();
-	kra.close();
-	return props;
+        kelondroRA kra = null;
+        try {
+            kra = new kelondroFileRA(f);
+            Properties props = kra.readProperties();
+            kra.close();
+            return props;
+        } finally {
+            if (kra != null) try{kra.close();}catch(Exception e) {}
+        }
     }
 
     public static void writeMap(File f, Map map, String comment) throws IOException {
-	File fp = f.getParentFile();
-	if (fp != null) fp.mkdirs();
-	kelondroRA kra = new kelondroFileRA(f);
-	kra.writeMap(map, comment);
-	kra.close();
+        File fp = f.getParentFile();
+        if (fp != null) fp.mkdirs();
+        kelondroRA kra = null;
+        try {
+            kra = new kelondroFileRA(f);
+            kra.writeMap(map, comment);
+            kra.close();
+        } finally {
+            if (kra != null) try {kra.close();}catch(Exception e){}
+        }
     }
 
     public static Map readMap(File f) throws IOException {
-	kelondroRA kra = new kelondroFileRA(f);
-	Map map = kra.readMap();
-	kra.close();
-	return map;
+        kelondroRA kra = null;
+        try {
+            kra = new kelondroFileRA(f);
+            Map map = kra.readMap();
+            kra.close();
+            return map;
+        } finally {
+            if (kra != null) try {kra.close();}catch(Exception e){}
+        }
     }
 
 }
diff --git a/source/de/anomic/plasma/plasmaWordIndexCache.java b/source/de/anomic/plasma/plasmaWordIndexCache.java
index f8462811b..c2047e0d7 100644
--- a/source/de/anomic/plasma/plasmaWordIndexCache.java
+++ b/source/de/anomic/plasma/plasmaWordIndexCache.java
@@ -139,7 +139,9 @@ public final class plasmaWordIndexCache implements plasmaWordIndexInterface {
         log.logSystem("creating dump for index cache, " + cache.size() + " words (and much more urls)");
         File indexDumpFile = new File(databaseRoot, indexArrayFileName);
         if (indexDumpFile.exists()) indexDumpFile.delete();
-        kelondroArray dumpArray = new kelondroArray(indexDumpFile, plasmaWordIndexAssortment.bufferStructureBasis, 0);
+        kelondroArray dumpArray = null;
+        try {
+        dumpArray = new kelondroArray(indexDumpFile, plasmaWordIndexAssortment.bufferStructureBasis, 0);
         long startTime = System.currentTimeMillis();
         long messageTime = System.currentTimeMillis() + 5000;
         long wordsPerSecond = 0, wordcount = 0, urlcount = 0;
@@ -183,8 +185,12 @@ public final class plasmaWordIndexCache implements plasmaWordIndexInterface {
                 }
             }
         }
-	dumpArray.close();
+        dumpArray.close();
+        dumpArray = null;
         log.logSystem("dumped " + urlcount + " word/url relations in " + ((System.currentTimeMillis() - startTime) / 1000) + " seconds");
+        } finally {
+            if (dumpArray != null) try {dumpArray.close();}catch(Exception e){}
+        }
     }
     
     private long restore() throws IOException {
@@ -207,7 +213,7 @@ public final class plasmaWordIndexCache implements plasmaWordIndexInterface {
                 while (i-- > 0) {
                     // get out one entry
                     row = dumpArray.get(i);
-                    if ((row[0] == null) || (row[1] == null) || (row[2] == null) || (row[3] == null) || (row[4] == null)) continue;
+                    if ((row[0] == null)/* || (row[1] == null) || (row[2] == null)*/ || (row[3] == null) || (row[4] == null)) continue;
                     wordHash = new String(row[0]);
                     creationTime = kelondroRecords.bytes2long(row[2]);
                     wordEntry = new plasmaWordIndexEntry(new String(row[3]), new String(row[4]));
@@ -231,6 +237,8 @@ public final class plasmaWordIndexCache implements plasmaWordIndexInterface {
         } catch (kelondroException e) {
             // restore failed
             log.logError("restore of indexCache array dump failed: " + e.getMessage(), e);
+        } finally {
+            if (dumpArray != null) try {dumpArray.close();}catch(Exception e){}
         }
         return urlCount;
     }