diff options
author | Harald Musum <musum@verizonmedia.com> | 2020-04-29 13:55:13 +0200 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2020-04-29 13:55:13 +0200 |
commit | 9f492628f7fa9c5f59c50d97af37907581bcc015 (patch) | |
tree | 8fdbeea15b290577d04b4725c6e816d7f0420325 /zkfacade/src/test/java/com | |
parent | a8fc679943ae9bdc6d6d58d82a2b9f43dac54ad4 (diff) |
Wait longer for servers to reach barrier
1. Wait up to 2 seconds for all to reach barrier.
2. If not, wait up to 4 seconds for the server that waits for the barrier to
be one of the respondents AND a majority of servers have reached barrier.
3. If not, wait for a majority of servers to have reached barrier.
Diffstat (limited to 'zkfacade/src/test/java/com')
-rw-r--r-- | zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorCompletionWaiterTest.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorCompletionWaiterTest.java b/zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorCompletionWaiterTest.java index d1ce744de7f..54bba4aa619 100644 --- a/zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorCompletionWaiterTest.java +++ b/zkfacade/src/test/java/com/yahoo/vespa/curator/CuratorCompletionWaiterTest.java @@ -17,8 +17,8 @@ public class CuratorCompletionWaiterTest { @Test public void testCompletionWaiter() throws InterruptedException { Curator curator = new MockCurator(); - Curator.CompletionWaiter waiter = CuratorCompletionWaiter.createAndInitialize(curator, Path.createRoot(), "foo", 1, "foo"); - Curator.CompletionWaiter notifier = CuratorCompletionWaiter.create(curator.framework(), Path.fromString("/foo"), 1, "bar"); + Curator.CompletionWaiter waiter = CuratorCompletionWaiter.createAndInitialize(curator, Path.createRoot(), "foo", "foo"); + Curator.CompletionWaiter notifier = CuratorCompletionWaiter.create(curator, Path.fromString("/foo"), "bar"); Thread t1 = new Thread(() -> { try { waiter.awaitCompletion(Duration.ofSeconds(120)); @@ -34,7 +34,7 @@ public class CuratorCompletionWaiterTest { @Test(expected = CompletionTimeoutException.class) public void testCompletionWaiterFailure() { Curator curator = new MockCurator(); - Curator.CompletionWaiter waiter = CuratorCompletionWaiter.createAndInitialize(curator, Path.createRoot(), "foo", 1, "foo"); + Curator.CompletionWaiter waiter = CuratorCompletionWaiter.createAndInitialize(curator, Path.createRoot(), "foo", "foo"); waiter.awaitCompletion(Duration.ofMillis(100)); } } |