Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/manager/ConfigWaiter.java @ 41:cf5a75bc3e55

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