Merge pull request #1118 from oracle/introspect-after-edit

Resolve failure in introspection following a console edit

Author: rjeberhard

operator/src/main/resources/scripts/introspectDomain.py

@@ -1,4 +1,4 @@
-# Copyright 2018, Oracle Corporation and/or its affiliates. All rights reserved.
+# Copyright 2018, 2019, Oracle Corporation and/or its affiliates. All rights reserved.
 # Licensed under the Universal Permissive License v 1.0 as shown at http://oss.oracle.com/licenses/upl.
 #
 # ------------
@@ -209,14 +209,14 @@ def printFile(self, path):
 
   def getEnv(self, name):
     val = os.getenv(name)
-    if val == None or val == "null":
+    if val is None or val == "null":
       trace("ERROR: Env var "+name+" not set.")
       sys.exit(1)
     return val
 
   def getEnvOrDef(self, name, deflt):
     val = os.getenv(name)
-    if val == None or val == "null":
+    if val is None or val == "null":
       return deflt
     return val
 
@@ -303,18 +303,33 @@ def generate(self):
   #     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
   #     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
   #     at java.lang.reflect.Method.invoke(Method.java:498)
-  def getDynamicServersWA(self,cluster):
+  def getDynamicServersOrNone(self,cluster):
     try:
       ret = cluster.getDynamicServers()
     except:
       trace("Ignoring getDynamicServers() exception, this is expected.")
       ret = None
     return ret
 
+  def getClusterOrNone(self,server):
+    try:
+      ret = server.getCluster()
+    except:
+      trace("Ignoring getCluster() exception, this is expected.")
+      ret = None
+    return ret
+
+  def getSSLOrNone(self,server):
+    try:
+      ret = server.getSSL()
+    except:
+      trace("Ignoring getSSL() exception, this is expected.")
+      ret = None
+    return ret
 
   def validateAdminServer(self):
     adminServerName = self.env.getDomain().getAdminServerName()
-    if adminServerName == None:
+    if adminServerName is None:
       addError("The admin server name is null.")
       return
     adminServer = None
@@ -324,16 +339,16 @@ def validateAdminServer(self):
     if adminServer is None:
       addError("The admin server '" + adminServerName + "' does not exist.")
       return
-    cluster = adminServer.getCluster()
-    if cluster != None:
+    cluster = self.getClusterOrNone(adminServer)
+    if cluster is not None:
       self.addError("The admin server " + self.name(adminServer) + " belongs to the cluster " + self.name(cluster) + ".")
 
   def validateClusters(self):
     for cluster in self.env.getDomain().getClusters():
       self.validateCluster(cluster)
 
   def validateCluster(self, cluster):
-    if self.getDynamicServersWA(cluster) is None:
+    if self.getDynamicServersOrNone(cluster) is None:
       self.validateNonDynamicCluster(cluster)
     else:
       self.validateDynamicCluster(cluster)
@@ -346,7 +361,7 @@ def validateNonDynamicCluster(self, cluster):
 
   def validateNonDynamicClusterReferencedByAtLeastOneServer(self, cluster):
     for server in self.env.getDomain().getServers():
-      if server.getCluster() is cluster:
+      if self.getClusterOrNone(server) is cluster:
         return
     self.addError("The non-dynamic cluster " + self.name(cluster) + " is not referenced by any servers.")
 
@@ -362,13 +377,14 @@ def validateNonDynamicClusterNotReferencedByAnyServerTemplates(self, cluster):
   ADMIN_LISTEN_PORT = 'admin listen port'
   ADMIN_LISTEN_PORT_ENABLED = 'admin listen port enabled'
 
-  def getServerClusterPortPropertyValue(server, clusterListenPortProperty):
+  def getServerClusterPortPropertyValue(self, server, clusterListenPortProperty):
     sslListenPort = None
-    if server.getSSL() != None:
-      sslListenPort = server.getSSL().getListenPort()
+    ssl = self.getSSLOrNone(server)
+    if ssl is not None:
+      sslListenPort = ssl.getListenPort()
     sslListenPortEnabled = None
