Author: kfujino
Date: Thu Dec 12 10:25:49 2013
New Revision: 1550391
URL: http://svn.apache.org/r1550391
Log:
In AbstractReplicatedMap#finalize, remove rpcChannel from channel Listener of
group channel before sending MapMessage.MSG_STOP message.
This prevent that the node that sent the MapMessage.MSG_STOP by normal shutdown
is added to member map again by ping at heartbeat thread in the node that
received the MapMessage.MSG_STOP.
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java?rev=1550391&r1=1550390&r2=1550391&view=diff
==============================================================================
---
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
(original)
+++
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Thu Dec 12 10:25:49 2013
@@ -333,11 +333,11 @@ public abstract class AbstractReplicated
@Override
public void finalize() {
- try {broadcast(MapMessage.MSG_STOP,false); }catch ( Exception ignore){}
- //cleanup
if (this.rpcChannel != null) {
this.rpcChannel.breakdown();
}
+ try {broadcast(MapMessage.MSG_STOP,false); }catch ( Exception ignore){}
+ //cleanup
if (this.channel != null) {
this.channel.removeChannelListener(this);
this.channel.removeMembershipListener(this);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
