fix

Lukas Molzberger · Lukas Molzberger · commit ea5dbdc0c4f2 · 2021-05-31T16:54:43.000+02:00
diff --git a/pom.xml b/pom.xml
@@ -5,7 +5,7 @@
     <groupId>network.aika</groupId>
     <artifactId>aika</artifactId>
     <packaging>jar</packaging>
-    <version>1.4.18</version>
+    <version>1.4.19</version>
     <name>aika</name>
     <url>https://aika.network</url>
     <description>An Artificial Intelligence for Knowledge Acquisition</description>
@@ -30,7 +30,7 @@
         <url>https://github.com/aika-algorithm/aika</url>
         <connection>scm:git:git://github.com/aika-algorithm/aika.git</connection>
         <developerConnection>scm:git:git@github.com:aika-algorithm/aika.git</developerConnection>
-        <tag>aika-1.4.16</tag>
+        <tag>aika-1.4.19</tag>
     </scm>
 
 
diff --git a/src/main/java/network/aika/storage/FSSuspensionCallbackImpl.java b/src/main/java/network/aika/storage/FSSuspensionCallbackImpl.java
@@ -31,6 +31,9 @@
  */
 public class FSSuspensionCallbackImpl implements SuspensionHook {
 
+    public static String MODEL = "model";
+    public static String INDEX = "index";
+
     private AtomicInteger currentId = new AtomicInteger(0);
 
     private Map<String, Integer> labels = Collections.synchronizedMap(new TreeMap<>());
@@ -46,12 +49,18 @@ public void open(File path, String modelLabel, boolean create) throws FileNotFou
         this.path = path;
         this.modelLabel = modelLabel;
         if(create) {
-            getFile("model").deleteOnExit();
-            getFile("index").deleteOnExit();
+            File modelFile = getFile(MODEL);
+            if(modelFile.exists())
+                modelFile.deleteOnExit();
+
+            File indexFile = getFile(INDEX);
+            if(indexFile.exists())
+                indexFile.deleteOnExit();
+
         } else {
             loadIndex();
         }
-        dataStore = new RandomAccessFile(getFile("model"), "rw");
+        dataStore = new RandomAccessFile(getFile(MODEL), "rw");
     }
 
     public void close() throws IOException {
@@ -115,7 +124,7 @@ public Iterable<Integer> getAllNodeIds() {
 
     @Override
     public void loadIndex() {
-        try (FileInputStream fis = new FileInputStream(getFile("index"));
+        try (FileInputStream fis = new FileInputStream(getFile(INDEX));
              ByteArrayInputStream bais = new ByteArrayInputStream(fis.readAllBytes());
              DataInputStream dis = new DataInputStream(bais)) {
             readIndex(dis);
@@ -129,7 +138,7 @@ public void storeIndex() {
         ByteArrayOutputStream baos = new ByteArrayOutputStream();
 
         try (DataOutputStream dos = new DataOutputStream(baos);
-             FileOutputStream fos = new FileOutputStream(getFile("index"))) {
+             FileOutputStream fos = new FileOutputStream(getFile(INDEX))) {
             writeIndex(dos);
             fos.write(baos.toByteArray());
         } catch (IOException e) {
