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'})