Mercurial > hg > Database > Christie

changeset 62:ea03d9c01601

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix ConfigWaiter commentout "start"
author akahori
date Tue, 28 Aug 2018 18:58:54 +0900
parents 20d4c0cce914
children c73bb6a17034
files src/main/java/christie/topology/manager/ConfigWaiter.java
diffstat 1 files changed, 4 insertions(+), 3 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/christie/topology/manager/ConfigWaiter.java	Tue Aug 28 18:56:45 2018 +0900
+++ b/src/main/java/christie/topology/manager/ConfigWaiter.java	Tue Aug 28 18:58:54 2018 +0900
@@ -4,6 +4,7 @@
 import christie.annotation.Take;
 import christie.codegear.CodeGear;
 import christie.codegear.CodeGearManager;
+import org.msgpack.type.NilValue;
 import org.msgpack.type.ValueFactory;
 
 public class ConfigWaiter extends CodeGear {
@@ -11,8 +12,8 @@
 
     // Question: done 変数がわからない...何やっているんだろう.
     // public Receiver done = ids.create(CommandType.TAKE);
-    //@Take
-    //boolean done;
+    @Take
+    String done;
 
     @Take
     int nodeNum;
@@ -23,7 +24,7 @@
     protected void run(CodeGearManager cgm) {
         nodeNum--;
         if (nodeNum == 0) {
-            getLocalDGM().put("start", ValueFactory.createNilValue());
+            //getLocalDGM().put("start", "start");
             getLocalDGM().put("startTime", System.currentTimeMillis());
             getLocalDGM().put("running", true);