diff options
author | Martin Polden <mpolden@mpolden.no> | 2020-12-15 11:08:25 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2020-12-15 11:23:14 +0100 |
commit | 56d4bd75d2d7cfb9fa3fe5095cf39fb7903a8bab (patch) | |
tree | c034c6eea09b41700bb8a8864ebdb570558e545a /zookeeper-server/zookeeper-server-common/src/test/java/com/yahoo | |
parent | 1468a9df93196f38d8fc86d5d2be61650a94980f (diff) |
Use exponential backoff for ZooKeeper restart
Diffstat (limited to 'zookeeper-server/zookeeper-server-common/src/test/java/com/yahoo')
-rw-r--r-- | zookeeper-server/zookeeper-server-common/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/zookeeper-server/zookeeper-server-common/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java b/zookeeper-server/zookeeper-server-common/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java index 6ea024db0a4..61ddc5996a4 100644 --- a/zookeeper-server/zookeeper-server-common/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java +++ b/zookeeper-server/zookeeper-server-common/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java @@ -12,6 +12,7 @@ import org.junit.rules.TemporaryFolder; import java.io.File; import java.io.IOException; import java.nio.file.Path; +import java.time.Duration; import java.util.stream.IntStream; import static org.junit.Assert.assertEquals; @@ -71,8 +72,8 @@ public class ReconfigurerTest { @Test public void testReconfigureFailsWithReconfigInProgressThenSucceeds() { + TestableReconfigurer reconfigurer = new TestableReconfigurer(new TestableVespaZooKeeperAdmin().failures(3)); try { - TestableReconfigurer reconfigurer = new TestableReconfigurer(new TestableVespaZooKeeperAdmin().failures(3)); ZookeeperServerConfig initialConfig = createConfig(3, true); reconfigurer.startOrReconfigure(initialConfig); assertSame(initialConfig, reconfigurer.activeConfig()); @@ -128,7 +129,12 @@ public class ReconfigurerTest { private final TestableVespaZooKeeperAdmin zooKeeperAdmin; TestableReconfigurer(TestableVespaZooKeeperAdmin zooKeeperAdmin) { - super(zooKeeperAdmin, (ignored) -> {}); + super(zooKeeperAdmin, new Sleeper() { + @Override + public void sleep(Duration duration) { + // Do nothing + } + }); this.zooKeeperAdmin = zooKeeperAdmin; HostName.setHostNameForTestingOnly("node1"); } |