Merge "CNS: CNS-542 Restart gluster-block provisioner pod"

1 files changed, 45 insertions, 0 deletions

diff --git a/tests/functional/common/gluster_block/test_restart_gluster_block.py b/tests/functional/common/gluster_block/test_restart_gluster_block.py
new file mode 100644
index 00000000..c46460a0
--- /dev/null
+++ b/tests/functional/common/gluster_block/test_restart_gluster_block.py
@@ -0,0 +1,45 @@
+from cnslibs.common.heketi_libs import HeketiClientSetupBaseClass
+from cnslibs.common.heketi_ops import (
+    heketi_blockvolume_create,
+    heketi_blockvolume_delete)
+from cnslibs.common.openshift_ops import (
+    get_pod_name_from_dc,
+    oc_delete,
+    wait_for_pod_be_ready,
+    wait_for_resource_absence)
+
+
+class TestRestartGlusterBlockPod(HeketiClientSetupBaseClass):
+
+    def test_restart_gluster_block_provisioner_pod(self):
+        # CNS-542 - Restart gluster-block provisioner pod
+
+        # create heketi block volume
+        vol_info = heketi_blockvolume_create(self.heketi_client_node,
+                                             self.heketi_server_url,
+                                             size=5, json=True)
+        self.assertTrue(vol_info, "Failed to create heketi block"
+                        "volume of size 5")
+        self.addCleanup(heketi_blockvolume_delete, self.heketi_client_node,
+                        self.heketi_server_url, vol_info['id'])
+
+        dc_name = ("glusterblock-%s-provisioner-dc"
+                   % self.cns_project_name)
+        # restart gluster-block-provisioner-pod
+        pod_name = get_pod_name_from_dc(self.ocp_master_node, dc_name)
+        oc_delete(self.ocp_master_node, 'pod', pod_name)
+        wait_for_resource_absence(self.ocp_master_node, 'pod', pod_name)
+
+        # new gluster-pod name
+        pod_name = get_pod_name_from_dc(self.ocp_master_node, dc_name)
+        wait_for_pod_be_ready(self.ocp_master_node, pod_name)
+
+        # create new heketi block volume
+        vol_info = heketi_blockvolume_create(self.heketi_client_node,
+                                             self.heketi_server_url,
+                                             size=2, json=True)
+        self.assertTrue(vol_info, "Failed to create heketi block"
+                        "volume of size 2")
+        heketi_blockvolume_delete(self.heketi_client_node,
+                                  self.heketi_server_url,
+                                  vol_info['id'])