Mercurial > hg > Database > Alice

annotate src/main/java/alice/topology/node/IncomingConnectionInfo.java @ 485:45b3fe2375ef dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
reconnetion process will execute after disconnection event
author sugi
date Sat, 06 Dec 2014 21:10:02 +0900
parents 6e304a7a60e7
children b789b8459996
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 {
1b32ea1263f3 work but have bug
sugi
parents: 419
diff changeset
31 ods.put("cMember", hostInfo.connectionName);
1b32ea1263f3 work but have bug
sugi
parents: 419
diff changeset
32 new CreateConnectionList();
467
6e304a7a60e7 remove white space
sugi
parents: 439
diff changeset
33 count++;
485
45b3fe2375ef reconnetion process will execute after disconnection event
sugi
parents: 467
diff changeset
34 DataSegment.connect(hostInfo.connectionName, hostInfo.reverseName, hostInfo.name, hostInfo.port);
45b3fe2375ef reconnetion process will execute after disconnection event
sugi
parents: 467
diff changeset
35 ods.put(hostInfo.connectionName, "reverseKey", hostInfo.reverseName);
467
6e304a7a60e7 remove white space
sugi
parents: 439
diff changeset
36 }
6e304a7a60e7 remove white space
sugi
parents: 439
diff changeset
37
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
38 }
467
6e304a7a60e7 remove white space
sugi
parents: 439
diff changeset
39
419
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
40 IncomingConnectionInfo cs = new IncomingConnectionInfo(absName, count);
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
41 cs.hostInfo.setKey("manager", absName);
aefbe41fcf12 change tab to space
sugi
parents: 416
diff changeset
42 }
345
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
43
8f71c3e6f11d Change directory structure Maven standard
sugi
parents:
diff changeset
44 }