<fix>[compute]: <description

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

@@ -0,0 +1,71 @@
+package org.zstack.compute.vm;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.zstack.core.cloudbus.CloudBusCallBack;
+import org.zstack.core.gc.GC;
+import org.zstack.core.gc.GCCompletion;
+import org.zstack.core.gc.TimeBasedGarbageCollector;
+import org.zstack.core.thread.ChainTask;
+import org.zstack.core.thread.SyncTaskChain;
+import org.zstack.core.thread.ThreadFacade;
+import org.zstack.header.core.progress.ChainInfo;
+import org.zstack.header.message.MessageReply;
+import org.zstack.header.vm.UpdateVmInstanceMetadataMsg;
+import org.zstack.header.volume.VolumeConstant;
+import org.zstack.header.volume.VolumeVO;
+
+public class UpdateVmInstanceMetadataGC extends TimeBasedGarbageCollector {
+    @GC
+    public String vmInstanceUuid;
+
+    @Autowired
+    protected ThreadFacade thdf;
+
+    static public String getUpdateVmInstanceMetadataSyncSignature(String vmInstanceUuid) {
+        return String.format("update-vm-%s-metadata", vmInstanceUuid);
+    }
+
+    @Override
+    protected void triggerNow(GCCompletion completion) {
+        if (!dbf.isExist(vmInstanceUuid, VolumeVO.class)) {
+            completion.cancel();
+            return;
+        }
+
+        String queueName = getUpdateVmInstanceMetadataSyncSignature(vmInstanceUuid);
+        ChainInfo chainInfo = thdf.getChainTaskInfo(queueName);
+        if (!chainInfo.getPendingTask().isEmpty()) {
+            completion.cancel();
+            return;
+        }
+
+        thdf.chainSubmit(new ChainTask(completion) {
+            @Override
+            public String getSyncSignature() {
+                return queueName;
+            }
+
+            @Override
+            public void run(final SyncTaskChain chain) {
+                UpdateVmInstanceMetadataMsg msg = new UpdateVmInstanceMetadataMsg();
+                msg.setUuid(vmInstanceUuid);
+                bus.makeTargetServiceIdByResourceUuid(msg, VolumeConstant.SERVICE_ID, vmInstanceUuid);
+                bus.send(msg, new CloudBusCallBack(completion) {
+                    @Override
+                    public void run(MessageReply reply) {
+                        if (!reply.isSuccess()) {
+                            completion.fail(reply.getError());
+                        } else {
+                            completion.success();
+                        }
+                    }
+                });
+            }
+
+            @Override
+            public String getName() {
+                return queueName;
+            }
+        });
+    }
+}

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

@@ -133,4 +133,7 @@ public class VmGlobalConfig {
     @GlobalConfigValidation(validValues = {"None", "AuthenticAMD"})
     @BindResourceConfig(value = {VmInstanceVO.class})
     public static GlobalConfig VM_CPUID_VENDOR = new GlobalConfig(CATEGORY, "vm.cpuid.vendor");
+
+//    @GlobalConfigValidation
+//    public static GlobalConfig GC_INTERVAL = new GlobalConfig(CATEGORY, "deletion.gcInterval");
 }