diff options
| author | Tony Asleson <tasleson@redhat.com> | 2022-09-22 17:11:45 -0500 |
|---|---|---|
| committer | Tony Asleson <tasleson@redhat.com> | 2022-09-22 17:14:10 -0500 |
| commit | fd05b79aad6ccf89f85bd85f5a4b32e1275ce785 (patch) | |
| tree | baef4d3a4fb074f0c5126e89d42996f0394a11e3 /test | |
| parent | 897b326cccc017b9e033b83d24ddcb007a3922f4 (diff) | |
| download | lvm2-fd05b79aad6ccf89f85bd85f5a4b32e1275ce785.tar.gz | |
lvmdbustest: Add test to stress mode changing
Add a test to toggle from fork & exec to lvm shell repeatedly, to stress
test it.
Diffstat (limited to 'test')
| -rwxr-xr-x | test/dbus/lvmdbustest.py | 29 |
1 files changed, 24 insertions, 5 deletions
diff --git a/test/dbus/lvmdbustest.py b/test/dbus/lvmdbustest.py index cf50bc564..41ee2fd1b 100755 --- a/test/dbus/lvmdbustest.py +++ b/test/dbus/lvmdbustest.py @@ -26,12 +26,14 @@ from testlib import * g_tmo = 0 +g_lvm_shell = False + # Approx. min size VDO_MIN_SIZE = mib(8192) VG_TEST_SUFFIX = "_vg_LvMdBuS_TEST" -EXE_NAME="/lvmdbusd" +EXE_NAME = "/lvmdbusd" # Prefix on created objects to enable easier clean-up g_prefix = os.getenv('PREFIX', '') @@ -164,18 +166,24 @@ def get_objects(): return _prune(rc, pv_device_list), bus +def set_exec_mode(lvmshell): + lvm_manager = dbus.Interface(bus.get_object( + BUS_NAME, "/com/redhat/lvmdbus1/Manager", introspect=False), + "com.redhat.lvmdbus1.Manager") + return lvm_manager.UseLvmShell(lvmshell) + + def set_execution(lvmshell, test_result): + global g_lvm_shell if lvmshell: m = 'lvm shell (non-fork)' else: m = "forking & exec'ing" - lvm_manager = dbus.Interface(bus.get_object( - BUS_NAME, "/com/redhat/lvmdbus1/Manager", introspect=False), - "com.redhat.lvmdbus1.Manager") - rc = lvm_manager.UseLvmShell(lvmshell) + rc = set_exec_mode(lvmshell) if rc: + g_lvm_shell = lvmshell std_err_print('Successfully changed execution mode to "%s"' % m) else: std_err_print('ERROR: Failed to change execution mode to "%s"' % m) @@ -2355,6 +2363,7 @@ class TestDbusService(unittest.TestCase): self.assertTrue(exited, "Failed to exit after sending signal %f seconds after " "queuing up work for signal %d" % (sleep_amt, signal.SIGINT)) + set_exec_mode(g_lvm_shell) def test_z_singleton_daemon(self): # Ensure we can only have 1 daemon running at a time, daemon should exit with 114 if already running @@ -2366,6 +2375,16 @@ class TestDbusService(unittest.TestCase): ec = di.start(True) self.assertEqual(ec, 114) + def test_z_switching(self): + # Ensure we can switch from forking to shell repeatedly + try: + t_mode = True + for _ in range(50): + t_mode = not t_mode + set_exec_mode(t_mode) + finally: + set_exec_mode(g_lvm_shell) + class AggregateResults(object): |