diff options
author | Harald Musum <musum@yahooinc.com> | 2023-05-12 11:25:06 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2023-05-12 11:25:06 +0200 |
commit | ee3f0e9cfd01a3989ae72907464df5d71df0e351 (patch) | |
tree | 8a38fef44b57691000038f725e515d2c139b81ef /clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java | |
parent | 1fca02b50e1c764063b8de71514fc5ccc79e3cd8 (diff) |
Create slobrok in constructor and simplify setup
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 | 12 |
1 files changed, 2 insertions, 10 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 8810172c801..dfef6e5a9d0 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 @@ -934,7 +934,7 @@ public class StateChangeTest extends FleetControllerTest { void testNoSystemStateBeforeInitialTimePeriod() throws Exception { FleetControllerOptions.Builder builder = defaultOptions() .setMinTimeBeforeFirstSystemStateBroadcast(3 * 60 * 1000); - setUpSystem(builder); + setUpFleetController(timer, builder); setUpVdsNodes(timer, 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) { @@ -942,7 +942,6 @@ public class StateChangeTest extends FleetControllerTest { nodes.get(i).connect(); } } - setUpFleetController(timer, builder); StateWaiter waiter = new StateWaiter(timer); fleetController().addSystemStateListener(waiter); @@ -978,8 +977,7 @@ public class StateChangeTest extends FleetControllerTest { void testSystemStateSentWhenNodesReplied() throws Exception { FleetControllerOptions.Builder builder = defaultOptions() .setMinTimeBeforeFirstSystemStateBroadcast(300 * 60 * 1000); - - setUpSystem(builder); + setUpFleetController(timer, builder); setUpVdsNodes(timer, true); for (DummyVdsNode node : nodes) { @@ -988,8 +986,6 @@ public class StateChangeTest extends FleetControllerTest { // Marking one node as 'initializing' improves testing of state later on. nodes.get(3).setNodeState(State.INITIALIZING); - setUpFleetController(timer, builder); - final StateWaiter waiter = new StateWaiter(timer); fleetController().addSystemStateListener(waiter); @@ -1375,10 +1371,6 @@ public class StateChangeTest extends FleetControllerTest { } } - private static FleetControllerOptions.Builder defaultOptions() { - return defaultOptions("mycluster", createNodes(10)); - } - private static FleetControllerOptions.Builder optionsWithZeroTransitionTime() { FleetControllerOptions.Builder options = defaultOptions(); options.setMaxTransitionTime(NodeType.STORAGE, 0); |