accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [1/4] git commit: ACCUMULO-2422 reset watch on non-delete events
Date Fri, 28 Feb 2014 17:52:36 GMT
Repository: accumulo
Updated Branches:
  refs/heads/1.6.0-SNAPSHOT bd970de81 -> 04d8cd8d4


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.6.0-SNAPSHOT
Commit: 853ed5bb2b2845284057af051a5d71835cfde8f5
Parents: 5dba407
Author: Eric Newton <eric.newton@gmail.com>
Authored: Fri Feb 28 12:51:42 2014 -0500
Committer: Eric Newton <eric.newton@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);
+          }
         }
       }
       


Mime
View raw message