Mercurial > hg > Database > Alice

annotate src/alice/topology/node/IncomingConnectionInfo.java @ 316:9e84deb9b1e0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Respond Worked
author sugi
date Tue, 10 Dec 2013 17:40:13 +0900
parents f866178f3018
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
25
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 package alice.topology.node;
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
2
258
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
3 import java.util.ArrayList;
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
4 import java.util.List;
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
5
25
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 import alice.codesegment.CodeSegment;
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 import alice.datasegment.CommandType;
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 import alice.datasegment.DataSegment;
33
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
9 import alice.datasegment.Receiver;
25
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
10 import alice.topology.HostMessage;
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
11
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 public class IncomingConnectionInfo extends CodeSegment {
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
13
33
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
14 public Receiver hostInfo = ids.create(CommandType.TAKE);
258
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
15 private List<String> connectionList;
26
9c6b9e032338 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
16 private String absName;
28
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 27
diff changeset
17 private int count;
26
9c6b9e032338 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
18
28
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 27
diff changeset
19 public IncomingConnectionInfo(String absName, int count) {
25
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
20 this.absName = absName;
28
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 27
diff changeset
21 this.count = count;
258
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
22 this.connectionList = new ArrayList<String>();
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
23 }
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
24
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
25 public IncomingConnectionInfo(String absName, int count, List<String> connectionList) {
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
26 this.absName = absName;
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
27 this.count = count;
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
28 this.connectionList = connectionList;
25
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
29 }
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
30
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
31 @Override
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
32 public void run() {
214
fec0726bb126 remove error
one
parents: 212
diff changeset
33 if (this.hostInfo.getVal() == null) {
31
5c704b9a9a87 add ring script
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
34 ods.put("local", "configNodeNum", count);
26
9c6b9e032338 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
35 return;
9c6b9e032338 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
36 }
34
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
37
216
21bd8af1cf26 change asClass method
one
parents: 214
diff changeset
38 HostMessage hostInfo = this.hostInfo.asClass(HostMessage.class);
316
9e84deb9b1e0 Respond Worked
sugi
parents: 274
diff changeset
39 //System.out.println(hostInfo.reconnectFlag);
274
f866178f3018 success to reconnect
sugi
parents: 271
diff changeset
40 DataSegment.connect(hostInfo.connectionName, hostInfo.reverseName, hostInfo.name, hostInfo.port, hostInfo.reconnectFlag);
34
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
41 ods.put(hostInfo.connectionName, "reverseKey", hostInfo.reverseName);
258
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
42 connectionList.add(hostInfo.connectionName);
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
43 ods.update("_CLIST", connectionList);
7f7b3506bff9 client can get connection list setkey(_CLIST);
sugi
parents: 216
diff changeset
44 IncomingConnectionInfo cs = new IncomingConnectionInfo(absName, ++count, connectionList);
26
9c6b9e032338 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
45 cs.hostInfo.setKey("manager", absName);
271
3667ab045530 refactor
sugi
parents: 270
diff changeset
46
25
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
47 }
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
48
50c75cb3de60 implements TopologyNode
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
49 }