diff options
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java index 7ed1b17a5b4..b4b8c14c876 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java @@ -147,20 +147,26 @@ public class RPCNetwork implements Network, MethodHandler { @Override public boolean waitUntilReady(double seconds) { - for (int i = 0; i < seconds * 100; ++i) { + int millis = (int) seconds * 1000; + int i = 0; + do { if (mirror.ready()) { + if (i > 100) { + log.log(Level.INFO, "network became ready (at "+i+" ms)"); + } return true; } - if ((i % 100) == 0) { - log.log(Level.INFO, "waiting for network to become ready ("+(i/100)+" of "+((int)seconds)+" seconds)"); + if ((i == 100) || ((i > 100) && ((i % 1000) == 0))) { + log.log(Level.INFO, "waiting for network to become ready ("+i+" of "+millis+" ms)"); mirror.dumpState(); } try { + i += 10; Thread.sleep(10); } catch (InterruptedException e) { // empty } - } + } while (i < millis); return false; } |