Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
belaban committed Apr 4, 2012
1 parent bae57fb commit 5c759df
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions src/org/jgroups/protocols/pbcast/FLUSH.java
Expand Up @@ -564,6 +564,8 @@ private void handleStartFlush(Message msg, FlushHeader fh) {

private void rejectFlush(Collection<? extends Address> participants, long viewId) {
for (Address flushMember : participants) {
if(flushMember == null)
continue;
Message reject = new Message(flushMember, localAddress, null);
reject.setFlag(Message.OOB);
reject.putHeader(this.id, new FlushHeader(FlushHeader.ABORT_FLUSH, viewId,participants));
Expand Down

0 comments on commit 5c759df

Please sign in to comment.