made compression optional

LukasMolzberger · LukasMolzberger · commit 67acb45de17f · 2021-05-28T14:05:41.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.14</version>
+    <version>1.4.15</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.13</tag>
+        <tag>aika-1.4.15</tag>
     </scm>
 
 
diff --git a/src/main/java/network/aika/Provider.java b/src/main/java/network/aika/Provider.java
@@ -20,6 +20,8 @@ public class Provider<T extends AbstractNode> implements Comparable<Provider<?>>
 
     private static final Logger log = LoggerFactory.getLogger(Provider.class);
 
+    public static boolean ENABLE_COMPRESSION = true;
+
     protected Model model;
     protected Integer id;
 
@@ -129,13 +131,20 @@ public synchronized void suspend(SuspensionMode sm) {
     public void save() {
         if (n.modified) {
             ByteArrayOutputStream baos = new ByteArrayOutputStream();
-            try (
-                    GZIPOutputStream gzipos = new GZIPOutputStream(baos);
-                    DataOutputStream dos = new DataOutputStream(gzipos)) {
-
-                n.write(dos);
-            } catch (IOException e) {
-                throw new RuntimeException(e);
+            if(ENABLE_COMPRESSION) {
+                try (
+                        GZIPOutputStream gzipos = new GZIPOutputStream(baos);
+                        DataOutputStream dos = new DataOutputStream(gzipos)) {
+                    n.write(dos);
+                } catch (IOException e) {
+                    throw new RuntimeException(e);
+                }
+            } else {
+                try (DataOutputStream dos = new DataOutputStream(baos)) {
+                    n.write(dos);
+                } catch (IOException e) {
+                    throw new RuntimeException(e);
+                }
             }
 
             model.suspensionHook.store(id, n.getLabel(), n.getModelLabels(), n.isNeuron(), baos.toByteArray());
@@ -155,12 +164,20 @@ private void reactivate() {
         }
 
         ByteArrayInputStream bais = new ByteArrayInputStream(data);
-        try (
-                GZIPInputStream gzipis = new GZIPInputStream(bais);
-                DataInputStream dis = new DataInputStream(gzipis)) {
-            n = (T) AbstractNode.read(dis, this);
-        } catch (IOException e) {
-            throw new RuntimeException(e);
+        if(ENABLE_COMPRESSION) {
+            try (
+                    GZIPInputStream gzipis = new GZIPInputStream(bais);
+                    DataInputStream dis = new DataInputStream(gzipis)) {
+                n = (T) AbstractNode.read(dis, this);
+            } catch (IOException e) {
+                throw new RuntimeException(e);
+            }
+        } else {
+            try (DataInputStream dis = new DataInputStream(bais)) {
+                n = (T) AbstractNode.read(dis, this);
+            } catch (IOException e) {
+                throw new RuntimeException(e);
+            }
         }
 
         n.reactivate();
