Handle scenario where if VM.start, xcp-persistent-database is InUse, are on failing disk-host, then VM.start may get stuck.

The state can be recovered by bringing the failed device online however it means that the test failed.

Signed-off-by: Rushikesh Jadhav <[email protected]>

Author: rushikeshjadhav

tests/storage/linstor/test_linstor_sr.py

@@ -138,6 +138,7 @@ def test_linstor_sr_fail_disk(self, linstor_sr, vm_on_linstor_sr, provisioning_t
         Identify random host within the same pool, detect used disks, fail one, and test VM useability on LINSTOR SR.
         """
         import random
+        import multiprocessing
 
         sr = linstor_sr
         if provisioning_type == "thick":
@@ -162,10 +163,22 @@ def test_linstor_sr_fail_disk(self, linstor_sr, vm_on_linstor_sr, provisioning_t
 
         # Ensure that VM is able to start on all hosts despite Linstor pool disk failure
         for h in sr.pool.hosts:
-            logging.info(f"Checking VM on host {h.hostname_or_ip}")
-            vm.start(on=h.uuid)
-            vm.wait_for_os_booted()
-            vm.shutdown(verify=True)
+            logging.info("Checking VM on host %s", h.hostname_or_ip)
+            try:
+                proc = multiprocessing.Process(target=vm.start, kwargs={'on': h.uuid})
+                proc.start()
+                proc.join(timeout=30)
+                if proc.is_alive():
+                    proc.terminate()
+                    proc.join()
+                    logging.warning("VM start on host %s timed out. Recovering failed disk.", h.hostname_or_ip)
+                    random_host.ssh(['echo', '"running"', '>', f'/sys/block/{fail_device}/device/state'])
+                    pytest.fail("VM start timed out on host %s after 30s. Disk recovered.", h.hostname_or_ip)
+                else: # VM booted fine
+                    vm.wait_for_os_booted()
+                    vm.shutdown(verify=True)
+            except Exception as e:
+                logging.info("Caught exception in multiprocessing: %s", e)
 
         random_host.reboot(verify=True)