<fix>[multi]: batch guard NPE quality issues

- UpdateQueryImpl: guard val.getClass() NPE
- LogSafeGson: return JsonNull when input is null
- HostAllocatorChain: null check completion
- VmInstanceVO: use Objects.equals to avoid NPE
- SessionManagerImpl: guard null session
- VmCapabilitiesJudger: guard null PS type result
- CephPSMonBase: guard null self when evicted
- CephPSBase: guard null mon.getSelf()
- HostBase: guard null self when HostVO deleted
- ExternalPSFactory: guard null URI protocol
- LocalStorageBase: guard null errorCode.getCause()

Resolves: ZSTAC-69300, ZSTAC-69957, ZSTAC-71973,
 ZSTAC-81294, ZSTAC-70180, ZSTAC-70181,
 ZSTAC-78309, ZSTAC-78310, ZSTAC-70668,
 ZSTAC-71909, ZSTAC-80555, ZSTAC-81270,
 ZSTAC-70101, ZSTAC-72034, ZSTAC-73197,
 ZSTAC-79921, ZSTAC-81160, ZSTAC-81224,
 ZSTAC-81805, ZSTAC-72304, ZSTAC-81804,
 ZSTAC-74898, ZSTAC-69215, ZSTAC-70151,
 ZSTAC-68933

Change-Id: I910e9b542ecd254fdf7e956f943316988a56a1f9

Author: AlanJager

compute/src/main/java/org/zstack/compute/allocator/HostAllocatorChain.java

@@ -146,7 +146,10 @@ private void runFlow(AbstractHostAllocatorFlow flow) {
             }
         } catch (Throwable t) {
             logger.warn("unhandled throwable", t);
-            completion.fail(inerr(ORG_ZSTACK_COMPUTE_ALLOCATOR_10019, t.toString()));
+            String errMsg = t != null ? t.toString() : "unknown error";
+            if (completion != null) {
+                completion.fail(inerr(ORG_ZSTACK_COMPUTE_ALLOCATOR_10019, errMsg));
+            }
         }
     }
 

compute/src/main/java/org/zstack/compute/host/HostBase.java

@@ -1443,7 +1443,7 @@ public String getName() {
 
             @Override
             protected String getDeduplicateString() {
-                return String.format("connect-host-%s", self.getUuid());
+                return String.format("connect-host-%s", self == null ? "unknown" : self.getUuid());
             }
         });
     }

compute/src/main/java/org/zstack/compute/vm/VmCapabilitiesJudger.java

