Mercurial > hg > Database > Alice
annotate src/main/java/alice/topology/manager/ConfigWaiter.java @ 599:3284428f525e dispose
add MetaCodeSegment & MetaDSM
author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
---|---|
date | Mon, 15 Feb 2016 01:16:35 +0900 |
parents | 59e84cd75403 |
children | 8a9fd716c335 |
rev | line source |
---|---|
401 | 1 package alice.topology.manager; |
2 | |
599
3284428f525e
add MetaCodeSegment & MetaDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
432
diff
changeset
|
3 import alice.codesegment.MetaCodeSegment; |
401 | 4 import org.msgpack.type.ValueFactory; |
5 | |
6 import alice.codesegment.CodeSegment; | |
7 import alice.datasegment.CommandType; | |
8 import alice.datasegment.Receiver; | |
9 | |
599
3284428f525e
add MetaCodeSegment & MetaDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
432
diff
changeset
|
10 public class ConfigWaiter extends MetaCodeSegment { |
419 | 11 |
12 public Receiver done = ids.create(CommandType.TAKE); | |
13 public int count; | |
14 | |
15 public ConfigWaiter(int nodeNum) { | |
16 this.count = nodeNum; | |
17 } | |
401 | 18 |
419 | 19 @Override |
20 public void run() { | |
21 count--; | |
22 if (count == 0) { | |
23 ods.put("local", "start", ValueFactory.createNilValue()); | |
432 | 24 ods.update("running", true); |
419 | 25 return; |
26 } | |
27 ConfigWaiter cs3 = new ConfigWaiter(count); | |
28 cs3.done.setKey("local", "done"); | |
29 } | |
401 | 30 |
31 } |