From 093bdd6edff7ec391145018a0d3ce8e9dc1f84ff Mon Sep 17 00:00:00 2001 From: Russell Bryant Date: Tue, 29 May 2012 18:39:07 -0400 Subject: Add pre_live_migration() to the compute rpcapi. Part of bug 1006467. This patch adds pre_live_migration() to the compute rpcapi. It is used by the compute manager. Change-Id: I70fb66ad194837faa1139e644888c4a7c7a5a0a6 --- nova/compute/manager.py | 8 ++------ nova/compute/rpcapi.py | 6 ++++++ 2 files changed, 8 insertions(+), 6 deletions(-) (limited to 'nova/compute') diff --git a/nova/compute/manager.py b/nova/compute/manager.py index 95c5bd763..2ac5a7eaf 100644 --- a/nova/compute/manager.py +++ b/nova/compute/manager.py @@ -2027,12 +2027,8 @@ class ComputeManager(manager.SchedulerDependentManager): else: disk = None - rpc.call(context, - rpc.queue_get_for(context, FLAGS.compute_topic, dest), - {'method': 'pre_live_migration', - 'args': {'instance_id': instance_id, - 'block_migration': block_migration, - 'disk': disk}}) + self.compute_rpcapi.pre_live_migration(context, instance_ref, + block_migration, disk, dest) except Exception: with excutils.save_and_reraise_exception(): diff --git a/nova/compute/rpcapi.py b/nova/compute/rpcapi.py index c08cdfe15..18da7b779 100644 --- a/nova/compute/rpcapi.py +++ b/nova/compute/rpcapi.py @@ -176,6 +176,12 @@ class ComputeAPI(nova.rpc.proxy.RpcProxy): instance_uuid=instance['uuid']), topic=self._compute_topic(ctxt, None, instance)) + def pre_live_migration(self, ctxt, instance, block_migration, disk, + host): + return self.call(ctxt, self.make_msg('pre_live_migration', + instance_id=instance['id'], block_migration=block_migration, + disk=disk), self._compute_topic(ctxt, host, None)) + def reboot_instance(self, ctxt, instance, reboot_type): self.cast(ctxt, self.make_msg('reboot_instance', instance_uuid=instance['uuid'], reboot_type=reboot_type), -- cgit