diff options
Diffstat (limited to 'zookeeper-server/src/main/java/org/apache/zookeeper/server/RequestThrottler.java')
-rw-r--r-- | zookeeper-server/src/main/java/org/apache/zookeeper/server/RequestThrottler.java | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/RequestThrottler.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/RequestThrottler.java index d60efa087..4a401e5b9 100644 --- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/RequestThrottler.java +++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/RequestThrottler.java @@ -195,13 +195,11 @@ public class RequestThrottler extends ZooKeeperCriticalThread { LOG.info("RequestThrottler shutdown. Dropped {} requests", dropped); } - private synchronized void throttleSleep(int stallTime) { - try { - ServerMetrics.getMetrics().REQUEST_THROTTLE_WAIT_COUNT.add(1); - this.wait(stallTime); - } catch (InterruptedException ie) { - return; - } + + // @VisibleForTesting + synchronized void throttleSleep(int stallTime) throws InterruptedException { + ServerMetrics.getMetrics().REQUEST_THROTTLE_WAIT_COUNT.add(1); + this.wait(stallTime); } @SuppressFBWarnings(value = "NN_NAKED_NOTIFY", justification = "state change is in ZooKeeperServer.decInProgress() ") |