Mercurial > hg > Database > Christie
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); } }