aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorArne H Juul <arnej@yahooinc.com>2021-12-15 12:23:19 +0000
committerArne H Juul <arnej@yahooinc.com>2021-12-15 12:23:19 +0000
commitad6d3c26f18daf39bcc2138e37dfe666da7aca9c (patch)
tree7d229a924de7e38b34d3e5d4914f774a13549ca4 /messagebus
parent084ad28ba2db5b728a2d7c243349f0319d8e04a6 (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.java14
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;
}