[JGRP-1494] Log members that did not respond to FLUSH at WARN level

belaban · Jul 23, 2012 · d267a31 · d267a31
1 parent 7802523
commit d267a31
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/org/jgroups/protocols/pbcast/FLUSH.java b/src/org/jgroups/protocols/pbcast/FLUSH.java
@@ -235,10 +235,14 @@ private boolean startFlush(List<Address> flushParticipants) {
                 Boolean r = flush_promise.getResultWithTimeout(start_flush_timeout);
                 successfulFlush = r.booleanValue();
             } catch (TimeoutException e) {
-                if (log.isDebugEnabled())
-                    log.debug("At " + localAddress
-                                    + " timed out waiting for flush responses after "
-                                    + start_flush_timeout + " msec. Rejecting flush to participants " + flushParticipants);                
+                Set<Address> missingMembers = new HashSet<Address>();
+                synchronized(sharedLock) {
+                    missingMembers.addAll(flushMembers);
+                    missingMembers.removeAll(flushCompletedMap.keySet());
+                }
+                log.warn("At " + localAddress
+                                + " timed out waiting for flush responses from " + missingMembers + " after "
+                                + start_flush_timeout + " msec. Rejecting flush to participants " + flushParticipants);                
                 rejectFlush(flushParticipants, currentViewId());
             }
         }