diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-25 13:12:13 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-25 13:12:13 +0100 |
commit | d69aeb4ee39c352c87336e617f5d73c58b2faeb8 (patch) | |
tree | ece110670f6fbc5eb89ea443a63fce72e1dc0fee /messagebus/src | |
parent | 1f48f1e0cb904906e18ec220b0a3b21f8676dd27 (diff) |
- Use a utility method that recomputes a timeout if VESPA_TIMER_HZ deviates from the default of 1000hz.
Diffstat (limited to 'messagebus/src')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java | 2 | ||||
-rwxr-xr-x | messagebus/src/main/java/com/yahoo/messagebus/Messenger.java | 2 |
2 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 d7f488346ff..c47fe88dc71 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java @@ -88,7 +88,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, } private void sendBlockedMessages() { - int timeout = 10*1000/SystemTimer.detectHz(); + int timeout = SystemTimer.adjustTimeoutByDetectedHz(10); while (! destroyed.get()) { for (SendBlockedMessages sender : blockedSenders.keySet()) { if (!sender.trySend()) { diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java b/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java index 478cb7554ee..4f36cb3b328 100755 --- a/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java @@ -149,7 +149,7 @@ public class Messenger implements Runnable { @Override public void run() { - int timeoutMS = 100*1000/SystemTimer.detectHz(); + int timeoutMS = SystemTimer.adjustTimeoutByDetectedHz(100); while (true) { Task task = null; synchronized (this) { |