Skip to content
Snippets Groups Projects
Commit d3833ebd authored by Michael Hanselmann's avatar Michael Hanselmann
Browse files

bootstrap: Convert to utils.Retry


Signed-off-by: default avatarMichael Hanselmann <hansmi@google.com>
Reviewed-by: default avatarIustin Pop <iustin@google.com>
parent def8e2f6
No related branches found
No related tags found
No related merge requests found
......@@ -134,18 +134,16 @@ def _InitGanetiServerSetup(master_name):
(result.cmd, result.exit_code, result.output))
# Wait for node daemon to become responsive
end_time = time.time() + 10.0
while True:
def _CheckNodeDaemon():
result = rpc.RpcRunner.call_version([master_name])[master_name]
if not result.fail_msg:
break
if time.time() > end_time:
raise errors.OpExecError("Node daemon didn't answer queries within"
" 10 seconds")
time.sleep(1)
if result.fail_msg:
raise utils.RetryAgain()
try:
utils.Retry(_CheckNodeDaemon, 1.0, 10.0)
except utils.RetryTimeout:
raise errors.OpExecError("Node daemon didn't answer queries within"
" 10 seconds")
def InitCluster(cluster_name, mac_prefix,
master_netdev, file_storage_dir, candidate_pool_size,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment