aboutsummaryrefslogtreecommitdiffstats
path: root/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-08-11 10:59:37 +0200
committerHarald Musum <musum@yahooinc.com>2022-08-11 10:59:37 +0200
commitb850ca20f9002c087312e3f4866a2564c87410cd (patch)
treec71a00bdafd370df78ab06004c041a185b952884 /clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java
parentec12f2b01d34f284d1cadbde8d06f30decb87638 (diff)
Remove the need for storing an instance variable in FleetControllerTest
Diffstat (limited to 'clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java')
-rw-r--r--clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java14
1 files changed, 8 insertions, 6 deletions
diff --git a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java
index 24e65a89d2b..af4984bdb26 100644
--- a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java
+++ b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java
@@ -951,15 +951,16 @@ public class StateChangeTest extends FleetControllerTest {
startingTest("StateChangeTest::testNoSystemStateBeforeInitialTimePeriod()");
FleetControllerOptions options = defaultOptions("mycluster", createNodes(10));
options.minTimeBeforeFirstSystemStateBroadcast = 3 * 60 * 1000;
- setUpSystem(true, options);
- setUpVdsNodes(true, new DummyVdsNodeOptions(), true);
+ setUpSystem(options);
+ boolean useFakeTimer = true;
+ setUpVdsNodes(useFakeTimer, new DummyVdsNodeOptions(), true);
// Leave one node down to avoid sending cluster state due to having seen all node states.
for (int i = 0; i < nodes.size(); ++i) {
if (i != 3) {
nodes.get(i).connect();
}
}
- setUpFleetController(true, options);
+ setUpFleetController(useFakeTimer, options);
StateWaiter waiter = new StateWaiter(timer);
fleetController.addSystemStateListener(waiter);
@@ -997,9 +998,10 @@ public class StateChangeTest extends FleetControllerTest {
final FleetControllerOptions options = defaultOptions("mycluster", createNodes(10));
options.minTimeBeforeFirstSystemStateBroadcast = 300 * 60 * 1000;
- setUpSystem(true, options);
+ boolean useFakeTimer = true;
+ setUpSystem(options);
- setUpVdsNodes(true, new DummyVdsNodeOptions(), true);
+ setUpVdsNodes(useFakeTimer, new DummyVdsNodeOptions(), true);
for (DummyVdsNode node : nodes) {
node.connect();
@@ -1007,7 +1009,7 @@ public class StateChangeTest extends FleetControllerTest {
// Marking one node as 'initializing' improves testing of state later on.
nodes.get(3).setNodeState(State.INITIALIZING);
- setUpFleetController(true, options);
+ setUpFleetController(useFakeTimer, options);
final StateWaiter waiter = new StateWaiter(timer);