Allow one extra pending in a fraction of the resize interval

... equal to the fractional part of the window size
@baldersheim please review

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