Skip to content

Commit 4192696

Browse files
committed
Minor cleanup related changes.
1 parent 3d1b7ad commit 4192696

File tree

3 files changed

+13
-21
lines changed

3 files changed

+13
-21
lines changed

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

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1382,10 +1382,15 @@ private void invoke() {
13821382
info, waiting.getReason(), waiting.getMessage(), null)));
13831383
break;
13841384
case INIT_CONTAINERS_NOT_READY:
1385-
List<String> waitingMessages = new ArrayList<>();
13861385
List<String> waitingReasons = new ArrayList<>();
1386+
List<String> waitingMessages = new ArrayList<>();
13871387

1388-
getInitContainersWaitingReasonsAndMessages(introspectorPod, waitingReasons, waitingMessages);
1388+
Optional.ofNullable(getInitContainerStatuses(introspectorPod))
1389+
.orElseGet(Collections::emptyList).stream()
1390+
.forEach(status -> {
1391+
waitingMessages.add(getWaitingMessageFromStatus(status));
1392+
waitingReasons.add(getWaitingReason(status));
1393+
});
13891394
if (!waitingReasons.isEmpty()) {
13901395
delegate.runSteps(DomainStatusUpdater.createFailureRelatedSteps(
13911396
info, onSeparateLines(waitingReasons), onSeparateLines(waitingMessages), null));
@@ -1419,14 +1424,6 @@ private void invoke() {
14191424
}
14201425
}
14211426

1422-
private void getInitContainersWaitingReasonsAndMessages(V1Pod pod, List waitingReasons, List waitingMessages) {
1423-
Optional.ofNullable(getInitContainerStatuses(pod)).orElseGet(Collections::emptyList).stream()
1424-
.forEach(status -> {
1425-
waitingMessages.add(getWaitingMessageFromStatus(status));
1426-
waitingReasons.add(getWaitingReason(status));
1427-
});
1428-
}
1429-
14301427
private String getWaitingReason(V1ContainerStatus status) {
14311428
return Optional.ofNullable(status)
14321429
.map(V1ContainerStatus::getState)

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -265,9 +265,9 @@ private static String getReason(V1PodCondition podCondition) {
265265
return Optional.ofNullable(podCondition).map(V1PodCondition::getReason).orElse("");
266266
}
267267

268-
private static boolean notReady(List<V1ContainerStatus> initContainerStatus) {
269-
return Optional.ofNullable(initContainerStatus)
270-
.orElseGet(Collections::emptyList).stream().anyMatch(statuses -> notReady(statuses));
268+
private static boolean notReady(List<V1ContainerStatus> initContainerStatuses) {
269+
return Optional.ofNullable(initContainerStatuses)
270+
.orElseGet(Collections::emptyList).stream().anyMatch(status -> notReady(status));
271271
}
272272

273273
private static boolean notReady(V1ContainerStatus conStatus) {

operator/src/main/java/oracle/kubernetes/operator/helpers/JobHelper.java

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -568,9 +568,8 @@ private void recordJobPodNameAndStatus(Packet packet, V1Pod pod) {
568568
.map(V1PodStatus::getContainerStatuses).map(statuses -> statuses.get(0))
569569
.map(V1ContainerStatus::getState).map(V1ContainerState::getWaiting)
570570
.map(V1ContainerStateWaiting::getReason).orElse(null));
571+
packet.put(ProcessingConstants.JOB_POD_INIT_CONTAINER_WAITING_REASON, getInitContainerWaitingMessages(pod));
571572
}
572-
573-
packet.put(ProcessingConstants.JOB_POD_INIT_CONTAINER_WAITING_REASON, getInitContainerWaitingMessages(pod));
574573
}
575574

576575
private Boolean getInitContainerWaitingMessages(V1Pod pod) {
@@ -624,12 +623,8 @@ static OffsetDateTime createNextSteps(List<Step> nextSteps, Packet packet, V1Job
624623
}
625624

626625
private static Boolean getjobInitContainerImagePullError(Packet packet) {
627-
Boolean containerWaitingReason = packet.getValue(ProcessingConstants.JOB_POD_INIT_CONTAINER_WAITING_REASON);
628-
return Optional.ofNullable(containerWaitingReason).orElse(Boolean.FALSE);
629-
}
630-
631-
private static Boolean isNotNull(Boolean jobInitContainerImagePullError) {
632-
return Optional.ofNullable(jobInitContainerImagePullError).orElse(false);
626+
return Optional.ofNullable(packet.<Boolean>getValue(ProcessingConstants.JOB_POD_INIT_CONTAINER_WAITING_REASON))
627+
.orElse(Boolean.FALSE);
633628
}
634629
}
635630

0 commit comments

Comments
 (0)