summaryrefslogtreecommitdiffstats
path: root/tests/functional/heketi/test_node_info.py
diff options
context:
space:
mode:
authorValerii Ponomarov <vponomar@redhat.com>2019-03-06 16:15:25 +0530
committerValerii Ponomarov <vponomar@redhat.com>2019-03-06 16:28:52 +0530
commit3de9a4ea9623cd3a928ce30cbae3364beeac5edb (patch)
tree1746204da26e4648d20b656b2421ef42c78044a4 /tests/functional/heketi/test_node_info.py
parent3d4ab96edfa54ec7f2dd9682d1ee3e3077dfa79c (diff)
Reorder test files removing redundant dirs
Move all the files of 'tests/functional/common/' dir to the 'tests/functional/', because 'common' is the only dir there, which doesn't really makes sense. Do the same about 'tests/functional/common/heketi/heketi_tests' and 'tests/functional/common/heketi/'. Change-Id: I1fa55e2e7bf09e9b9115629b06e1fd160e291a36
Diffstat (limited to 'tests/functional/heketi/test_node_info.py')
-rw-r--r--tests/functional/heketi/test_node_info.py80
1 files changed, 80 insertions, 0 deletions
diff --git a/tests/functional/heketi/test_node_info.py b/tests/functional/heketi/test_node_info.py
new file mode 100644
index 00000000..ad60b844
--- /dev/null
+++ b/tests/functional/heketi/test_node_info.py
@@ -0,0 +1,80 @@
+from glusto.core import Glusto as g
+from glustolibs.gluster.exceptions import ExecutionError
+from glustolibs.gluster.peer_ops import get_pool_list
+
+from cnslibs.common.baseclass import BaseClass
+from cnslibs.common import heketi_ops, podcmd
+
+
+class TestHeketiVolume(BaseClass):
+ """
+ Class to test heketi volume create
+ """
+
+ @podcmd.GlustoPod()
+ def test_to_get_list_of_nodes(self):
+ """
+ Listing all nodes and compare the
+ node listed in previous step
+ """
+
+ # List all list
+ ip = []
+ g.log.info("Listing the node id")
+ heketi_node_id_list = heketi_ops.heketi_node_list(
+ self.heketi_client_node, self.heketi_server_url)
+
+ g.log.info("Successfully listed the node")
+
+ if (len(heketi_node_id_list) == 0):
+ raise ExecutionError("Node list empty")
+
+ for node_id in heketi_node_id_list:
+ g.log.info("Retrieve the node info")
+ node_info = heketi_ops.heketi_node_info(
+ self.heketi_client_node, self.heketi_server_url,
+ node_id, json=True)
+ self.assertTrue(node_info, ("Failed to "
+ "retrieve the node info"))
+ g.log.info("Successfully retrieved the node info %s" % node_id)
+ ip.append(node_info["hostnames"]["storage"])
+
+ # Compare the node listed in previous step
+ hostname = []
+
+ g.log.info("Get the pool list")
+ list_of_pools = get_pool_list('auto_get_gluster_endpoint')
+ self.assertTrue(list_of_pools, ("Failed to get the "
+ "pool list from gluster pods/nodes"))
+ g.log.info("Successfully got the pool list from gluster pods/nodes")
+ for pool in list_of_pools:
+ hostname.append(pool["hostname"])
+
+ if (len(heketi_node_id_list) != len(list_of_pools)):
+ raise ExecutionError(
+ "Heketi volume list %s is not equal "
+ "to gluster volume list %s" % ((ip), (hostname)))
+ g.log.info("The node IP's from node info and list"
+ " is : %s/n and pool list from gluster"
+ " pods/nodes is %s" % ((ip), (hostname)))
+
+ def test_to_retrieve_node_info(self):
+ """
+ List and retrieve node related info
+ """
+
+ # List all list
+ g.log.info("Listing the node id")
+ heketi_node_id_list = heketi_ops.heketi_node_list(
+ self.heketi_client_node, self.heketi_server_url)
+ self.assertTrue(heketi_node_id_list, ("Node Id list is empty."))
+ g.log.info("Successfully listed the node")
+
+ for node_id in heketi_node_id_list:
+ g.log.info("Retrieve the node info")
+ node_info = heketi_ops.heketi_node_info(
+ self.heketi_client_node, self.heketi_server_url,
+ node_id, json=True)
+ self.assertTrue(node_info, ("Failed to "
+ "retrieve the node info"))
+ g.log.info("Successfully retrieved the node info %s" % node_id)