diff src/main/java/christie/topology/manager/ConfigWaiter.java @ 44:6664efac18ee

fix CheckCommingHost ConfigWaiter IncommingHosts
author akahori
date Thu, 02 Aug 2018 11:44:47 +0900
parents cf5a75bc3e55
children 8dfd93810041
line wrap: on
line diff
--- a/src/main/java/christie/topology/manager/ConfigWaiter.java	Thu Aug 02 11:41:29 2018 +0900
+++ b/src/main/java/christie/topology/manager/ConfigWaiter.java	Thu Aug 02 11:44:47 2018 +0900
@@ -9,7 +9,7 @@
 public class ConfigWaiter extends CodeGear {
 
 
-    // Question; done 変数がわからない...何やっているんだろう.
+    // Question: done 変数がわからない...何やっているんだろう.
     // public Receiver done = ids.create(CommandType.TAKE);
     @Take
     boolean done;
@@ -17,27 +17,21 @@
     @Take
     int nodeNum;
 
-
-
     public ConfigWaiter() { }
 
     @Override
     public void run(CodeGearManager cgm) {
         nodeNum--;
         if (nodeNum == 0) {
-            put("local", "start", ValueFactory.createNilValue());
-            put("startTime", System.currentTimeMillis());
-            put("done", true);
-            //update("running", true);
+            getLocalDGM().put("start", ValueFactory.createNilValue());
+            getLocalDGM().put("startTime", System.currentTimeMillis());
+            getLocalDGM().put("running", true);
 
             return;
         }
-        //ConfigWaiter cs3 = new ConfigWaiter(count);
-        //cs3.done.setKey("local", "done");
 
         cgm.setup(new ConfigWaiter());
         getLocalDGM().put("nodeNum", nodeNum);
-        getLocalDGM().put("done", false);
     }
 
 }