changeset 502:7d83a188a4f7 dispose

bug fix keepAlive
author sugi
date Wed, 17 Dec 2014 20:48:34 +0900
parents c5072a63b257
children 79d5b317b2b6
files src/main/java/alice/topology/fix/FixTopology.java src/main/java/alice/topology/node/CloseRemoteDataSegment.java
diffstat 2 files changed, 3 insertions(+), 3 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/alice/topology/fix/FixTopology.java	Tue Dec 16 16:03:15 2014 +0900
+++ b/src/main/java/alice/topology/fix/FixTopology.java	Wed Dec 17 20:48:34 2014 +0900
@@ -65,9 +65,9 @@
             if (!lastJoinNodeName.equals(lostNodeName)) {
                 if (!lostNodeName.equals(parentNode.remoteAbsName)) {
                     // send close message to lastJoinedNode
-                    ods.put(lastJoinNodeName, "_CLOSEMESSEAGE", parentNode.reverseName);
+                    ods.put(lastJoinNodeName, "_CLOSEMESSEAGE", parentNode.connectionName);
                     // send close message to lastJoinedNode's parent
-                    ods.put(parentNode.absName, "_CLOSEMESSEAGE", parentNode.connectionName);
+                    ods.put(parentNode.absName, "_CLOSEMESSEAGE", parentNode.reverseName);
                 }
 
                 HostMessage lastJoinNode = nameTable.get(lastJoinNodeName);
--- a/src/main/java/alice/topology/node/CloseRemoteDataSegment.java	Tue Dec 16 16:03:15 2014 +0900
+++ b/src/main/java/alice/topology/node/CloseRemoteDataSegment.java	Wed Dec 17 20:48:34 2014 +0900
@@ -30,7 +30,7 @@
             manager.deleteAll(managerKey);
         }
 
-        ods.update(info1.key, manager);
+        ods.update(info3.key, manager);
         new ReceiveCloseMessage(CommandType.PEEK);
     }