check_is_all_vms_migrated()
1
def check_is_all_vms_migrated(self, context):
suspended_nodes = utils.get_compute_node_stats(
context,
read_suspended='suspending')
for node in suspended_nodes:
LOG.debug('Suspending host found: %s' % node)
active_migrations = objects.migration.MigrationList\
.get_in_progress_by_host_and_node(context,
node['hypervisor_hostname'],
node['hypervisor_hostname'])
if active_migrations:
LOG.debug('There is some migrations that are in active state')
for migration in active_migrations:
if migration['status'] == 'finished':
self.minimizeSD.confirm_migration(
context,
migration['instace_uuid'])
return
else:
if self._host_is_empty(context, node['hypervisor_hostname']):
mac = self.compute_rpc.prepare_host_for_suspending(
context, node['hypervisor_hostname'])
db.compute_node_update(context, node['compute_id'],
{'mac_to_wake': mac})
self.compute_rpc.suspend_host(context,
node['hypervisor_hostname'])
db.compute_node_update(context, node['compute_id'],
{'suspend_state': 'suspended'})
else:
if not self.minimizeSD.migrate_all_vms_from_host(
context,
node['hypervisor_hostname']):
db.compute_node_update(context, node['compute_id'],
{'suspend_state':
'active'})
Python
INFO