diff src/main/java/christie/topology/node/IncomingConnectionInfo.java @ 170:f9f83bb213e8

fix topology manager
author akahori
date Tue, 22 Jan 2019 18:32:39 +0900
parents c7300be0fff6
children 6eb548c188e5
line wrap: on
line diff
--- a/src/main/java/christie/topology/node/IncomingConnectionInfo.java	Tue Jan 22 18:32:13 2019 +0900
+++ b/src/main/java/christie/topology/node/IncomingConnectionInfo.java	Tue Jan 22 18:32:39 2019 +0900
@@ -14,11 +14,11 @@
     @Take
     HostMessage remoteNodeInfo;
 
+    int count;
+
     @Take
     TopologyDataGear topoDG;
 
-    int count;
-
     public IncomingConnectionInfo() {
         this.count = 0;
     }
@@ -32,22 +32,19 @@
     protected void run(CodeGearManager cgm) {
         String connectionName = remoteNodeInfo.getConnectionName();
 
-
         if (remoteNodeInfo.getHostName().equals("")) { // end case
-            put("connectNodeNum", count);
             getLocalDGM().put("topoDG", topoDG);
             return;
-        }else{
+        }
 
         cgm.createRemoteDGM(connectionName,
                     remoteNodeInfo.getHostName(),
                     remoteNodeInfo.getPort());
 
-        getDGM(connectionName).put("reverseNodeName", topoDG.getNodeName());
         topoDG.addConnection(connectionName);
         getLocalDGM().put("topoDG", topoDG);
+        getDGM(connectionName).put("reverseNodeName",connectionName);
         count++;
-        }
 
         cgm.setup(new IncomingConnectionInfo(count));
     }