Fix up coding style issues in tests

Change-Id: I14609030983d4485dbce5a4ffed1e0353e3d1bc7

4 files changed, 941 insertions, 82 deletions

diff --git a/tests/functional/afr/heal/__init__.py b/tests/functional/afr/heal/__init__.py
new file mode 100644
index 000000000..e69de29bb
--- /dev/null
+++ b/tests/functional/afr/heal/__init__.py
diff --git a/tests/functional/afr/heal/test_heal_info_while_accessing_file.py b/tests/functional/afr/heal/test_heal_info_while_accessing_file.py
new file mode 100644
index 000000000..965adbdc1
--- /dev/null
+++ b/tests/functional/afr/heal/test_heal_info_while_accessing_file.py
@@ -0,0 +1,228 @@
+#  Copyright (C) 2015-2016  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
+#  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.
+
+from glusto.core import Glusto as g
+from glustolibs.gluster.gluster_base_class import (GlusterBaseClass, runs_on)
+from glustolibs.gluster.exceptions import ExecutionError
+from glustolibs.gluster.volume_libs import get_subvols
+from glustolibs.gluster.brick_libs import (bring_bricks_offline,
+                                           are_bricks_offline,
+                                           get_all_bricks)
+
+from glustolibs.gluster.heal_ops import get_heal_info_summary
+from glustolibs.misc.misc_libs import upload_scripts
+from glustolibs.io.utils import (validate_io_procs,
+                                 list_all_files_and_dirs_mounts,
+                                 wait_for_io_to_complete)
+
+
+@runs_on([['distributed-replicated'],
+          ['glusterfs']])
+class TestSelfHeal(GlusterBaseClass):
+    """
+    Description:
+        Test cases related to
+        healing in default configuration of the volume
+    """
+
+    @classmethod
+    def setUpClass(cls):
+        # Calling GlusterBaseClass setUpClass
+        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 %s"
+                                 % cls.clients)
+        g.log.info("Successfully uploaded IO scripts to clients %s",
+                   cls.clients)
+
+        cls.counter = 1
+        # int: Value of counter is used for dirname-start-num argument for
+        # file_dir_ops.py create_deep_dirs_with_files.
+
+        # The --dir-length argument value for file_dir_ops.py
+        # create_deep_dirs_with_files is set to 10 (refer to the cmd in setUp
+        # method). This means every mount will create
+        # 10 top level dirs. For every mountpoint/testcase to create new set of
+        # dirs, we are incrementing the counter by --dir-length value i.e 10 in
+        # this test suite.
+
+        # If we are changing the --dir-length to new value, ensure the counter
+        # is also incremented by same value to create new set of files/dirs.
+
+    def setUp(self):
+        # Calling GlusterBaseClass setUp
+        GlusterBaseClass.setUp.im_func(self)
+
+        self.all_mounts_procs = []
+        self.io_validation_complete = False
+
+        # Setup Volume and Mount Volume
+        g.log.info("Starting to Setup Volume and Mount Volume")
+        ret = self.setup_volume_and_mount_volume(mounts=self.mounts,
+                                                 volume_create_force=False)
+        if not ret:
+            raise ExecutionError("Failed to Setup_Volume and Mount_Volume")
+        g.log.info("Successful in Setup Volume and Mount Volume")
+
+        self.bricks_list = get_all_bricks(self.mnode, self.volname)
+
+    def tearDown(self):
+        """
+        If test method failed before validating IO, tearDown waits for the
+        IO's to complete and checks for the IO exit status
+
+        Cleanup and umount volume
+        """
+        if not self.io_validation_complete:
+            g.log.info("Wait for IO to complete as IO validation did not "
+                       "succeed in test method")
+            ret = wait_for_io_to_complete(self.all_mounts_procs, self.mounts)
+            if not ret:
+                raise ExecutionError("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)
+            if not ret:
+                raise ExecutionError("Failed to list all files and dirs")
+            g.log.info("Listing all files and directories is successful")
+
+        # Cleanup and umount volume
+        g.log.info("Starting to Unmount Volume and Cleanup Volume")
+        ret = self.unmount_volume_and_cleanup_volume(mounts=self.mounts)
+        if not ret:
+            raise ExecutionError("Failed to umount the vol & cleanup Volume")
+        g.log.info("Successful in umounting the volume and Cleanup")
+
+        # Calling GlusterBaseClass teardown
+        GlusterBaseClass.tearDown.im_func(self)
+
+    def test_heal_info_shouldnot_list_files_being_accessed(self):
+        """
+        - bring brick 1 offline
+        - create files and validate IO
+        - get entries before accessing file
+        - get first filename from active subvol without offline bricks
+        - access and modify the file
+        - while accessing - get entries
+        - Compare entries before accessing and while accessing
+        - validate IO
+        """
+
+        # Bring 1-st brick offline
+        brick_to_bring_offline = [self.bricks_list[0]]
+        g.log.info('Bringing bricks %s offline...', brick_to_bring_offline)
+        ret = bring_bricks_offline(self.volname, brick_to_bring_offline)
+        self.assertTrue(ret, 'Failed to bring bricks %s offline'
+                        % brick_to_bring_offline)
+
+        ret = are_bricks_offline(self.mnode, self.volname,
+                                 brick_to_bring_offline)
+        self.assertTrue(ret, 'Bricks %s are not offline'
+                        % brick_to_bring_offline)
+        g.log.info('Bringing bricks %s offline is successful',
+                   brick_to_bring_offline)
+
+        # Creating files on client side
+        for mount_obj in self.mounts:
+            g.log.info("Generating data for %s:%s",
+                       mount_obj.client_system, mount_obj.mountpoint)
+
+            # Creating files
+            cmd = ("python %s create_files -f 100 %s"
+                   % (self.script_upload_path, mount_obj.mountpoint))
+
+            proc = g.run_async(mount_obj.client_system, cmd,
+                               user=mount_obj.user)
+            self.all_mounts_procs.append(proc)
+
+        # 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")
+
+        # Get entries before accessing file
+        g.log.info("Getting entries_before_accessing file...")
+        entries_before_accessing = get_heal_info_summary(
+            self.mnode, self.volname)
+        self.assertNotEqual(entries_before_accessing, None,
+                            'Can`t get heal info summary')
+        g.log.info(
+            "Getting entries_before_accessing file finished successfully")
+
+        # Get filename to access from active subvol without offline bricks
+        # Get last subvol
+        subvols = get_subvols(self.mnode, self.volname)
+        subvol_without_offline_brick = subvols['volume_subvols'][-1]
+
+        # Get first brick server and brick path
+        # and get first file from filelist
+        subvol_mnode, mnode_brick = subvol_without_offline_brick[0].split(':')
+        ret, file_list, _ = g.run(subvol_mnode, 'ls %s' % mnode_brick)
+        file_to_edit = file_list.splitlines()[0]
+
+        # Access and modify the file
+        g.log.info("Start modifying IO on all mounts...")
+        self.all_mounts_procs = []
+        for mount_obj in self.mounts:
+            g.log.info("Modifying IO on %s:%s", mount_obj.client_system,
+                       mount_obj.mountpoint)
+
+            cmd = ("cd %s/ ; "
+                   "dd if=/dev/zero of=%s bs=1G count=1"
+                   % (mount_obj.mountpoint, file_to_edit))
+            proc = g.run_async(mount_obj.client_system, cmd,
+                               user=mount_obj.user)
+            self.all_mounts_procs.append(proc)
+            g.log.info("IO on %s:%s is modified successfully",
+                       mount_obj.client_system, mount_obj.mountpoint)
+        self.io_validation_complete = False
+
+        # Get entries while accessing file
+        g.log.info("Getting entries while accessing file...")
+        entries_while_accessing = get_heal_info_summary(
+            self.mnode, self.volname)
+        self.assertNotEqual(entries_before_accessing, None,
+                            'Can`t get heal info summary')
+        g.log.info("Getting entries while accessing file "
+                   "finished successfully")
+
+        # Compare dicts before accessing and while accessing
+        g.log.info('Comparing entries before modifying and while modifying...')
+        ret = cmp(entries_before_accessing, entries_while_accessing)
+        self.assertEqual(ret, 0, 'Entries before modifying and while modifying'
+                                 'are not equal')
+        g.log.info('Comparison entries before modifying and while modifying'
+                   'finished successfully.')
+
+        # 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("IO is successful on all mounts")
diff --git a/tests/functional/afr/heal/test_self_heal.py b/tests/functional/afr/heal/test_self_heal.py
index 7837d958c..b2e52e392 100755..100644
--- a/tests/functional/afr/heal/test_self_heal.py
+++ b/tests/functional/afr/heal/test_self_heal.py
@@ -55,8 +55,8 @@ class TestSelfHeal(GlusterBaseClass):
         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)
