RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-29 14:34:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make reconnect() use Remote.reconnect()

Browse Source 
Signed-off-by: Zack Cerza <zack.cerza@inktank.com>
This commit is contained in:
Zack Cerza 2014-02-12 11:08:25 -06:00
parent 61e9ac4db5
commit e3f336d15b
1 changed files with 5 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
teuthology/misc.py
View File

@ -938,23 +938,14 @@ def reconnect(ctx, timeout, remotes=None):
else:
need_reconnect = ctx.cluster.remotes.keys()
for r in need_reconnect:
r.ssh.close()
while need_reconnect:
for remote in need_reconnect:
try:
log.info('trying to connect to %s', remote.name)
key = ctx.config['targets'][remote.name]
from .orchestra import connection
remote.ssh = connection.connect(
user_at_host=remote.name,
host_key=key,
keep_alive=True,
)
except Exception:
log.info('trying to connect to %s', remote.name)
success = remote.reconnect()
if not success:
if time.time() - starttime > timeout:
raise
raise RuntimeError("Could not reconnect to %s" %
remote.name)
else:
need_reconnect.remove(remote)