Mercurial > hg > Database > Christie

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

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix CheckCommingHost ConfigWaiter IncommingHosts
author akahori
date Thu, 02 Aug 2018 11:44:47 +0900
parents cf5a75bc3e55
children 8dfd93810041
comparison
equal deleted inserted replaced
43:ea9657dc8311 44:6664efac18ee
7 import org.msgpack.type.ValueFactory; 7 import org.msgpack.type.ValueFactory;
8 8
9 public class ConfigWaiter extends CodeGear { 9 public class ConfigWaiter extends CodeGear {
10 10
11 11
12 // Question; done 変数がわからない...何やっているんだろう. 12 // Question: done 変数がわからない...何やっているんだろう.
13 // public Receiver done = ids.create(CommandType.TAKE); 13 // public Receiver done = ids.create(CommandType.TAKE);
14 @Take 14 @Take
15 boolean done; 15 boolean done;
16 16
17 @Take 17 @Take
18 int nodeNum; 18 int nodeNum;
19 19
20
21
22 public ConfigWaiter() { } 20 public ConfigWaiter() { }
23 21
24 @Override 22 @Override
25 public void run(CodeGearManager cgm) { 23 public void run(CodeGearManager cgm) {
26 nodeNum--; 24 nodeNum--;
27 if (nodeNum == 0) { 25 if (nodeNum == 0) {
28 put("local", "start", ValueFactory.createNilValue()); 26 getLocalDGM().put("start", ValueFactory.createNilValue());
29 put("startTime", System.currentTimeMillis()); 27 getLocalDGM().put("startTime", System.currentTimeMillis());
30 put("done", true); 28 getLocalDGM().put("running", true);
31 //update("running", true);
32 29
33 return; 30 return;
34 } 31 }
35 //ConfigWaiter cs3 = new ConfigWaiter(count);
36 //cs3.done.setKey("local", "done");
37 32
38 cgm.setup(new ConfigWaiter()); 33 cgm.setup(new ConfigWaiter());
39 getLocalDGM().put("nodeNum", nodeNum); 34 getLocalDGM().put("nodeNum", nodeNum);
40 getLocalDGM().put("done", false);
41 } 35 }
42 36
43 } 37 }