[Test+Lib] Add tests to check self heal

Test scenarios added:
1. Test to check entry self heal.
2. Test to check meta data self heal.
3. Test self heal when files are removed and dirs
   created with the same name.

Additional libraries added:
1. group_del(): Deletes groups created
2. enable_granular_heal(): Enables granular heal
3. disable_granular_heal(): Disables granular heal

Change-Id: Iffa9a100fddaecae99c384afe3aaeaf13dd37e0d
Signed-off-by: kshithijiyer <kshithij.ki@gmail.com>

2 files changed, 64 insertions, 2 deletions

diff --git a/glustolibs-gluster/glustolibs/gluster/heal_libs.py b/glustolibs-gluster/glustolibs/gluster/heal_libs.py
index 91d720e41..4a551cd48 100755
--- a/glustolibs-gluster/glustolibs/gluster/heal_libs.py
+++ b/glustolibs-gluster/glustolibs/gluster/heal_libs.py
@@ -1,5 +1,5 @@
 #!/usr/bin/env python
-#  Copyright (C) 2016-2020 Red Hat, Inc. <http://www.redhat.com>
+#  Copyright (C) 2016-2021 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
@@ -551,3 +551,41 @@ def is_shd_daemon_running(mnode, node, volname):
         return True
     except KeyError:
         return False
+
+
+def enable_granular_heal(mnode, volname):
+    """Enable granular heal on a given volume
+
+    Args:
+     mnode(str): Node on which command has to be exectued
+     volname(str): Name of the volume on which granular heal is to be enabled
+
+    Returns:
+     bool: True if granular heal is enabled successfully else False
+    """
+    cmd = "gluster volume heal {} granular-entry-heal enable".format(volname)
+    ret, _, _ = g.run(mnode, cmd)
+    if ret:
+        g.log.error('Unable to enable granular-entry-heal on volume %s',
+                    volname)
+        return False
+    return True
+
+
+def disable_granular_heal(mnode, volname):
+    """Diable granular heal on a given volume
+
+    Args:
+     mnode(str): Node on which command will be exectued
+     volname(str): Name of the volume on which granular heal is to be disabled
+
+    Returns:
+     bool: True if granular heal is disabled successfully else False
+    """
+    cmd = "gluster volume heal {} granular-entry-heal disable".format(volname)
+    ret, _, _ = g.run(mnode, cmd)
+    if ret:
+        g.log.error('Unable to disable granular-entry-heal on volume %s',
+                    volname)
+        return False
+    return True
diff --git a/glustolibs-gluster/glustolibs/gluster/lib_utils.py b/glustolibs-gluster/glustolibs/gluster/lib_utils.py
index aa919e344..b04976b1c 100755
--- a/glustolibs-gluster/glustolibs/gluster/lib_utils.py
+++ b/glustolibs-gluster/glustolibs/gluster/lib_utils.py
@@ -1,5 +1,5 @@
 #!/usr/bin/env python
-#  Copyright (C) 2015-2020  Red Hat, Inc. <http://www.redhat.com>
+#  Copyright (C) 2015-2021  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
@@ -1016,6 +1016,30 @@ def group_add(servers, groupname):
     return True
 
 
+def group_del(servers, groupname):
+    """
+    Deletes a group in all the servers.
+
+    Args:
+        servers(list|str): Nodes on which cmd is to be executed.
+        groupname(str): Name of the group to be removed.
+
+    Return always True
+    """
+    if not isinstance(servers, list):
+        servers = [servers]
+
+    cmd = "groupdel %s" % groupname
+    results = g.run_parallel(servers, cmd)
+
+    for server, ret_value in list(results.items()):
+        retcode, _, err = ret_value
+        if retcode != 0 and "does not exist" in err:
+            g.log.error("Group %s on server %s already removed",
+                        groupname, server)
+    return True
+
+
 def ssh_keygen(mnode):
     """
     Creates a pair of ssh private and public key if not present