remove allowMessagesToPassUp

src/org/jgroups/protocols/pbcast/FLUSH.java

@@ -130,8 +130,6 @@ public class FLUSH extends Protocol {
     @GuardedBy("sharedLock")
     private boolean flushCompleted = false;
 
-    private volatile boolean allowMessagesToPassUp = false;
-
     private final Promise<Boolean> flush_promise = new Promise<Boolean>();    
 
     private final AtomicBoolean flushInProgress = new AtomicBoolean(false);
@@ -182,7 +180,6 @@ public void start() throws Exception {
         synchronized(blockMutex){
             isBlockingFlushDown = true;
         }
-        allowMessagesToPassUp = false;
     }
 
     public void stop() {
@@ -435,9 +432,6 @@ public void run() {
                 if(dest != null && !dest.isMulticastAddress()) {
                     return up_prot.up(evt); // allow unicasts to pass, virtual synchrony olny applies to multicasts
                 }
-
-                if(!allowMessagesToPassUp)
-                    return null;
             }
             break;
 
@@ -631,7 +625,6 @@ private void onStopFlush() {
             flushMembers.clear();
             suspected.clear();
             flushCoordinator = null;
-            allowMessagesToPassUp = true;
             flushCompleted = false;
         }