From f26c9c2efb50d6d860ad459f6a752911b8dec54f Mon Sep 17 00:00:00 2001 From: fhanik Date: Wed, 24 Dec 2008 19:41:22 +0000 Subject: [PATCH] IF the application is shutting down, we don't need to print the WARN message git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@729364 13f79535-47bb-0310-9956-ffa450edef68 --- .../catalina/tribes/membership/McastServiceImpl.java | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/java/org/apache/catalina/tribes/membership/McastServiceImpl.java b/java/org/apache/catalina/tribes/membership/McastServiceImpl.java index ea629e41a..db53e7a31 100644 --- a/java/org/apache/catalina/tribes/membership/McastServiceImpl.java +++ b/java/org/apache/catalina/tribes/membership/McastServiceImpl.java @@ -429,12 +429,14 @@ public class McastServiceImpl } 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); + } } } } -- 2.11.0