From 064fefb810eab07d4ddde3dd50537a6236567423 Mon Sep 17 00:00:00 2001 From: Kravchenko Pavel Date: Mon, 4 Feb 2013 18:21:18 +0200 Subject: Adds evacuate method to compute.api Added decorator to check whether the vm is suitable to be evacuated. The decorator validates that vm host is down. The new evacuate method calls rebuild with the recreate flag and specified target host. This implements blueprint rebuild-for-ha DocImpact Change-Id: I877b29928c922fa366fb85deb85ddfc72d97daf8 Co-authored-by: Oshrit Feder --- nova/tests/compute/test_compute.py | 101 +++++++++++++++++++++++++++++++ nova/tests/compute/test_compute_cells.py | 3 + 2 files changed, 104 insertions(+) (limited to 'nova/tests') diff --git a/nova/tests/compute/test_compute.py b/nova/tests/compute/test_compute.py index b5a8b91a2..a745a8874 100644 --- a/nova/tests/compute/test_compute.py +++ b/nova/tests/compute/test_compute.py @@ -5933,6 +5933,107 @@ class ComputeAPITestCase(BaseTestCase): db.instance_destroy(self.context, instance['uuid']) + def test_evacuate(self): + instance = jsonutils.to_primitive(self._create_fake_instance()) + instance_uuid = instance['uuid'] + instance = db.instance_get_by_uuid(self.context, instance_uuid) + self.assertEqual(instance['task_state'], None) + + def fake_service_is_up(*args, **kwargs): + return False + + self.stubs.Set(self.compute_api.servicegroup_api, 'service_is_up', + fake_service_is_up) + self.compute_api.evacuate(self.context.elevated(), + instance, + host='fake_dest_host', + on_shared_storage=True, + admin_password=None) + + instance = db.instance_get_by_uuid(self.context, instance_uuid) + self.assertEqual(instance['task_state'], task_states.REBUILDING) + + db.instance_destroy(self.context, instance['uuid']) + + def test_fail_evacuate_from_non_existing_host(self): + inst = {} + inst['vm_state'] = vm_states.ACTIVE + inst['image_ref'] = FAKE_IMAGE_REF + inst['reservation_id'] = 'r-fakeres' + inst['launch_time'] = '10' + inst['user_id'] = self.user_id + inst['project_id'] = self.project_id + inst['host'] = 'fake_host' + inst['node'] = NODENAME + type_id = instance_types.get_instance_type_by_name('m1.tiny')['id'] + inst['instance_type_id'] = type_id + inst['ami_launch_index'] = 0 + inst['memory_mb'] = 0 + inst['vcpus'] = 0 + inst['root_gb'] = 0 + inst['ephemeral_gb'] = 0 + inst['architecture'] = 'x86_64' + inst['os_type'] = 'Linux' + + instance = jsonutils.to_primitive(db.instance_create(self.context, + inst)) + instance_uuid = instance['uuid'] + instance = db.instance_get_by_uuid(self.context, instance_uuid) + self.assertEqual(instance['task_state'], None) + + self.assertRaises(exception.ComputeHostNotFound, + self.compute_api.evacuate, self.context.elevated(), instance, + host='fake_dest_host', on_shared_storage=True, + admin_password=None) + + db.instance_destroy(self.context, instance['uuid']) + + def test_fail_evacuate_from_running_host(self): + instance = jsonutils.to_primitive(self._create_fake_instance()) + instance_uuid = instance['uuid'] + instance = db.instance_get_by_uuid(self.context, instance_uuid) + self.assertEqual(instance['task_state'], None) + + def fake_service_is_up(*args, **kwargs): + return True + + self.stubs.Set(self.compute_api.servicegroup_api, 'service_is_up', + fake_service_is_up) + + self.assertRaises(exception.ComputeServiceUnavailable, + self.compute_api.evacuate, self.context.elevated(), instance, + host='fake_dest_host', on_shared_storage=True, + admin_password=None) + + db.instance_destroy(self.context, instance['uuid']) + + def test_fail_evacuate_instance_in_wrong_state(self): + instances = [ + jsonutils.to_primitive(self._create_fake_instance( + {'vm_state': vm_states.BUILDING})), + jsonutils.to_primitive(self._create_fake_instance( + {'vm_state': vm_states.PAUSED})), + jsonutils.to_primitive(self._create_fake_instance( + {'vm_state': vm_states.SUSPENDED})), + jsonutils.to_primitive(self._create_fake_instance( + {'vm_state': vm_states.RESCUED})), + jsonutils.to_primitive(self._create_fake_instance( + {'vm_state': vm_states.RESIZED})), + jsonutils.to_primitive(self._create_fake_instance( + {'vm_state': vm_states.SOFT_DELETED})), + jsonutils.to_primitive(self._create_fake_instance( + {'vm_state': vm_states.DELETED})), + jsonutils.to_primitive(self._create_fake_instance( + {'vm_state': vm_states.ERROR})) + ] + + for instance in instances: + self.assertRaises(exception.InstanceInvalidState, + self.compute_api.evacuate, self.context, instance, + host='fake_dest_host', on_shared_storage=True, + admin_password=None) + db.instance_destroy(self.context, instance['uuid']) + def fake_rpc_method(context, topic, msg, do_cast=True): pass diff --git a/nova/tests/compute/test_compute_cells.py b/nova/tests/compute/test_compute_cells.py index df78c37f3..8ba35e033 100644 --- a/nova/tests/compute/test_compute_cells.py +++ b/nova/tests/compute/test_compute_cells.py @@ -168,6 +168,9 @@ class CellsComputeAPITestCase(test_compute.ComputeAPITestCase): self.skipTest("This test is failing due to TypeError: " "detach_volume() takes exactly 3 arguments (4 given).") + def test_evacuate(self): + self.skipTest("Test is incompatible with cells.") + class CellsComputePolicyTestCase(test_compute.ComputePolicyTestCase): def setUp(self): -- cgit