diff options
| author | Arne H Juul <arnej@yahooinc.com> | 2021-12-15 12:29:36 +0000 |
|---|---|---|
| committer | Arne H Juul <arnej@yahooinc.com> | 2021-12-15 12:29:36 +0000 |
| commit | 06964c7d6bda6f93894fa87253c705f836759421 (patch) | |
| tree | 38e2b65c5b3fa4bb87a967f4502f3c6098b798d5 /messagebus | |
| parent | ad6d3c26f18daf39bcc2138e37dfe666da7aca9c (diff) | |
wait a bit more before spamming the log
Diffstat (limited to 'messagebus')
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java | 5 |
1 files changed, 3 insertions, 2 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 b4b8c14c876..5ff9a4b0313 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 @@ -151,16 +151,17 @@ public class RPCNetwork implements Network, MethodHandler { int i = 0; do { if (mirror.ready()) { - if (i > 100) { + if (i > 200) { log.log(Level.INFO, "network became ready (at "+i+" ms)"); } return true; } - if ((i == 100) || ((i > 100) && ((i % 1000) == 0))) { + if ((i == 200) || ((i > 200) && ((i % 1000) == 0))) { log.log(Level.INFO, "waiting for network to become ready ("+i+" of "+millis+" ms)"); mirror.dumpState(); } try { + // could maybe have some back-off here, fixed at 10ms for now i += 10; Thread.sleep(10); } catch (InterruptedException e) { |