From: fhanik <fhanik@13f79535-47bb-0310-9956-ffa450edef68>
Date: Wed, 24 Dec 2008 19:41:22 +0000 (+0000)
Subject: IF the application is shutting down, we don't need to print the WARN message
X-Git-Url: https://git.internetallee.de/?a=commitdiff_plain;h=f26c9c2efb50d6d860ad459f6a752911b8dec54f;p=tomcat7.0

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
---

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);
+                            }
                         }
                     }
                 }