-    if server.getSSL()!= None:
-      sslListenPortEnabled = server.getSSL().isListenPortEnabled()
+    if ssl is not None:
+      sslListenPortEnabled = ssl.isListenPortEnabled()
     return {
              LISTEN_PORT: server.getListenPort(),
              LISTEN_PORT_ENABLED: server.isListenPortEnabled(),
@@ -387,10 +403,10 @@ def validateNonDynamicClusterServersHaveSameListenPort(self, cluster):
     firstAdminPort = None
     firstAdminPortEnabled = None
     for server in self.env.getDomain().getServers():
-      if cluster is server.getCluster():
+      if cluster is self.getClusterOrNone(server):
         listenPort = server.getListenPort()
         listenPortEnabled = server.isListenPortEnabled()
-        ssl = server.getSSL()
+        ssl = self.getSSLOrNone(server)
         sslListenPort = None
         sslListenPortEnabled = None
         if ssl is not None:
@@ -426,8 +442,8 @@ def validateClusterServersListenPortProperty(self, cluster, errorMsg, clusterLis
     firstServer = None
     firstListenPortProperty = None
     for server in self.env.getDomain().getServers():
-      if cluster is server.getCluster():
-        listenPortProperty = getServerClusterPortPropertyValue(server, clusterListenPortProperty)
+      if cluster is self.getClusterOrNone(server):
+        listenPortProperty = getServerClusterPortPropertyValue(self, server, clusterListenPortProperty)
         if firstServer is None:
           firstServer = server
           firstListenPortProperty = listenPortProperty
@@ -440,7 +456,7 @@ def validateNonDynamicClusterServerHaveSameCustomChannels(self, cluster):
      firstServer = None
      serverNap = {}
      for server in self.env.getDomain().getServers():
-       if cluster is server.getCluster():
+       if cluster is self.getClusterOrNone(server):
          if firstServer is None:
            for nap in server.getNetworkAccessPoints():
              serverNap[nap.getName()] = nap.getProtocol() + "~" + str(nap.getListenPort());
@@ -481,7 +497,7 @@ def validateDynamicClusterReferencedByOneServerTemplate(self, cluster):
 
   def validateDynamicClusterNotReferencedByAnyServers(self, cluster):
     for server in self.env.getDomain().getServers():
-      if server.getCluster() is cluster:
+      if self.getClusterOrNone(server) is cluster:
         self.addError("The dynamic cluster " + self.name(cluster) + " is referenced by the server " + self.name(server) + ".")
 
   def validateDynamicClusterDynamicServersDoNotUseCalculatedListenPorts(self, cluster):
@@ -535,13 +551,13 @@ def addConfiguredClusters(self):
   def getConfiguredClusters(self):
     rtn = []
     for cluster in self.env.getDomain().getClusters():
-      if self.getDynamicServersWA(cluster) is None:
+      if self.getDynamicServersOrNone(cluster) is None:
         rtn.append(cluster)
     return rtn
 
   def addConfiguredCluster(self, cluster):
     self.writeln("- name: " + self.name(cluster))
-    dynamicServers = self.getDynamicServersWA(cluster)
+    dynamicServers = self.getDynamicServersOrNone(cluster)
     if dynamicServers is not None:
       self.indent();
       self.writeln("dynamicServersConfig:")
@@ -571,7 +587,7 @@ def addDynamicServer(self, dynamicServer):
   def getClusteredServers(self, cluster):
     rtn = []
     for server in self.env.getDomain().getServers():
-      if server.getCluster() is cluster:
+      if self.getClusterOrNone(server) is cluster:
         rtn.append(server)
     return rtn
 
@@ -590,7 +606,7 @@ def addServer(self, server):
     self.addNetworkAccessPoints(server)
 
   def addSSL(self, server):
-    ssl = server.getSSL()
+    ssl = self.getSSLOrNone(server)
     if ssl is not None and ssl.isEnabled():
       self.indent()
       self.writeln("sslListenPort: " + str(ssl.getListenPort()))
@@ -623,7 +639,7 @@ def addDynamicClusters(self):
   def getDynamicClusters(self):
     rtn = []
     for cluster in self.env.getDomain().getClusters():
-      if self.getDynamicServersWA(cluster) is not None:
+      if self.getDynamicServersOrNone(cluster) is not None:
         rtn.append(cluster)
     return rtn
 
@@ -651,7 +667,7 @@ def addNonClusteredServers(self):
     self.writeln("servers:")
     self.indent()
     for server in self.env.getDomain().getServers():
-      if server.getCluster() is None:
+      if self.getClusterOrNone(server) is None:
         self.addServer(server)
     self.undent()
 
@@ -845,20 +861,29 @@ def customizeNetworkAccessPoint(self, nap, listen_address):
       self.undent()
       self.writeln("</d:network-access-point>")
 
+  def getLogOrNone(self,server):
+    try:
+      ret = server.getLog()
+    except:
+      trace("Ignoring getLog() exception, this is expected.")
+      ret = None
+    return ret
+
   def customizeLog(self, name, bean, isDomainBean):
     logs_dir = self.env.getDomainLogHome()
     if logs_dir is None or len(logs_dir) == 0:
       return
 
     logaction=''
     fileaction=''
-    if bean.getLog() is None:
+    log = self.getLogOrNone(bean)
+    if log is None:
       if not isDomainBean:
         # don't know why, but don't need to "add" a missing domain log bean, and adding it causes trouble
         logaction=' f:combine-mode="add"'
       fileaction=' f:combine-mode="add"'
     else:
-      if bean.getLog().getFileName() is None:
+      if log.getFileName() is None:
         fileaction=' f:combine-mode="add"'
       else:
         fileaction=' f:combine-mode="replace"'
@@ -1129,6 +1154,7 @@ def main(env):
     traceback.print_exc()
     exit(exitcode=1)
   except UndeclaredThrowableException, f:
+    dumpStack()
     print f
     trace("Domain introspection failed with undeclared exception:")
     traceback.print_exc()