+        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/"
@@ -65,23 +65,22 @@ class TestSelfHeal(GlusterBaseClass):
         if not ret:
             raise ExecutionError("Failed to upload IO scripts to clients %s"
                                  % cls.clients)
-        g.log.info("Successfully uploaded IO scripts to clients %s"
-                   % cls.clients)
+        g.log.info("Successfully uploaded IO scripts to clients %s",
+                   cls.clients)
 
         cls.counter = 1
-        """int: Value of counter is used for dirname-start-num argument for
-        file_dir_ops.py create_deep_dirs_with_files.
-
-        The --dir-length argument value for
-        file_dir_ops.py create_deep_dirs_with_files is set to 10
-        (refer to the cmd in setUp method). This means every mount will create
-        10 top level dirs. For every mountpoint/testcase to create new set of
-        dirs, we are incrementing the counter by --dir-length value i.e 10
-        in this test suite.
-
-        If we are changing the --dir-length to new value, ensure the counter
-        is also incremented by same value to create new set of files/dirs.
-        """
+        # int: Value of counter is used for dirname-start-num argument for
+        # file_dir_ops.py create_deep_dirs_with_files.
+
+        # The --dir-length argument value for file_dir_ops.py
+        # create_deep_dirs_with_files is set to 10 (refer to the cmd in setUp
+        # method). This means every mount will create
+        # 10 top level dirs. For every mountpoint/testcase to create new set of
+        # dirs, we are incrementing the counter by --dir-length value i.e 10
+        # in this test suite.
+
+        # If we are changing the --dir-length to new value, ensure the counter
+        # is also incremented by same value to create new set of files/dirs.
 
     def setUp(self):
         # Calling GlusterBaseClass setUp
@@ -129,13 +128,6 @@ class TestSelfHeal(GlusterBaseClass):
         # Calling GlusterBaseClass teardown
         GlusterBaseClass.tearDown.im_func(self)
 
-    @classmethod
-    def tearDownClass(cls):
-        """tearDownClass. This will be executed once per class.
-        """
-        # Calling GlusterBaseClass tearDownClass.
-        GlusterBaseClass.tearDownClass.im_func(cls)
-
     def test_data_self_heal_daemon_off(self):
         """
         Test Data-Self-Heal (heal command)
@@ -166,22 +158,22 @@ class TestSelfHeal(GlusterBaseClass):
         in cycle
         - validate IO
         """
+        # pylint: disable=too-many-statements
 
         # Setting options
         g.log.info('Setting options...')
         options = {"metadata-self-heal": "off",
                    "entry-self-heal": "off",
-                   "data-self-heal": "off",
-                   }
+                   "data-self-heal": "off"}
         ret = set_volume_options(self.mnode, self.volname, options)
         self.assertTrue(ret, 'Failed to set options %s' % options)
-        g.log.info("Successfully set %s for volume %s"
-                   % (options, self.volname))
+        g.log.info("Successfully set %s for volume %s",
+                   options, self.volname)
 
         # Creating files on client side
         for mount_obj in self.mounts:
-            g.log.info("Generating data for %s:%s"
-                       % (mount_obj.client_system, mount_obj.mountpoint))
+            g.log.info("Generating data for %s:%s",
+                       mount_obj.client_system, mount_obj.mountpoint)
             # Create files
             g.log.info('Creating files...')
             command = ("python %s create_files -f 100 --fixed-file-size 1k %s"
@@ -217,12 +209,12 @@ class TestSelfHeal(GlusterBaseClass):
         bricks_to_bring_offline_dict = (select_bricks_to_bring_offline(
             self.mnode, self.volname))
         bricks_to_bring_offline = filter(None, (
-                bricks_to_bring_offline_dict['hot_tier_bricks'] +
-                bricks_to_bring_offline_dict['cold_tier_bricks'] +
-                bricks_to_bring_offline_dict['volume_bricks']))
+            bricks_to_bring_offline_dict['hot_tier_bricks'] +
+            bricks_to_bring_offline_dict['cold_tier_bricks'] +
+            bricks_to_bring_offline_dict['volume_bricks']))
 
         # Bring brick offline
