diff options
author | Harald Musum <musum@yahooinc.com> | 2022-08-11 10:59:37 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-08-11 10:59:37 +0200 |
commit | b850ca20f9002c087312e3f4866a2564c87410cd (patch) | |
tree | c71a00bdafd370df78ab06004c041a185b952884 /clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java | |
parent | ec12f2b01d34f284d1cadbde8d06f30decb87638 (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.java | 14 |
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); |