Execute quicktest for each SM driver

Signed-off-by: Ronan Abhamon <[email protected]>

lib/pool.py

@@ -196,3 +196,9 @@ def eject_host(self, host):
         wait_for_not(lambda: host.uuid in self.hosts_uuids(), f"Wait for host {host} to be ejected of pool {master}.")
         self.hosts = [h for h in self.hosts if h.uuid != host.uuid]
         wait_for(host.is_enabled, f"Wait for host {host} to restart in its own pool.", timeout_secs=600)
+
+    def get_default_sr(self):
+        return self.master.xe('pool-param-get', {'uuid': self.uuid, 'param-name': 'default-SR'})
+
+    def set_default_sr(self, sr_uuid):
+        self.master.xe('pool-param-set', {'uuid': self.uuid, 'default-SR': sr_uuid})

tests/storage/cephfs/test_cephfs_sr.py

@@ -4,7 +4,7 @@
 
 from lib.commands import SSHCommandFailed
 from lib.common import wait_for, vm_image
-from tests.storage import vdi_is_open
+from tests.storage import run_quicktest_on_sr, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host >= 8.2
@@ -42,6 +42,9 @@ def test_create_and_destroy_sr(self, host, cephfs_device_config, pool_with_ceph)
 
 @pytest.mark.usefixtures("cephfs_sr")
 class TestCephFSSR:
+    def test_quicktest(self, cephfs_sr):
+        run_quicktest_on_sr(cephfs_sr)
+
     def test_vdi_is_not_open(self, vdi_on_cephfs_sr):
         assert not vdi_is_open(vdi_on_cephfs_sr)
 

tests/storage/ext/test_ext_sr.py

@@ -1,6 +1,6 @@
 import pytest
 from lib.common import wait_for, vm_image
-from tests.storage import try_to_create_sr_with_missing_device, vdi_is_open
+from tests.storage import run_quicktest_on_sr, try_to_create_sr_with_missing_device, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host with an additional unused disk for the SR
@@ -26,6 +26,9 @@ def test_create_and_destroy_sr(self, host, sr_disk):
 
 @pytest.mark.usefixtures("ext_sr")
 class TestEXTSR:
+    def test_quicktest(self, ext_sr):
+        run_quicktest_on_sr(ext_sr)
+
     def test_vdi_is_not_open(self, vdi_on_ext_sr):
         assert not vdi_is_open(vdi_on_ext_sr)
 

tests/storage/fsp/test_fsp_sr.py

@@ -3,6 +3,7 @@
 import logging
 
 from .conftest import DIRECTORIES_PATH
+from tests.storage import run_quicktest_on_sr
 
 # Requirements:
 # From --hosts parameter:

tests/storage/glusterfs/test_glusterfs_sr.py

@@ -3,7 +3,7 @@
 
 from lib.commands import SSHCommandFailed
 from lib.common import wait_for, vm_image
