summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-02-25 12:37:43 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-02-25 12:37:43 +0100
commit4a23616becf49bf591af6730ddf8b700b138e4aa (patch)
treec89971a013829ca8f0364deda9e4e8505c9365f5 /messagebus
parentc9202507993c8100923ecadd694716bf2593843a (diff)
Take VESPA_TIMER_HZ into consideration.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java4
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;
}