diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2020-12-01 21:15:17 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2020-12-01 21:15:17 +0100 |
commit | b1419c4d804a4b5bf24b2a7354ba17204bbae556 (patch) | |
tree | 88be4d26f971088ce6e1217836beffa0dab863bf /messagebus | |
parent | 690af07be1a04af09fc046b52306ebdab19122e7 (diff) |
Allow one extra pending in a fraction of the resize interval
... equal to the fractional part of the window size
@baldersheim please review
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java b/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java index fca29695acc..ece8c0a009a 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/DynamicThrottlePolicy.java @@ -77,8 +77,8 @@ public class DynamicThrottlePolicy extends StaticThrottlePolicy { } timeOfLastMessage = time; int windowSizeFloored = (int) windowSize; - boolean carry = numSent / (windowSize * resizeRate) < windowSize - windowSizeFloored; - return pendingCount < windowSizeFloored + (carry ? 1 : 0); + boolean carry = numSent < (windowSize * resizeRate) * windowSize - windowSizeFloored; + return pendingCount < windowSizeFloored + (carry ? 1 : 0); } @Override |