Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/manager/ConfigWaiter.java @ 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 f4b388422045
children f884c1bd0d36
comparison
equal deleted inserted replaced
61:20d4c0cce914 62:ea03d9c01601
2 2
3 3
4 import christie.annotation.Take; 4 import christie.annotation.Take;
5 import christie.codegear.CodeGear; 5 import christie.codegear.CodeGear;
6 import christie.codegear.CodeGearManager; 6 import christie.codegear.CodeGearManager;
7 import org.msgpack.type.NilValue;
7 import org.msgpack.type.ValueFactory; 8 import org.msgpack.type.ValueFactory;
8 9
9 public class ConfigWaiter extends CodeGear { 10 public class ConfigWaiter extends CodeGear {
10 11
11 12
12 // Question: done 変数がわからない...何やっているんだろう. 13 // Question: done 変数がわからない...何やっているんだろう.
13 // public Receiver done = ids.create(CommandType.TAKE); 14 // public Receiver done = ids.create(CommandType.TAKE);
14 //@Take 15 @Take
15 //boolean done; 16 String done;
16 17
17 @Take 18 @Take
18 int nodeNum; 19 int nodeNum;
19 20
20 public ConfigWaiter() { } 21 public ConfigWaiter() { }
21 22
22 @Override 23 @Override
23 protected void run(CodeGearManager cgm) { 24 protected void run(CodeGearManager cgm) {
24 nodeNum--; 25 nodeNum--;
25 if (nodeNum == 0) { 26 if (nodeNum == 0) {
26 getLocalDGM().put("start", ValueFactory.createNilValue()); 27 //getLocalDGM().put("start", "start");
27 getLocalDGM().put("startTime", System.currentTimeMillis()); 28 getLocalDGM().put("startTime", System.currentTimeMillis());
28 getLocalDGM().put("running", true); 29 getLocalDGM().put("running", true);
29 30
30 return; 31 return;
31 } 32 }