From 3a829e3543b8a346fce95f71cd51f68e7c4aae41 Mon Sep 17 00:00:00 2001 From: Russell Bryant Date: Tue, 29 May 2012 18:28:09 -0400 Subject: Add rollback_live_migration_at_destination() to compute rpcapi. Part of bug 1006467. This patch adds rollback_live_migration_at_destination() to the compute rpcapi. This method is used by the compute manager. Change-Id: Iadbb50fc5cb0f7b5ad483d48666bc81e033ac5f4 --- nova/compute/manager.py | 6 ++---- nova/compute/rpcapi.py | 5 +++++ 2 files changed, 7 insertions(+), 4 deletions(-) (limited to 'nova/compute') diff --git a/nova/compute/manager.py b/nova/compute/manager.py index e0c2eb2da..95c5bd763 100644 --- a/nova/compute/manager.py +++ b/nova/compute/manager.py @@ -2214,10 +2214,8 @@ class ComputeManager(manager.SchedulerDependentManager): # before migration starts, so if any failure occurs, # any empty images has to be deleted. if block_migration: - rpc.cast(context, - rpc.queue_get_for(context, FLAGS.compute_topic, dest), - {"method": "rollback_live_migration_at_destination", - "args": {'instance_id': instance_ref['id']}}) + self.compute_rpcapi.rollback_live_migration_at_destination(context, + instance_ref, dest) def rollback_live_migration_at_destination(self, context, instance_id): """ Cleaning up image directory that is created pre_live_migration. diff --git a/nova/compute/rpcapi.py b/nova/compute/rpcapi.py index 908c40c5e..c08cdfe15 100644 --- a/nova/compute/rpcapi.py +++ b/nova/compute/rpcapi.py @@ -244,6 +244,11 @@ class ComputeAPI(nova.rpc.proxy.RpcProxy): instance_uuid=instance['uuid'], migration_id=migration_id), topic=self._compute_topic(ctxt, host, instance)) + def rollback_live_migration_at_destination(self, ctxt, instance, host): + self.cast(ctxt, self.make_msg('rollback_live_migration_at_destination', + instance_id=instance['id']), + topic=self._compute_topic(ctxt, host, None)) + def set_admin_password(self, ctxt, instance, new_pass): self.cast(ctxt, self.make_msg('set_admin_password', instance_uuid=instance['uuid'], new_pass=new_pass), -- cgit