Mercurial > hg > Database > Alice

annotate src/main/java/alice/topology/node/IncomingConnectionInfo.java @ 523:145c425db88d dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add CompressedLDSM
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Thu, 09 Apr 2015 18:36:26 +0900
parents 80e461aa10e9
children 0832af83583f 767d93626b88 1a860019b2fe ded89ea8861f 8f765e3eed24 8d9f35701fdb
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;
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
8
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
9 public class IncomingConnectionInfo extends CodeSegment {
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
10
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
11 public Receiver hostInfo = ids.create(CommandType.TAKE);
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
12 private String absName;
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
13 private int count;
404
fee3efd9257d add node when application status running
sugi
parents: 403
diff changeset
14
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
15 public IncomingConnectionInfo(String absName, int count) {
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
16 this.absName = absName;
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
17 this.count = count;
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
18 }
404
fee3efd9257d add node when application status running
sugi
parents: 403
diff changeset
19
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
20
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
21 @Override
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
22 public void run() {
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
23 if (this.hostInfo.getVal() == null) {
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
24 ods.put("local", "configNodeNum", count);
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
25 } else {
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
26 HostMessage hostInfo = this.hostInfo.asClass(HostMessage.class);
429
1b32ea1263f3 work but have bug
sugi
parents: 419
diff changeset
27 if (DataSegment.contains(hostInfo.connectionName)) {
485
45b3fe2375ef reconnetion process will execute after disconnection event
sugi
parents: 467
diff changeset
28 // need to wait remove by DeleteConnection
45b3fe2375ef reconnetion process will execute after disconnection event
sugi
parents: 467
diff changeset
29 ods.put("manager", absName, hostInfo);
429
1b32ea1263f3 work but have bug
sugi
parents: 419
diff changeset
30 } else {
485
45b3fe2375ef reconnetion process will execute after disconnection event
sugi
parents: 467
diff changeset
31 DataSegment.connect(hostInfo.connectionName, hostInfo.reverseName, hostInfo.name, hostInfo.port);
45b3fe2375ef reconnetion process will execute after disconnection event
sugi
parents: 467
diff changeset
32 ods.put(hostInfo.connectionName, "reverseKey", hostInfo.reverseName);
495
b789b8459996 change timing add managerKey to connectionList
sugi
parents: 485
diff changeset
33 count++;
523
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 517
diff changeset
34
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 517
diff changeset
35 ods.put("cMember", hostInfo.connectionName);
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 517
diff changeset
36 new CreateConnectionList();
467
6e304a7a60e7 remove white space
sugi
parents: 439
diff changeset
37 }
523
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 517
diff changeset
38
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
39 }
467
6e304a7a60e7 remove white space
sugi
parents: 439
diff changeset
40
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
41 IncomingConnectionInfo cs = new IncomingConnectionInfo(absName, count);
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
42 cs.hostInfo.setKey("manager", absName);
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
43 }
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
44
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
45 }