Repository: accumulo Updated Branches: refs/heads/master 90b661991 -> 07604ca05
ACCUMULO-2422 reset watch on non-delete events Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/853ed5bb Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/853ed5bb Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/853ed5bb Branch: refs/heads/master Commit: 853ed5bb2b2845284057af051a5d71835cfde8f5 Parents: 5dba407 Author: Eric Newton <eric.new...@gmail.com> Authored: Fri Feb 28 12:51:42 2014 -0500 Committer: Eric Newton <eric.new...@gmail.com> Committed: Fri Feb 28 12:51:42 2014 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/853ed5bb/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java ---------------------------------------------------------------------- diff --git a/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java b/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java index 86c3b88..25f1020 100644 --- a/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java +++ b/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java @@ -195,6 +195,12 @@ public class ZooLock implements Watcher { lw.failedToAcquireLock(new Exception("Zookeeper Session expired")); } } + } else { + try { + zooKeeper.getStatus(event.getPath(), this); + } catch (Exception ex) { + lw.failedToAcquireLock(ex); + } } }
