Skip to content

Commit ce3ad75

Browse files
committed
Read of existing situ config map only on up flow
1 parent 0e3a8c1 commit ce3ad75

File tree

2 files changed

+26
-18
lines changed

2 files changed

+26
-18
lines changed

operator/src/main/java/oracle/kubernetes/operator/DomainProcessorImpl.java

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -687,10 +687,7 @@ public StartPlanStep(DomainPresenceInfo info, Step next) {
687687

688688
@Override
689689
public NextAction apply(Packet packet) {
690-
Step strategy =
691-
Step.chain(
692-
ConfigMapHelper.readExistingSituConfigMap(info.getNamespace(), info.getDomainUID()),
693-
new RegisterStep(info, getNext()));
690+
Step strategy = getNext();
694691
if (!info.isPopulated()) {
695692
strategy = Step.chain(readExistingPods(info), readExistingServices(info), strategy);
696693
}
@@ -890,12 +887,17 @@ static Step createDomainUpPlan(DomainPresenceInfo info) {
890887
info,
891888
new DomainStatusStep(info, bringAdminServerUp(info, managedServerStrategy)))));
892889

893-
return new UpHeadStep(
894-
info,
895-
DomainStatusUpdater.createProgressingStep(
896-
DomainStatusUpdater.INSPECTING_DOMAIN_PROGRESS_REASON,
897-
true,
898-
DomainPresenceStep.createDomainPresenceStep(dom, strategy, managedServerStrategy)));
890+
strategy =
891+
new UpHeadStep(
892+
info,
893+
DomainStatusUpdater.createProgressingStep(
894+
DomainStatusUpdater.INSPECTING_DOMAIN_PROGRESS_REASON,
895+
true,
896+
DomainPresenceStep.createDomainPresenceStep(dom, strategy, managedServerStrategy)));
897+
898+
return Step.chain(
899+
ConfigMapHelper.readExistingSituConfigMap(info.getNamespace(), info.getDomainUID()),
900+
new RegisterStep(info, strategy));
899901
}
900902

901903
static Step createDomainDownPlan(DomainPresenceInfo info) {

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

Lines changed: 14 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,11 @@ public void whenNoPreexistingDomains_createEmptyDomainPresenceInfoMap() {
147147
}
148148

149149
private void readExistingResources() {
150-
createCannedListDomainResponses();
150+
readExistingResources(false);
151+
}
152+
153+
private void readExistingResources(boolean isDelete) {
154+
createCannedListDomainResponses(isDelete);
151155
testSupport.runStepsToCompletion(Main.readExistingResources("operator", NS));
152156
}
153157

@@ -332,7 +336,7 @@ private V1Event createEventResource(String uid, String serverName, String messag
332336
}
333337

334338
@SuppressWarnings("unchecked")
335-
private void createCannedListDomainResponses() {
339+
private void createCannedListDomainResponses(boolean isDelete) {
336340
testSupport.createCannedResponse("listDomain").withNamespace(NS).returning(domains);
337341
testSupport
338342
.createCannedResponse("listService")
@@ -360,11 +364,13 @@ private void createCannedListDomainResponses() {
360364
.withName(DOMAIN_CONFIG_MAP_NAME)
361365
.ignoringBody()
362366
.returning(domainConfigMap);
363-
testSupport
364-
.createCannedResponse("readConfigMap")
365-
.withNamespace(NS)
366-
.withName(UID + INTROSPECTOR_CONFIG_MAP_NAME_SUFFIX)
367-
.returning(createEmptyConfigMap());
367+
if (!isDelete) {
368+
testSupport
369+
.createCannedResponse("readConfigMap")
370+
.withNamespace(NS)
371+
.withName(UID + INTROSPECTOR_CONFIG_MAP_NAME_SUFFIX)
372+
.returning(createEmptyConfigMap());
373+
}
368374
}
369375

370376
private DomainList createEmptyDomainList() {
@@ -467,7 +473,7 @@ public void whenStrandedResourcesExist_removeThem() {
467473

468474
isNamespaceStopping.get(NS).set(false);
469475

470-
readExistingResources();
476+
readExistingResources(true);
471477

472478
testSupport.verifyAllDefinedResponsesInvoked();
473479
}

0 commit comments

Comments
 (0)