changeset 495:b789b8459996 dispose

change timing add managerKey to connectionList
author sugi
date Thu, 11 Dec 2014 18:28:18 +0900
parents dca4b392f788
children f82f259ea93b
files src/main/java/alice/topology/node/IncomingConnectionInfo.java src/main/java/alice/topology/node/IncomingReverseKey.java
diffstat 2 files changed, 4 insertions(+), 3 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/alice/topology/node/IncomingConnectionInfo.java	Thu Dec 11 18:27:36 2014 +0900
+++ b/src/main/java/alice/topology/node/IncomingConnectionInfo.java	Thu Dec 11 18:28:18 2014 +0900
@@ -28,11 +28,9 @@
                 // need to wait remove by DeleteConnection
                 ods.put("manager", absName, hostInfo);
             } else {
-                ods.put("cMember", hostInfo.connectionName);
-                new CreateConnectionList();
-                count++;
                 DataSegment.connect(hostInfo.connectionName, hostInfo.reverseName, hostInfo.name, hostInfo.port);
                 ods.put(hostInfo.connectionName, "reverseKey", hostInfo.reverseName);
+                count++;
             }
 
         }
--- a/src/main/java/alice/topology/node/IncomingReverseKey.java	Thu Dec 11 18:27:36 2014 +0900
+++ b/src/main/java/alice/topology/node/IncomingReverseKey.java	Thu Dec 11 18:28:18 2014 +0900
@@ -20,6 +20,9 @@
         reverseCount++;
         ods.update("local", "reverseCount", reverseCount);
 
+        ods.put("cMember", reverseKey);
+        new CreateConnectionList();
+
         IncomingReverseKey cs = new IncomingReverseKey();
         cs.reverseKey.setKey("local", "reverseKey");
         cs.reverseCount.setKey("local", "reverseCount");