diff options
| author | Jon Marius Venstad <venstad@gmail.com> | 2020-12-01 21:17:31 +0100 |
|---|---|---|
| committer | Jon Marius Venstad <venstad@gmail.com> | 2020-12-01 21:17:31 +0100 |
| commit | a9aa229c03145beba34c3cf2e8db21169fac2e8f (patch) | |
| tree | 3b103cb394f16301ae9c9fe67c6f3ad880a8196e /messagebus | |
| parent | b1419c4d804a4b5bf24b2a7354ba17204bbae556 (diff) | |
Make throttle policy slightly more aggressive
Diffstat (limited to 'messagebus')
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java b/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java index ece8c0a009a..73270b032eb 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java @@ -99,7 +99,7 @@ public class DynamicThrottlePolicy extends StaticThrottlePolicy { if (maxThroughput > 0 && throughput > maxThroughput * 0.95) { // No need to increase window when we're this close to max. - } else if (throughput > localMaxThroughput * 1.01) { + } else if (throughput >= localMaxThroughput) { localMaxThroughput = throughput; windowSize += weight*windowSizeIncrement; if (log.isLoggable(Level.FINE)) { |