@@ -53,6 +53,12 @@ private void checkPrimaryStorageCapabilities(VmCapabilities capabilities, VmInst
             q.add(PrimaryStorageVO_.uuid, SimpleQuery.Op.EQ, rootVolume.getPrimaryStorageUuid());
             String type = q.findValue();
 
+            if (type == null) {
+                capabilities.setSupportLiveMigration(false);
+                capabilities.setSupportVolumeMigration(false);
+                return;
+            }
+
             PrimaryStorageType psType = PrimaryStorageType.valueOf(type);
 
             if (vm.getState() != VmInstanceState.Running) {

core/src/main/java/org/zstack/core/db/UpdateQueryImpl.java

@@ -54,7 +54,8 @@ public UpdateQuery set(SingularAttribute attr, Object val) {
     @Override
     public UpdateQuery condAnd(SingularAttribute attr, Op op, Object val) {
         if ((op == Op.IN || op == Op.NOT_IN) && !(val instanceof Collection)) {
-            throw new CloudRuntimeException(String.format("for operation IN or NOT IN, a Collection value is expected, but %s got", val.getClass()));
+            throw new CloudRuntimeException(String.format("for operation IN or NOT IN, a Collection value is expected, but %s got",
+                    val == null ? "null" : val.getClass()));
         }
 
         Cond cond = new Cond();

core/src/main/java/org/zstack/core/log/LogSafeGson.java

@@ -208,6 +208,9 @@ private static <T> JsonSerializer<T> getSerializer() {
     }
 
     public static JsonElement toJsonElement(Object o) {
+        if (o == null) {
+            return JsonNull.INSTANCE;
+        }
         return logSafeGson.toJsonTree(o, getGsonType(o.getClass()));
     }
 

header/src/main/java/org/zstack/header/vm/VmAbnormalLifeCycleStruct.java

@@ -72,7 +72,7 @@ boolean match(VmAbnormalLifeCycleStruct struct) {
             boolean match(VmAbnormalLifeCycleStruct struct) {
                 return struct.getOriginalState() == VmInstanceState.Paused
                         && struct.getCurrentState() == VmInstanceState.Stopped
-                        && struct.getCurrentHostUuid().equals(struct.getOriginalHostUuid());
+                        && Objects.equals(struct.getCurrentHostUuid(), struct.getOriginalHostUuid());
             }
         },
         VmMigrateToAnotherHost {

identity/src/main/java/org/zstack/identity/AuthorizationManager.java

@@ -116,6 +116,11 @@ public APIMessage intercept(APIMessage msg) throws ApiMessageInterceptionExcepti
             session = evaluateSession(msg);
         }
 
+        if (session == null) {
+            throw new ApiMessageInterceptionException(err(ORG_ZSTACK_IDENTITY_10012, IdentityErrors.INVALID_SESSION,
+                    "evaluated session is null for message[%s]", msg.getMessageName()));
+        }
+
         logger.trace(String.format("authorizing message[%s] with user[accountUuid:%s, uuid:%s] session",
                 msg.getMessageName(),
                 session.getAccountUuid(),

plugin/ceph/src/main/java/org/zstack/storage/ceph/primary/CephPrimaryStorageBase.java

@@ -3974,15 +3974,17 @@ public void done() {
                     mon.connect(new Completion(releaseLock) {
                         @Override
                         public void success() {
+                            String monUuid = mon.getSelf() == null ? "unknown" : mon.getSelf().getUuid();
                             logger.debug(String.format("successfully reconnected the mon[uuid:%s] of the ceph primary" +
-                                    " storage[uuid:%s, name:%s]", mon.getSelf().getUuid(), self.getUuid(), self.getName()));
+                                    " storage[uuid:%s, name:%s]", monUuid, self.getUuid(), self.getName()));
                             releaseLock.done();
                         }
 
                         @Override
                         public void fail(ErrorCode errorCode) {
+                            String monUuid = mon.getSelf() == null ? "unknown" : mon.getSelf().getUuid();
                             logger.warn(String.format("failed to reconnect the mon[uuid:%s] server of the ceph primary" +
-                                    " storage[uuid:%s, name:%s], %s", mon.getSelf().getUuid(), self.getUuid(), self.getName(), errorCode));
+                                    " storage[uuid:%s, name:%s], %s", monUuid, self.getUuid(), self.getName(), errorCode));
                             releaseLock.done();
                         }
                     });

plugin/ceph/src/main/java/org/zstack/storage/ceph/primary/CephPrimaryStorageMonBase.java

@@ -141,7 +141,7 @@ public void fail(ErrorCode errorCode) {
 
             @Override
             public String getName() {
-                return String.format("connect-ceph-primary-storage-mon-%s", self.getUuid());
+                return String.format("connect-ceph-primary-storage-mon-%s", self == null ? "unknown" : self.getUuid());
             }
         });
     }
@@ -420,7 +420,7 @@ public void fail(ErrorCode errorCode) {
 
             @Override
             public String getName() {
-                return String.format("ping-ceph-primary-storage-%s", self.getUuid());
+                return String.format("ping-ceph-primary-storage-%s", self == null ? "unknown" : self.getUuid());
             }
         });
     }

plugin/localstorage/src/main/java/org/zstack/storage/primary/local/LocalStorageAllocatorFactory.java

@@ -385,7 +385,12 @@ private String getHostUuidFromAllocateMsg(AllocatePrimaryStorageSpaceMsg msg) {
                 throw new OperationFailureException(
                         argerr(ORG_ZSTACK_STORAGE_PRIMARY_LOCAL_10023, "invalid uri, correct example is file://$URL;hostUuid://$HOSTUUID or volume://$VOLUMEUUID "));
             }
-            hostUuid = uriParsers.get(protocol).parseUri(msg.getRequiredInstallUri()).hostUuid;
+            AbstractUriParser parser = uriParsers.get(protocol);
+            if (parser == null) {
+                throw new OperationFailureException(
+                        argerr(ORG_ZSTACK_STORAGE_PRIMARY_LOCAL_10023, "unsupported protocol[%s] in uri[%s]", protocol, msg.getRequiredInstallUri()));
+            }
+            hostUuid = parser.parseUri(msg.getRequiredInstallUri()).hostUuid;
         }
 
         if (hostUuid != null) {