time.sleep(5)
log.info('ceph-fuse is mounted on %s', mountpoint)
-def reconnect(ctx, timeout):
+def reconnect(ctx, timeout, remotes=None):
"""
Connect to all the machines in ctx.cluster.
log.info('Re-opening connections...')
starttime = time.time()
- for r in ctx.cluster.remotes.iterkeys():
+ if remotes:
+ need_reconnect = remotes
+ else:
+ need_reconnect = ctx.cluster.remotes.keys()
+
+ for r in need_reconnect:
r.ssh.close()
- need_reconnect = ctx.cluster.remotes.keys()
while need_reconnect:
for remote in need_reconnect:
try:
remote.console.power_on()
if not remote.console.check_status(300):
raise Exception('Failed to revive osd.{o} via ipmi'.format(o=osd))
- teuthology.reconnect(self.ctx, 60)
+ teuthology.reconnect(self.ctx, 60, [remote])
ceph_task.mount_osd_data(self.ctx, remote, osd)
ceph_task.make_admin_daemon_dir(self.ctx, remote)
self.ctx.daemons.get_daemon('osd', osd).reset()