fbbfe8af2b
- refactor to leverage Client's transactional capabilities - General refactor to improve the driver's reliability Implements blueprint: apic-driver-enhancements Change-Id: I5a19039e82988a0570622bc1ddb1429e9833d478
196 lines
7.2 KiB
Python
196 lines
7.2 KiB
Python
# Copyright (c) 2014 Cisco Systems 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: Arvind Somya (asomya@cisco.com), Cisco Systems Inc.
|
|
|
|
import sqlalchemy as sa
|
|
from sqlalchemy import orm
|
|
|
|
from neutron.db import api as db_api
|
|
from neutron.db import model_base
|
|
|
|
from neutron.db import models_v2
|
|
from neutron.plugins.ml2 import models as models_ml2
|
|
|
|
|
|
class RouterContract(model_base.BASEV2, models_v2.HasTenant):
|
|
|
|
"""Contracts created on the APIC.
|
|
|
|
tenant_id represents the owner (APIC side) of the contract.
|
|
router_id is the UUID of the router (Neutron side) this contract is
|
|
referring to.
|
|
"""
|
|
|
|
__tablename__ = 'cisco_ml2_apic_contracts'
|
|
|
|
router_id = sa.Column(sa.String(64), sa.ForeignKey('routers.id',
|
|
ondelete='CASCADE'),
|
|
primary_key=True)
|
|
|
|
|
|
class HostLink(model_base.BASEV2):
|
|
|
|
"""Connectivity of host links."""
|
|
|
|
__tablename__ = 'cisco_ml2_apic_host_links'
|
|
|
|
host = sa.Column(sa.String(255), nullable=False, primary_key=True)
|
|
ifname = sa.Column(sa.String(64), nullable=False, primary_key=True)
|
|
ifmac = sa.Column(sa.String(32), nullable=True)
|
|
swid = sa.Column(sa.String(32), nullable=False)
|
|
module = sa.Column(sa.String(32), nullable=False)
|
|
port = sa.Column(sa.String(32), nullable=False)
|
|
|
|
|
|
class ApicName(model_base.BASEV2):
|
|
"""Mapping of names created on the APIC."""
|
|
|
|
__tablename__ = 'cisco_ml2_apic_names'
|
|
|
|
neutron_id = sa.Column(sa.String(36), nullable=False, primary_key=True)
|
|
neutron_type = sa.Column(sa.String(32), nullable=False, primary_key=True)
|
|
apic_name = sa.Column(sa.String(255), nullable=False)
|
|
|
|
|
|
class ApicDbModel(object):
|
|
|
|
"""DB Model to manage all APIC DB interactions."""
|
|
|
|
def __init__(self):
|
|
self.session = db_api.get_session()
|
|
|
|
def get_contract_for_router(self, router_id):
|
|
"""Returns the specified router's contract."""
|
|
return self.session.query(RouterContract).filter_by(
|
|
router_id=router_id).first()
|
|
|
|
def write_contract_for_router(self, tenant_id, router_id):
|
|
"""Stores a new contract for the given tenant."""
|
|
contract = RouterContract(tenant_id=tenant_id,
|
|
router_id=router_id)
|
|
with self.session.begin(subtransactions=True):
|
|
self.session.add(contract)
|
|
return contract
|
|
|
|
def update_contract_for_router(self, tenant_id, router_id):
|
|
with self.session.begin(subtransactions=True):
|
|
contract = self.session.query(RouterContract).filter_by(
|
|
router_id=router_id).with_lockmode('update').first()
|
|
if contract:
|
|
contract.tenant_id = tenant_id
|
|
self.session.merge(contract)
|
|
else:
|
|
self.write_contract_for_router(tenant_id, router_id)
|
|
|
|
def delete_contract_for_router(self, router_id):
|
|
with self.session.begin(subtransactions=True):
|
|
try:
|
|
self.session.query(RouterContract).filter_by(
|
|
router_id=router_id).delete()
|
|
except orm.exc.NoResultFound:
|
|
return
|
|
|
|
def add_hostlink(self, host, ifname, ifmac, swid, module, port):
|
|
link = HostLink(host=host, ifname=ifname, ifmac=ifmac,
|
|
swid=swid, module=module, port=port)
|
|
with self.session.begin(subtransactions=True):
|
|
self.session.merge(link)
|
|
|
|
def get_hostlinks(self):
|
|
return self.session.query(HostLink).all()
|
|
|
|
def get_hostlink(self, host, ifname):
|
|
return self.session.query(HostLink).filter_by(
|
|
host=host, ifname=ifname).first()
|
|
|
|
def get_hostlinks_for_host(self, host):
|
|
return self.session.query(HostLink).filter_by(
|
|
host=host).all()
|
|
|
|
def get_hostlinks_for_host_switchport(self, host, swid, module, port):
|
|
return self.session.query(HostLink).filter_by(
|
|
host=host, swid=swid, module=module, port=port).all()
|
|
|
|
def get_hostlinks_for_switchport(self, swid, module, port):
|
|
return self.session.query(HostLink).filter_by(
|
|
swid=swid, module=module, port=port).all()
|
|
|
|
def delete_hostlink(self, host, ifname):
|
|
with self.session.begin(subtransactions=True):
|
|
try:
|
|
self.session.query(HostLink).filter_by(host=host,
|
|
ifname=ifname).delete()
|
|
except orm.exc.NoResultFound:
|
|
return
|
|
|
|
def get_switches(self):
|
|
return self.session.query(HostLink.swid).distinct()
|
|
|
|
def get_modules_for_switch(self, swid):
|
|
return self.session.query(
|
|
HostLink.module).filter_by(swid=swid).distinct()
|
|
|
|
def get_ports_for_switch_module(self, swid, module):
|
|
return self.session.query(
|
|
HostLink.port).filter_by(swid=swid, module=module).distinct()
|
|
|
|
def get_switch_and_port_for_host(self, host):
|
|
return self.session.query(
|
|
HostLink.swid, HostLink.module, HostLink.port).filter_by(
|
|
host=host).distinct()
|
|
|
|
def get_tenant_network_vlan_for_host(self, host):
|
|
pb = models_ml2.PortBinding
|
|
po = models_v2.Port
|
|
ns = models_ml2.NetworkSegment
|
|
return self.session.query(
|
|
po.tenant_id, ns.network_id, ns.segmentation_id).filter(
|
|
po.id == pb.port_id).filter(pb.host == host).filter(
|
|
po.network_id == ns.network_id).distinct()
|
|
|
|
def add_apic_name(self, neutron_id, neutron_type, apic_name):
|
|
name = ApicName(neutron_id=neutron_id,
|
|
neutron_type=neutron_type,
|
|
apic_name=apic_name)
|
|
with self.session.begin(subtransactions=True):
|
|
self.session.add(name)
|
|
|
|
def update_apic_name(self, neutron_id, neutron_type, apic_name):
|
|
with self.session.begin(subtransactions=True):
|
|
name = self.session.query(ApicName).filter_by(
|
|
neutron_id=neutron_id,
|
|
neutron_type=neutron_type).with_lockmode('update').first()
|
|
if name:
|
|
name.apic_name = apic_name
|
|
self.session.merge(name)
|
|
else:
|
|
self.add_apic_name(neutron_id, neutron_type, apic_name)
|
|
|
|
def get_apic_names(self):
|
|
return self.session.query(ApicName).all()
|
|
|
|
def get_apic_name(self, neutron_id, neutron_type):
|
|
return self.session.query(ApicName.apic_name).filter_by(
|
|
neutron_id=neutron_id, neutron_type=neutron_type).first()
|
|
|
|
def delete_apic_name(self, neutron_id):
|
|
with self.session.begin(subtransactions=True):
|
|
try:
|
|
self.session.query(ApicName).filter_by(
|
|
neutron_id=neutron_id).delete()
|
|
except orm.exc.NoResultFound:
|
|
return
|