You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2014/02/28 18:52:18 UTC
git commit: ACCUMULO-2422 reset watch on non-delete events
Repository: accumulo
Updated Branches:
refs/heads/1.5.1-SNAPSHOT 5dba407cc -> 853ed5bb2
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/1.5.1-SNAPSHOT
Commit: 853ed5bb2b2845284057af051a5d71835cfde8f5
Parents: 5dba407
Author: Eric Newton <er...@gmail.com>
Authored: Fri Feb 28 12:51:42 2014 -0500
Committer: Eric Newton <er...@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);
+ }
}
}