diff options
| author | Arne H Juul <arnej@yahooinc.com> | 2021-12-17 08:06:21 +0000 |
|---|---|---|
| committer | Arne H Juul <arnej@yahooinc.com> | 2021-12-17 08:06:21 +0000 |
| commit | d0fa8ebf20f0117eea8e17ea95e4b65a8dee418c (patch) | |
| tree | dd21b473950e8ee57501449ede20441e350925ef /messagebus | |
| parent | 8fe9d1f5580b30aa9df48cd6f956b569bd632f96 (diff) | |
more aggressive waitState
Diffstat (limited to 'messagebus')
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/test/TestServer.java | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/test/TestServer.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/test/TestServer.java index b130b694770..92f8de93b03 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/test/TestServer.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/test/TestServer.java @@ -6,7 +6,6 @@ import com.yahoo.component.Vtag; import com.yahoo.jrt.Spec; import com.yahoo.jrt.slobrok.api.Mirror; import com.yahoo.jrt.slobrok.server.Slobrok; -import java.util.logging.Level; import com.yahoo.messagebus.MessageBus; import com.yahoo.messagebus.MessageBusParams; import com.yahoo.messagebus.Protocol; @@ -141,7 +140,8 @@ public class TestServer { * @return whether or not the required state was reached */ public boolean waitState(SlobrokState slobrokState) { - for (int i = 0; i < 6000 && !Thread.currentThread().isInterrupted(); ++i) { + int millis = 120 * 1000; + for (int i = 0; i < millis && !Thread.currentThread().isInterrupted(); ++i) { boolean done = true; for (String pattern : slobrokState.getPatterns()) { List<Mirror.Entry> res = net.getMirror().lookup(pattern); @@ -150,10 +150,16 @@ public class TestServer { } } if (done) { + if (i > 50) log.log(Level.INFO, "waitState OK after "+i+" ms"); return true; } + if ((i % 1000) == 50) { + log.log(Level.INFO, "waitState still waiting, "+i+" ms"); + var m = (Mirror) net.getMirror(); + m.dumpState(); + } try { - Thread.sleep(10); + Thread.sleep(1); } catch (InterruptedException e) { // ignore |