Permalink
Browse files

Added flushing of down queues before calling start()

  • Loading branch information...
1 parent 433e8f8 commit 70e8d69466f03e6c44f734338cd27b13a39d6180 Bela Ban committed Sep 23, 2003
Showing with 5 additions and 3 deletions.
  1. +5 −3 src/org/jgroups/stack/ProtocolStack.java
@@ -1,4 +1,4 @@
-// $Id: ProtocolStack.java,v 1.2 2003/09/20 01:33:23 belaban Exp $
+// $Id: ProtocolStack.java,v 1.3 2003/09/23 00:41:39 belaban Exp $
package org.jgroups.stack;
@@ -212,13 +212,15 @@ public void start() throws Exception {
// flush events out of the queue, e.g. Event.CONFIG
try {
start=System.currentTimeMillis();
- p.getDownQueue().waitUntilEmpty(50); // todo: replace with 0 timeout
+ p.getDownQueue().waitUntilEmpty(0);
}
catch(Exception ex) {}
finally {
stop=System.currentTimeMillis();
}
- System.out.println("time for " + p.getName() + ": " + (stop-start) + " msecs");
+ if(Trace.trace)
+ Trace.info("ProtocolStack.start()", "time for flushing down events for " +
+ p.getName() + ": " + (stop-start) + " msecs");
p.start();
}
stopped=false;

0 comments on commit 70e8d69

Please sign in to comment.