Mercurial > hg > Database > Alice
comparison src/main/java/alice/topology/fix/FixTopology.java @ 502:7d83a188a4f7 dispose
bug fix keepAlive
author | sugi |
---|---|
date | Wed, 17 Dec 2014 20:48:34 +0900 |
parents | 5adb0f530e3d |
children | 80e461aa10e9 |
comparison
equal
deleted
inserted
replaced
501:c5072a63b257 | 502:7d83a188a4f7 |
---|---|
63 } | 63 } |
64 | 64 |
65 if (!lastJoinNodeName.equals(lostNodeName)) { | 65 if (!lastJoinNodeName.equals(lostNodeName)) { |
66 if (!lostNodeName.equals(parentNode.remoteAbsName)) { | 66 if (!lostNodeName.equals(parentNode.remoteAbsName)) { |
67 // send close message to lastJoinedNode | 67 // send close message to lastJoinedNode |
68 ods.put(lastJoinNodeName, "_CLOSEMESSEAGE", parentNode.reverseName); | 68 ods.put(lastJoinNodeName, "_CLOSEMESSEAGE", parentNode.connectionName); |
69 // send close message to lastJoinedNode's parent | 69 // send close message to lastJoinedNode's parent |
70 ods.put(parentNode.absName, "_CLOSEMESSEAGE", parentNode.connectionName); | 70 ods.put(parentNode.absName, "_CLOSEMESSEAGE", parentNode.reverseName); |
71 } | 71 } |
72 | 72 |
73 HostMessage lastJoinNode = nameTable.get(lastJoinNodeName); | 73 HostMessage lastJoinNode = nameTable.get(lastJoinNodeName); |
74 connectionList = topology.get(lastJoinNodeName); | 74 connectionList = topology.get(lastJoinNodeName); |
75 LinkedList<HostMessage> disconnectionList = topology.get(lostNodeName); | 75 LinkedList<HostMessage> disconnectionList = topology.get(lostNodeName); |