Mercurial > hg > Database > Alice

annotate src/main/java/alice/topology/node/IncomingConnectionInfo.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 646f705e65b1
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 alice.codesegment.CodeSegment;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
4 import alice.datasegment.CommandType;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
5 import alice.datasegment.DataSegment;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
6 import alice.datasegment.Receiver;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
7 import alice.topology.HostMessage;
641
646f705e65b1 setkey on remote
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 639
diff changeset
8 import org.apache.log4j.Logger;
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
9
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
10 public class IncomingConnectionInfo extends CodeSegment {
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
11
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
12 public Receiver hostInfo = ids.create(CommandType.TAKE);
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
13 private String absName;
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
14 private int count;
641
646f705e65b1 setkey on remote
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 639
diff changeset
15 private Logger log = Logger.getLogger(IncomingConnectionInfo.class);
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
16 private String managerKey;
404
fee3efd9257d add node when application status running
sugi
parents: 403
diff changeset
17
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
18 public IncomingConnectionInfo(String absName, int count, String managerKey) {
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
19 this.absName = absName;
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
20 this.count = count;
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
21 this.managerKey = managerKey;
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
22 hostInfo.setKey(managerKey,absName);
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
23 }
404
fee3efd9257d add node when application status running
sugi
parents: 403
diff changeset
24
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
25
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
26
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
27 @Override
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
28 public void run() {
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
29 HostMessage hostInfo = this.hostInfo.asClass(HostMessage.class);
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
30 log.info(hostInfo.toString());
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
31 if ( hostInfo.name.equals("")) { // end case
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
32 log.info(" topology node finished " + absName);
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
33 ods.put("local", "configNodeNum", count);
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
34 return ;
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
35 }
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
36 log.info("topology node " + absName + " will connect to " + hostInfo.name );
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
37 if (DataSegment.contains(hostInfo.connectionName)) {
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
38 // need to wait remove by DeleteConnection
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
39 ods.put("manager", absName, hostInfo);
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
40 } else {
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
41 DataSegment.connect(hostInfo.connectionName, hostInfo.reverseName, hostInfo.name, hostInfo.port);
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
42 ods.put(hostInfo.connectionName, "reverseKey", hostInfo.reverseName);
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
43 count++;
523
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 517
diff changeset
44
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
45 ods.put("cMember", hostInfo.connectionName);
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
46 new CreateConnectionList();
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
47 }
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 641
diff changeset
48 new IncomingConnectionInfo(absName, count, managerKey);
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
49 }
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
50
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
51 }