Author: fhanik
Date: Wed Dec 24 11:41:22 2008
New Revision: 729364
URL: http://svn.apache.org/viewvc?rev=729364&view=rev
Log:
IF the application is shutting down, we don't need to print the WARN message
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java?rev=729364&r1=729363&r2=729364&view=diff
==============================================================================
---
tomcat/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java
(original)
+++
tomcat/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java
Wed Dec 24 11:41:22 2008
@@ -429,12 +429,14 @@
} catch ( Exception x ) {
if (x instanceof InterruptedException) interrupted();
else {
- if (errorCounter==0) log.warn("Error receiving mcast
package. Sleeping 500ms",x);
- else log.debug("Error receiving mcast package.
Sleeping 500ms",x);
- try { Thread.sleep(500); } catch ( Exception ignore ){}
- if ( (++errorCounter)>=recoveryCounter ) {
- errorCounter=0;
- new RecoveryThread(McastServiceImpl.this);
+ if (errorCounter==0 && doRunReceiver) log.warn("Error
receiving mcast package. Sleeping 500ms",x);
+ else if (log.isDebugEnabled()) log.debug("Error
receiving mcast package"+(doRunReceiver?". Sleeping 500ms":"."),x);
+ if (doRunReceiver) {
+ try { Thread.sleep(500); } catch ( Exception
ignore ){}
+ if ( (++errorCounter)>=recoveryCounter ) {
+ errorCounter=0;
+ new RecoveryThread(McastServiceImpl.this);
+ }
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
