diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-12-01 10:31:57 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-12-01 10:31:57 +0100 |
commit | 50606da5b18839e61baac27f48acc3d0d4df39c1 (patch) | |
tree | e58de93846464b5af861ef9cd9e646956ff731eb /messagebus | |
parent | 14bf2d67787ac11c375117c4271b2ab783ae5612 (diff) | |
parent | 4236c6b7d3d7d4520402e754b1e6dae183ae73ff (diff) |
Merge pull request #15554 from vespa-engine/jonmv/reindexing-adjustments-again
Set initial window size to max of min and increment, in dynamic throt…
Diffstat (limited to 'messagebus')
-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; } } |