Merge "Enforce fuel_slave nodes to get slaves"

This commit is contained in:
Jenkins 2016-10-10 12:22:42 +00:00 committed by Gerrit Code Review
commit c1f8071126
1 changed files with 16 additions and 10 deletions

View File

@ -181,9 +181,12 @@ class NetworkOutage(TestBasic):
logger.debug(benchmark_results[tag].show())
self.show_step(5)
nodes = [node for node in self.env.d_env.get_nodes()
if node.driver.node_active(node)]
for interface in nodes[1].interfaces:
nodes = [
node for node in sorted(
self.env.d_env.get_nodes(role='fuel_slave'),
key=lambda x: x.name)
if node.driver.node_active(node)]
for interface in nodes[0].interfaces:
if interface.is_blocked:
raise Exception('Interface {0} is blocked'.format(interface))
else:
@ -193,7 +196,7 @@ class NetworkOutage(TestBasic):
time.sleep(60 * 5)
self.show_step(7)
for interface in nodes[1].interfaces:
for interface in nodes[0].interfaces:
if interface.network.is_blocked:
interface.network.unblock()
else:
@ -201,7 +204,7 @@ class NetworkOutage(TestBasic):
'Interface {0} was not blocked'.format(interface))
self.show_step(8)
self.fuel_web.wait_nodes_get_online_state(nodes[1:])
self.fuel_web.wait_nodes_get_online_state(nodes)
self.show_step(9)
self.fuel_web.verify_network(cluster_id)
@ -363,9 +366,12 @@ class NetworkOutage(TestBasic):
logger.debug(benchmark_results[tag].show())
self.show_step(5)
nodes = [node for node in self.env.d_env.get_nodes()
if node.driver.node_active(node)]
for interface in nodes[1].interfaces:
nodes = [
node for node in sorted(
self.env.d_env.get_nodes(role='fuel_slave'),
key=lambda x: x.name)
if node.driver.node_active(node)]
for interface in nodes[0].interfaces:
if interface.is_blocked:
raise Exception('Interface {0} is blocked'.format(interface))
else:
@ -374,7 +380,7 @@ class NetworkOutage(TestBasic):
self.show_step(6)
time.sleep(60 * 5)
self.show_step(7)
for interface in nodes[1].interfaces:
for interface in nodes[0].interfaces:
if interface.network.is_blocked:
interface.network.unblock()
else:
@ -382,7 +388,7 @@ class NetworkOutage(TestBasic):
'Interface {0} was not blocked'.format(interface))
self.show_step(8)
self.fuel_web.wait_nodes_get_online_state(nodes[1:])
self.fuel_web.wait_nodes_get_online_state(nodes)
self.show_step(9)
self.fuel_web.verify_network(cluster_id)