Mercurial > hg > Database > Christie
diff src/main/java/christie/topology/manager/IncomingHosts.java @ 64:f884c1bd0d36
fix IncomingHosts and RecordTopology. and refactor.
author | akahori |
---|---|
date | Thu, 30 Aug 2018 10:55:37 +0900 |
parents | cfd79a71f9cd |
children | d74a64a3940a |
line wrap: on
line diff
--- a/src/main/java/christie/topology/manager/IncomingHosts.java Wed Aug 29 10:40:39 2018 +0900 +++ b/src/main/java/christie/topology/manager/IncomingHosts.java Thu Aug 30 10:55:37 2018 +0900 @@ -20,7 +20,6 @@ @Peek HashMap<String, String> absCookieTable; - @Take // new coming host info HostMessage newHost; @Take @@ -43,19 +42,21 @@ absCookieTable.put(MD5, nodeName); - getDGM(nodeName).put( "host", nodeName); + getDGM(nodeName).put( "nodeName", nodeName); getDGM(nodeName).put("cookie", MD5); log.info( "toplology manager connected from " + nodeName); + + LinkedList<NodeInfo> nodeInfoList = resultParse.get(nodeName); for (NodeInfo nodeInfo : nodeInfoList) { HostMessage hostMessage = new HostMessage(newHost.hostName, newHost.port, - nodeInfo.connectionName, nodeInfo.reverseName); - hostMessage.absName = nodeName; - hostMessage.remoteAbsName = nodeInfo.sourceNodeName; + nodeInfo.connectionName, ""); + hostMessage.nodeName = nodeName; + hostMessage.remoteNodeName = nodeInfo.targetNodeName; getLocalDGM().put("nodeInfo", hostMessage); - getLocalDGM().put("hostInfo", hostMessage); + log.info(" write to " + nodeInfo.sourceNodeName + " config message =" + hostMessage.toString() + " remain " + Integer.toString((nodeNames.size())));