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