Revision 61643226 lib/cmdlib.py
| b/lib/cmdlib.py | ||
|---|---|---|
| 7027 | 7027 |
""" |
| 7028 | 7028 |
|
| 7029 | 7029 |
# Constants |
| 7030 |
_MIGRATION_POLL_INTERVAL = 0.5 |
|
| 7030 |
_MIGRATION_POLL_INTERVAL = 1 # seconds |
|
| 7031 |
_MIGRATION_FEEDBACK_INTERVAL = 10 # seconds |
|
| 7031 | 7032 |
|
| 7032 | 7033 |
def __init__(self, lu, instance_name, cleanup=False, |
| 7033 | 7034 |
failover=False, fallback=False, |
| ... | ... | |
| 7445 | 7446 |
(instance.name, msg)) |
| 7446 | 7447 |
|
| 7447 | 7448 |
self.feedback_fn("* starting memory transfer")
|
| 7449 |
last_feedback = time.time() |
|
| 7448 | 7450 |
while True: |
| 7449 | 7451 |
result = self.rpc.call_instance_get_migration_status(source_node, |
| 7450 | 7452 |
instance) |
| ... | ... | |
| 7463 | 7465 |
self.feedback_fn("* memory transfer complete")
|
| 7464 | 7466 |
break |
| 7465 | 7467 |
|
| 7468 |
if (utils.TimeoutExpired(last_feedback, |
|
| 7469 |
self._MIGRATION_FEEDBACK_INTERVAL) and |
|
| 7470 |
ms.transferred_ram is not None): |
|
| 7471 |
mem_progress = 100 * float(ms.transferred_ram) / float(ms.total_ram) |
|
| 7472 |
self.feedback_fn("* memory transfer progress: %.2f %%" % mem_progress)
|
|
| 7473 |
last_feedback = time.time() |
|
| 7474 |
|
|
| 7466 | 7475 |
time.sleep(self._MIGRATION_POLL_INTERVAL) |
| 7467 | 7476 |
|
| 7468 | 7477 |
result = self.rpc.call_instance_finalize_migration_src(source_node, |
Also available in: Unified diff