diff options
author | Henning Baldersheim <balder@verizonmedia.com> | 2020-04-07 13:06:01 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@verizonmedia.com> | 2020-04-07 13:06:01 +0000 |
commit | ef044f95d1c82aff7a0b4fcb88c7fb23c3383398 (patch) | |
tree | b2fad87ebdd91bc33d3b833965d864652db57530 /messagebus/src/main | |
parent | 27f3c2a9cc66b272d4473bbbc0e7dbf58cd1c78a (diff) |
Update abi and min/max confusion.
Diffstat (limited to 'messagebus/src/main')
-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 13e90b9a65d..76d3bc07d2b 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java @@ -114,7 +114,7 @@ public class DynamicThrottlePolicy extends StaticThrottlePolicy { } double efficiency = throughput*period/windowSize; if (efficiency < efficiencyThreshold) { - windowSize = Math.max(windowSize * windowSizeBackOff, windowSize - decrementFactor * windowSizeIncrement); + windowSize = Math.min(windowSize * windowSizeBackOff, windowSize - decrementFactor * windowSizeIncrement); localMaxThroughput = 0; } else { windowSize += weight*windowSizeIncrement; |