-from tests.storage import vdi_is_open
+from tests.storage import run_quicktest_on_sr, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host >= 8.2 with an additional unused disk for the SR
@@ -41,6 +41,9 @@ def test_create_and_destroy_sr(self, host, glusterfs_device_config, pool_with_gl
 
 @pytest.mark.usefixtures("sr_disk_for_all_hosts", "glusterfs_sr")
 class TestGlusterFSSR:
+    def test_quicktest(self, glusterfs_sr):
+        run_quicktest_on_sr(glusterfs_sr)
+
     def test_vdi_is_not_open(self, vdi_on_glusterfs_sr):
         assert not vdi_is_open(vdi_on_glusterfs_sr)
 

tests/storage/iso/test_cifs_iso_sr.py

@@ -1,7 +1,9 @@
 import pytest
 import logging
 import os
+
 from .conftest import copy_tools_iso_to_iso_sr, check_iso_mount_and_read_from_vm, remove_iso_from_sr
+from tests.storage import run_quicktest_on_sr
 
 # Requirements:
 # From --hosts parameter:
@@ -35,6 +37,8 @@ def test_create_and_destroy_sr(self, host, cifs_iso_device_config):
 @pytest.mark.small_vm
 @pytest.mark.usefixtures("cifs_iso_sr")
 class TestCIFSISOSR:
+    def test_quicktest(self, cifs_iso_sr):
+        run_quicktest_on_sr(cifs_iso_sr)
 
     def test_iso_mount_and_read(self, host, cifs_iso_sr, running_unix_vm):
         # create the ISO SR on CIFS

tests/storage/iso/test_local_iso_sr.py

@@ -1,8 +1,10 @@
 import pytest
 import logging
 import os
+
 from .conftest import create_local_iso_sr, copy_tools_iso_to_iso_sr, \
     check_iso_mount_and_read_from_vm, remove_iso_from_sr
+from tests.storage import run_quicktest_on_sr
 
 # Requirements:
 # From --hosts parameter:
@@ -41,6 +43,9 @@ def test_create_and_destroy_sr(self, host, formatted_and_mounted_ext4_disk):
 @pytest.mark.small_vm
 @pytest.mark.usefixtures("local_iso_sr")
 class TestLocalISOSR:
+    def test_quicktest(self, local_iso_sr):
+        sr, location = local_iso_sr
+        run_quicktest_on_sr(sr)
 
     def test_iso_mount_and_read(self, host, local_iso_sr, running_unix_vm):
         sr, location = local_iso_sr

tests/storage/iso/test_nfs_iso_sr.py

@@ -1,7 +1,9 @@
 import pytest
 import os
 import logging
+
 from .conftest import copy_tools_iso_to_iso_sr, check_iso_mount_and_read_from_vm, remove_iso_from_sr
+from tests.storage import run_quicktest_on_sr
 
 # Requirements:
 # From --hosts parameter:
@@ -37,6 +39,8 @@ def test_create_and_destroy_sr(self, host, nfs_iso_device_config):
 @pytest.mark.small_vm
 @pytest.mark.usefixtures("nfs_iso_sr")
 class TestNFSISOSR:
+    def test_quicktest(self, nfs_iso_sr):
+        run_quicktest_on_sr(nfs_iso_sr)
 
     def test_iso_mount_and_read(self, host, nfs_iso_sr, running_unix_vm):
         # create the ISO SR on NFS

tests/storage/linstor/test_linstor_sr.py

@@ -5,7 +5,7 @@
 from .conftest import GROUP_NAME, create_linstor_sr, destroy_linstor_sr
 from lib.commands import SSHCommandFailed
 from lib.common import wait_for, vm_image
-from tests.storage import vdi_is_open
+from tests.storage import run_quicktest_on_sr, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host >= 8.2 with an additional unused disk for the SR
@@ -48,6 +48,9 @@ def test_create_and_destroy_sr(self, hosts_with_linstor, lvm_disks):
 
 @pytest.mark.usefixtures("linstor_sr")
 class TestLinstorSR:
+    def test_quicktest(self, linstor_sr):
+        run_quicktest_on_sr(linstor_sr)
+
     def test_vdi_is_not_open(self, vdi_on_linstor_sr):
         assert not vdi_is_open(vdi_on_linstor_sr)
 

tests/storage/lvm/test_lvm_sr.py

@@ -1,6 +1,6 @@
 import pytest
 from lib.common import wait_for, vm_image
-from tests.storage import try_to_create_sr_with_missing_device, vdi_is_open
+from tests.storage import run_quicktest_on_sr, try_to_create_sr_with_missing_device, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host with an additional unused disk for the SR
@@ -26,6 +26,9 @@ def test_create_and_destroy_sr(self, host, sr_disk):
 
 @pytest.mark.usefixtures("lvm_sr")
 class TestLVMSR:
+    def test_quicktest(self, lvm_sr):
+        run_quicktest_on_sr(lvm_sr)
+
     def test_vdi_is_not_open(self, vdi_on_lvm_sr):
         assert not vdi_is_open(vdi_on_lvm_sr)
 

tests/storage/lvmoiscsi/test_lvmoiscsi_sr.py

@@ -1,6 +1,6 @@
 import pytest
 from lib.common import wait_for, vm_image
-from tests.storage import vdi_is_open
+from tests.storage import run_quicktest_on_sr, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host >= 8.2
@@ -24,6 +24,9 @@ def test_create_and_destroy_sr(self, host, lvmoiscsi_device_config):
 
 @pytest.mark.usefixtures("lvmoiscsi_sr")
 class TestLVMOISCSISR:
+    def test_quicktest(self, lvmoiscsi_sr):
+        run_quicktest_on_sr(lvmoiscsi_sr)
+
     def test_vdi_is_not_open(self, vdi_on_lvmoiscsi_sr):
         assert not vdi_is_open(vdi_on_lvmoiscsi_sr)
 

tests/storage/moosefs/test_moosefs_sr.py

@@ -4,7 +4,7 @@
 
 from lib.commands import SSHCommandFailed
 from lib.common import wait_for, vm_image
-from tests.storage import vdi_is_open
+from tests.storage import run_quicktest_on_sr, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host >= 8.2
@@ -43,6 +43,9 @@ def test_create_and_destroy_sr(self, moosefs_device_config, pool_with_moosefs_en
 
 @pytest.mark.usefixtures("moosefs_sr")
 class TestMooseFSSR:
+    def test_quicktest(self, moosefs_sr):
+        run_quicktest_on_sr(moosefs_sr)
+
     def test_vdi_is_not_open(self, vdi_on_moosefs_sr):
         assert not vdi_is_open(vdi_on_moosefs_sr)
 

tests/storage/nfs/test_nfs_sr.py

@@ -1,6 +1,6 @@
 import pytest
 from lib.common import wait_for, vm_image
-from tests.storage import vdi_is_open
+from tests.storage import run_quicktest_on_sr, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host >= 8.0 with an additional unused disk for the SR
@@ -17,6 +17,9 @@ def test_create_and_destroy_sr(self, host, nfs_device_config):
 
 @pytest.mark.usefixtures("nfs_sr")
 class TestNFSSR:
+    def test_quicktest(self, nfs_sr):
+        run_quicktest_on_sr(nfs_sr)
+
     def test_vdi_is_not_open(self, vdi_on_nfs_sr):
         assert not vdi_is_open(vdi_on_nfs_sr)
 

tests/storage/storage.py

@@ -70,3 +70,13 @@ def get_xapi_session():
         'vdiUuid': vdi.uuid,
         'srRef': master.execute_script(get_sr_ref, shebang='python')
     }))
