Mercurial > hg > Database > Alice
annotate src/main/java/alice/topology/manager/IncomingHosts.java @ 641:646f705e65b1
setkey on remote
author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
---|---|
date | Sun, 31 Dec 2017 01:08:52 +0900 |
parents | 8d9f35701fdb |
children | e321c5ec9b58 |
rev | line source |
---|---|
401 | 1 package alice.topology.manager; |
2 | |
3 import java.util.HashMap; | |
4 import java.util.LinkedList; | |
5 | |
641 | 6 import org.apache.log4j.Logger; |
401 | 7 import org.msgpack.type.ValueFactory; |
8 | |
9 import alice.codesegment.CodeSegment; | |
10 import alice.datasegment.CommandType; | |
11 import alice.datasegment.DataSegment; | |
12 import alice.datasegment.Receiver; | |
13 import alice.topology.HostMessage; | |
14 | |
15 public class IncomingHosts extends CodeSegment { | |
410 | 16 |
437 | 17 private Receiver topology = ids.create(CommandType.TAKE); // Topology from parse file |
18 private Receiver nodeNames = ids.create(CommandType.TAKE); // nodeName list | |
19 private Receiver host = ids.create(CommandType.TAKE); // new coming host info | |
434 | 20 private Receiver absCookieTable = ids.create(CommandType.TAKE); // cookie, AbsName HashMap |
437 | 21 private Receiver cookie = ids.create(CommandType.TAKE); // MD5 |
641 | 22 private Logger log = Logger.getLogger(IncomingHosts.class); |
410 | 23 |
437 | 24 public IncomingHosts() { |
25 this.topology.setKey("resultParse"); | |
26 this.nodeNames.setKey("nodeNames"); | |
438 | 27 this.host.setKey("newHost"); |
434 | 28 this.absCookieTable.setKey("absCookieTable"); |
431 | 29 this.cookie.setKey("MD5"); |
410 | 30 } |
401 | 31 |
410 | 32 @Override |
33 public void run() { | |
34 HostMessage host = this.host.asClass(HostMessage.class); | |
431 | 35 @SuppressWarnings("unchecked") |
434 | 36 HashMap<String, String> absCookieTable = this.absCookieTable.asClass(HashMap.class); |
437 | 37 @SuppressWarnings("unchecked") |
38 HashMap<String, LinkedList<NodeInfo>> topology = this.topology.asClass(HashMap.class); | |
39 @SuppressWarnings("unchecked") | |
40 LinkedList<String> nodeNames = this.nodeNames.asClass(LinkedList.class); | |
41 | |
466 | 42 // not have or match cookie |
437 | 43 String nodeName = nodeNames.poll(); |
44 // Manager connect to Node | |
45 DataSegment.connect(nodeName, "", host.name, host.port); | |
46 ods.put(nodeName, "host", nodeName); | |
47 | |
48 String cookie = this.cookie.asString(); | |
49 absCookieTable.put(cookie, nodeName); | |
50 ods.put(this.absCookieTable.key, absCookieTable); | |
51 | |
52 ods.put(nodeName, "cookie", cookie); | |
641 | 53 log.info( "toplology manager connected from " + nodeName); |
437 | 54 |
55 LinkedList<NodeInfo> nodes = topology.get(nodeName); | |
56 for (NodeInfo nodeInfo : nodes) { | |
57 HostMessage newHost = new HostMessage(host.name, host.port, | |
58 nodeInfo.connectionName, nodeInfo.reverseName); | |
59 newHost.absName = nodeName; | |
60 newHost.remoteAbsName = nodeInfo.sourceNodeName; | |
61 | |
62 ods.put("nodeInfo", newHost); | |
63 ods.put(nodeInfo.sourceNodeName, newHost); | |
639 | 64 new RecordTopology(); |
437 | 65 } |
66 | |
67 if (nodeNames.isEmpty()) { | |
68 // configuration finish | |
69 for (String key : topology.keySet()) { | |
70 ods.put("local", key, ValueFactory.createNilValue()); | |
428
93995b7a9a05
change HostMessage field from parentAbsName to remoteAbsName
sugi
parents:
424
diff
changeset
|
71 } |
424
faae3e976cc1
change cookie LinkedLIst Type from String.class to HostMessage.class
sugi
parents:
423
diff
changeset
|
72 } |
466 | 73 |
437 | 74 ods.put(this.nodeNames.key, nodeNames); |
75 ods.put(this.topology.key, topology); | |
466 | 76 |
437 | 77 new IncomingHosts(); |
410 | 78 } |
401 | 79 } |