Mercurial > hg > Database > Alice

annotate src/main/java/alice/topology/node/StartTopologyNode.java @ 647:e321c5ec9b58

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix toplogy manager; ring worked
author suruga
date Sun, 31 Dec 2017 19:32:27 +0900
parents cb16036404ba
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 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();
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 645
diff changeset
35 if (conf.localPort == 0) {
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 645
diff changeset
36 // local test mode
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 645
diff changeset
37 localHostName = conf.getLocalKey();
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 645
diff changeset
38 }
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 645
diff changeset
39 ods.put("config" , conf );
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
40
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
41 HostMessage host = new HostMessage(localHostName, conf.localPort);
427
6a5925219dc6 add argument "-cookie"
sugi
parents: 419
diff changeset
42 host.cookie = conf.cookie;
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 645
diff changeset
43 ods.put(manager, "hostMessage", host);
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
44
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
45 ods.put(local,"_CLIST", new ArrayList<String>());
467
6e304a7a60e7 remove white space
sugi
parents: 439
diff changeset
46
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
47 IncomingAbstractHostName cs = new IncomingAbstractHostName(conf);
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
48 cs.absName.setKey(local, "host");
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
49
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
50 IncomingReverseKey cs2 = new IncomingReverseKey();
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
51 cs2.reverseKey.setKey(local, "reverseKey");
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
52 cs2.reverseCount.setKey(local, "reverseCount");
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
53
645
cb16036404ba fix local topology test
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 562
diff changeset
54 ods.put(local, "reverseCount", 0);
419
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
55
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
56 ConfigurationFinish cs3 = new ConfigurationFinish(startCS);
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
57
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
58 }
aefbe41fcf12 change tab to space
sugi
parents: 404
diff changeset
59
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
60 }