aboutsummaryrefslogtreecommitdiffstats
path: root/zkfacade/src/test/java/com
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2020-04-29 13:55:13 +0200
committerHarald Musum <musum@verizonmedia.com>2020-04-29 13:55:13 +0200
commit9f492628f7fa9c5f59c50d97af37907581bcc015 (patch)
tree8fdbeea15b290577d04b4725c6e816d7f0420325 /zkfacade/src/test/java/com
parenta8fc679943ae9bdc6d6d58d82a2b9f43dac54ad4 (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.java6
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));
}
}