# HG changeset patch # User akahori # Date 1548138663 -32400 # Node ID 240058b2ce3ea3776762ea86c9138e0d6f303455 # Parent f2218b5590d327c212adaca52f39e59fc0c0fe6e fix incominghosts diff -r f2218b5590d3 -r 240058b2ce3e src/main/java/christie/topology/manager/IncomingHosts.java --- a/src/main/java/christie/topology/manager/IncomingHosts.java Tue Jan 22 15:07:12 2019 +0900 +++ b/src/main/java/christie/topology/manager/IncomingHosts.java Tue Jan 22 15:31:03 2019 +0900 @@ -51,7 +51,8 @@ getDGM(nodeName).put("cookie", MD5); LinkedList nodeInfoList = resultParse.get(nodeName); - getDGM(nodeName).put("connectNodeNum",nodeInfoList.size()); + getDGM(nodeName).put("connectNodeNum", nodeInfoList.size()); + if(nodeInfoList.size() == 0) getDGM(nodeName).put("reverseNodeName", "node"); for (HostMessage nodeInfo : nodeInfoList) { nodeInfo.setHostAndPort(newHost); @@ -60,6 +61,14 @@ getDGM(nodeName).put("remoteNodeInfo", nodeInfo); cgm.setup(new RecordTopology()); } + + /*if (nodeNames.isEmpty()) { + // configuration finish + + for (String key : resultParse.keySet()) { + put(key, "remoteNodeInfo", new HostMessage()); // end mark + } + }*/ getLocalDGM().put("resultParse", resultParse); cgm.setup(new IncomingHosts());