¡@
OpenStack Study: attach_interfaces.py**** CubicPower OpenStack Study ****
# All Rights Reserved. # # Licensed under the Apache License, Version 2.0 (the "License"); you may # not use this file except in compliance with the License. You may obtain # a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the # License for the specific language governing permissions and limitations # under the License. """The instance interfaces extension.""" import webob from webob import exc from nova.api.openstack import common from nova.api.openstack import extensions from nova import compute from nova import exception from nova import network from nova.openstack.common.gettextutils import _ from nova.openstack.common import log as logging LOG = logging.getLogger(__name__) ALIAS = 'os-attach-interfaces' authorize = extensions.extension_authorizer('compute', 'v3:' + ALIAS)
**** CubicPower OpenStack Study **** def _translate_interface_attachment_view(port_info): """Maps keys for interface attachment details view.""" return { 'net_id': port_info['network_id'], 'port_id': port_info['id'], 'mac_addr': port_info['mac_address'], 'port_state': port_info['status'], 'fixed_ips': port_info.get('fixed_ips', None), }
**** CubicPower OpenStack Study **** class InterfaceAttachmentController(object): """The interface attachment API controller for the OpenStack API."""
**** CubicPower OpenStack Study **** def __init__(self): self.compute_api = compute.API() self.network_api = network.API() super(InterfaceAttachmentController, self).__init__()
**** CubicPower OpenStack Study **** def index(self, req, server_id): """Returns the list of interface attachments for a given instance.""" return self._items(req, server_id, entity_maker=_translate_interface_attachment_view)
**** CubicPower OpenStack Study **** def show(self, req, server_id, id): """Return data about the given interface attachment.""" context = req.environ['nova.context'] authorize(context) port_id = id common.get_instance(self.compute_api, context, server_id) try: port_info = self.network_api.show_port(context, port_id) except exception.NotFound: raise exc.HTTPNotFound() if port_info['port']['device_id'] != server_id: raise exc.HTTPNotFound() return {'interface_attachment': _translate_interface_attachment_view( port_info['port'])}
**** CubicPower OpenStack Study **** def create(self, req, server_id, body): """Attach an interface to an instance.""" context = req.environ['nova.context'] authorize(context) network_id = None port_id = None req_ip = None if body: attachment = body['interface_attachment'] network_id = attachment.get('net_id', None) port_id = attachment.get('port_id', None) try: req_ip = attachment['fixed_ips'][0]['ip_address'] except Exception: pass if network_id and port_id: raise exc.HTTPBadRequest() if req_ip and not network_id: raise exc.HTTPBadRequest() instance = common.get_instance(self.compute_api, context, server_id, want_objects=True) LOG.audit(_("Attach interface to %s"), instance=instance) try: vif = self.compute_api.attach_interface(context, instance, network_id, port_id, req_ip) except (exception.PortNotFound, exception.PortInUse, exception.NetworkDuplicated, exception.NetworkAmbiguous, exception.NetworkNotFound) as e: raise exc.HTTPBadRequest(explanation=e.format_message()) except NotImplementedError as e: raise webob.exc.HTTPNotImplemented(explanation=e.format_message()) except exception.InterfaceAttachFailed as e: LOG.exception(e) raise webob.exc.HTTPInternalServerError( explanation=e.format_message()) return self.show(req, server_id, vif['id'])
**** CubicPower OpenStack Study **** def update(self, req, server_id, id, body): """Update a interface attachment. We don't currently support this.""" msg = _("Attachments update is not supported") raise exc.HTTPNotImplemented(explanation=msg)
**** CubicPower OpenStack Study **** def delete(self, req, server_id, id): """Detach an interface from an instance.""" context = req.environ['nova.context'] authorize(context) port_id = id instance = common.get_instance(self.compute_api, context, server_id, want_objects=True) LOG.audit(_("Detach interface %s"), port_id, instance=instance) try: self.compute_api.detach_interface(context, instance, port_id=port_id) except exception.PortNotFound: raise exc.HTTPNotFound() except NotImplementedError as e: raise webob.exc.HTTPNotImplemented(explanation=e.format_message()) return webob.Response(status_int=202)
**** CubicPower OpenStack Study **** def _items(self, req, server_id, entity_maker): """Returns a list of attachments, transformed through entity_maker.""" context = req.environ['nova.context'] authorize(context) instance = common.get_instance(self.compute_api, context, server_id) results = [] search_opts = {'device_id': instance['uuid']} try: data = self.network_api.list_ports(context, **search_opts) except exception.NotFound: raise exc.HTTPNotFound() except NotImplementedError: msg = _("Network driver does not support this function.") raise webob.exc.HTTPNotImplemented(explanation=msg) ports = data.get('ports', []) results = [entity_maker(port) for port in ports] return {'interface_attachments': results}
**** CubicPower OpenStack Study **** class AttachInterfaces(extensions.V3APIExtensionBase): """Attach interface support.""" name = "AttachInterfaces" alias = ALIAS version = 1
**** CubicPower OpenStack Study **** def get_resources(self): res = [extensions.ResourceExtension(ALIAS, InterfaceAttachmentController(), parent=dict( member_name='server', collection_name='servers'))] return res
**** CubicPower OpenStack Study **** def get_controller_extensions(self): """It's an abstract function V3APIExtensionBase and the extension will not be loaded without it. """ return []
|