# Copyright (C) 2017-2018 Red Hat, Inc. # # 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 # the Free Software Foundation; either version 2 of the License, or # any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License along # with this program; if not, write to the Free Software Foundation, Inc., # 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. """ Description: This test case will validate USS functionality. Activated snaps should get listed in .snap directory while deactivated snap should not. """ from glusto.core import Glusto as g from glustolibs.gluster.exceptions import ExecutionError from glustolibs.gluster.gluster_base_class import GlusterBaseClass from glustolibs.gluster.gluster_base_class import runs_on from glustolibs.io.utils import (validate_io_procs, view_snaps_from_mount) from glustolibs.gluster.snap_ops import (snap_create, snap_delete_all, get_snap_list, snap_activate, snap_deactivate) from glustolibs.gluster.uss_ops import (enable_uss, is_uss_enabled, is_snapd_running, uss_list_snaps, disable_uss) from glustolibs.misc.misc_libs import upload_scripts @runs_on([['replicated', 'distributed-replicated', 'dispersed', 'distributed', 'distributed-dispersed'], ['glusterfs', 'nfs', 'cifs']]) class SnapUssActiveD(GlusterBaseClass): @classmethod def setUpClass(cls): GlusterBaseClass.setUpClass.im_func(cls) # 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) if not ret: raise ExecutionError("Failed to upload IO scripts " "to clients ") g.log.info("Successfully uploaded IO scripts to clients %s") def setUp(self): # SettingUp and Mounting the volume GlusterBaseClass.setUpClass.im_func(self) g.log.info("Starting to SetUp Volume and mount volume") ret = self.setup_volume_and_mount_volume(mounts=self.mounts) if not ret: raise ExecutionError("Failed to setup volume %s" % self.volname) g.log.info("Volume %s has been setup successfully", self.volname) def tearDown(self): # Deleting all snapshot g.log.info("Deleting all snapshots created") ret, _, _ = snap_delete_all(self.mnode) if ret != 0: raise ExecutionError("Snapshot Delete Failed") g.log.info("Successfully deleted all snapshots") # Disable uss for volume g.log.info("Disabling uss for volume") ret, _, _ = disable_uss(self.mnode, self.volname) if ret != 0: raise ExecutionError("Failed to disable uss") g.log.info("Successfully disabled uss for volume" "%s", self.volname) # Unmount and cleanup original volume g.log.info("Starting to Unmount and Cleanup Volume") ret = self.unmount_volume_and_cleanup_volume(mounts=self.mounts) if not ret: raise ExecutionError("Failed to umount and cleanup Volume") g.log.info("Successful in umounting the volume and Cleanup") def test_uss_snap_active_deactive(self): # pylint: disable=too-many-statements """ Steps: * Create volume * Mount volume * Perform I/O on mounts * Create 2 snapshots snapy1 & snapy2 * Validate snap created * Enbale USS * Validate USS is enabled * Validate snapd is running * Activate snapy1 & snapy2 * List snaps under .snap directory -- snap1 and snap2 should be listed under .snaps * Deactivate snapy2 * List snaps under .snap directory -- snapy2 is not listed as it is deactivated * Activate snapy2 * List snaps under .snap directory -- snap1 and snap2 should be listed under .snaps """ # Perform I/O g.log.info("Starting IO on all mounts...") self.counter = 1 self.all_mounts_procs = [] 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 " "--dirname-start-num %d " "--dir-depth 2 " "--dir-length 2 " "--max-num-of-dirs 2 " "--num-of-files 2 %s" % (self.script_upload_path, self.counter, mount_obj.mountpoint)) proc = g.run_async(mount_obj.client_system, cmd, user=mount_obj.user) self.all_mounts_procs.append(proc) self.io_validation_complete = False # Validate IO g.log.info("Wait for IO to complete and validate IO ...") ret = validate_io_procs(self.all_mounts_procs, self.mounts) self.assertTrue(ret, "IO failed on some of the clients") self.io_validation_complete = True g.log.info("I/O successful on clients") # Enable USS g.log.info("Enable USS on volume") ret, _, _ = enable_uss(self.mnode, self.volname) self.assertEqual(ret, 0, "Failed to enable USS on volume") g.log.info("Successfully enabled USS on volume") # Validate USS is enabled g.log.info("Validating USS is enabled") ret = is_uss_enabled(self.mnode, self.volname) self.assertTrue(ret, "USS is disabled on volume " "%s" % self.volname) g.log.info("USS enabled on volume %s", self.volname) # Validate snapd running for server in self.servers: g.log.info("Validating snapd daemon on:%s", server) ret = is_snapd_running(server, self.volname) self.assertTrue(ret, "Snapd is Not running on " "%s" % server) g.log.info("Snapd Running on node: %s", server) # Create 2 snapshot g.log.info("Creating 2 snapshots for volume %s", self.volname) for i in range(0, 2): ret, _, _ = snap_create(self.mnode, self.volname, "snapy%s" % i) self.assertEqual(ret, 0, ("Failed to create snapshot for %s" % self.volname)) g.log.info("Snapshot %s created successfully for volume %s", "snapy%s" % i, self.volname) # Check for no of snaps using snap_list it should be 2 now snap_list = get_snap_list(self.mnode) self.assertEqual(2, len(snap_list), "No of snaps not consistent " "for volume %s" % self.volname) g.log.info("Successfully validated number of snaps.") # Activate snapshot snapy1 & snapy2 g.log.info("Activating snapshot snapy1 & snapy2") for i in range(0, 2): ret, _, _ = snap_activate(self.mnode, "snapy%s" % i) self.assertEqual(ret, 0, "Failed to activate snapshot snapy%s" % i) g.log.info("Both snapshots activated successfully") # list activated snapshots directory under .snaps g.log.info("Listing activated snapshots under .snaps") for mount_obj in self.mounts: ret, out, _ = uss_list_snaps(mount_obj.client_system, mount_obj.mountpoint) self.assertEqual(ret, 0, "Directory Listing Failed for" " Activated Snapshot") validate_dir = out.split('\n') self.assertIn("snapy1", validate_dir, "Failed to " "validate snapy1 under .snaps directory") g.log.info("Activated Snapshot snapy1 listed Successfully") self.assertIn("snapy2", validate_dir, "Successfully listed" " snapy2 under.snaps directory") g.log.info("Expected: De-activated Snapshot not listed") # Deactivate snapshot snapy2 g.log.info("Deactivating snapshot snapy2") ret, _, _ = snap_deactivate(self.mnode, "snapy2") self.assertEqual(ret, 0, "Failed to deactivate snapshot snapy2") g.log.info("Successfully deactivated snapshot snapy2") # validate snapy2 should not present in mountpoint ret = view_snaps_from_mount(self.mounts, "snapy2") self.assertFalse(ret, " UnExpected : Still able to View snapy2" " from mount ") g.log.info("Successfully varified deactivated snapshot " "snapy2 is not listed") # Activate snapshot snapy2 ret, _, _ = snap_activate(self.mnode, "snapy2") self.assertEqual(ret, 0, "Failed to activate Snapshot snapy2") g.log.info("Snapshot snapy2 activated successfully") # list activated snapshots directory under .snaps g.log.info("Listing activated snapshots under .snaps") for mount_obj in self.mounts: ret, out, _ = uss_list_snaps(mount_obj.client_system, mount_obj.mountpoint) self.assertEqual(ret, 0, "Directory Listing Failed for" " Activated Snapshot") validate_dir = out.split('\n') self.assertIn("snapy1", validate_dir, "Failed to " "validate snapy%s under .snaps directory") g.log.info("Activated Snapshot listed Successfully") self.assertIn("snapy2", validate_dir, "Successfully listed" "snapy2 under .snaps directory") g.log.info("Expected: De-activated Snapshot not listed")