|
87 | 87 | import static oracle.kubernetes.operator.ProcessingConstants.DOMAIN_TOPOLOGY;
|
88 | 88 | import static oracle.kubernetes.operator.ProcessingConstants.MII_DYNAMIC_UPDATE;
|
89 | 89 | import static oracle.kubernetes.operator.ProcessingConstants.MII_DYNAMIC_UPDATE_RESTART_REQUIRED;
|
| 90 | +import static oracle.kubernetes.operator.ProcessingConstants.MII_DYNAMIC_UPDATE_SUCCESS; |
90 | 91 | import static oracle.kubernetes.operator.ProcessingConstants.SERVER_HEALTH_MAP;
|
91 | 92 | import static oracle.kubernetes.operator.ProcessingConstants.SERVER_STATE_MAP;
|
92 | 93 | import static oracle.kubernetes.operator.WebLogicConstants.RUNNING_STATE;
|
@@ -429,10 +430,12 @@ static class DomainStatusUpdaterContext {
|
429 | 430 | private DomainStatus newStatus;
|
430 | 431 | private final List<EventData> newEvents = new ArrayList<>();
|
431 | 432 | final boolean endOfProcessing;
|
| 433 | + private Packet packet; |
432 | 434 |
|
433 | 435 | DomainStatusUpdaterContext(Packet packet, DomainStatusUpdaterStep domainStatusUpdaterStep) {
|
434 | 436 | info = DomainPresenceInfo.fromPacket(packet).orElseThrow();
|
435 | 437 | isMakeRight = MakeRightDomainOperation.isMakeRight(packet);
|
| 438 | + this.packet = packet; |
436 | 439 | this.domainStatusUpdaterStep = domainStatusUpdaterStep;
|
437 | 440 | endOfProcessing = (Boolean) packet.getOrDefault(ProcessingConstants.END_OF_PROCESSING, Boolean.FALSE);
|
438 | 441 | }
|
@@ -546,7 +549,10 @@ Step createUpdateSteps(Step next) {
|
546 | 549 | if (!isStatusUnchanged()) {
|
547 | 550 | result.add(createDomainStatusReplaceStep());
|
548 | 551 | } else {
|
549 |
| - if (endOfProcessing && isMakeRight) { |
| 552 | + boolean successFullDynamicUpdate = MII_DYNAMIC_UPDATE_SUCCESS.equals(packet.get(MII_DYNAMIC_UPDATE)) |
| 553 | + || MII_DYNAMIC_UPDATE_RESTART_REQUIRED.equals(packet.get(MII_DYNAMIC_UPDATE)); |
| 554 | + |
| 555 | + if ((endOfProcessing && isMakeRight) || successFullDynamicUpdate) { |
550 | 556 | Optional.ofNullable(createDomainStatusObservedGenerationReplaceStep()).ifPresent(result::add);
|
551 | 557 | }
|
552 | 558 | }
|
|
0 commit comments