diff options
Diffstat (limited to 'nova/compute')
| -rw-r--r-- | nova/compute/api.py | 31 | ||||
| -rw-r--r-- | nova/compute/manager.py | 20 | ||||
| -rw-r--r-- | nova/compute/rpcapi.py | 12 |
3 files changed, 52 insertions, 11 deletions
diff --git a/nova/compute/api.py b/nova/compute/api.py index e98f8a654..29f52c4e5 100644 --- a/nova/compute/api.py +++ b/nova/compute/api.py @@ -1358,6 +1358,27 @@ class API(base.Base): return min_ram, min_disk + def _get_block_device_info(self, context, instance_uuid): + bdms = self.db.block_device_mapping_get_all_by_instance(context, + instance_uuid) + block_device_mapping = [] + for bdm in bdms: + if not bdm['volume_id']: + continue + try: + cinfo = jsonutils.loads(bdm['connection_info']) + if cinfo and 'serial' not in cinfo: + cinfo['serial'] = bdm['volume_id'] + bdmap = {'connection_info': cinfo, + 'mount_device': bdm['volume_id'], + 'delete_on_termination': bdm['delete_on_termination']} + block_device_mapping.append(bdmap) + except TypeError: + # if the block_device_mapping has no value in connection_info + # (returned as None), don't include in the mapping + pass + return {'block_device_mapping': block_device_mapping} + @wrap_check_policy @check_instance_lock @check_instance_state(vm_state=[vm_states.ACTIVE, vm_states.STOPPED, @@ -1377,8 +1398,16 @@ class API(base.Base): task_state=state, expected_task_state=[None, task_states.REBOOTING]) + elevated = context.elevated() + block_info = self._get_block_device_info(elevated, + instance['uuid']) + network_info = self.network_api.get_instance_nw_info(elevated, + instance) + self.compute_rpcapi.reboot_instance(context, instance=instance, - reboot_type=reboot_type) + block_device_info=block_info, + network_info=network_info, + reboot_type=reboot_type) def _get_image(self, context, image_href): """Throws an ImageNotFound exception if image_href does not exist.""" diff --git a/nova/compute/manager.py b/nova/compute/manager.py index 46760e772..8057ae4e1 100644 --- a/nova/compute/manager.py +++ b/nova/compute/manager.py @@ -210,7 +210,7 @@ def _get_image_meta(context, image_ref): class ComputeManager(manager.SchedulerDependentManager): """Manages the running instances from creation to destruction.""" - RPC_API_VERSION = '2.4' + RPC_API_VERSION = '2.5' def __init__(self, compute_driver=None, *args, **kwargs): """Load configuration options and connect to the hypervisor.""" @@ -1093,11 +1093,22 @@ class ComputeManager(manager.SchedulerDependentManager): @exception.wrap_exception(notifier=notifier, publisher_id=publisher_id()) @reverts_task_state @wrap_instance_fault - def reboot_instance(self, context, instance, reboot_type="SOFT"): + def reboot_instance(self, context, instance, + block_device_info=None, + network_info=None, + reboot_type="SOFT"): """Reboot an instance on this host.""" context = context.elevated() LOG.audit(_("Rebooting instance"), context=context, instance=instance) + # NOTE(danms): remove these when RPC API < 2.5 compatibility + # is no longer needed + if block_device_info is None: + block_device_info = self._get_instance_volume_block_device_info( + context, instance['uuid']) + if network_info is None: + network_info = self._get_instance_nw_info(context, instance) + self._notify_about_instance_usage(context, instance, "reboot.start") current_power_state = self._get_power_state(context, instance) @@ -1113,11 +1124,6 @@ class ComputeManager(manager.SchedulerDependentManager): 'expected: %(running)s)') % locals(), context=context, instance=instance) - network_info = self._get_instance_nw_info(context, instance) - - block_device_info = self._get_instance_volume_block_device_info( - context, instance['uuid']) - try: self.driver.reboot(instance, self._legacy_nw_info(network_info), reboot_type, block_device_info) diff --git a/nova/compute/rpcapi.py b/nova/compute/rpcapi.py index e0c4bae3b..6a47bb096 100644 --- a/nova/compute/rpcapi.py +++ b/nova/compute/rpcapi.py @@ -132,6 +132,7 @@ class ComputeAPI(nova.openstack.common.rpc.proxy.RpcProxy): remove_aggregate_host() 2.3 - Adds volume_id to reserve_block_device_name() 2.4 - Add bdms to terminate_instance + 2.5 - Add block device and network info to reboot_instance ''' # @@ -342,11 +343,16 @@ class ComputeAPI(nova.openstack.common.rpc.proxy.RpcProxy): image=image, reservations=reservations), _compute_topic(self.topic, ctxt, host, None)) - def reboot_instance(self, ctxt, instance, reboot_type): + def reboot_instance(self, ctxt, instance, + block_device_info, network_info, reboot_type): instance_p = jsonutils.to_primitive(instance) self.cast(ctxt, self.make_msg('reboot_instance', - instance=instance_p, reboot_type=reboot_type), - topic=_compute_topic(self.topic, ctxt, None, instance)) + instance=instance_p, + block_device_info=block_device_info, + network_info=network_info, + reboot_type=reboot_type), + topic=_compute_topic(self.topic, ctxt, None, instance), + version='2.5') def rebuild_instance(self, ctxt, instance, new_pass, injected_files, image_ref, orig_image_ref, orig_sys_metadata): |