¡@
OpenStack Study: base_plugin.py**** CubicPower OpenStack Study ****
# vim: tabstop=4 shiftwidth=4 softtabstop=4 # Copyright 2013 Embrane, Inc. # 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. # # @author: Ivar Lazzaro, Embrane, Inc. from heleosapi import backend_operations as h_op from heleosapi import constants as h_con from heleosapi import exceptions as h_exc from oslo.config import cfg from sqlalchemy.orm import exc from neutron.common import constants as l3_constants from neutron.common import exceptions as neutron_exc from neutron.db import extraroute_db from neutron.db import l3_db from neutron.db import models_v2 from neutron.extensions import l3 from neutron.openstack.common import log as logging from neutron.plugins.embrane.agent import dispatcher from neutron.plugins.embrane.common import config # noqa from neutron.plugins.embrane.common import constants as p_con from neutron.plugins.embrane.common import contexts as embrane_ctx from neutron.plugins.embrane.common import operation from neutron.plugins.embrane.common import utils LOG = logging.getLogger(__name__) conf = cfg.CONF.heleos
**** CubicPower OpenStack Study **** class EmbranePlugin(object): """Embrane Neutron plugin. uses the heleos(c) platform and a support L2 plugin to leverage networking in cloud environments. """ _l3super = extraroute_db.ExtraRoute_db_mixin
**** CubicPower OpenStack Study **** def __init__(self): pass
**** CubicPower OpenStack Study **** def _run_embrane_config(self): # read configurations config_esm_mgmt = conf.esm_mgmt config_admin_username = conf.admin_username config_admin_password = conf.admin_password config_router_image_id = conf.router_image config_security_zones = {h_con.SzType.IB: conf.inband_id, h_con.SzType.OOB: conf.oob_id, h_con.SzType.MGMT: conf.mgmt_id, h_con.SzType.DUMMY: conf.dummy_utif_id} config_resource_pool = conf.resource_pool_id self._embrane_async = conf.async_requests self._esm_api = h_op.BackendOperations( esm_mgmt=config_esm_mgmt, admin_username=config_admin_username, admin_password=config_admin_password, router_image_id=config_router_image_id, security_zones=config_security_zones, resource_pool=config_resource_pool) self._dispatcher = dispatcher.Dispatcher(self, self._embrane_async)
**** CubicPower OpenStack Study **** def _make_router_dict(self, *args, **kwargs): return self._l3super._make_router_dict(self, *args, **kwargs)
**** CubicPower OpenStack Study **** def _delete_router(self, context, router_id): self._l3super.delete_router(self, context, router_id)
**** CubicPower OpenStack Study **** def _update_db_router_state(self, context, neutron_router, dva_state): if not dva_state: new_state = p_con.Status.ERROR elif dva_state == h_con.DvaState.POWER_ON: new_state = p_con.Status.ACTIVE else: new_state = p_con.Status.READY self._set_db_router_state(context, neutron_router, new_state) return new_state
**** CubicPower OpenStack Study **** def _set_db_router_state(self, context, neutron_router, new_state): return utils.set_db_item_state(context, neutron_router, new_state)
**** CubicPower OpenStack Study **** def _update_db_interfaces_state(self, context, neutron_router): router_ports = self.get_ports(context, {"device_id": [neutron_router["id"]]}) self._esm_api.update_ports_status(neutron_router["id"], router_ports) for port in router_ports: db_port = self._get_port(context, port["id"]) db_port["status"] = port["status"] context.session.merge(db_port)
**** CubicPower OpenStack Study **** def _update_neutron_state(self, context, neutron_router, state): try: self._update_db_interfaces_state(context, neutron_router) except Exception: LOG.exception(_("Unhandled exception occurred")) return self._set_db_router_state(context, neutron_router, state)
**** CubicPower OpenStack Study **** def _retrieve_prefix_from_port(self, context, neutron_port): subnet_id = neutron_port["fixed_ips"][0]["subnet_id"] subnet = utils.retrieve_subnet(context, subnet_id) prefix = subnet["cidr"].split("/")[1] return prefix # L3 extension
**** CubicPower OpenStack Study **** def create_router(self, context, router): r = router["router"] self._get_tenant_id_for_create(context, r) db_router = self._l3super.create_router(self, context, router) neutron_router = self._get_router(context, db_router['id']) gw_port = neutron_router.gw_port # For now, only small flavor is used utif_info = (self._plugin_support.retrieve_utif_info(context, gw_port) if gw_port else None) ip_allocation_info = (utils.retrieve_ip_allocation_info(context, gw_port) if gw_port else None) neutron_router = self._l3super._get_router(self, context, neutron_router["id"]) neutron_router["status"] = p_con.Status.CREATING self._dispatcher.dispatch_l3( d_context=embrane_ctx.DispatcherContext( p_con.Events.CREATE_ROUTER, neutron_router, context, None), args=(h_con.Flavor.SMALL, utif_info, ip_allocation_info)) return self._make_router_dict(neutron_router)
**** CubicPower OpenStack Study **** def update_router(self, context, id, router): db_router = self._l3super.update_router(self, context, id, router) neutron_router = self._get_router(context, db_router['id']) gw_port = neutron_router.gw_port utif_info = (self._plugin_support.retrieve_utif_info(context, gw_port) if gw_port else None) ip_allocation_info = (utils.retrieve_ip_allocation_info(context, gw_port) if gw_port else None) routes_info = router["router"].get("routes") neutron_router = self._l3super._get_router(self, context, id) state_change = operation.Operation( self._set_db_router_state, args=(context, neutron_router, p_con.Status.UPDATING)) self._dispatcher.dispatch_l3( d_context=embrane_ctx.DispatcherContext( p_con.Events.UPDATE_ROUTER, neutron_router, context, state_change), args=(utif_info, ip_allocation_info, routes_info)) return self._make_router_dict(neutron_router)
**** CubicPower OpenStack Study **** def get_router(self, context, id, fields=None): """Ensures that id does exist in the ESM.""" neutron_router = self._get_router(context, id) try: if neutron_router["status"] != p_con.Status.CREATING: self._esm_api.get_dva(id) except h_exc.DvaNotFound: LOG.error(_("The following routers have not physical match: %s"), id) self._set_db_router_state(context, neutron_router, p_con.Status.ERROR) LOG.debug(_("Requested router: %s"), neutron_router) return self._make_router_dict(neutron_router, fields)
**** CubicPower OpenStack Study **** def get_routers(self, context, filters=None, fields=None, sorts=None, limit=None, marker=None, page_reverse=False): """Retrieves the router list defined by the incoming filters.""" router_query = self._apply_filters_to_query( self._model_query(context, l3_db.Router), l3_db.Router, filters) id_list = [x["id"] for x in router_query if x["status"] != p_con.Status.CREATING] try: self._esm_api.get_dvas(id_list) except h_exc.DvaNotFound: LOG.error(_("The following routers have not physical match: %s"), repr(id_list)) error_routers = [] for id in id_list: try: error_routers.append(self._get_router(context, id)) except l3.RouterNotFound: pass for error_router in error_routers: self._set_db_router_state(context, error_router, p_con.Status.ERROR) return [self._make_router_dict(router, fields) for router in router_query]
**** CubicPower OpenStack Study **** def delete_router(self, context, id): """Deletes the DVA with the specific router id.""" # Copy of the parent validation code, shouldn't the base modules # provide functions for validating operations? device_owner_router_intf = l3_constants.DEVICE_OWNER_ROUTER_INTF fips = self.get_floatingips_count(context.elevated(), filters={"router_id": [id]}) if fips: raise l3.RouterInUse(router_id=id) device_filter = {"device_id": [id], "device_owner": [device_owner_router_intf]} ports = self.get_ports_count(context.elevated(), filters=device_filter) if ports: raise l3.RouterInUse(router_id=id) neutron_router = self._get_router(context, id) state_change = operation.Operation(self._set_db_router_state, args=(context, neutron_router, p_con.Status.DELETING)) self._dispatcher.dispatch_l3( d_context=embrane_ctx.DispatcherContext( p_con.Events.DELETE_ROUTER, neutron_router, context, state_change), args=()) LOG.debug(_("Deleting router=%s"), neutron_router) return neutron_router
**** CubicPower OpenStack Study **** def add_router_interface(self, context, router_id, interface_info): """Grows DVA interface in the specified subnet.""" neutron_router = self._get_router(context, router_id) rport_qry = context.session.query(models_v2.Port) ports = rport_qry.filter_by( device_id=router_id).all() if len(ports) >= p_con.UTIF_LIMIT: raise neutron_exc.BadRequest( resource=router_id, msg=("this router doesn't support more than " + str(p_con.UTIF_LIMIT) + " interfaces")) neutron_router_iface = self._l3super.add_router_interface( self, context, router_id, interface_info) port = self._get_port(context, neutron_router_iface["port_id"]) utif_info = self._plugin_support.retrieve_utif_info(context, port) ip_allocation_info = utils.retrieve_ip_allocation_info(context, port) state_change = operation.Operation(self._set_db_router_state, args=(context, neutron_router, p_con.Status.UPDATING)) self._dispatcher.dispatch_l3( d_context=embrane_ctx.DispatcherContext( p_con.Events.GROW_ROUTER_IF, neutron_router, context, state_change), args=(utif_info, ip_allocation_info)) return neutron_router_iface
**** CubicPower OpenStack Study **** def remove_router_interface(self, context, router_id, interface_info): port_id = None if "port_id" in interface_info: port_id = interface_info["port_id"] elif "subnet_id" in interface_info: subnet_id = interface_info["subnet_id"] subnet = utils.retrieve_subnet(context, subnet_id) rport_qry = context.session.query(models_v2.Port) ports = rport_qry.filter_by( device_id=router_id, device_owner=l3_constants.DEVICE_OWNER_ROUTER_INTF, network_id=subnet["network_id"]) for p in ports: if p["fixed_ips"][0]["subnet_id"] == subnet_id: port_id = p["id"] break neutron_router = self._get_router(context, router_id) self._l3super.remove_router_interface(self, context, router_id, interface_info) state_change = operation.Operation(self._set_db_router_state, args=(context, neutron_router, p_con.Status.UPDATING)) self._dispatcher.dispatch_l3( d_context=embrane_ctx.DispatcherContext( p_con.Events.SHRINK_ROUTER_IF, neutron_router, context, state_change), args=(port_id,))
**** CubicPower OpenStack Study **** def create_floatingip(self, context, floatingip): result = self._l3super.create_floatingip( self, context, floatingip) if result["port_id"]: neutron_router = self._get_router(context, result["router_id"]) db_fixed_port = self._get_port(context, result["port_id"]) fixed_prefix = self._retrieve_prefix_from_port(context, db_fixed_port) db_floating_port = neutron_router["gw_port"] floating_prefix = self._retrieve_prefix_from_port( context, db_floating_port) nat_info = utils.retrieve_nat_info(context, result, fixed_prefix, floating_prefix, neutron_router) state_change = operation.Operation( self._set_db_router_state, args=(context, neutron_router, p_con.Status.UPDATING)) self._dispatcher.dispatch_l3( d_context=embrane_ctx.DispatcherContext( p_con.Events.SET_NAT_RULE, neutron_router, context, state_change), args=(nat_info,)) return result
**** CubicPower OpenStack Study **** def update_floatingip(self, context, id, floatingip): db_fip = self._l3super.get_floatingip(self, context, id) result = self._l3super.update_floatingip(self, context, id, floatingip) if db_fip["port_id"] and db_fip["port_id"] != result["port_id"]: neutron_router = self._get_router(context, db_fip["router_id"]) fip_id = db_fip["id"] state_change = operation.Operation( self._set_db_router_state, args=(context, neutron_router, p_con.Status.UPDATING)) self._dispatcher.dispatch_l3( d_context=embrane_ctx.DispatcherContext( p_con.Events.RESET_NAT_RULE, neutron_router, context, state_change), args=(fip_id,)) if result["port_id"]: neutron_router = self._get_router(context, result["router_id"]) db_fixed_port = self._get_port(context, result["port_id"]) fixed_prefix = self._retrieve_prefix_from_port(context, db_fixed_port) db_floating_port = neutron_router["gw_port"] floating_prefix = self._retrieve_prefix_from_port( context, db_floating_port) nat_info = utils.retrieve_nat_info(context, result, fixed_prefix, floating_prefix, neutron_router) state_change = operation.Operation( self._set_db_router_state, args=(context, neutron_router, p_con.Status.UPDATING)) self._dispatcher.dispatch_l3( d_context=embrane_ctx.DispatcherContext( p_con.Events.SET_NAT_RULE, neutron_router, context, state_change), args=(nat_info,)) return result
**** CubicPower OpenStack Study **** def disassociate_floatingips(self, context, port_id): try: fip_qry = context.session.query(l3_db.FloatingIP) floating_ip = fip_qry.filter_by(fixed_port_id=port_id).one() router_id = floating_ip["router_id"] except exc.NoResultFound: return self._l3super.disassociate_floatingips(self, context, port_id) if router_id: neutron_router = self._get_router(context, router_id) fip_id = floating_ip["id"] state_change = operation.Operation( self._set_db_router_state, args=(context, neutron_router, p_con.Status.UPDATING)) self._dispatcher.dispatch_l3( d_context=embrane_ctx.DispatcherContext( p_con.Events.RESET_NAT_RULE, neutron_router, context, state_change), args=(fip_id,))
|