Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/manager/IncomingHosts.java @ 50:8dfd93810041

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix config and HostMessage
author akahori
date Thu, 23 Aug 2018 09:30:36 +0900
parents 6664efac18ee
children 34181394333f
comparison
equal deleted inserted replaced
49:fd944876257b 50:8dfd93810041
20 LinkedList<String> nodeNames; 20 LinkedList<String> nodeNames;
21 21
22 @Take // new coming host info 22 @Take // new coming host info
23 HostMessage newHost; 23 HostMessage newHost;
24 24
25 @Take 25 //@Take
26 @Peek
26 HashMap<String, String> absCookieTable; 27 HashMap<String, String> absCookieTable;
27 28
28 @Take 29 @Take
29 String MD5; 30 String MD5;
30 31
40 41
41 // not have or match cookie 42 // not have or match cookie
42 String nodeName = nodeNames.poll(); 43 String nodeName = nodeNames.poll();
43 44
44 // Manager connect to Node 45 // Manager connect to Node
45 cgm.createRemoteDGM(nodeName, newHost.name, newHost.port); 46 cgm.createRemoteDGM(nodeName, newHost.hostName, newHost.port);
46 getDGM(nodeName).put( "host", nodeName); 47 getDGM(nodeName).put( "host", nodeName);
47 48
48 49
49 absCookieTable.put(MD5, nodeName); 50 absCookieTable.put(MD5, nodeName);
50 getLocalDGM().put("absCookieTable", absCookieTable); 51 //getLocalDGM().put("absCookieTable", absCookieTable);
51 52
52 getDGM(nodeName).put("cookie", MD5); 53 getDGM(nodeName).put("cookie", MD5);
53 log.info( "toplology manager connected from " + nodeName); 54 log.info( "toplology manager connected from " + nodeName);
54 55
55 LinkedList<NodeInfo> nodeInfoList = resultParse.get(nodeName); 56 LinkedList<NodeInfo> nodeInfoList = resultParse.get(nodeName);
56 for (NodeInfo nodeInfo : nodeInfoList) { 57 for (NodeInfo nodeInfo : nodeInfoList) {
57 HostMessage hostMessage = new HostMessage(newHost.name, newHost.port, 58 HostMessage hostMessage = new HostMessage(newHost.hostName, newHost.port,
58 nodeInfo.connectionName, nodeInfo.reverseName); 59 nodeInfo.connectionName, nodeInfo.reverseName);
59 hostMessage.absName = nodeName; 60 hostMessage.absName = nodeName;
60 hostMessage.remoteAbsName = nodeInfo.sourceNodeName; 61 hostMessage.remoteAbsName = nodeInfo.sourceNodeName;
61 62
62 getLocalDGM().put("nodeInfo", hostMessage); 63 getLocalDGM().put("nodeInfo", hostMessage);