From 8f09d6d30b5745bd2abf8b73b5d8df8c63b79f63 Mon Sep 17 00:00:00 2001
From: Shwetha Panduranga <spandura@redhat.com>
Date: Mon, 20 Mar 2017 14:39:05 +0530
Subject: Adding a sanity case to test shrinking volume. i.e remove-brick

Remove brick Sanity case covers testing of remove-brick of a subvolume,
waiting for rebalance to complete, commiting the operation and validate
IO is successful on the mount.

Change-Id: I5912f62b3df5dfb5bf5339de036967f83b6a5117
Signed-off-by: Shwetha Panduranga <spandura@redhat.com>
---
 tests/functional/bvt/test_cvt.py | 67 ++++++++++++++++++++++++++++++++++++++--
 1 file changed, 65 insertions(+), 2 deletions(-)

(limited to 'tests/functional/bvt')

diff --git a/tests/functional/bvt/test_cvt.py b/tests/functional/bvt/test_cvt.py
index ef086cf30..d56fb100b 100644
--- a/tests/functional/bvt/test_cvt.py
+++ b/tests/functional/bvt/test_cvt.py
@@ -25,8 +25,8 @@
             - set volume options which changes the client graphs
             - enable quota
             - collecting snapshot
-        TODO:
             - remove-brick
+        TODO:
             - n/w failure followed by heal
             - replace-brick
             - attach-tier, detach-tier
@@ -40,7 +40,7 @@ from glustolibs.gluster.volume_libs import enable_and_validate_volume_options
 from glustolibs.gluster.volume_libs import (
     verify_all_process_of_volume_are_online)
 from glustolibs.gluster.volume_libs import (log_volume_info_and_status,
-                                            expand_volume)
+                                            expand_volume, shrink_volume)
 from glustolibs.gluster.rebalance_ops import (rebalance_start,
                                               wait_for_rebalance_to_complete,
                                               rebalance_status)
@@ -244,6 +244,69 @@ class TestGlusterExpandVolumeSanity(GlusterBasicFeaturesSanityBaseClass):
         g.log.info("Listing all files and directories is successful")
 
 
+@runs_on([['distributed', 'distributed-replicated', 'distributed-dispersed'],
+          ['glusterfs', 'nfs', 'cifs']])
+class TestGlusterShrinkVolumeSanity(GlusterBasicFeaturesSanityBaseClass):
+    """Sanity tests for Shrinking Volume"""
+    @pytest.mark.bvt_cvt
+    def test_shrinking_volume_when_io_in_progress(self):
+        """Test shrinking volume (Decrease distribute count) using existing
+        servers bricks when IO is in progress.
+
+        Description:
+            - remove brick (start, status, commit)
+            - validate IO
+        """
+        # Log Volume Info and Status before shrinking the volume.
+        g.log.info("Logging volume info and Status before shrinking volume")
+        ret = log_volume_info_and_status(self.mnode, self.volname)
+        self.assertTrue(ret, ("Logging volume info and status failed on "
+                              "volume %s", self.volname))
+        g.log.info("Successful in logging volume info and status of volume %s",
+                   self.volname)
+
+        # Shrinking volume by removing bricks from volume when IO in progress
+        g.log.info("Start removing bricks from volume when IO in progress")
+        ret = shrink_volume(self.mnode, self.volname)
+        self.assertTrue(ret, ("Failed to shrink the volume when IO in "
+                              "progress on volume %s", self.volname))
+        g.log.info("Shrinking volume when IO in progress is successful on "
+                   "volume %s", self.volname)
+
+        # Wait for gluster processes to come online
+        time.sleep(30)
+
+        # Log Volume Info and Status after shrinking the volume
+        g.log.info("Logging volume info and Status after shrinking volume")
+        ret = log_volume_info_and_status(self.mnode, self.volname)
+        self.assertTrue(ret, ("Logging volume info and status failed on "
+                              "volume %s", self.volname))
+        g.log.info("Successful in logging volume info and status of volume %s",
+                   self.volname)
+
+        # Verify volume's all process are online
+        g.log.info("Verifying volume's all process are online after "
+                   "shrinking volume")
+        ret = verify_all_process_of_volume_are_online(self.mnode, self.volname)
+        self.assertTrue(ret, ("Volume %s : All process are not online",
+                              self.volname))
+        g.log.info("Volume %s : All process are online after shrinking volume",
+                   self.volname)
+
+        # Validate IO
+        g.log.info("Wait for IO to complete and validate IO ...")
+        ret = validate_io_procs(self.all_mounts_procs, self.mounts)
+        self.io_validation_complete = True
+        self.assertTrue(ret, "IO failed on some of the clients")
+        g.log.info("IO is successful on all mounts")
+
+        # List all files and dirs created
+        g.log.info("List all files and directories:")
+        ret = list_all_files_and_dirs_mounts(self.mounts)
+        self.assertTrue(ret, "Failed to list all files and dirs")
+        g.log.info("Listing all files and directories is successful")
+
+
 @runs_on([['replicated', 'distributed', 'distributed-replicated',
            'dispersed', 'distributed-dispersed'],
           ['glusterfs', 'nfs', 'cifs']])
-- 
cgit