Mercurial > hg > Database > Alice
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");