diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2020-12-01 08:50:47 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2020-12-01 08:50:47 +0100 |
commit | 4236c6b7d3d7d4520402e754b1e6dae183ae73ff (patch) | |
tree | 3873aecc570f932f2d77d536afbd1cab48f11e29 /messagebus/src/main | |
parent | 957d713221f40cd3107b5e06979ffe1b063419cd (diff) |
Set initial window size to max of min and increment, in dynamic throttle policy
Diffstat (limited to 'messagebus/src/main')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java | 4 |
1 files changed, 3 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 28d74c0b9f0..1cfbefae29b 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java @@ -157,6 +157,7 @@ public class DynamicThrottlePolicy extends StaticThrottlePolicy { */ public DynamicThrottlePolicy setWindowSizeIncrement(double windowSizeIncrement) { this.windowSizeIncrement = windowSizeIncrement; + this.windowSize = Math.max(this.minWindowSize, this.windowSizeIncrement); return this; } @@ -240,6 +241,7 @@ public class DynamicThrottlePolicy extends StaticThrottlePolicy { */ public DynamicThrottlePolicy setMinWindowSize(double min) { this.minWindowSize = min; + this.windowSize = Math.max(this.minWindowSize, this.windowSizeIncrement); return this; } @@ -265,7 +267,7 @@ public class DynamicThrottlePolicy extends StaticThrottlePolicy { * @return the max limit */ public int getMaxPendingCount() { - return (int)windowSize; + return (int) windowSize; } } |