Only clear status on lack of ready when was previously ready

rjeberhard · rjeberhard · commit 4f79647f650a · 2018-04-02T14:14:57.000-04:00
diff --git a/operator/src/main/java/oracle/kubernetes/operator/PodWatcher.java b/operator/src/main/java/oracle/kubernetes/operator/PodWatcher.java
@@ -91,10 +91,17 @@ public void receivedResponse(Watch.Response<V1Pod> item) {
         sko.getLastKnownStatus().set(isReady ? WebLogicConstants.RUNNING_STATE : null);
       }
       if (isReady) {
+        if (sko != null) {
+          sko.getLastKnownStatus().set(WebLogicConstants.RUNNING_STATE);
+        }
         OnReady ready = readyCallbackRegistrations.remove(podName);
         if (ready != null) {
           ready.onReady();
         }
+      } else {
+        if (sko != null) {
+          sko.getLastKnownStatus().compareAndSet(WebLogicConstants.RUNNING_STATE, null);
+        }
       }
       break;
     case "DELETED":

Original file line number	Diff line number	Diff line change
`@@ -91,10 +91,17 @@ public void receivedResponse(Watch.Response<V1Pod> item) {`
`91`	`91`	`sko.getLastKnownStatus().set(isReady ? WebLogicConstants.RUNNING_STATE : null);`
`92`	`92`	`}`
`93`	`93`	`if (isReady) {`
	`94`	`+ if (sko != null) {`
	`95`	`+ sko.getLastKnownStatus().set(WebLogicConstants.RUNNING_STATE);`
	`96`	`+ }`
`94`	`97`	`OnReady ready = readyCallbackRegistrations.remove(podName);`
`95`	`98`	`if (ready != null) {`
`96`	`99`	`ready.onReady();`
`97`	`100`	`}`
	`101`	`+ } else {`
	`102`	`+ if (sko != null) {`
	`103`	`+ sko.getLastKnownStatus().compareAndSet(WebLogicConstants.RUNNING_STATE, null);`
	`104`	`+ }`
`98`	`105`	`}`
`99`	`106`	`break;`
`100`	`107`	`case "DELETED":`