Repository: curator Updated Branches: refs/heads/CURATOR-443 3f7b610ad -> 166b5c3d5
queue multiple operations for a more complete test Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/166b5c3d Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/166b5c3d Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/166b5c3d Branch: refs/heads/CURATOR-443 Commit: 166b5c3d5091bd254747f6372534519d37883bfa Parents: 3f7b610 Author: randgalt <[email protected]> Authored: Tue Dec 5 12:57:41 2017 -0800 Committer: randgalt <[email protected]> Committed: Tue Dec 5 12:57:41 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/166b5c3d/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 35e9fb1..75d97b1 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 @@ -71,7 +71,7 @@ public class TestFrameworkEdges extends BaseClassForTests client.start(); ((CuratorFrameworkImpl)client).sleepAndQueueOperationSeconds = Integer.MAX_VALUE; - final CountDownLatch latch = new CountDownLatch(1); + final CountDownLatch latch = new CountDownLatch(3); BackgroundCallback callback = new BackgroundCallback() { @Override @@ -80,7 +80,10 @@ public class TestFrameworkEdges extends BaseClassForTests latch.countDown(); } }; + // queue multiple operations for a more complete test client.create().inBackground(callback).forPath("/test"); + client.create().inBackground(callback).forPath("/test/one"); + client.create().inBackground(callback).forPath("/test/two"); server.restart(); Assert.assertTrue(timing.awaitLatch(latch));
