Skip to content
Browse files

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

  • Loading branch information...
1 parent 7802523 commit d267a31208a0cb0af7698007b95455eb6dd84027 @dereed dereed committed Jul 23, 2012
Showing with 8 additions and 4 deletions.
  1. +8 −4 src/org/jgroups/protocols/pbcast/FLUSH.java
View
12 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());
}
}

0 comments on commit d267a31

Please sign in to comment.
Something went wrong with that request. Please try again.