1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
from cnslibs.common.heketi_libs import HeketiBaseClass
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(HeketiBaseClass):
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'])
# restart gluster-block-provisioner-pod
dc_name = "glusterblock-%s-provisioner-dc" % self.storage_project_name
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'])
|