|
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