JGRP-1450 don't forget who is suspected

belaban · Apr 23, 2012 · d77c440 · d77c440
1 parent ffa98d8
commit d77c440
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/org/jgroups/protocols/pbcast/ParticipantGmsImpl.java b/src/org/jgroups/protocols/pbcast/ParticipantGmsImpl.java
@@ -33,7 +33,7 @@ public void init() throws Exception {
     public void join(Address mbr, boolean useFlushIfPresent) {
         wrongMethod("join");
     }
-    
+
     public void joinWithStateTransfer(Address mbr,boolean useFlushIfPresent) {
         wrongMethod("join");
     }
@@ -85,7 +85,7 @@ public void handleJoinResponse(JoinRsp join_rsp) {
         }
     }
 
-    public void handleLeaveResponse() {       
+    public void handleLeaveResponse() {
         leave_promise.setResult(true);  // unblocks thread waiting in leave()
     }
 
@@ -110,7 +110,7 @@ public void handleMembershipChange(Collection<Request> requests) {
             if(req.type == Request.SUSPECT)
                 suspectedMembers.add(req.mbr);
         }
-        
+
         if(suspectedMembers.isEmpty())
             return;
 
@@ -126,12 +126,12 @@ public void handleMembershipChange(Collection<Request> requests) {
             if(log.isDebugEnabled())
                 log.debug("members are " + gms.members + ", coord=" + gms.local_addr + ": I'm the new coord !");
 
-            suspected_mbrs.clear();
             gms.becomeCoordinator();
-            for(Address mbr: suspectedMembers) {
+            for(Address mbr: suspected_mbrs) {
                 gms.getViewHandler().add(new Request(Request.SUSPECT, mbr, true));
                 gms.ack_collector.suspect(mbr);
             }
+            suspected_mbrs.clear();
         }
     }