Mercurial > hg > Database > Christie

changeset 167:240058b2ce3e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix incominghosts
author akahori
date Tue, 22 Jan 2019 15:31:03 +0900
parents f2218b5590d3
children c7300be0fff6
files src/main/java/christie/topology/manager/IncomingHosts.java
diffstat 1 files changed, 10 insertions(+), 1 deletions(-) [+]
line wrap: on
line diff
--- 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<HostMessage> 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());