From ad6d3c26f18daf39bcc2138e37dfe666da7aca9c Mon Sep 17 00:00:00 2001 From: Arne H Juul Date: Wed, 15 Dec 2021 12:23:19 +0000 Subject: improve signal-to-noise ratio in informational logging --- .../java/com/yahoo/messagebus/network/rpc/RPCNetwork.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) (limited to 'messagebus/src/main') 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; } -- cgit v1.2.3