Loading cloudcontrol/server/jobs/migration.py +1 −14 Original line number Diff line number Diff line Loading @@ -205,20 +205,7 @@ class MigrationJob(Job): watcher.register(source.conn, 'vol_export', pool, name, dest.ip, xferprop['port']) watcher.register(dest.conn, 'vol_import_wait', xferprop['id']) # Loop to poll status while job is running job_running = True while job_running: # Timeout to get transfered bytes and update status msgs = watcher.wait(timeout=10) if not msgs: _, percent = dest.proxy.vol_transfer_status(xferprop['id']) self.report('copy %s/%s: %s%% done' % (pool, name, percent)) else: job_running = False self._func_cancel_xfer = None # Wait a little more for the second response if needed: msgs += watcher.wait(timeout=10) msgs = watcher.wait() # Compare checksum of two answers: checksums = [] Loading Loading
cloudcontrol/server/jobs/migration.py +1 −14 Original line number Diff line number Diff line Loading @@ -205,20 +205,7 @@ class MigrationJob(Job): watcher.register(source.conn, 'vol_export', pool, name, dest.ip, xferprop['port']) watcher.register(dest.conn, 'vol_import_wait', xferprop['id']) # Loop to poll status while job is running job_running = True while job_running: # Timeout to get transfered bytes and update status msgs = watcher.wait(timeout=10) if not msgs: _, percent = dest.proxy.vol_transfer_status(xferprop['id']) self.report('copy %s/%s: %s%% done' % (pool, name, percent)) else: job_running = False self._func_cancel_xfer = None # Wait a little more for the second response if needed: msgs += watcher.wait(timeout=10) msgs = watcher.wait() # Compare checksum of two answers: checksums = [] Loading