Skip to content

Commit 8f946eb

Browse files
committed
Correct precreateServerService support
1 parent ce333d2 commit 8f946eb

File tree

2 files changed

+18
-13
lines changed

2 files changed

+18
-13
lines changed

operator/src/main/java/oracle/kubernetes/operator/steps/ServerDownStep.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// Copyright (c) 2017, 2024, Oracle and/or its affiliates.
1+
// Copyright (c) 2017, 2025, Oracle and/or its affiliates.
22
// Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
33

44
package oracle.kubernetes.operator.steps;
@@ -44,7 +44,7 @@ public class ServerDownStep extends Step {
4444
return doNext(createShutdownManagedServerStep(oldPod, next), packet);
4545
}
4646

47-
return doNext(packet);
47+
return doNext(next, packet);
4848
}
4949

5050
@Nonnull

operator/src/test/java/oracle/kubernetes/operator/DomainProcessorTest.java

Lines changed: 16 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -910,17 +910,6 @@ void whenDomainScaledDownAndServerStateUnknown_removeExcessPods() {
910910
assertThat(getRunningPods().size(), equalTo(MIN_REPLICAS + NUM_ADMIN_SERVERS + NUM_JOB_PODS));
911911
}
912912

913-
@Test
914-
void whenDomainWithoutPreCreateServerService_removeService() {
915-
defineServerResources(ADMIN_NAME);
916-
Arrays.stream(MANAGED_SERVER_NAMES).forEach(this::defineServerResources);
917-
domainConfigurator.configureCluster(newInfo, CLUSTER).withReplicas(MIN_REPLICAS).withPrecreateServerService(false);
918-
newInfo.getReferencedClusters().forEach(testSupport::defineResources);
919-
920-
createMakeRight(newInfo).execute();
921-
assertThat((int) getServerServices().count(), equalTo(MIN_REPLICAS + NUM_ADMIN_SERVERS));
922-
}
923-
924913
@Test
925914
void whenDomainScaledDown_withPreCreateServerService_doesNotRemoveServices() {
926915
defineServerResources(ADMIN_NAME);
@@ -951,6 +940,22 @@ void whenDomainScaledDown_withoutPreCreateServerService_removeService() {
951940
assertThat(getServerService(SERVER3).isPresent(), is(false));
952941
}
953942

943+
@Test
944+
void whenDomainWithoutPreCreateServerService_removeService() {
945+
defineServerResources(ADMIN_NAME);
946+
Arrays.stream(MANAGED_SERVER_NAMES).forEach(this::defineServerResources);
947+
domainConfigurator.configureCluster(newInfo, CLUSTER).withReplicas(MIN_REPLICAS).withPrecreateServerService(true);
948+
newInfo.getReferencedClusters().forEach(testSupport::defineResources);
949+
950+
createMakeRight(newInfo).execute();
951+
assertThat((int) getServerServices().count(), equalTo(MAX_SERVERS + NUM_ADMIN_SERVERS));
952+
newInfo.getReferencedClusters().getFirst().getSpec().setPrecreateServerService(false);
953+
newDomain.getSpec().setPrecreateServerService(false);
954+
newDomain.getMetadata().setCreationTimestamp(SystemClock.now());
955+
processor.createMakeRightOperation(newInfo).withExplicitRecheck().execute();
956+
assertThat((int) getServerServices().count(), equalTo(MIN_REPLICAS + NUM_ADMIN_SERVERS));
957+
}
958+
954959
@Test
955960
void whenDomainScaledDown_withPreCreateServerService_createClusterIPService() {
956961
final String SERVER3 = MANAGED_SERVER_NAMES[2];

0 commit comments

Comments
 (0)