diff options
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)) { |