Mercurial > hg > Database > Alice

annotate src/main/java/alice/topology/node/StartTopologyNode.java @ 646:3c060de44c2e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
debug toplogy test
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sun, 31 Dec 2017 12:06:45 +0900
parents cb16036404ba
children e321c5ec9b58
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 java.net.InetAddress;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
4 import java.net.UnknownHostException;
439
9f6674e503df change timing putting Connection list
sugi
parents: 427
diff changeset
5 import java.util.ArrayList;
9f6674e503df change timing putting Connection list
sugi
parents: 427
diff changeset
6
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
7 import alice.codesegment.CodeSegment;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
8 import alice.datasegment.DataSegment;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
9 import alice.topology.HostMessage;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
10
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
11 public class StartTopologyNode extends CodeSegment {
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
12
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
13 private final String manager;
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
14 private final String local;
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
15 private TopologyNodeConfig conf;
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
16 private CodeSegment startCS;
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
17
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
18 public StartTopologyNode(TopologyNodeConfig conf, CodeSegment startCS) {
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
19 this.conf = conf;
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
20 this.startCS = startCS;
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
21 this.manager = conf.getManagerKey();
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
22 this.local = conf.getLocalKey();
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
23 }
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
24
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
25 @Override
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
26 public void run() {
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
27 DataSegment.connect(manager, manager, conf.getManagerHostName(), conf.getManagerPort());
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
28 String localHostName = null;
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
29 try {
562
1cf2697d51a6 add j3dcore.jar to lib
Nozomi
parents: 523
diff changeset
30 localHostName = InetAddress.getLocalHost().getHostAddress();
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
31 } catch (UnknownHostException e) {
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
32 e.printStackTrace();
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
33 }
427
6a5925219dc6 add argument "-cookie"
sugi
parents: 419
diff changeset
34 new SaveCookie();
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
35
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
36 HostMessage host = new HostMessage(localHostName, conf.localPort);
427
6a5925219dc6 add argument "-cookie"
sugi
parents: 419
diff changeset
37 host.cookie = conf.cookie;
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
38 ods.put(manager, "host", host);
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
39
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
40 ods.put(local,"_CLIST", new ArrayList<String>());
467
6e304a7a60e7 remove white space
sugi
parents: 439
diff changeset
41
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
42 IncomingAbstractHostName cs = new IncomingAbstractHostName(conf);
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
43 cs.absName.setKey(local, "host");
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
44
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
45 IncomingReverseKey cs2 = new IncomingReverseKey();
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
46 cs2.reverseKey.setKey(local, "reverseKey");
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
47 cs2.reverseCount.setKey(local, "reverseCount");
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
48
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
49 ods.put(local, "reverseCount", 0);
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
50
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
51 ConfigurationFinish cs3 = new ConfigurationFinish(startCS);
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
52 cs3.reverseCount.setKey(local, "reverseCount");
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
53 cs3.configNodeNum.setKey(local, "configNodeNum");
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
54
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
55 }
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
56
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
57 }