From 55d7c7a1921d1773f25789dcbb9041320ba9ec2a Mon Sep 17 00:00:00 2001
From: Anil Koyuncu <koyuncu.anil@gmail.com>
Date: Thu, 5 Apr 2018 18:29:56 +0200
Subject: [PATCH] deneme

---
 .../cluster/AkkaTreeLoader.java               | 26 +++++++++++++++++++
 .../cluster/ImportPairs2DB.java               | 12 ++++++---
 2 files changed, 34 insertions(+), 4 deletions(-)

diff --git a/src/main/java/edu/lu/uni/serval/FixPatternParser/cluster/AkkaTreeLoader.java b/src/main/java/edu/lu/uni/serval/FixPatternParser/cluster/AkkaTreeLoader.java
index 1e2e76e..3a718bc 100644
--- a/src/main/java/edu/lu/uni/serval/FixPatternParser/cluster/AkkaTreeLoader.java
+++ b/src/main/java/edu/lu/uni/serval/FixPatternParser/cluster/AkkaTreeLoader.java
@@ -65,6 +65,32 @@ public class AkkaTreeLoader {
         log.info("Load done");
     }
 
+    public static void loadRedisWait(String cmd){
+        Process process;
+
+        try {
+//            String comd = String.format(cmd, f.getAbsoluteFile());
+            process = Runtime.getRuntime()
+
+                    .exec(cmd);
+
+
+            StreamGobbler streamGobbler =
+                    new StreamGobbler(process.getInputStream(), System.out::println);
+            Executors.newSingleThreadExecutor().submit(streamGobbler);
+            int exitCode = process.waitFor();
+            assert exitCode == 0;
+
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        log.info("Load done");
+    }
+
     public static void main(String[] args) {
 
 
diff --git a/src/main/java/edu/lu/uni/serval/FixPatternParser/cluster/ImportPairs2DB.java b/src/main/java/edu/lu/uni/serval/FixPatternParser/cluster/ImportPairs2DB.java
index 2bb5d5a..a5a54ed 100644
--- a/src/main/java/edu/lu/uni/serval/FixPatternParser/cluster/ImportPairs2DB.java
+++ b/src/main/java/edu/lu/uni/serval/FixPatternParser/cluster/ImportPairs2DB.java
@@ -11,7 +11,8 @@ import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import static edu.lu.uni.serval.FixPatternParser.cluster.AkkaTreeLoader.loadRedis;
-import static jdk.nashorn.internal.runtime.regexp.joni.Config.log;
+import static edu.lu.uni.serval.FixPatternParser.cluster.AkkaTreeLoader.loadRedisWait;
+
 
 /**
  * Created by anilkoyuncu on 05/04/2018.
@@ -54,16 +55,17 @@ public class ImportPairs2DB {
         Integer portInt = Integer.valueOf(portInner);
 
         for (File pj : pjs) {
-            log.info(String.valueOf(portInt));
+
             String cmd = "bash "+dbDir + "/" + "startServer.sh" +" %s %s %s";
             cmd = String.format(cmd, dbDir,pj.getName() +".rdb", portInt);
-            loadRedis(cmd,serverWait);
+            log.info(cmd);
+            loadRedisWait(cmd);
 
             cmd = "bash "+dbDir + "redisImportSingle.sh" +" %s %s";
 
             cmd = String.format(cmd, pj.getPath(), portInt);
             log.info(cmd);
-            loadRedis(cmd,serverWait);
+            loadRedisWait(cmd);
 
             portInt++;
 
@@ -72,4 +74,6 @@ public class ImportPairs2DB {
 
         log.info(parameters);
     }
+
+
 }