Debugging

Author: rjeberhard

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

@@ -195,6 +195,7 @@ private static void begin() {
       // this would happen when the Domain was running BEFORE the Operator starts up
       LOGGER.info(MessageKeys.LISTING_DOMAINS);
       for (String ns : targetNamespaces) {
+        initialized.put(ns, Boolean.TRUE);
         Step domainList = callBuilderFactory.create().listDomainAsync(ns, new ResponseStep<DomainList>(null) {
           @Override
           public NextAction onFailure(Packet packet, ApiException e, int statusCode,
@@ -208,25 +209,12 @@ public NextAction onFailure(Packet packet, ApiException e, int statusCode,
           @Override
           public NextAction onSuccess(Packet packet, DomainList result, int statusCode,
               Map<String, List<String>> responseHeaders) {
-            initialized.put(ns, Boolean.TRUE);
             if (result != null) {
               for (Domain dom : result.getItems()) {
                 doCheckAndCreateDomainPresence(dom);
               }
             }
 
-            // delete stranded resources
-            for (Map.Entry<String, DomainPresenceInfo> entry : domains.entrySet()) {
-              String domainUID = entry.getKey();
-              DomainPresenceInfo info = entry.getValue();
-              if (info != null) {
-                if (info.getDomain() == null) {
-                  // no domain resource
-                  deleteDomainPresence(info.getNamespace(), domainUID);
-                }
-              }
-            }
-            
             // main logic now happens in the watch handlers
             domainWatchers.put(ns, createDomainWatcher(ns, result != null ? result.getMetadata().getResourceVersion() : ""));
             return doNext(packet);
@@ -361,6 +349,18 @@ public void onThrowable(Packet packet, Throwable throwable) {
           }
         }); 
       }
+      
+      // delete stranded resources
+      for (Map.Entry<String, DomainPresenceInfo> entry : domains.entrySet()) {
+        String domainUID = entry.getKey();
+        DomainPresenceInfo info = entry.getValue();
+        if (info != null) {
+          if (info.getDomain() == null) {
+            // no domain resource
+            deleteDomainPresence(info.getNamespace(), domainUID);
+          }
+        }
+      }
     } catch (Throwable e) {
       LOGGER.warning(MessageKeys.EXCEPTION, e);
     } finally {
@@ -577,6 +577,9 @@ private static void doCheckAndCreateDomainPresence(
     normalizeDomainSpec(spec);
     String domainUID = spec.getDomainUID();
 
+    // TEST
+    System.out.println("**** -1 **** domainUID: " + domainUID);
+
     DomainPresenceInfo created = new DomainPresenceInfo(dom);
     DomainPresenceInfo info = domains.putIfAbsent(domainUID, created);
     if (info == null) {