summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2016-09-13 19:21:14 +0000
committerGerrit Code Review <review@openstack.org>2016-09-13 19:21:14 +0000
commit96661bafae09289b4310502a0936194b66f4e8a6 (patch)
treef64b4bf2503d0b612db42486da6d7b9ed6dbfdba
parent1ef945d6fa8012486b625a98d3baab8db2b4ca12 (diff)
parent9979d48442ae6dd1cddfcb0f1225c91b3d5bcacb (diff)
downloadtrove-96661bafae09289b4310502a0936194b66f4e8a6.tar.gz
Merge "Tests verify cluster data via every node"
-rw-r--r--trove/tests/scenario/runners/cluster_actions_runners.py18
1 files changed, 11 insertions, 7 deletions
diff --git a/trove/tests/scenario/runners/cluster_actions_runners.py b/trove/tests/scenario/runners/cluster_actions_runners.py
index 52abd8f9..5c08d846 100644
--- a/trove/tests/scenario/runners/cluster_actions_runners.py
+++ b/trove/tests/scenario/runners/cluster_actions_runners.py
@@ -172,12 +172,14 @@ class ClusterActionsRunner(TestRunner):
instance['id'])
self.assert_true(root_enabled_test.rootEnabled)
- ping_response = self.test_helper.ping(
- cluster.ip[0],
- username=self.current_root_creds[0],
- password=self.current_root_creds[1]
- )
- self.assert_true(ping_response)
+ for ip in cluster.ip:
+ self.report.log("Pinging cluster as superuser via node: %s" % ip)
+ ping_response = self.test_helper.ping(
+ ip,
+ username=self.current_root_creds[0],
+ password=self.current_root_creds[1]
+ )
+ self.assert_true(ping_response)
def run_add_initial_cluster_data(self, data_type=DataType.tiny):
self.assert_add_cluster_data(data_type, self.cluster_id)
@@ -197,7 +199,9 @@ class ClusterActionsRunner(TestRunner):
def assert_verify_cluster_data(self, data_type, cluster_id):
cluster = self.auth_client.clusters.get(cluster_id)
- self.test_helper.verify_data(data_type, cluster.ip[0])
+ for ip in cluster.ip:
+ self.report.log("Verifying cluster data via node: %s" % ip)
+ self.test_helper.verify_data(data_type, ip)
def run_remove_initial_cluster_data(self, data_type=DataType.tiny):
self.assert_remove_cluster_data(data_type, self.cluster_id)