aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java
diff options
context:
space:
mode:
Diffstat (limited to 'messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java6
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;
}