diff options
author | Arne H Juul <arnej@yahooinc.com> | 2021-12-15 12:23:19 +0000 |
---|---|---|
committer | Arne H Juul <arnej@yahooinc.com> | 2021-12-15 12:23:19 +0000 |
commit | ad6d3c26f18daf39bcc2138e37dfe666da7aca9c (patch) | |
tree | 7d229a924de7e38b34d3e5d4914f774a13549ca4 /messagebus | |
parent | 084ad28ba2db5b728a2d7c243349f0319d8e04a6 (diff) |
improve signal-to-noise ratio in informational logging
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; } |