glusterfs: Don't uninstall glusterfs tools when SR couldn't be destroyed

Signed-off-by: Antoine Bartuccio <[email protected]>

Author: klmp200

tests/storage/glusterfs/conftest.py

@@ -1,15 +1,27 @@
 import pytest
 
 import logging
+from dataclasses import dataclass
 
 from lib.common import exec_nofail, raise_errors, setup_formatted_and_mounted_disk, teardown_formatted_and_mounted_disk
 from lib.netutil import is_ipv6
 
+from typing import TYPE_CHECKING
+
+if TYPE_CHECKING:
+    from lib.host import Host
+    from lib.pool import Pool
+    from lib.sr import SR
+
 # explicit import for package-scope fixtures
 from pkgfixtures import pool_with_saved_yum_state
 
 GLUSTERFS_PORTS = [('24007', 'tcp'), ('49152:49251', 'tcp')]
 
+@dataclass
+class GlusterFsConfig:
+    uninstall_glusterfs: bool = True
+
 def _setup_host_with_glusterfs(host):
     for service in ['iptables', 'ip6tables']:
         host.ssh(['cp', '/etc/sysconfig/%s' % service, '/etc/sysconfig/%s.orig' % service])
@@ -30,13 +42,18 @@ def _setup_host_with_glusterfs(host):
 
     host.ssh(['systemctl', 'enable', '--now', 'glusterd.service'])
 
-def _teardown_host_with_glusterfs(host):
+def _uninstall_host_glusterfs(host: 'Host'):
     errors = []
     errors += exec_nofail(lambda: host.ssh(['systemctl', 'disable', '--now', 'glusterd.service']))
 
     # Remove any remaining gluster-related data to avoid issues in future test runs
     errors += exec_nofail(lambda: host.ssh(['rm', '-rf', '/var/lib/glusterd']))
 
+    raise_errors(errors)
+
+def _restore_host_iptables(host: 'Host'):
+    errors = []
+
     iptables = 'ip6tables' if is_ipv6(host.hostname_or_ip) else 'iptables'
     for h in host.pool.hosts:
         hostname_or_ip = h.hostname_or_ip
@@ -56,7 +73,7 @@ def _teardown_host_with_glusterfs(host):
     raise_errors(errors)
 
 @pytest.fixture(scope='package')
-def pool_without_glusterfs(host):
+def pool_without_glusterfs(host: 'Host'):
     for h in host.pool.hosts:
         if h.file_exists('/usr/sbin/glusterd'):
             raise Exception(
@@ -65,11 +82,30 @@ def pool_without_glusterfs(host):
     yield host.pool
 
 @pytest.fixture(scope='package')
-def pool_with_glusterfs(pool_without_glusterfs, pool_with_saved_yum_state):
+def _glusterfs_config():
+    return GlusterFsConfig()
+
+@pytest.fixture(scope='package')
+def pool_with_glusterfs(
+    pool_without_glusterfs: 'Pool',
+    pool_with_saved_yum_state: 'Pool',
+    _glusterfs_config: GlusterFsConfig
+):
+
+    def _host_rollback(host: 'Host'):
+        _uninstall_host_glusterfs(host)
+        _restore_host_iptables(host)
+    def _disable_yum_rollback(host: 'Host'):
+        host.saved_rollback_id = None
+
     pool = pool_with_saved_yum_state
-    pool.exec_on_hosts_on_error_rollback(_setup_host_with_glusterfs, _teardown_host_with_glusterfs)
+    pool.exec_on_hosts_on_error_rollback(_setup_host_with_glusterfs, _host_rollback)
     yield pool
-    pool.exec_on_hosts_on_error_continue(_teardown_host_with_glusterfs)
+    if _glusterfs_config.uninstall_glusterfs:
+        pool.exec_on_hosts_on_error_continue(_uninstall_host_glusterfs)
+    else:
+        pool.exec_on_hosts_on_error_continue(_disable_yum_rollback)
+    pool.exec_on_hosts_on_error_continue(_restore_host_iptables)
 
 @pytest.fixture(scope='package')
 def gluster_disk(pool_with_unused_512B_disk, unused_512B_disks):
@@ -184,13 +220,22 @@ def glusterfs_device_config(host):
     }
 
 @pytest.fixture(scope='package')
-def glusterfs_sr(host, pool_with_glusterfs, gluster_volume_started, glusterfs_device_config):
+def glusterfs_sr(host: 'Host',
+    pool_with_glusterfs: 'Pool',
+    gluster_volume_started: None,
+    glusterfs_device_config,
+    _glusterfs_config: GlusterFsConfig
+):
     """ A GlusterFS SR on first host. """
     # Create the SR
     sr = host.sr_create('glusterfs', "GlusterFS-SR-test", glusterfs_device_config, shared=True)
     yield sr
     # teardown
-    sr.destroy()
+    try:
+        sr.destroy()
+    except Exception as e:
+        _glusterfs_config.uninstall_glusterfs = False
+        raise e
 
 @pytest.fixture(scope='module')
 def vdi_on_glusterfs_sr(glusterfs_sr):