xenserver: do not destroy halted hypervisor vm (apache#9175)

shwstppr · dhslove · commit ec0c6e2cbd37 · 2025-04-18T10:47:50.000+09:00
Signed-off-by: Abhishek Kumar &lt;abhishek.mrt22@gmail.com&gt;
diff --git a/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/CitrixResourceBase.java b/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/CitrixResourceBase.java
@@ -51,10 +51,6 @@
 import javax.naming.ConfigurationException;
 import javax.xml.parsers.ParserConfigurationException;
 
-import com.trilead.ssh2.SFTPException;
-import com.trilead.ssh2.SFTPv3Client;
-import com.trilead.ssh2.SFTPv3DirectoryEntry;
-import com.trilead.ssh2.SFTPv3FileAttributes;
 import org.apache.cloudstack.api.ApiConstants;
 import org.apache.cloudstack.diagnostics.CopyToSecondaryStorageAnswer;
 import org.apache.cloudstack.diagnostics.CopyToSecondaryStorageCommand;
@@ -71,6 +67,8 @@
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.BooleanUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.log4j.Logger;
+import org.apache.maven.artifact.versioning.ComparableVersion;
 import org.apache.xmlrpc.XmlRpcException;
 import org.joda.time.Duration;
 import org.w3c.dom.Document;
@@ -152,6 +150,10 @@
 import com.cloud.vm.VirtualMachine.PowerState;
 import com.cloud.vm.VmDetailConstants;
 import com.trilead.ssh2.SCPClient;
+import com.trilead.ssh2.SFTPException;
+import com.trilead.ssh2.SFTPv3Client;
+import com.trilead.ssh2.SFTPv3DirectoryEntry;
+import com.trilead.ssh2.SFTPv3FileAttributes;
 import com.xensource.xenapi.Bond;
 import com.xensource.xenapi.Connection;
 import com.xensource.xenapi.Console;
@@ -625,7 +627,7 @@ public boolean cleanupHaltedVms(final Connection conn) throws XenAPIException, X
 
                 if (VmPowerState.HALTED.equals(vmRec.powerState) && vmRec.affinity.equals(host) && !isAlienVm(vm, conn)) {
                     try {
-                        vm.destroy(conn);
+                        destroyVm(vm, conn);
                     } catch (final Exception e) {
                         logger.warn("Catch Exception " + e.getClass().getName() + ": unable to destroy VM " + vmRec.nameLabel + " due to ", e);
                         success = false;
@@ -1450,7 +1452,7 @@ public VM createVmFromTemplate(final Connection conn, final VirtualMachineTO vmS
                 vm.setPVBootloader(conn, "pygrub");
                 vm.setPVBootloaderArgs(conn, CitrixHelper.getPVbootloaderArgs(guestOsTypeName));
             } else {
-                vm.destroy(conn);
+                destroyVm(vm, conn, true);
                 throw new CloudRuntimeException("Unable to handle boot loader type: " + vmSpec.getBootloader());
             }
         }
@@ -2036,7 +2038,7 @@ void forceShutdownVM(final Connection conn, final VM vm) {
             final Long domId = vm.getDomid(conn);
             callHostPlugin(conn, "vmopspremium", "forceShutdownVM", "domId", domId.toString());
             vm.powerStateReset(conn);
-            vm.destroy(conn);
+            destroyVm(vm, conn);
         } catch (final Exception e) {
             final String msg = "forceShutdown failed due to " + e.toString();
             logger.warn(msg, e);
@@ -3689,7 +3691,7 @@ public String handleVmStartFailure(final Connection conn, final String vmName, f
             }
             if (vm.getPowerState(conn) == VmPowerState.HALTED) {
                 try {
-                    vm.destroy(conn);
+                    destroyVm(vm, conn, true);
                 } catch (final Exception e) {
                     logger.warn("VM destroy failed due to ", e);
                 }
@@ -5213,7 +5215,7 @@ protected void startvmfailhandle(final Connection conn, final VM vm, final List<
                 }
                 if (vm.getPowerState(conn) == VmPowerState.HALTED) {
                     try {
-                        vm.destroy(conn);
+                        destroyVm(vm, conn, true);
                     } catch (final Exception e) {
                         final String msg = "VM destroy failed due to " + e.toString();
                         logger.warn(msg, e);
@@ -5880,4 +5882,23 @@ private void umountNfs(Connection conn, String remoteDir, String localDir) {
             logger.warn(errMsg);
         }
     }
+
+    public boolean isDestroyHaltedVms() {
+        ComparableVersion version = new ComparableVersion(getHost().getProductVersion());
+        if (version.compareTo(new ComparableVersion("8.0")) >= 0) {
+            return false;
+        }
+        return true;
+    }
+
+    public void destroyVm(VM vm, Connection connection, boolean forced) throws XenAPIException, XmlRpcException {
+        if (!isDestroyHaltedVms() && !forced) {
+            return;
+        }
+        vm.destroy(connection);
+    }
+
+    public void destroyVm(VM vm, Connection connection) throws XenAPIException, XmlRpcException {
+        destroyVm(vm, connection, false);
+    }
 }
diff --git a/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xen56/XenServer56FenceCommandWrapper.java b/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xen56/XenServer56FenceCommandWrapper.java
@@ -54,7 +54,7 @@ public Answer execute(final FenceCommand command, final XenServer56Resource xenS
             for (final VM vm : vms) {
                 logger.info("Fence command for VM " + command.getVmName());
                 vm.powerStateReset(conn);
-                vm.destroy(conn);
+                xenServer56.destroyVm(vm, conn);
             }
             return new FenceAnswer(command);
         } catch (final XmlRpcException e) {
diff --git a/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xen56p1/XenServer56FP1FenceCommandWrapper.java b/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xen56p1/XenServer56FP1FenceCommandWrapper.java
@@ -66,7 +66,7 @@ public Answer execute(final FenceCommand command, final XenServer56Resource xenS
                 }
                 logger.info("Fence command for VM " + command.getVmName());
                 vm.powerStateReset(conn);
-                vm.destroy(conn);
+                xenServer56.destroyVm(vm, conn);
                 for (final VDI vdi : vdis) {
                     final Map<String, String> smConfig = vdi.getSmConfig(conn);
                     for (final String key : smConfig.keySet()) {
diff --git a/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixCreateVMSnapshotCommandWrapper.java b/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixCreateVMSnapshotCommandWrapper.java
@@ -98,6 +98,7 @@ public Answer execute(final CreateVMSnapshotCommand command, final CitrixResourc
                     vm = citrixResourceBase.getVM(conn, vmName);
                     vmState = vm.getPowerState(conn);
                 } catch (final Exception e) {
+                    s_logger.debug(String.format("Failed to find VM with name: %s due to:", vmName), e);
                     if (!snapshotMemory) {
                         vm = citrixResourceBase.createWorkingVM(conn, vmName, guestOSType, platformEmulator, listVolumeTo);
                     }
@@ -176,13 +177,11 @@ public Answer execute(final CreateVMSnapshotCommand command, final CitrixResourc
                                 vdi.destroy(conn);
                             }
                         }
-                        vmSnapshot.destroy(conn);
+                        citrixResourceBase.destroyVm(vmSnapshot, conn, true);
                     }
                 }
-                if (vmState == VmPowerState.HALTED) {
-                    if (vm != null) {
-                        vm.destroy(conn);
-                    }
+                if (vmState == VmPowerState.HALTED && vm != null) {
+                    citrixResourceBase.destroyVm(vm, conn);
                 }
             } catch (final Exception e2) {
                 logger.error("delete snapshot error due to " + e2.getMessage());
diff --git a/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixDeleteVMSnapshotCommandWrapper.java b/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixDeleteVMSnapshotCommandWrapper.java
@@ -66,7 +66,7 @@ public Answer execute(final DeleteVMSnapshotCommand command, final CitrixResourc
             if (command.getTarget().getType() == VMSnapshot.Type.DiskAndMemory) {
                 vdiList.add(snapshot.getSuspendVDI(conn));
             }
-            snapshot.destroy(conn);
+            citrixResourceBase.destroyVm(snapshot, conn, true);
             for (final VDI vdi : vdiList) {
                 vdi.destroy(conn);
             }
diff --git a/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixRevertToVMSnapshotCommandWrapper.java b/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixRevertToVMSnapshotCommandWrapper.java
@@ -66,6 +66,7 @@ public Answer execute(final RevertToVMSnapshotCommand command, final CitrixResou
             try {
                 vm = citrixResourceBase.getVM(conn, vmName);
             } catch (final Exception e) {
+                s_logger.debug(String.format("Failed to find VM with name: %s due to:", vmName), e);
                 vm = citrixResourceBase.createWorkingVM(conn, vmName, command.getGuestOSType(), command.getPlatformEmulator(), listVolumeTo);
             }
 
@@ -88,7 +89,7 @@ public Answer execute(final RevertToVMSnapshotCommand command, final CitrixResou
             }
 
             if (!snapshotMemory) {
-                vm.destroy(conn);
+                citrixResourceBase.destroyVm(vm, conn);
                 vmState = PowerState.PowerOff;
             } else {
                 vmState = PowerState.PowerOn;
diff --git a/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixStartCommandWrapper.java b/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixStartCommandWrapper.java
@@ -73,7 +73,7 @@ public Answer execute(final StartCommand command, final CitrixResourceBase citri
                 for (final VM v : vms) {
                     final VM.Record vRec = v.getRecord(conn);
                     if (vRec.powerState == VmPowerState.HALTED) {
-                        v.destroy(conn);
+                        citrixResourceBase.destroyVm(v, conn, true);
                     } else if (vRec.powerState == VmPowerState.RUNNING) {
                         final String host = vRec.residentOn.getUuid(conn);
                         final String msg = "VM " + vmName + " is runing on host " + host;
diff --git a/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixStopCommandWrapper.java b/plugins/hypervisors/xenserver/src/main/java/com/cloud/hypervisor/xenserver/resource/wrapper/xenbase/CitrixStopCommandWrapper.java
@@ -141,7 +141,7 @@ public Answer execute(final StopCommand command, final CitrixResourceBase citrix
                             for (final VIF vif : vifs) {
                                 networks.add(vif.getNetwork(conn));
                             }
-                            vm.destroy(conn);
+                            citrixResourceBase.destroyVm(vm, conn);
                             final SR sr = citrixResourceBase.getISOSRbyVmName(conn, command.getVmName(), false);
                             citrixResourceBase.removeSR(conn, sr);
                             final SR configDriveSR = citrixResourceBase.getISOSRbyVmName(conn, command.getVmName(), true);

Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ public Answer execute(final FenceCommand command, final XenServer56Resource xenS`
`54`	`54`	`for (final VM vm : vms) {`
`55`	`55`	`logger.info("Fence command for VM " + command.getVmName());`
`56`	`56`	`vm.powerStateReset(conn);`
`57`		`- vm.destroy(conn);`
	`57`	`+ xenServer56.destroyVm(vm, conn);`
`58`	`58`	`}`
`59`	`59`	`return new FenceAnswer(command);`
`60`	`60`	`} catch (final XmlRpcException e) {`
Original file line number	Diff line number	Diff line change
`@@ -66,7 +66,7 @@ public Answer execute(final FenceCommand command, final XenServer56Resource xenS`
`66`	`66`	`}`
`67`	`67`	`logger.info("Fence command for VM " + command.getVmName());`
`68`	`68`	`vm.powerStateReset(conn);`
`69`		`- vm.destroy(conn);`
	`69`	`+ xenServer56.destroyVm(vm, conn);`
`70`	`70`	`for (final VDI vdi : vdis) {`
`71`	`71`	`final Map<String, String> smConfig = vdi.getSmConfig(conn);`
`72`	`72`	`for (final String key : smConfig.keySet()) {`
Original file line number	Diff line number	Diff line change
`@@ -98,6 +98,7 @@ public Answer execute(final CreateVMSnapshotCommand command, final CitrixResourc`
`98`	`98`	`vm = citrixResourceBase.getVM(conn, vmName);`
`99`	`99`	`vmState = vm.getPowerState(conn);`
`100`	`100`	`} catch (final Exception e) {`
	`101`	`+ s_logger.debug(String.format("Failed to find VM with name: %s due to:", vmName), e);`
`101`	`102`	`if (!snapshotMemory) {`
`102`	`103`	`vm = citrixResourceBase.createWorkingVM(conn, vmName, guestOSType, platformEmulator, listVolumeTo);`
`103`	`104`	`}`
`@@ -176,13 +177,11 @@ public Answer execute(final CreateVMSnapshotCommand command, final CitrixResourc`
`176`	`177`	`vdi.destroy(conn);`
`177`	`178`	`}`
`178`	`179`	`}`
`179`		`- vmSnapshot.destroy(conn);`
	`180`	`+ citrixResourceBase.destroyVm(vmSnapshot, conn, true);`
`180`	`181`	`}`
`181`	`182`	`}`
`182`		`- if (vmState == VmPowerState.HALTED) {`
`183`		`- if (vm != null) {`
`184`		`- vm.destroy(conn);`
`185`		`- }`
	`183`	`+ if (vmState == VmPowerState.HALTED && vm != null) {`
	`184`	`+ citrixResourceBase.destroyVm(vm, conn);`
`186`	`185`	`}`
`187`	`186`	`} catch (final Exception e2) {`
`188`	`187`	`logger.error("delete snapshot error due to " + e2.getMessage());`
Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,7 @@ public Answer execute(final RevertToVMSnapshotCommand command, final CitrixResou`
`66`	`66`	`try {`
`67`	`67`	`vm = citrixResourceBase.getVM(conn, vmName);`
`68`	`68`	`} catch (final Exception e) {`
	`69`	`+ s_logger.debug(String.format("Failed to find VM with name: %s due to:", vmName), e);`
`69`	`70`	`vm = citrixResourceBase.createWorkingVM(conn, vmName, command.getGuestOSType(), command.getPlatformEmulator(), listVolumeTo);`
`70`	`71`	`}`
`71`	`72`
`@@ -88,7 +89,7 @@ public Answer execute(final RevertToVMSnapshotCommand command, final CitrixResou`
`88`	`89`	`}`
`89`	`90`
`90`	`91`	`if (!snapshotMemory) {`
`91`		`- vm.destroy(conn);`
	`92`	`+ citrixResourceBase.destroyVm(vm, conn);`
`92`	`93`	`vmState = PowerState.PowerOff;`
`93`	`94`	`} else {`
`94`	`95`	`vmState = PowerState.PowerOn;`
Original file line number	Diff line number	Diff line change
`@@ -141,7 +141,7 @@ public Answer execute(final StopCommand command, final CitrixResourceBase citrix`
`141`	`141`	`for (final VIF vif : vifs) {`
`142`	`142`	`networks.add(vif.getNetwork(conn));`
`143`	`143`	`}`
`144`		`- vm.destroy(conn);`
	`144`	`+ citrixResourceBase.destroyVm(vm, conn);`
`145`	`145`	`final SR sr = citrixResourceBase.getISOSRbyVmName(conn, command.getVmName(), false);`
`146`	`146`	`citrixResourceBase.removeSR(conn, sr);`
`147`	`147`	`final SR configDriveSR = citrixResourceBase.getISOSRbyVmName(conn, command.getVmName(), true);`