+
+def run_quicktest_on_sr(sr):
+    old_sr_uuid = sr.pool.get_default_sr()
+    if sr.uuid != old_sr_uuid:
+        sr.pool.set_default_sr(sr.uuid)
+    try:
+        sr.pool.master.ssh(['/opt/xensource/debug/quicktest', '-default-sr'])
+    finally:
+        if sr.uuid != old_sr_uuid:
+            sr.pool.set_default_sr(old_sr_uuid)

tests/storage/xfs/test_xfs_sr.py

@@ -4,7 +4,7 @@
 
 from lib.commands import SSHCommandFailed
 from lib.common import wait_for, vm_image
-from tests.storage import vdi_is_open
+from tests.storage import run_quicktest_on_sr, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host >= 8.2 with an additional unused disk for the SR
@@ -42,6 +42,9 @@ def test_create_and_destroy_sr(self, sr_disk, host_with_xfsprogs):
 
 @pytest.mark.usefixtures("xfs_sr")
 class TestXFSSR:
+    def test_quicktest(self, xfs_sr):
+        run_quicktest_on_sr(xfs_sr)
+
     def test_vdi_is_not_open(self, vdi_on_xfs_sr):
         assert not vdi_is_open(vdi_on_xfs_sr)
 

tests/storage/zfs/test_zfs_sr.py

@@ -5,7 +5,7 @@
 from .conftest import VOLUME_PATH, VOLUME_NAME
 from lib.commands import SSHCommandFailed
 from lib.common import wait_for, vm_image
-from tests.storage import vdi_is_open
+from tests.storage import run_quicktest_on_sr, vdi_is_open
 
 # Requirements:
 # - one XCP-ng host >= 8.2 with an additional unused disk for the SR
@@ -44,6 +44,9 @@ def test_create_and_destroy_sr(self, host):
 
 @pytest.mark.usefixtures("zpool_vol0")
 class TestZFSSR:
+    def test_quicktest(self, zfs_sr):
+        run_quicktest_on_sr(zfs_sr)
+
     def test_vdi_is_not_open(self, vdi_on_zfs_sr):
         assert not vdi_is_open(vdi_on_zfs_sr)