diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-25 12:37:43 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-25 12:37:43 +0100 |
commit | 4a23616becf49bf591af6730ddf8b700b138e4aa (patch) | |
tree | c89971a013829ca8f0364deda9e4e8505c9365f5 /messagebus | |
parent | c9202507993c8100923ecadd694716bf2593843a (diff) |
Take VESPA_TIMER_HZ into consideration.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java | 4 |
1 files changed, 2 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..d7f488346ff 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java @@ -88,6 +88,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, } private void sendBlockedMessages() { + int timeout = 10*1000/SystemTimer.detectHz(); while (! destroyed.get()) { for (SendBlockedMessages sender : blockedSenders.keySet()) { if (!sender.trySend()) { @@ -95,8 +96,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, } } try { - - Thread.sleep(10); + Thread.sleep(timeout); } catch (InterruptedException e) { return; } |