-        g.log.info('Bringing bricks %s offline...' % bricks_to_bring_offline)
+        g.log.info('Bringing bricks %s offline...', bricks_to_bring_offline)
         ret = bring_bricks_offline(self.volname, bricks_to_bring_offline)
         self.assertTrue(ret, 'Failed to bring bricks %s offline' %
                         bricks_to_bring_offline)
@@ -231,8 +223,8 @@ class TestSelfHeal(GlusterBaseClass):
                                  bricks_to_bring_offline)
         self.assertTrue(ret, 'Bricks %s are not offline'
                         % bricks_to_bring_offline)
-        g.log.info('Bringing bricks %s offline is successful'
-                   % bricks_to_bring_offline)
+        g.log.info('Bringing bricks %s offline is successful',
+                   bricks_to_bring_offline)
 
         # Get areequal after getting bricks offline
         g.log.info('Getting areequal after getting bricks offline...')
@@ -252,8 +244,8 @@ class TestSelfHeal(GlusterBaseClass):
         # Modify the data
         self.all_mounts_procs = []
         for mount_obj in self.mounts:
-            g.log.info("Modifying data for %s:%s" %
-                       (mount_obj.client_system, mount_obj.mountpoint))
+            g.log.info("Modifying data for %s:%s", mount_obj.client_system,
+                       mount_obj.mountpoint)
             # Create files
             g.log.info('Creating files...')
             command = ("python %s create_files -f 100 --fixed-file-size 10k %s"
@@ -272,13 +264,13 @@ class TestSelfHeal(GlusterBaseClass):
         g.log.info("IO is successful on all mounts")
 
         # Bring brick online
-        g.log.info('Bringing bricks %s online...' % bricks_to_bring_offline)
+        g.log.info('Bringing bricks %s online...', bricks_to_bring_offline)
         ret = bring_bricks_online(self.mnode, self.volname,
                                   bricks_to_bring_offline)
         self.assertTrue(ret, 'Failed to bring bricks %s online' %
                         bricks_to_bring_offline)
-        g.log.info('Bringing bricks %s online is successful'
-                   % bricks_to_bring_offline)
+        g.log.info('Bringing bricks %s online is successful',
+                   bricks_to_bring_offline)
 
         # Setting options
         g.log.info('Setting options...')
@@ -300,7 +292,7 @@ class TestSelfHeal(GlusterBaseClass):
         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" % self.volname)
+        g.log.info("Volume %s : All process are online", self.volname)
 
         # Wait for self-heal-daemons to be online
         g.log.info("Waiting for self-heal-daemons to be online")
@@ -333,10 +325,10 @@ class TestSelfHeal(GlusterBaseClass):
                             self.all_servers_info)
         self.assertTrue(ret, ("Failed to expand the volume %s", self.volname))
         g.log.info("Expanding volume is successful on "
-                   "volume %s" % self.volname)
+                   "volume %s", self.volname)
 
         # Do rebalance
-        ret, out, err = rebalance_start(self.mnode, self.volname)
+        ret, _, _ = rebalance_start(self.mnode, self.volname)
         self.assertEqual(ret, 0, 'Failed to start rebalance')
         g.log.info('Rebalance is started')
 
@@ -347,8 +339,8 @@ class TestSelfHeal(GlusterBaseClass):
         # Create 1k files
         self.all_mounts_procs = []
         for mount_obj in self.mounts:
-            g.log.info("Modifying data for %s:%s" %
-                       (mount_obj.client_system, mount_obj.mountpoint))
+            g.log.info("Modifying data for %s:%s", mount_obj.client_system,
+                       mount_obj.mountpoint)
             # Create files
             g.log.info('Creating files...')
             command = ("python %s create_files -f 1000 %s"
@@ -363,7 +355,7 @@ class TestSelfHeal(GlusterBaseClass):
         bricks_list = get_all_bricks(self.mnode, self.volname)
         for brick in bricks_list:
             # Bring brick offline
-            g.log.info('Bringing bricks %s offline' % brick)
+            g.log.info('Bringing bricks %s offline', brick)
             ret = bring_bricks_offline(self.volname, [brick])
             self.assertTrue(ret, 'Failed to bring bricks %s offline' % brick)
 
@@ -371,17 +363,17 @@ class TestSelfHeal(GlusterBaseClass):
                                      [brick])
             self.assertTrue(ret, 'Bricks %s are not offline'
                             % brick)
-            g.log.info('Bringing bricks %s offline is successful'
-                       % bricks_to_bring_offline)
+            g.log.info('Bringing bricks %s offline is successful',
+                       bricks_to_bring_offline)
 
             # Bring brick online
-            g.log.info('Bringing bricks %s online...' % brick)
+            g.log.info('Bringing bricks %s online...', brick)
             ret = bring_bricks_online(self.mnode, self.volname,
                                       [brick])
             self.assertTrue(ret, 'Failed to bring bricks %s online' %
                             bricks_to_bring_offline)
-            g.log.info('Bringing bricks %s online is successful'
-                       % bricks_to_bring_offline)
+            g.log.info('Bringing bricks %s online is successful',
+                       bricks_to_bring_offline)
 
             # Wait for volume processes to be online
             g.log.info("Wait for volume processes to be online")
@@ -398,7 +390,7 @@ class TestSelfHeal(GlusterBaseClass):
                                                           self.volname)
             self.assertTrue(ret, ("Volume %s : All process are not online"
                                   % self.volname))
-            g.log.info("Volume %s : All process are online" % self.volname)
+            g.log.info("Volume %s : All process are online", self.volname)
 
             # Wait for self-heal-daemons to be online
             g.log.info("Waiting for self-heal-daemons to be online")
