Github user tumativ commented on a diff in the pull request:
https://github.com/apache/zookeeper/pull/689#discussion_r236063614
--- Diff:
zookeeper-server/src/main/java/org/apache/zookeeper/server/watch/WatcherCleaner.java
---
@@ -163,8 +165,8 @@ public void doWork() throws Exception {
long latency = Time.currentElapsedTime() -
startTime;
LOG.info("Takes {} to process {} watches",
latency, total);
totalDeadWatchers.addAndGet(-total);
- synchronized(totalDeadWatchers) {
- totalDeadWatchers.notifyAll();
+ synchronized(processingCompletedEvent) {
+ processingCompletedEvent.notifyAll();
--- End diff --
Done
---
