You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@curator.apache.org by ra...@apache.org on 2018/01/02 16:03:58 UTC

[6/7] curator git commit: only countdown on success

only countdown on success


Project: http://git-wip-us.apache.org/repos/asf/curator/repo
Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/ab2e7563
Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/ab2e7563
Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/ab2e7563

Branch: refs/heads/master
Commit: ab2e756323b5c5398b01cb1493fbc984f572b946
Parents: 166b5c3
Author: randgalt <ra...@apache.org>
Authored: Tue Dec 5 13:00:02 2017 -0800
Committer: randgalt <ra...@apache.org>
Committed: Tue Dec 5 13:00:02 2017 -0800

----------------------------------------------------------------------
 .../org/apache/curator/framework/imps/TestFrameworkEdges.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/curator/blob/ab2e7563/curator-framework/src/test/java/org/apache/curator/framework/imps/TestFrameworkEdges.java
----------------------------------------------------------------------
diff --git a/curator-framework/src/test/java/org/apache/curator/framework/imps/TestFrameworkEdges.java b/curator-framework/src/test/java/org/apache/curator/framework/imps/TestFrameworkEdges.java
index 75d97b1..86133b8 100644
--- a/curator-framework/src/test/java/org/apache/curator/framework/imps/TestFrameworkEdges.java
+++ b/curator-framework/src/test/java/org/apache/curator/framework/imps/TestFrameworkEdges.java
@@ -77,7 +77,10 @@ public class TestFrameworkEdges extends BaseClassForTests
                 @Override
                 public void processResult(CuratorFramework client, CuratorEvent event) throws Exception
                 {
-                    latch.countDown();
+                    if ( (event.getType() == CuratorEventType.CREATE) && (event.getResultCode() == KeeperException.Code.OK.intValue()) )
+                    {
+                        latch.countDown();
+                    }
                 }
             };
             // queue multiple operations for a more complete test