diff options
Diffstat (limited to 'tests/functional/bvt/test_vvt.py')
| -rw-r--r-- | tests/functional/bvt/test_vvt.py | 50 |
1 files changed, 12 insertions, 38 deletions
diff --git a/tests/functional/bvt/test_vvt.py b/tests/functional/bvt/test_vvt.py index 8b3b69bf3..13ffd9dde 100644 --- a/tests/functional/bvt/test_vvt.py +++ b/tests/functional/bvt/test_vvt.py @@ -1,4 +1,4 @@ -# Copyright (C) 2015-2016 Red Hat, Inc. <http://www.redhat.com> +# Copyright (C) 2015-2020 Red Hat, Inc. <http://www.redhat.com> # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by @@ -19,9 +19,9 @@ Volume Operations like start, status, stop, delete. """ - -import pytest from glusto.core import Glusto as g +import pytest + from glustolibs.gluster.gluster_base_class import (GlusterBaseClass, runs_on) from glustolibs.gluster.exceptions import ExecutionError from glustolibs.gluster.gluster_init import is_glusterd_running @@ -46,16 +46,12 @@ class VolumeAccessibilityTests(GlusterBaseClass): """Upload the necessary scripts to run tests. """ # Calling GlusterBaseClass setUpClass - GlusterBaseClass.setUpClass.im_func(cls) + cls.get_super_method(cls, 'setUpClass')() # Upload io scripts for running IO on mounts - g.log.info("Upload io scripts to clients %s for running IO on " - "mounts", cls.clients) - script_local_path = ("/usr/share/glustolibs/io/scripts/" - "file_dir_ops.py") cls.script_upload_path = ("/usr/share/glustolibs/io/scripts/" "file_dir_ops.py") - ret = upload_scripts(cls.clients, script_local_path) + ret = upload_scripts(cls.clients, cls.script_upload_path) if not ret: raise ExecutionError("Failed to upload IO scripts to clients %s" % cls.clients) @@ -66,27 +62,23 @@ class VolumeAccessibilityTests(GlusterBaseClass): """Setup Volume """ # Calling GlusterBaseClass setUp - GlusterBaseClass.setUp.im_func(self) + self.get_super_method(self, 'setUp')() # Setup_Volume - g.log.info("Starting to Setup Volume %s", self.volname) ret = self.setup_volume() if not ret: raise ExecutionError("Failed to Setup Volume %s" % self.volname) - g.log.info("Successful in Setup Volume %s", self.volname) def tearDown(self): """Cleanup the volume """ # Cleanup Volume - g.log.info("Starting to Setup Volume %s", self.volname) ret = self.cleanup_volume() if not ret: raise ExecutionError("Failed to Setup_Volume %s" % self.volname) - g.log.info("Successful in Setup Volume %s", self.volname) # Calling GlusterBaseClass tearDown - GlusterBaseClass.tearDown.im_func(self) + self.get_super_method(self, 'tearDown')() @pytest.mark.bvt_vvt def test_volume_create_start_stop_start(self): @@ -95,7 +87,6 @@ class VolumeAccessibilityTests(GlusterBaseClass): start of the volume. """ # Verify volume processes are online - g.log.info("Verify volume %s processes are online", self.volname) ret = verify_all_process_of_volume_are_online(self.mnode, self.volname) self.assertTrue(ret, ("Volume %s : All process are not online" % self.volname)) @@ -103,27 +94,21 @@ class VolumeAccessibilityTests(GlusterBaseClass): self.volname) # Stop Volume - g.log.info("Stopping Volume %s", self.volname) ret, _, _ = volume_stop(self.mnode, self.volname, force=True) self.assertEqual(ret, 0, "Failed to stop volume %s" % self.volname) g.log.info("Successfully stopped volume %s", self.volname) # Start Volume - g.log.info("Starting Volume %s", self.volname) ret, _, _ = volume_start(self.mnode, self.volname) self.assertEqual(ret, 0, "Failed to start volume %s" % self.volname) g.log.info("Successfully started volume %s", self.volname) # Wait for volume processes to be online - g.log.info("Wait for volume processes to be online") ret = wait_for_volume_process_to_be_online(self.mnode, self.volname) self.assertTrue(ret, ("Failed to wait for volume %s processes to " "be online", self.volname)) - g.log.info("Successful in waiting for volume %s processes to be " - "online", self.volname) # Log Volume Info and Status - g.log.info("Logging Volume %s Info and Status", self.volname) ret = log_volume_info_and_status(self.mnode, self.volname) self.assertTrue(ret, ("Failed to Log volume %s info and status", self.volname)) @@ -131,7 +116,6 @@ class VolumeAccessibilityTests(GlusterBaseClass): self.volname) # Verify volume's all process are online - g.log.info("Verify volume %s processes are online", self.volname) ret = verify_all_process_of_volume_are_online(self.mnode, self.volname) self.assertTrue(ret, ("Volume %s : All process are not online" % self.volname)) @@ -139,7 +123,6 @@ class VolumeAccessibilityTests(GlusterBaseClass): self.volname) # Log Volume Info and Status - g.log.info("Logging Volume %s Info and Status", self.volname) ret = log_volume_info_and_status(self.mnode, self.volname) self.assertTrue(ret, ("Failed to Log volume %s info and status", self.volname)) @@ -147,8 +130,6 @@ class VolumeAccessibilityTests(GlusterBaseClass): self.volname) # Check if glusterd is running on all servers(expected: active) - g.log.info("Check if glusterd is running on all servers" - "(expected: active)") ret = is_glusterd_running(self.servers) self.assertEqual(ret, 0, "Glusterd is not running on all servers") g.log.info("Glusterd is running on all the servers") @@ -158,10 +139,8 @@ class VolumeAccessibilityTests(GlusterBaseClass): """Test File Directory Creation on the volume. """ # Mount Volume - g.log.info("Starting to Mount Volume %s", self.volname) ret = self.mount_volume(self.mounts) self.assertTrue(ret, ("Failed to Mount Volume %s", self.volname)) - g.log.info("Successful in Mounting Volume %s", self.volname) # Start IO on all mounts. all_mounts_procs = [] @@ -169,32 +148,27 @@ class VolumeAccessibilityTests(GlusterBaseClass): for mount_obj in self.mounts: g.log.info("Starting IO on %s:%s", mount_obj.client_system, mount_obj.mountpoint) - cmd = ("python %s create_deep_dirs_with_files " + cmd = ("/usr/bin/env python %s create_deep_dirs_with_files " "--dirname-start-num %d " "--dir-depth 2 " "--dir-length 10 " "--max-num-of-dirs 5 " - "--num-of-files 5 %s" % (self.script_upload_path, count, - mount_obj.mountpoint)) + "--num-of-files 5 %s" % ( + self.script_upload_path, count, + mount_obj.mountpoint)) proc = g.run_async(mount_obj.client_system, cmd, user=mount_obj.user) all_mounts_procs.append(proc) - count = count + 10 + count += 10 # Validate IO - g.log.info("Validating IO's") ret = validate_io_procs(all_mounts_procs, self.mounts) self.assertTrue(ret, "IO failed on some of the clients") - g.log.info("Successfully validated all io's") # Get stat of all the files/dirs created. - g.log.info("Get stat of all the files/dirs created.") ret = get_mounts_stat(self.mounts) self.assertTrue(ret, "Stat failed on some of the clients") - g.log.info("Successfully got stat of all files/dirs created") # UnMount Volume - g.log.info("Starting to Unmount Volume %s", self.volname) ret = self.unmount_volume(self.mounts) self.assertTrue(ret, ("Failed to Unmount Volume %s" % self.volname)) - g.log.info("Successfully Unmounted Volume %s", self.volname) |