diff options
Diffstat (limited to 'messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java index 8611801b9a9..c3279d994c9 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java @@ -2,6 +2,8 @@ package com.yahoo.messagebus; import com.yahoo.concurrent.SystemTimer; + +import java.time.Duration; import java.util.logging.Level; import com.yahoo.messagebus.network.Network; import com.yahoo.messagebus.network.NetworkMultiplexer; @@ -88,6 +90,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, } private void sendBlockedMessages() { + long timeout = SystemTimer.adjustTimeoutByDetectedHz(Duration.ofMillis(10)).toMillis(); while (! destroyed.get()) { for (SendBlockedMessages sender : blockedSenders.keySet()) { if (!sender.trySend()) { @@ -95,8 +98,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, } } try { - - Thread.sleep(10); + Thread.sleep(timeout); } catch (InterruptedException e) { return; } |