Author: fhanik Date: Fri Jun 30 06:24:11 2006 New Revision: 418261 URL: http://svn.apache.org/viewvc?rev=418261&view=rev Log: Fixed bug about shutdown command
Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastServiceImpl.java tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastServiceImpl.java URL: http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastServiceImpl.java?rev=418261&r1=418260&r2=418261&view=diff ============================================================================== --- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastServiceImpl.java (original) +++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastServiceImpl.java Fri Jun 30 06:24:11 2006 @@ -258,8 +258,6 @@ member.setCommand(Member.SHUTDOWN_PAYLOAD); member.getData(true, true); send(false); - //restore payload - member.getData(true, true); //leave mcast group try {socket.leaveGroup(address);}catch ( Exception ignore){} serviceStartTime = Long.MAX_VALUE; Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java URL: http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java?rev=418261&r1=418260&r2=418261&view=diff ============================================================================== --- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java (original) +++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/MemberImpl.java Fri Jun 30 06:24:11 2006 @@ -301,6 +301,7 @@ member.setUniqueId(uniqueId); member.payload = payload; member.domain = domain; + member.command = command; member.dataPkg = new byte[data.length]; System.arraycopy(data,0,member.dataPkg,0,data.length); --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]