diff options
Diffstat (limited to 'clustercontroller-core')
-rw-r--r-- | clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/MaintenanceWhenPendingGlobalMergesTest.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/MaintenanceWhenPendingGlobalMergesTest.java b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/MaintenanceWhenPendingGlobalMergesTest.java index 3b052a1bcb2..294c57d520c 100644 --- a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/MaintenanceWhenPendingGlobalMergesTest.java +++ b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/MaintenanceWhenPendingGlobalMergesTest.java @@ -20,11 +20,11 @@ public class MaintenanceWhenPendingGlobalMergesTest { private static class Fixture { MergePendingChecker mockPendingChecker = mock(MergePendingChecker.class); - MaintenanceTransitionConstraint mockEligibilityChecker = mock(MaintenanceTransitionConstraint.class); - MaintenanceWhenPendingGlobalMerges deriver = new MaintenanceWhenPendingGlobalMerges(mockPendingChecker, mockEligibilityChecker); + MaintenanceTransitionConstraint mockTransitionConstraint = mock(MaintenanceTransitionConstraint.class); + MaintenanceWhenPendingGlobalMerges deriver = new MaintenanceWhenPendingGlobalMerges(mockPendingChecker, mockTransitionConstraint); Fixture() { - when(mockEligibilityChecker.maintenanceTransitionAllowed(anyInt())).thenReturn(true); + when(mockTransitionConstraint.maintenanceTransitionAllowed(anyInt())).thenReturn(true); } } @@ -111,7 +111,7 @@ public class MaintenanceWhenPendingGlobalMergesTest { public void node_with_pending_merges_only_set_to_maintenance_if_eligible() { Fixture f = new Fixture(); Arrays.asList(1, 2, 3).forEach(idx -> when(f.mockPendingChecker.mayHaveMergesPending(globalSpace(), idx)).thenReturn(true)); - Arrays.asList(1, 2, 4).forEach(idx -> when(f.mockEligibilityChecker.maintenanceTransitionAllowed(idx)).thenReturn(false)); + Arrays.asList(1, 2, 4).forEach(idx -> when(f.mockTransitionConstraint.maintenanceTransitionAllowed(idx)).thenReturn(false)); AnnotatedClusterState derived = f.deriver.derivedFrom(stateFromString("distributor:5 storage:5"), defaultSpace()); assertThat(derived, equalTo(AnnotatedClusterStateBuilder.ofState("distributor:5 storage:5 .3.s:m") .reason(MAY_HAVE_MERGES_PENDING, 3).build())); |