return True
# probing nodes
- def check_nodes_ping(self, timeout_seconds=240, period_seconds=10):
+ def check_nodes_ping(self, timeout_seconds=30, period_seconds=10):
class CompleterTaskPingNode(CompleterTask):
def __init__ (self, hostname):
self.hostname=hostname
local_key = "keys/key_admin.rsa"
utils.header("checking ssh access to nodes (expected in %s mode)"%message)
node_infos = self.all_node_infos()
- tasks = [ CompleterTaskNodeSsh (nodename, qemuname, local_key, boot_state=message) \
+ tasks = [ CompleterTaskNodeSsh (nodename, qemuname, local_key,
+ boot_state=message, dry_run=self.options.dry_run) \
for (nodename,qemuname) in node_infos ]
return Completer (tasks, message=completer_message).run (timeout, graceout, period)
for spec in specs:
port = spec['port']
# server side
- s_test_sliver = self.locate_sliver_obj_cross (spec['server_node'],spec['server_slice'],other_plcs)
- if not s_test_sliver.run_tcp_server(port,timeout=20):
- overall=False
+ # the issue here is that we have the server run in background
+ # and so we have no clue if it took off properly or not
+ # looks like in some cases it does not
+ s_test_sliver = self.locate_sliver_obj_cross (spec['server_node'], spec['server_slice'], other_plcs)
+ if not s_test_sliver.run_tcp_server(port, timeout=20):
+ overall = False
break
# idem for the client side
- c_test_sliver = self.locate_sliver_obj_cross (spec['client_node'],spec['client_slice'],other_plcs)
+ c_test_sliver = self.locate_sliver_obj_cross (spec['client_node'], spec['client_slice'], other_plcs)
# use nodename from locatesd sliver, unless 'client_connect' is set
if 'client_connect' in spec:
destination = spec['client_connect']
else:
- destination=s_test_sliver.test_node.name()
- if not c_test_sliver.run_tcp_client(destination,port):
- overall=False
+ destination = s_test_sliver.test_node.name()
+ if not c_test_sliver.run_tcp_client(destination, port):
+ overall = False
return overall
# painfully enough, we need to allow for some time as netflow might show up last