Mercurial > hg > Members > tatsuki > Alice

annotate src/main/java/alice/topology/node/ConfigurationFinish.java @ 346:d46c42352e4f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
change images position. It is under src/main/resources
author sugi
date Mon, 21 Apr 2014 19:57:44 +0900
parents 8f71c3e6f11d
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
1 package alice.topology.node;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
2
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
3 import org.msgpack.type.ValueFactory;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
4
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
5 import alice.codesegment.CodeSegment;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
6 import alice.datasegment.CommandType;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
7 import alice.datasegment.Receiver;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
8 import alice.topology.manager.reconnection.ReceiveReconnectData;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
9
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
10 public class ConfigurationFinish extends CodeSegment {
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
11
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
12 public Receiver reverseCount = ids.create(CommandType.PEEK);
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
13 public Receiver configNodeNum = ids.create(CommandType.PEEK);
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
14 private CodeSegment startCS;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
15
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
16 public ConfigurationFinish(CodeSegment startCS) {
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
17 this.startCS = startCS;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
18 }
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
19
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
20 @Override
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
21 public void run() {
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
22 if (reverseCount.getVal().equals(configNodeNum.getVal())) {
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
23 new ReceiveReconnectData();
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
24
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
25 ods.put("manager", "done", ValueFactory.createNilValue());
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
26 Start cs = new Start(startCS);
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
27 cs.done.setKey("manager", "start");
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
28 return;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
29 }
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
30
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
31 ConfigurationFinish cs3 = new ConfigurationFinish(startCS);
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
32 cs3.reverseCount.setKey("local", "reverseCount", this.reverseCount.index);
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
33 cs3.configNodeNum.setKey("local", "configNodeNum");
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
34 }
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
35
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
36 }