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>2023-05-12 11:25:06 +0200
committerHarald Musum <musum@yahooinc.com>2023-05-12 11:25:06 +0200
commitee3f0e9cfd01a3989ae72907464df5d71df0e351 (patch)
tree8a38fef44b57691000038f725e515d2c139b81ef /clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java
parent1fca02b50e1c764063b8de71514fc5ccc79e3cd8 (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.java12
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);