diff options
Diffstat (limited to 'nova/scheduler/filter_scheduler.py')
| -rw-r--r-- | nova/scheduler/filter_scheduler.py | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/nova/scheduler/filter_scheduler.py b/nova/scheduler/filter_scheduler.py index 08cb6a20e..4e5662e65 100644 --- a/nova/scheduler/filter_scheduler.py +++ b/nova/scheduler/filter_scheduler.py @@ -24,6 +24,8 @@ import random from oslo.config import cfg from nova.compute import flavors +from nova.compute import rpcapi as compute_rpcapi +from nova import db from nova import exception from nova.openstack.common import log as logging from nova.openstack.common.notifier import api as notifier @@ -54,6 +56,7 @@ class FilterScheduler(driver.Scheduler): def __init__(self, *args, **kwargs): super(FilterScheduler, self).__init__(*args, **kwargs) self.options = scheduler_options.SchedulerOptions() + self.compute_rpcapi = compute_rpcapi.ComputeAPI() def schedule_run_instance(self, context, request_spec, admin_password, injected_files, @@ -377,6 +380,17 @@ class FilterScheduler(driver.Scheduler): filter_properties['group_hosts'].append(chosen_host.obj.host) return selected_hosts + def _get_compute_info(self, context, dest): + """Get compute node's information + + :param context: security context + :param dest: hostname (must be compute node) + :return: dict of compute node information + + """ + service_ref = db.service_get_by_compute_host(context, dest) + return service_ref['compute_node'][0] + def _assert_compute_node_has_enough_memory(self, context, instance_ref, dest): """Checks if destination host has enough memory for live migration. |