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())));