@@ -442,13 +434,13 @@ class TestSelfHeal(GlusterBaseClass):
         - get areequal after getting bricks online and compare with
         arequal before bringing bricks online
         """
+        # pylint: disable=too-many-statements
 
         # Setting options
         g.log.info('Setting options...')
         options = {"metadata-self-heal": "off",
                    "entry-self-heal": "off",
-                   "data-self-heal": "off",
-                   }
+                   "data-self-heal": "off"}
         ret = set_volume_options(self.mnode, self.volname, options)
         self.assertTrue(ret, 'Failed to set options %s' % options)
         g.log.info("Options "
@@ -461,9 +453,8 @@ class TestSelfHeal(GlusterBaseClass):
         g.log.info("Starting IO on all mounts...")
         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))
+            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-length 2 "
@@ -476,9 +467,8 @@ class TestSelfHeal(GlusterBaseClass):
                                user=mount_obj.user)
             self.all_mounts_procs.append(proc)
             self.counter = self.counter + 10
-            g.log.info("IO on %s:%s is started successfully"
-                       % (mount_obj.client_system,
-                          mount_obj.mountpoint))
+            g.log.info("IO on %s:%s is started successfully",
+                       mount_obj.client_system, mount_obj.mountpoint)
         self.io_validation_complete = False
 
         # Validate IO
@@ -493,8 +483,7 @@ class TestSelfHeal(GlusterBaseClass):
         cmd_list = ["python %s create_files -f 20 %s",
                     "python %s mv -i '.trashcan' %s",
                     "python %s copy --dest-dir new_dir %s",
-                    "python %s delete %s",
-                    ]
+                    "python %s delete %s"]
 
         for cmd in cmd_list:
             # Get areequal before getting bricks offline
@@ -506,8 +495,7 @@ class TestSelfHeal(GlusterBaseClass):
 
             # Setting options
             g.log.info('Setting options...')
-            options = {"self-heal-daemon": "off",
-                       }
+            options = {"self-heal-daemon": "off"}
             ret = set_volume_options(self.mnode, self.volname, options)
             self.assertTrue(ret, 'Failed to set options %s' % options)
             g.log.info("Option 'self-heal-daemon' "
@@ -517,13 +505,13 @@ class TestSelfHeal(GlusterBaseClass):
             bricks_to_bring_offline_dict = (select_bricks_to_bring_offline(
                 self.mnode, self.volname))
             bricks_to_bring_offline = filter(None, (
-                    bricks_to_bring_offline_dict['hot_tier_bricks'] +
-                    bricks_to_bring_offline_dict['cold_tier_bricks'] +
-                    bricks_to_bring_offline_dict['volume_bricks']))
+                bricks_to_bring_offline_dict['hot_tier_bricks'] +
+                bricks_to_bring_offline_dict['cold_tier_bricks'] +
+                bricks_to_bring_offline_dict['volume_bricks']))
 
             # Bring brick offline
-            g.log.info('Bringing bricks %s offline...'
-                       % bricks_to_bring_offline)
+            g.log.info('Bringing bricks %s offline...',
+                       bricks_to_bring_offline)
             ret = bring_bricks_offline(self.volname, bricks_to_bring_offline)
             self.assertTrue(ret, 'Failed to bring bricks %s offline' %
                             bricks_to_bring_offline)
@@ -532,8 +520,8 @@ class TestSelfHeal(GlusterBaseClass):
                                      bricks_to_bring_offline)
             self.assertTrue(ret, 'Bricks %s are not offline'
                             % bricks_to_bring_offline)
-            g.log.info('Bringing bricks %s offline is successful'
-                       % bricks_to_bring_offline)
+            g.log.info('Bringing bricks %s offline is successful',
+                       bricks_to_bring_offline)
 
             # Get areequal after getting bricks offline
             g.log.info('Getting areequal after getting bricks offline...')
@@ -559,9 +547,8 @@ class TestSelfHeal(GlusterBaseClass):
                 proc = g.run_async(mount_obj.client_system, cmd,
                                    user=mount_obj.user)
                 self.all_mounts_procs.append(proc)
-                g.log.info("IO on %s:%s is modified successfully"
-                           % (mount_obj.client_system,
-                              mount_obj.mountpoint))
+                g.log.info("IO on %s:%s is modified successfully",
+                           mount_obj.client_system, mount_obj.mountpoint)
             self.io_validation_complete = False
 
             # Validate IO
@@ -586,19 +573,18 @@ class TestSelfHeal(GlusterBaseClass):
             g.log.info("Listing all files and directories is successful")
 
             # Bring brick online
-            g.log.info('Bringing bricks %s online...'
-                       % bricks_to_bring_offline)
+            g.log.info('Bringing bricks %s online...',
+                       bricks_to_bring_offline)
             ret = bring_bricks_online(self.mnode, self.volname,
                                       bricks_to_bring_offline)
             self.assertTrue(ret, 'Failed to bring bricks %s online'
                             % bricks_to_bring_offline)
-            g.log.info('Bringing bricks %s online is successful'
-                       % bricks_to_bring_offline)
+            g.log.info('Bringing bricks %s online is successful',
+                       bricks_to_bring_offline)
 
             # Setting options
             g.log.info('Setting options...')
-            options = {"self-heal-daemon": "on",
-                       }
+            options = {"self-heal-daemon": "on"}
             ret = set_volume_options(self.mnode, self.volname, options)
             self.assertTrue(ret, 'Failed to set options %s' % options)
             g.log.info("Option 'self-heal-daemon' is set to 'on' successfully")
@@ -618,7 +604,7 @@ class TestSelfHeal(GlusterBaseClass):
                                                           self.volname)
             self.assertTrue(ret, ("Volume %s : All process are not online"
                                   % self.volname))
-            g.log.info("Volume %s : All process are online" % self.volname)
+            g.log.info("Volume %s : All process are online", self.volname)
 
             # Wait for self-heal-daemons to be online
             g.log.info("Waiting for self-heal-daemons to be online")
diff --git a/tests/functional/afr/heal/test_self_heal_daemon_process.py b/tests/functional/afr/heal/test_self_heal_daemon_process.py
new file mode 100644
index 000000000..3412c1b49
--- /dev/null
+++ b/tests/functional/afr/heal/test_self_heal_daemon_process.py
@@ -0,0 +1,645 @@
+#  Copyright (C) 2016-2017  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
+#  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:
+        Test Cases in this module tests the self heal daemon process.
+"""
+
+from glusto.core import Glusto as g
+from glustolibs.gluster.exceptions import ExecutionError
+from glustolibs.gluster.gluster_base_class import GlusterBaseClass, runs_on
+from glustolibs.gluster.volume_libs import (
+    expand_volume, shrink_volume, log_volume_info_and_status,
+    wait_for_volume_process_to_be_online)
+from glustolibs.gluster.rebalance_ops import (rebalance_start,
+                                              wait_for_rebalance_to_complete,
+                                              rebalance_status)
+from glustolibs.gluster.brick_libs import (get_all_bricks,
+                                           bring_bricks_offline,
+                                           bring_bricks_online,
+                                           are_bricks_online,
+                                           select_bricks_to_bring_offline)
+from glustolibs.gluster.brick_ops import replace_brick
+from glustolibs.gluster.heal_libs import (get_self_heal_daemon_pid,
+                                          do_bricks_exist_in_shd_volfile,
+                                          is_shd_daemonized,
+                                          are_all_self_heal_daemons_are_online)
+from glustolibs.gluster.volume_ops import (volume_stop, volume_start)
+from glustolibs.gluster.gluster_init import restart_glusterd
+
+
+@runs_on([['replicated', 'distributed-replicated', 'dispersed',
+           'distributed-dispersed'], ['glusterfs', 'nfs', 'cifs']])
+class SelfHealDaemonProcessTests(GlusterBaseClass):
+    """
+    SelfHealDaemonProcessTests contains tests which verifies the
+    self-heal daemon process of the nodes
+    """
+    def setUp(self):
+        """
+        setup volume, mount volume and initialize necessary variables
+        which is used in tests
+        """
+
+        # calling GlusterBaseClass setUpClass
+        GlusterBaseClass.setUp.im_func(self)
+
+        # Setup Volume and Mount Volume
+        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 and Mount_Volume")
+        g.log.info("Successful in Setup Volume and Mount Volume")
+
+        # Verfiy glustershd process releases its parent process
+        ret = is_shd_daemonized(self.servers)
+        if not ret:
+            raise ExecutionError("Self Heal Daemon process was still"
+                                 " holding parent process.")
+        g.log.info("Self Heal Daemon processes are online")
+
+        self.glustershd = "/var/lib/glusterd/glustershd/glustershd-server.vol"
+
+    def tearDown(self):
+        """
+        Clean up the volume and umount volume from client
+        """
+
+        # stopping the volume
+        g.log.info("Starting to Unmount Volume and Cleanup Volume")
+        ret = self.unmount_volume_and_cleanup_volume(mounts=self.mounts)
+        if not ret:
+            raise ExecutionError("Failed to Unmount Volume and Cleanup Volume")
+        g.log.info("Successful in Unmount Volume and Cleanup Volume")
+
+        # calling GlusterBaseClass tearDownClass
+        GlusterBaseClass.tearDown.im_func(self)
+
+    def test_glustershd_with_add_remove_brick(self):
+        """
+        Test script to verify glustershd process with adding and
+        removing bricks
+
+        * check glustershd process - only 1 glustershd process should
+          be running
+        * bricks must be present in glustershd-server.vol file for
+          the replicated involved volumes
+        * Add bricks
+        * check glustershd process - only 1 glustershd process should
+          be running and its should be different from previous one
+        * bricks which are added must present in glustershd-server.vol file
+        * remove bricks
+        * check glustershd process - only 1 glustershd process should
+          be running and its different from previous one
+        * bricks which are removed should not present
+          in glustershd-server.vol file
+
+        """
+        # pylint: disable=too-many-statements
+        nodes = self.volume['servers']
+        bricks_list = []
+        glustershd_pids = {}
+
+        # check the self-heal daemon process
+        g.log.info("Starting to get self-heal daemon process on "
+                   "nodes %s", nodes)
+        ret, pids = get_self_heal_daemon_pid(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process "
+                              "found : %s", pids))
+        g.log.info("Successful in getting Single self heal daemon process"
+                   " on all nodes %s", nodes)
+        glustershd_pids = pids
+
+        # get the bricks for the volume
+        g.log.info("Fetching bricks for the volume : %s", self.volname)
+        bricks_list = get_all_bricks(self.mnode, self.volname)
+        g.log.info("Brick List : %s", bricks_list)
+
+        # validate the bricks present in volume info with
+        # glustershd server volume file
+        g.log.info("Starting parsing file %s on "
+                   "node %s", self.glustershd, self.mnode)
+        ret = do_bricks_exist_in_shd_volfile(self.mnode, self.volname,
+                                             bricks_list)
+        self.assertTrue(ret, ("Brick List from volume info is different "
+                              "from glustershd server volume file. "
+                              "Please check log file for details"))
+        g.log.info("Successfully parsed %s file", self.glustershd)
+
+        # expanding volume
+        g.log.info("Start adding bricks to volume %s", self.volname)
+        ret = expand_volume(self.mnode, self.volname, self.servers,
+                            self.all_servers_info)
+        self.assertTrue(ret, ("Failed to add bricks to "
+                              "volume %s " % self.volname))
+        g.log.info("Add brick successfull")
+
+        # Log Volume Info and Status after expanding the volume
+        g.log.info("Logging volume info and Status after expanding 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 for 60 sec
+        g.log.info("Verifying volume's all process are online")
+        ret = wait_for_volume_process_to_be_online(self.mnode, self.volname,
+                                                   60)
+        self.assertTrue(ret, ("Volume %s : All process are not "
+                              "online", self.volname))
+        g.log.info("Successfully Verified volume %s processes are online",
+                   self.volname)
+
+        # Start Rebalance
+        g.log.info("Starting Rebalance on the volume")
+        ret, _, err = rebalance_start(self.mnode, self.volname)
+        self.assertEqual(ret, 0, ("Failed to start rebalance on "
+                                  "the volume %s with error %s" %
+                                  (self.volname, err)))
+        g.log.info("Successfully started rebalance on the "
+                   "volume %s", self.volname)
+
+        # Log Rebalance status
+        g.log.info("Log Rebalance status")
+        _, _, _ = rebalance_status(self.mnode, self.volname)
+
+        # Wait for rebalance to complete
+        g.log.info("Waiting for rebalance to complete")
+        ret = wait_for_rebalance_to_complete(self.mnode, self.volname)
+        self.assertTrue(ret, ("Rebalance is not yet complete "
+                              "on the volume %s", self.volname))
+        g.log.info("Rebalance is successfully complete on "
+                   "the volume %s", self.volname)
+
+        # Check Rebalance status after rebalance is complete
+        g.log.info("Checking Rebalance status")
+        ret, _, _ = rebalance_status(self.mnode, self.volname)
+        self.assertEqual(ret, 0, ("Failed to get rebalance status for "
+                                  "the volume %s", self.volname))
+        g.log.info("Successfully got rebalance status of the "
+                   "volume %s", self.volname)
+
+        # Check the self-heal daemon process after adding bricks
+        g.log.info("Starting to get self-heal daemon process on "
+                   "nodes %s", nodes)
+        glustershd_pids_after_expanding = {}
+        ret, pids = get_self_heal_daemon_pid(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process found"))
+        g.log.info("Successfull in getting self-heal daemon process "
+                   "on nodes %s", nodes)
+
+        glustershd_pids_after_expanding = pids
+        g.log.info("Self Heal Daemon Process ID's afetr expanding "
+                   "volume: %s", glustershd_pids_after_expanding)
+
+        self.assertNotEqual(glustershd_pids,
+                            glustershd_pids_after_expanding,
+                            "Self Daemon process is same before and"
+                            " after adding bricks")
+        g.log.info("Self Heal Daemon Process is different before and "
+                   "after adding bricks")
+
+        # get the bricks for the volume after expanding
+        bricks_list_after_expanding = get_all_bricks(self.mnode, self.volname)
+        g.log.info("Brick List after expanding "
+                   "volume: %s", bricks_list_after_expanding)
+
+        # validate the bricks present in volume info
+        # with glustershd server volume file after adding bricks
+        g.log.info("Starting parsing file %s", self.glustershd)
+        ret = do_bricks_exist_in_shd_volfile(self.mnode, self.volname,
+                                             bricks_list_after_expanding)
+
+        self.assertTrue(ret, ("Brick List from volume info is different "
+                              "from glustershd server volume file after "
+                              "expanding bricks. Please check log file "
+                              "for details"))
+        g.log.info("Successfully parsed %s file", self.glustershd)
+
+        # shrink the volume
+        g.log.info("Starting volume shrink")
+        ret = shrink_volume(self.mnode, self.volname)
+        self.assertTrue(ret, ("Failed to shrink the volume on "
+                              "volume %s", self.volname))
+        g.log.info("Shrinking volume is successful on "
+                   "volume %s", self.volname)
+
+        # 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)
+
+        # get the bricks after shrinking the volume
+        bricks_list_after_shrinking = get_all_bricks(self.mnode, self.volname)
+        g.log.info("Brick List after shrinking "
+                   "volume: %s", bricks_list_after_shrinking)
+
+        self.assertEqual(len(bricks_list_after_shrinking), len(bricks_list),
+                         "Brick Count is mismatched after "
+                         "shrinking the volume %s" % self.volname)
+        g.log.info("Brick Count matched before before expanding "
+                   "and after shrinking volume")
+
+        # Verfiy glustershd process releases its parent process
+        ret = is_shd_daemonized(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process found"))
+
+        # check the self-heal daemon process after removing bricks
+        g.log.info("Starting to get self-heal daemon process "
+                   "on nodes %s", nodes)
+        glustershd_pids_after_shrinking = {}
+        ret, pids = get_self_heal_daemon_pid(nodes)
+        glustershd_pids_after_shrinking = pids
+        self.assertNotEqual(glustershd_pids_after_expanding,
+                            glustershd_pids_after_shrinking,
+                            "Self Heal Daemon process is same "
+                            "after adding bricks and shrinking volume")
+        g.log.info("Self Heal Daemon Process is different after adding bricks "
+                   "and shrinking volume")
+
+        # validate bricks present in volume info
+        # with glustershd server volume file after removing bricks
+        g.log.info("Starting parsing file %s", self.glustershd)
+        ret = do_bricks_exist_in_shd_volfile(self.mnode, self.volname,
+                                             bricks_list_after_shrinking)
+        self.assertTrue(ret, ("Brick List from volume info is different "
+                              "from glustershd server volume file after "
+                              "removing bricks. Please check log file "
+                              "for details"))
+        g.log.info("Successfully parsed %s file", self.glustershd)
+
+    def test_glustershd_with_restarting_glusterd(self):
+        """
+        Test Script to verify the self heal daemon process with restarting
+        glusterd and rebooting the server
+
+        * stop all volumes
+        * restart glusterd - should not run self heal daemon process
+        * start replicated involved volumes
+        * single self heal daemon process running
+        * restart glusterd
+        * self heal daemon pid will change
+        * bring down brick and restart glusterd
+        * self heal daemon pid will change and its different from previous
+        * brought up the brick
+
+        """
+        # pylint: disable=too-many-statements
+        nodes = self.volume['servers']
+
+        # stop the volume
+        g.log.info("Stopping the volume %s", self.volname)
+        ret = volume_stop(self.mnode, self.volname)
+        self.assertTrue(ret, ("Failed to stop volume %s" % self.volname))
+        g.log.info("Successfully stopped volume %s", self.volname)
+
+        # check the self heal daemon process after stopping the volume
+        g.log.info("Verifying the self heal daemon process for "
+                   "volume %s", self.volname)
+        ret = are_all_self_heal_daemons_are_online(self.mnode, self.volname)
+        self.assertFalse(ret, ("Self Heal Daemon process is still running "
+                               "even after stopping volume %s" % self.volname))
+        g.log.info("Self Heal Daemon is not running after stopping  "
+                   "volume %s", self.volname)
+
+        # restart glusterd service on all the servers
+        g.log.info("Restarting glusterd on all servers %s", nodes)
+        ret = restart_glusterd(nodes)
+        self.assertTrue(ret, ("Failed to restart glusterd on all nodes %s",
+                              nodes))
+        g.log.info("Successfully restarted glusterd on all nodes %s",
+                   nodes)
+
+        # check the self heal daemon process after restarting glusterd process
+        g.log.info("Starting to get self-heal daemon process on"
+                   " nodes %s", nodes)
+        ret = are_all_self_heal_daemons_are_online(self.mnode, self.volname)
+        self.assertFalse(ret, ("Self Heal Daemon process is running after "
+                               "glusterd restart with volume %s in "
+                               "stop state" % self.volname))
+        g.log.info("Self Heal Daemon is not running after stopping  "
+                   "volume and restarting glusterd %s", self.volname)
+
+        # start the volume
+        g.log.info("Starting the volume %s", self.volname)
+        ret = volume_start(self.mnode, self.volname)
+        self.assertTrue(ret, ("Failed to start volume %s" % self.volname))
+        g.log.info("Volume %s started successfully", self.volname)
+
+        # Verfiy glustershd process releases its parent process
+        g.log.info("Checking whether glustershd process is daemonized or not")
+        ret = is_shd_daemonized(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process found"))
+        g.log.info("Single self heal daemon process on all nodes %s", nodes)
+
+        # get the self heal daemon pids after starting volume
+        g.log.info("Starting to get self-heal daemon process "
+                   "on nodes %s", nodes)
+        ret, pids = get_self_heal_daemon_pid(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process found"))
+        g.log.info("Succesfull in getting self heal daemon pids")
+        glustershd_pids = pids
+
+        # get the bricks for the volume
+        g.log.info("Fetching bricks for the volume : %s", self.volname)
+        bricks_list = get_all_bricks(self.mnode, self.volname)
+        g.log.info("Brick List : %s", bricks_list)
+
+        # validate the bricks present in volume info
+        # with glustershd server volume file
+        g.log.info("Starting parsing file %s on "
+                   "node %s", self.glustershd, self.mnode)
+        ret = do_bricks_exist_in_shd_volfile(self.mnode, self.volname,
+                                             bricks_list)
+        self.assertTrue(ret, ("Brick List from volume info is different from "
+                              "glustershd server volume file. "
+                              "Please check log file for details."))
+        g.log.info("Successfully parsed %s file", self.glustershd)
+
+        # restart glusterd service on all the servers
+        g.log.info("Restarting glusterd on all servers %s", nodes)
+        ret = restart_glusterd(nodes)
+        self.assertTrue(ret, ("Failed to restart glusterd on all nodes %s",
+                              nodes))
+        g.log.info("Successfully restarted glusterd on all nodes %s",
+                   nodes)
+
+        # Verify volume's all process are online for 60 sec
+        g.log.info("Verifying volume's all process are online")
+        ret = wait_for_volume_process_to_be_online(self.mnode, self.volname,
+                                                   60)
+        self.assertTrue(ret, ("Volume %s : All process are not "
+                              "online", self.volname))
+        g.log.info("Successfully Verified volume %s processes are online",
+                   self.volname)
+
+        # Verfiy glustershd process releases its parent process
+        ret = is_shd_daemonized(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process found"))
+
+        # check the self heal daemon process after starting volume and
+        # restarting glusterd process
+        g.log.info("Starting to get self-heal daemon process "
+                   "on nodes %s", nodes)
+        ret, pids = get_self_heal_daemon_pid(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process found"))
+        glustershd_pids_after_glusterd_restart = pids
+
+        self.assertNotEqual(glustershd_pids,
+                            glustershd_pids_after_glusterd_restart,
+                            ("Self Heal Daemon pids are same after "
+                             "restarting glusterd process"))
+        g.log.info("Self Heal Daemon process are different before and "
+                   "after restarting glusterd process")
+
+        # select bricks to bring offline
+        bricks_to_bring_offline_dict = (select_bricks_to_bring_offline(
+            self.mnode, self.volname))
+        bricks_to_bring_offline = filter(None, (
+            bricks_to_bring_offline_dict['hot_tier_bricks'] +
+            bricks_to_bring_offline_dict['cold_tier_bricks'] +
+            bricks_to_bring_offline_dict['volume_bricks']))
+
+        # bring bricks offline
+        g.log.info("Going to bring down the brick process "
+                   "for %s", bricks_to_bring_offline)
+        ret = bring_bricks_offline(self.volname, bricks_to_bring_offline)
+        self.assertTrue(ret, ("Failed to bring down the bricks. Please "
+                              "check the log file for more details."))
+        g.log.info("Brought down the brick process "
+                   "for %s succesfully", bricks_to_bring_offline)
+
+        # restart glusterd after brought down the brick
+        g.log.info("Restart glusterd on all servers %s", nodes)
+        ret = restart_glusterd(nodes)
+        self.assertTrue(ret, ("Failed to restart glusterd on all nodes %s",
+                              nodes))
+        g.log.info("Successfully restarted glusterd on all nodes %s",
+                   nodes)
+
+        # Verify volume's all process are online for 60 sec
+        g.log.info("Verifying volume's all process are online")
+        ret = wait_for_volume_process_to_be_online(self.mnode, self.volname,
+                                                   60)
+        self.assertTrue(ret, ("Volume %s : All process are not "
+                              "online", self.volname))
+        g.log.info("Successfully Verified volume %s processes are online",
+                   self.volname)
+
+        # Verfiy glustershd process releases its parent process
+        ret = is_shd_daemonized(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process found"))
+
+        # check the self heal daemon process after killing brick and
+        # restarting glusterd process
+        g.log.info("Starting to get self-heal daemon process "
+                   "on nodes %s", nodes)
+        ret, pids = get_self_heal_daemon_pid(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process found"))
+        glustershd_pids_after_killing_brick = pids
+
+        self.assertNotEqual(glustershd_pids_after_glusterd_restart,
+                            glustershd_pids_after_killing_brick,
+                            ("Self Heal Daemon process are same from before "
+                             "killing the brick,restarting glusterd process"))
+        g.log.info("Self Heal Daemon process are different after killing the "
+                   "brick, restarting the glusterd process")
+
+        # brought the brick online
+        g.log.info("bringing up the bricks : %s online",
+                   bricks_to_bring_offline)
+        ret = bring_bricks_online(self.mnode, self.volname,
+                                  bricks_to_bring_offline)
+        self.assertTrue(ret, ("Failed to brought the bricks online"))
+        g.log.info("Successfully brought the bricks online")
+
+        # check all bricks are online
+        g.log.info("Verifying all bricka are online or not.....")
+        ret = are_bricks_online(self.mnode, self.volname,
+                                bricks_to_bring_offline)
+        self.assertTrue(ret, ("Not all bricks are online"))
+        g.log.info("All bricks are online.")
+
+
+@runs_on([['replicated', 'distributed-replicated'],
+          ['glusterfs', 'nfs', 'cifs']])
+class ImpactOfReplaceBrickForGlustershdTests(GlusterBaseClass):
+    """
+    ClientSideQuorumTests contains tests which verifies the
+    client side quorum Test Cases
+    """
+
+    @classmethod
+    def setUpClass(cls):
+        # Calling GlusterBaseClass setUpClass
+        GlusterBaseClass.setUpClass.im_func(cls)
+
+        # Override Volumes
+        if cls.volume_type == "distributed-replicated":
+            # Define distributed-replicated volume
+            cls.volume['voltype'] = {
+                'type': 'distributed-replicated',
+                'dist_count': 2,
+                'replica_count': 3,
+                'arbiter_count': 1,
+                'transport': 'tcp'}
+
+        cls.glustershd = "/var/lib/glusterd/glustershd/glustershd-server.vol"
+
+    def setUp(self):
+        """
+        setUp method for every test
+        """
+
+        # calling GlusterBaseClass setUp
+        GlusterBaseClass.setUp.im_func(self)
+
+        self.all_mounts_procs = []
+        self.io_validation_complete = False
+
+        # Setup Volume and Mount Volume
+        g.log.info("Starting to Setup Volume %s", self.volname)
+        ret = self.setup_volume_and_mount_volume(self.mounts,
+                                                 volume_create_force=False)
+        if not ret:
+            raise ExecutionError("Failed to Setup_Volume and Mount_Volume")
+        g.log.info("Successful in Setup Volume and Mount Volume")
+
+    def tearDown(self):
+        """
+        If test method failed before validating IO, tearDown waits for the
+        IO's to complete and checks for the IO exit status
+
+        Cleanup and umount volume
+        """
+        # Cleanup and umount volume
+        g.log.info("Starting to Unmount Volume and Cleanup Volume")
+        ret = self.unmount_volume_and_cleanup_volume(mounts=self.mounts)
+        if not ret:
+            raise ExecutionError("Failed to umount the vol & cleanup Volume")
+        g.log.info("Successful in umounting the volume and Cleanup")
+
+        # Calling GlusterBaseClass teardown
+        GlusterBaseClass.tearDown.im_func(self)
+
+    def test_impact_of_replace_brick_for_glustershd(self):
+        nodes = self.volume['servers']
+
+        # check the self-heal daemon process
+        g.log.info("Starting to get self-heal daemon process on "
+                   "nodes %s", nodes)
+        ret, pids = get_self_heal_daemon_pid(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process "
+                              "found : %s" % pids))
+        g.log.info("Successful in getting Single self heal daemon process"
+                   " on all nodes %s", nodes)
+        glustershd_pids = pids
+
+        # get the bricks for the volume
+        g.log.info("Fetching bricks for the volume : %s", self.volname)
+        bricks_list = get_all_bricks(self.mnode, self.volname)
+        g.log.info("Brick List : %s", bricks_list)
+
+        # validate the bricks present in volume info with
+        # glustershd server volume file
+        g.log.info("Starting parsing file %s on "
+                   "node %s", self.glustershd, self.mnode)
+        ret = do_bricks_exist_in_shd_volfile(self.mnode, self.volname,
+                                             bricks_list)
+        self.assertTrue(ret, ("Brick List from volume info is different "
+                              "from glustershd server volume file. "
+                              "Please check log file for details"))
+        g.log.info("Successfully parsed %s file", self.glustershd)
+
+        # replace brick
+        brick_to_replace = bricks_list[-1]
+        new_brick = brick_to_replace + 'new'
+        g.log.info("Replacing the brick %s for the volume : %s",
+                   brick_to_replace, self.volname)
+        ret, _, err = replace_brick(self.mnode, self.volname,
+                                    brick_to_replace, new_brick)
+        self.assertFalse(ret, err)
+        g.log.info('Replaced brick %s to %s successfully',
+                   brick_to_replace, new_brick)
+
+        # check bricks
+        bricks_list = get_all_bricks(self.mnode, self.volname)
+        self.assertEqual(bricks_list[-1], new_brick, 'Replaced brick and '
+                                                     'new brick are not equal')
+
+        # Verify volume's all process are online for 60 sec
+        g.log.info("Verifying volume's all process are online")
+        ret = wait_for_volume_process_to_be_online(self.mnode, self.volname,
+                                                   timeout=60)
+        self.assertTrue(ret, ("Volume %s : All process are not "
+                              "online", self.volname))
+        g.log.info("Successfully Verified volume %s processes are online",
+                   self.volname)
+
+        # Verify glustershd process releases its parent process
+        ret = is_shd_daemonized(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process found"))
+
+        # check the self-heal daemon process
+        g.log.info("Starting to get self-heal daemon process on "
+                   "nodes %s", nodes)
+        ret, pids = get_self_heal_daemon_pid(nodes)
+        self.assertTrue(ret, ("Either No self heal daemon process found or "
+                              "more than One self heal daemon process "
+                              "found : %s" % pids))
+        g.log.info("Successful in getting Single self heal daemon process"
+                   " on all nodes %s", nodes)
+        glustershd_pids_after_replacement = pids
+
+        # Compare pids before and after replacing
+        self.assertNotEqual(glustershd_pids,
+                            glustershd_pids_after_replacement,
+                            "Self Daemon process is same before and"
+                            " after replacing bricks")
+        g.log.info("Self Heal Daemon Process is different before and "
+                   "after replacing bricks")
+
+        # get the bricks for the volume after replacing
+        bricks_list_after_replacing = get_all_bricks(self.mnode, self.volname)
+        g.log.info("Brick List after expanding "
+                   "volume: %s", bricks_list_after_replacing)
+
+        # validate the bricks present in volume info
+        # with glustershd server volume file after replacing bricks
+        g.log.info("Starting parsing file %s", self.glustershd)
+        ret = do_bricks_exist_in_shd_volfile(self.mnode, self.volname,
+                                             bricks_list_after_replacing)
+
+        self.assertTrue(ret, ("Brick List from volume info is different "
+                              "from glustershd server volume file after "
+                              "replacing bricks. Please check log file "
+                              "for details"))
+        g.log.info("Successfully parsed %s file", self.glustershd)