zookeeper-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tumativ <...@git.apache.org>
Subject [GitHub] zookeeper pull request #689: ZOOKEEPER-3183:Notifying the WatcherCleaner thr...
Date Mon, 26 Nov 2018 01:31:34 GMT
Github user tumativ commented on a diff in the pull request:

    https://github.com/apache/zookeeper/pull/689#discussion_r236102347
  
    --- Diff: zookeeper-server/src/main/java/org/apache/zookeeper/server/watch/WatcherCleaner.java
---
    @@ -102,12 +103,13 @@ public void addDeadWatcher(int watcherBit) {
                     totalDeadWatchers.get() >= maxInProcessingDeadWatchers) {
                 try {
                     RATE_LOGGER.rateLimitLog("Waiting for dead watchers cleaning");
    -                synchronized(totalDeadWatchers) {
    -                    totalDeadWatchers.wait(100);
    +                synchronized(processingCompletedEvent) {
    +                    processingCompletedEvent.wait(100);
                     }
                 } catch (InterruptedException e) {
    -                LOG.info("Got interrupted while waiting for dead watches " +
    +                LOG.info("Got interrupted while waiting for dead watchers " +
    --- End diff --
    
    Done


---

Mime
View raw message