We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aeadf57 commit 3598b81Copy full SHA for 3598b81
zookeeper-server/src/main/java/org/apache/zookeeper/server/BlueThrottle.java
@@ -323,6 +323,7 @@ public synchronized boolean checkLimit(int need) {
323
324
long now = Time.currentElapsedTime();
325
long diff = now - lastTime;
326
+ diff = Math.min((long) maxTokens * fillTime / fillCount, diff);
327
328
if (diff > fillTime) {
329
int refill = (int) (diff * fillCount / fillTime);
0 commit comments