Mercurial > hg > Database > Alice

comparison src/main/java/alice/topology/manager/IncomingHosts.java @ 641:646f705e65b1

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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
comparison
equal deleted inserted replaced
640:f05a89484ec1 641:646f705e65b1
1 package alice.topology.manager; 1 package alice.topology.manager;
2 2
3 import java.util.HashMap; 3 import java.util.HashMap;
4 import java.util.LinkedList; 4 import java.util.LinkedList;
5 5
6 import org.apache.log4j.Logger;
6 import org.msgpack.type.ValueFactory; 7 import org.msgpack.type.ValueFactory;
7 8
8 import alice.codesegment.CodeSegment; 9 import alice.codesegment.CodeSegment;
9 import alice.datasegment.CommandType; 10 import alice.datasegment.CommandType;
10 import alice.datasegment.DataSegment; 11 import alice.datasegment.DataSegment;
16 private Receiver topology = ids.create(CommandType.TAKE); // Topology from parse file 17 private Receiver topology = ids.create(CommandType.TAKE); // Topology from parse file
17 private Receiver nodeNames = ids.create(CommandType.TAKE); // nodeName list 18 private Receiver nodeNames = ids.create(CommandType.TAKE); // nodeName list
18 private Receiver host = ids.create(CommandType.TAKE); // new coming host info 19 private Receiver host = ids.create(CommandType.TAKE); // new coming host info
19 private Receiver absCookieTable = ids.create(CommandType.TAKE); // cookie, AbsName HashMap 20 private Receiver absCookieTable = ids.create(CommandType.TAKE); // cookie, AbsName HashMap
20 private Receiver cookie = ids.create(CommandType.TAKE); // MD5 21 private Receiver cookie = ids.create(CommandType.TAKE); // MD5
22 private Logger log = Logger.getLogger(IncomingHosts.class);
21 23
22 public IncomingHosts() { 24 public IncomingHosts() {
23 this.topology.setKey("resultParse"); 25 this.topology.setKey("resultParse");
24 this.nodeNames.setKey("nodeNames"); 26 this.nodeNames.setKey("nodeNames");
25 this.host.setKey("newHost"); 27 this.host.setKey("newHost");
46 String cookie = this.cookie.asString(); 48 String cookie = this.cookie.asString();
47 absCookieTable.put(cookie, nodeName); 49 absCookieTable.put(cookie, nodeName);
48 ods.put(this.absCookieTable.key, absCookieTable); 50 ods.put(this.absCookieTable.key, absCookieTable);
49 51
50 ods.put(nodeName, "cookie", cookie); 52 ods.put(nodeName, "cookie", cookie);
53 log.info( "toplology manager connected from " + nodeName);
51 54
52 LinkedList<NodeInfo> nodes = topology.get(nodeName); 55 LinkedList<NodeInfo> nodes = topology.get(nodeName);
53 for (NodeInfo nodeInfo : nodes) { 56 for (NodeInfo nodeInfo : nodes) {
54 HostMessage newHost = new HostMessage(host.name, host.port, 57 HostMessage newHost = new HostMessage(host.name, host.port,
55 nodeInfo.connectionName, nodeInfo.reverseName); 58 nodeInfo.connectionName, nodeInfo.reverseName);