openstack
/
neutron
Code Issues Proposed changes

Plugins should call __init__ of db_base_plugin for db.configure 

Currently each plugin calls db.configure() within the plugin's __init__
class or defines an initialize() method that's sole job is to call this
method. Instead we should just call the super method of a plugin so that
db.configure() is called for us out of the db_base_plugin class.

Note: the only reason why I'm making this change is that I want to add
something to the __init__() class of the db_base_plugin that's needed for
the nova-event-callback blueprint and adding it in the base class of init
looks to be the best place.

Change-Id: Iec3c912735021ceb90f657108aad3a57460d66e7
Closes-bug: #1282303
This commit is contained in:
Aaron Rosen 2014-02-19 15:08:54 -08:00 committed by Aaron Rosen
parent 4d72fe0251
commit 326b85dd61
30 changed files with 36 additions and 77 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
neutron/db/db_base_plugin_v2.py
View File

@ -224,10 +224,6 @@ class NeutronDbPluginV2(neutron_plugin_base_v2.NeutronPluginBaseV2,
__native_sorting_support = True __native_sorting_support = True
def __init__(self): def __init__(self):
# NOTE(jkoelker) This is an incomplete implementation. Subclasses
# must override __init__ and setup the database
# and not call into this class's __init__.
# This connection is setup as memory for the tests.
db.configure_db() db.configure_db()
@classmethod @classmethod

5
neutron/plugins/bigswitch/plugin.py
View File

@ -57,7 +57,6 @@ from neutron.common import topics
from neutron import context as qcontext from neutron import context as qcontext
from neutron.db import agents_db from neutron.db import agents_db
from neutron.db import agentschedulers_db from neutron.db import agentschedulers_db
from neutron.db import api as db
from neutron.db import db_base_plugin_v2 from neutron.db import db_base_plugin_v2
from neutron.db import dhcp_rpc_base from neutron.db import dhcp_rpc_base
from neutron.db import external_net_db from neutron.db import external_net_db
@ -102,6 +101,7 @@ class NeutronRestProxyV2Base(db_base_plugin_v2.NeutronDbPluginV2,
servers = None servers = None
def __init__(self, server_timeout=None): def __init__(self, server_timeout=None):
super(NeutronRestProxyV2Base, self).__init__()
# This base class is not intended to be instantiated directly. # This base class is not intended to be instantiated directly.
# Extending class should set ServerPool. # Extending class should set ServerPool.
if not self.servers: if not self.servers:
@ -321,11 +321,10 @@ class NeutronRestProxyV2(NeutronRestProxyV2Base,
"dhcp_agent_scheduler", "agent"] "dhcp_agent_scheduler", "agent"]
def __init__(self, server_timeout=None): def __init__(self, server_timeout=None):
super(NeutronRestProxyV2, self).__init__()
LOG.info(_('NeutronRestProxy: Starting plugin. Version=%s'), LOG.info(_('NeutronRestProxy: Starting plugin. Version=%s'),
version_string_with_vcs()) version_string_with_vcs())
pl_config.register_config() pl_config.register_config()
# init DB, proxy's persistent store defaults to in-memory sql-lite DB
db.configure_db()
# Include the BigSwitch Extensions path in the api_extensions # Include the BigSwitch Extensions path in the api_extensions
neutron_extensions.append_api_extensions_path(extensions.__path__) neutron_extensions.append_api_extensions_path(extensions.__path__)

2
neutron/plugins/brocade/NeutronPlugin.py
View File

@ -225,6 +225,7 @@ class BrocadePluginV2(db_base_plugin_v2.NeutronDbPluginV2,
Specify switch address and db configuration. Specify switch address and db configuration.
""" """
super(BrocadePluginV2, self).__init__()
self.supported_extension_aliases = ["binding", "security-group", self.supported_extension_aliases = ["binding", "security-group",
"external-net", "router", "external-net", "router",
"extraroute", "agent", "extraroute", "agent",
@ -235,7 +236,6 @@ class BrocadePluginV2(db_base_plugin_v2.NeutronDbPluginV2,
physical_interface) physical_interface)
self.base_binding_dict = self._get_base_binding_dict() self.base_binding_dict = self._get_base_binding_dict()
portbindings_base.register_port_dict_function() portbindings_base.register_port_dict_function()
db.configure_db()
self.ctxt = context.get_admin_context() self.ctxt = context.get_admin_context()
self.ctxt.session = db.get_session() self.ctxt.session = db.get_session()
self._vlan_bitmap = vbm.VlanBitmap(self.ctxt) self._vlan_bitmap = vbm.VlanBitmap(self.ctxt)

5
neutron/plugins/cisco/db/n1kv_db_v2.py
View File

@ -35,11 +35,6 @@ from neutron.plugins.cisco.db import n1kv_models_v2
LOG = logging.getLogger(__name__) LOG = logging.getLogger(__name__)
def initialize():
"""Initialize the database."""
db.configure_db()
def del_trunk_segment_binding(db_session, trunk_segment_id, segment_pairs): def del_trunk_segment_binding(db_session, trunk_segment_id, segment_pairs):
""" """
Delete a trunk network binding. Delete a trunk network binding.

2
neutron/plugins/cisco/n1kv/n1kv_neutron_plugin.py
View File

@ -102,7 +102,7 @@ class N1kvNeutronPluginV2(db_base_plugin_v2.NeutronDbPluginV2,
1. Initialize Nexus1000v and Credential DB 1. Initialize Nexus1000v and Credential DB
2. Establish communication with Cisco Nexus1000V 2. Establish communication with Cisco Nexus1000V
""" """
n1kv_db_v2.initialize() super(N1kvNeutronPluginV2, self).__init__()
c_cred.Store.initialize() c_cred.Store.initialize()
self._initialize_network_ranges() self._initialize_network_ranges()
self._setup_vsm() self._setup_vsm()

4
neutron/plugins/linuxbridge/db/l2network_db_v2.py
View File

@ -29,10 +29,6 @@ from neutron.plugins.linuxbridge.db import l2network_models_v2
LOG = logging.getLogger(__name__) LOG = logging.getLogger(__name__)
def initialize():
db.configure_db()
def sync_network_states(network_vlan_ranges): def sync_network_states(network_vlan_ranges):
"""Synchronize network_states table with current configured VLAN ranges.""" """Synchronize network_states table with current configured VLAN ranges."""

2
neutron/plugins/linuxbridge/lb_neutron_plugin.py
View File

@ -252,12 +252,12 @@ class LinuxBridgePluginV2(db_base_plugin_v2.NeutronDbPluginV2,
return self._aliases return self._aliases
def __init__(self): def __init__(self):
super(LinuxBridgePluginV2, self).__init__()
self.base_binding_dict = { self.base_binding_dict = {
portbindings.VIF_TYPE: portbindings.VIF_TYPE_BRIDGE, portbindings.VIF_TYPE: portbindings.VIF_TYPE_BRIDGE,
portbindings.CAPABILITIES: { portbindings.CAPABILITIES: {
portbindings.CAP_PORT_FILTER: portbindings.CAP_PORT_FILTER:
'security-group' in self.supported_extension_aliases}} 'security-group' in self.supported_extension_aliases}}
db.initialize()
self._parse_network_vlan_ranges() self._parse_network_vlan_ranges()
db.sync_network_states(self.network_vlan_ranges) db.sync_network_states(self.network_vlan_ranges)
self.tenant_network_type = cfg.CONF.VLANS.tenant_network_type self.tenant_network_type = cfg.CONF.VLANS.tenant_network_type

3
neutron/plugins/metaplugin/meta_neutron_plugin.py
View File

@ -50,6 +50,7 @@ class MetaPluginV2(db_base_plugin_v2.NeutronDbPluginV2,
extraroute_db.ExtraRoute_db_mixin): extraroute_db.ExtraRoute_db_mixin):
def __init__(self, configfile=None): def __init__(self, configfile=None):
super(MetaPluginV2, self).__init__()
LOG.debug(_("Start initializing metaplugin")) LOG.debug(_("Start initializing metaplugin"))
self.supported_extension_aliases = ['flavor', 'external-net', self.supported_extension_aliases = ['flavor', 'external-net',
'router', 'ext-gw-mode', 'router', 'ext-gw-mode',
@ -99,8 +100,6 @@ class MetaPluginV2(db_base_plugin_v2.NeutronDbPluginV2,
raise exc.Invalid(_('default_l3_flavor %s is not plugin list') % raise exc.Invalid(_('default_l3_flavor %s is not plugin list') %
self.default_l3_flavor) self.default_l3_flavor)
db.configure_db()
self.extension_map = {} self.extension_map = {}
if not cfg.CONF.META.extension_map == '': if not cfg.CONF.META.extension_map == '':
extension_list = [method_set.split(':') extension_list = [method_set.split(':')

3
neutron/plugins/metaplugin/proxy_neutron_plugin.py
View File

@ -17,7 +17,6 @@
from oslo.config import cfg from oslo.config import cfg
from neutron.db import api as db
from neutron.db import db_base_plugin_v2 from neutron.db import db_base_plugin_v2
from neutron.db import external_net_db from neutron.db import external_net_db
from neutron.db import l3_db from neutron.db import l3_db
@ -35,7 +34,7 @@ class ProxyPluginV2(db_base_plugin_v2.NeutronDbPluginV2,
supported_extension_aliases = ["external-net", "router"] supported_extension_aliases = ["external-net", "router"]
def __init__(self, configfile=None): def __init__(self, configfile=None):
db.configure_db() super(ProxyPluginV2, self).__init__()
self.neutron = client.Client( self.neutron = client.Client(
username=cfg.CONF.PROXY.admin_user, username=cfg.CONF.PROXY.admin_user,
password=cfg.CONF.PROXY.admin_password, password=cfg.CONF.PROXY.admin_password,

3
neutron/plugins/midonet/plugin.py
View File

@ -33,7 +33,6 @@ from neutron.common import rpc as n_rpc
from neutron.common import topics from neutron.common import topics
from neutron.db import agents_db from neutron.db import agents_db
from neutron.db import agentschedulers_db from neutron.db import agentschedulers_db
from neutron.db import api as db
from neutron.db import db_base_plugin_v2 from neutron.db import db_base_plugin_v2
from neutron.db import dhcp_rpc_base from neutron.db import dhcp_rpc_base
from neutron.db import external_net_db from neutron.db import external_net_db
@ -209,6 +208,7 @@ class MidonetPluginV2(db_base_plugin_v2.NeutronDbPluginV2,
__native_bulk_support = False __native_bulk_support = False
def __init__(self): def __init__(self):
super(MidonetPluginV2, self).__init__()
# Read config values # Read config values
midonet_conf = cfg.CONF.MIDONET midonet_conf = cfg.CONF.MIDONET
midonet_uri = midonet_conf.midonet_uri midonet_uri = midonet_conf.midonet_uri
@ -231,7 +231,6 @@ class MidonetPluginV2(db_base_plugin_v2.NeutronDbPluginV2,
raise MidonetPluginException(msg=msg) raise MidonetPluginException(msg=msg)
self.setup_rpc() self.setup_rpc()
db.configure_db()
self.base_binding_dict = { self.base_binding_dict = {
portbindings.VIF_TYPE: portbindings.VIF_TYPE_MIDONET, portbindings.VIF_TYPE: portbindings.VIF_TYPE_MIDONET,

4
neutron/plugins/ml2/db.py
View File

@ -28,10 +28,6 @@ from neutron.plugins.ml2 import models
LOG = log.getLogger(__name__) LOG = log.getLogger(__name__)
def initialize():
db_api.configure_db()
def add_network_segment(session, network_id, segment): def add_network_segment(session, network_id, segment):
with session.begin(subtransactions=True): with session.begin(subtransactions=True):
record = models.NetworkSegment( record = models.NetworkSegment(

2
neutron/plugins/ml2/plugin.py
View File

@ -98,10 +98,10 @@ class Ml2Plugin(db_base_plugin_v2.NeutronDbPluginV2,
return self._aliases return self._aliases
def __init__(self): def __init__(self):
super(Ml2Plugin, self).__init__()
# First load drivers, then initialize DB, then initialize drivers # First load drivers, then initialize DB, then initialize drivers
self.type_manager = managers.TypeManager() self.type_manager = managers.TypeManager()
self.mechanism_manager = managers.MechanismManager() self.mechanism_manager = managers.MechanismManager()
db.initialize()
self.type_manager.initialize() self.type_manager.initialize()
self.mechanism_manager.initialize() self.mechanism_manager.initialize()
# bulk support depends on the underlying drivers # bulk support depends on the underlying drivers

4
neutron/plugins/mlnx/db/mlnx_db_v2.py
View File

@ -29,10 +29,6 @@ from neutron.plugins.mlnx.db import mlnx_models_v2
LOG = logging.getLogger(__name__) LOG = logging.getLogger(__name__)
def initialize():
db.configure_db()
def _remove_non_allocatable_vlans(session, allocations, def _remove_non_allocatable_vlans(session, allocations,
physical_network, vlan_ids): physical_network, vlan_ids):
if physical_network in allocations: if physical_network in allocations:

2
neutron/plugins/mlnx/mlnx_plugin.py
View File

@ -95,7 +95,7 @@ class MellanoxEswitchPlugin(db_base_plugin_v2.NeutronDbPluginV2,
def __init__(self): def __init__(self):
"""Start Mellanox Neutron Plugin.""" """Start Mellanox Neutron Plugin."""
db.initialize() super(MellanoxEswitchPlugin, self).__init__()
self._parse_network_vlan_ranges() self._parse_network_vlan_ranges()
db.sync_network_states(self.network_vlan_ranges) db.sync_network_states(self.network_vlan_ranges)
self._set_tenant_network_type() self._set_tenant_network_type()

4
neutron/plugins/nec/db/api.py
View File

@ -56,10 +56,6 @@ def _get_resource_model(resource, old_style):
return resource_map[resource] return resource_map[resource]
def initialize():
db.configure_db()
def clear_db(base=model_base.BASEV2): def clear_db(base=model_base.BASEV2):
db.clear_db(base) db.clear_db(base)

3
neutron/plugins/nec/nec_plugin.py
View File

@ -102,8 +102,7 @@ class NECPluginV2(db_base_plugin_v2.NeutronDbPluginV2,
return self._aliases return self._aliases
def __init__(self): def __init__(self):
super(NECPluginV2, self).__init__()
ndb.initialize()
self.ofc = ofc_manager.OFCManager() self.ofc = ofc_manager.OFCManager()
self.base_binding_dict = self._get_base_binding_dict() self.base_binding_dict = self._get_base_binding_dict()
portbindings_base.register_port_dict_function() portbindings_base.register_port_dict_function()

4
neutron/plugins/nicira/NeutronPlugin.py
View File

@ -38,7 +38,6 @@ from neutron.common import utils
from neutron import context as q_context from neutron import context as q_context
from neutron.db import agentschedulers_db from neutron.db import agentschedulers_db
from neutron.db import allowedaddresspairs_db as addr_pair_db from neutron.db import allowedaddresspairs_db as addr_pair_db
from neutron.db import api as db
from neutron.db import db_base_plugin_v2 from neutron.db import db_base_plugin_v2
from neutron.db import external_net_db from neutron.db import external_net_db
from neutron.db import extraroute_db from neutron.db import extraroute_db
@ -144,7 +143,7 @@ class NvpPluginV2(addr_pair_db.AllowedAddressPairsMixin,
novazone_cluster_map = {} novazone_cluster_map = {}
def __init__(self): def __init__(self):
super(NvpPluginV2, self).__init__()
# TODO(salv-orlando): Replace These dicts with # TODO(salv-orlando): Replace These dicts with
# collections.defaultdict for better handling of default values # collections.defaultdict for better handling of default values
# Routines for managing logical ports in NVP # Routines for managing logical ports in NVP
@ -185,7 +184,6 @@ class NvpPluginV2(addr_pair_db.AllowedAddressPairsMixin,
pbin.CAP_PORT_FILTER: pbin.CAP_PORT_FILTER:
'security-group' in self.supported_extension_aliases}} 'security-group' in self.supported_extension_aliases}}
db.configure_db()
self._extend_fault_map() self._extend_fault_map()
self.setup_dhcpmeta_access() self.setup_dhcpmeta_access()
# Set this flag to false as the default gateway has not # Set this flag to false as the default gateway has not

4
neutron/plugins/openvswitch/ovs_db_v2.py
View File

@ -33,10 +33,6 @@ from neutron.plugins.openvswitch import ovs_models_v2
LOG = logging.getLogger(__name__) LOG = logging.getLogger(__name__)
def initialize():
db.configure_db()
def get_network_binding(session, network_id): def get_network_binding(session, network_id):
session = session or db.get_session() session = session or db.get_session()
try: try:

2
neutron/plugins/openvswitch/ovs_neutron_plugin.py
View File

@ -294,12 +294,12 @@ class OVSNeutronPluginV2(db_base_plugin_v2.NeutronDbPluginV2,
attributes.NETWORKS, ['_extend_network_dict_provider_ovs']) attributes.NETWORKS, ['_extend_network_dict_provider_ovs'])
def __init__(self, configfile=None): def __init__(self, configfile=None):
super(OVSNeutronPluginV2, self).__init__()
self.base_binding_dict = { self.base_binding_dict = {
portbindings.VIF_TYPE: portbindings.VIF_TYPE_OVS, portbindings.VIF_TYPE: portbindings.VIF_TYPE_OVS,
portbindings.CAPABILITIES: { portbindings.CAPABILITIES: {
portbindings.CAP_PORT_FILTER: portbindings.CAP_PORT_FILTER:
'security-group' in self.supported_extension_aliases}} 'security-group' in self.supported_extension_aliases}}
ovs_db_v2.initialize()
self._parse_network_vlan_ranges() self._parse_network_vlan_ranges()
ovs_db_v2.sync_vlan_allocations(self.network_vlan_ranges) ovs_db_v2.sync_vlan_allocations(self.network_vlan_ranges)
self.tenant_network_type = cfg.CONF.OVS.tenant_network_type self.tenant_network_type = cfg.CONF.OVS.tenant_network_type

5
neutron/plugins/plumgrid/plumgrid_plugin/plumgrid_plugin.py
View File

@ -25,7 +25,6 @@ import netaddr
from oslo.config import cfg from oslo.config import cfg
from neutron.api.v2 import attributes from neutron.api.v2 import attributes
from neutron.db import api as db
from neutron.db import db_base_plugin_v2 from neutron.db import db_base_plugin_v2
from neutron.db import external_net_db from neutron.db import external_net_db
from neutron.db import l3_db from neutron.db import l3_db
@ -69,9 +68,7 @@ class NeutronPluginPLUMgridV2(db_base_plugin_v2.NeutronDbPluginV2,
def __init__(self): def __init__(self):
LOG.info(_('Neutron PLUMgrid Director: Starting Plugin')) LOG.info(_('Neutron PLUMgrid Director: Starting Plugin'))
# Plugin DB initialization super(NeutronPluginPLUMgridV2, self).__init__()
db.configure_db()
self.plumgrid_init() self.plumgrid_init()
LOG.debug(_('Neutron PLUMgrid Director: Neutron server with ' LOG.debug(_('Neutron PLUMgrid Director: Neutron server with '

2
neutron/plugins/ryu/ryu_neutron_plugin.py
View File

@ -109,13 +109,13 @@ class RyuNeutronPluginV2(db_base_plugin_v2.NeutronDbPluginV2,
return self._aliases return self._aliases
def __init__(self, configfile=None): def __init__(self, configfile=None):
super(RyuNeutronPluginV2, self).__init__()
self.base_binding_dict = { self.base_binding_dict = {
portbindings.VIF_TYPE: portbindings.VIF_TYPE_OVS, portbindings.VIF_TYPE: portbindings.VIF_TYPE_OVS,
portbindings.CAPABILITIES: { portbindings.CAPABILITIES: {
portbindings.CAP_PORT_FILTER: portbindings.CAP_PORT_FILTER:
'security-group' in self.supported_extension_aliases}} 'security-group' in self.supported_extension_aliases}}
portbindings_base.register_port_dict_function() portbindings_base.register_port_dict_function()
db.configure_db()
self.tunnel_key = db_api_v2.TunnelKey( self.tunnel_key = db_api_v2.TunnelKey(
cfg.CONF.OVS.tunnel_key_min, cfg.CONF.OVS.tunnel_key_max) cfg.CONF.OVS.tunnel_key_min, cfg.CONF.OVS.tunnel_key_max)
self.ofp_api_host = cfg.CONF.OVS.openflow_rest_api self.ofp_api_host = cfg.CONF.OVS.openflow_rest_api

12
neutron/tests/unit/cisco/n1kv/test_n1kv_db.py
View File

@ -100,7 +100,7 @@ class VlanAllocationsTest(base.BaseTestCase):
def setUp(self): def setUp(self):
super(VlanAllocationsTest, self).setUp() super(VlanAllocationsTest, self).setUp()
n1kv_db_v2.initialize() db.configure_db()
self.session = db.get_session() self.session = db.get_session()
n1kv_db_v2.sync_vlan_allocations(self.session, VLAN_RANGES) n1kv_db_v2.sync_vlan_allocations(self.session, VLAN_RANGES)
@ -284,7 +284,7 @@ class VxlanAllocationsTest(base.BaseTestCase,
def setUp(self): def setUp(self):
super(VxlanAllocationsTest, self).setUp() super(VxlanAllocationsTest, self).setUp()
n1kv_db_v2.initialize() db.configure_db()
self.session = db.get_session() self.session = db.get_session()
n1kv_db_v2.sync_vxlan_allocations(self.session, VXLAN_RANGES) n1kv_db_v2.sync_vxlan_allocations(self.session, VXLAN_RANGES)
@ -392,7 +392,7 @@ class NetworkBindingsTest(test_plugin.NeutronDbPluginV2TestCase):
def setUp(self): def setUp(self):
super(NetworkBindingsTest, self).setUp() super(NetworkBindingsTest, self).setUp()
n1kv_db_v2.initialize() db.configure_db()
self.session = db.get_session() self.session = db.get_session()
def tearDown(self): def tearDown(self):
@ -643,7 +643,7 @@ class NetworkProfileTests(base.BaseTestCase,
def setUp(self): def setUp(self):
super(NetworkProfileTests, self).setUp() super(NetworkProfileTests, self).setUp()
n1kv_db_v2.initialize() db.configure_db()
self.session = db.get_session() self.session = db.get_session()
def tearDown(self): def tearDown(self):
@ -828,7 +828,7 @@ class PolicyProfileTests(base.BaseTestCase):
def setUp(self): def setUp(self):
super(PolicyProfileTests, self).setUp() super(PolicyProfileTests, self).setUp()
n1kv_db_v2.initialize() db.configure_db()
self.session = db.get_session() self.session = db.get_session()
def tearDown(self): def tearDown(self):
@ -876,7 +876,7 @@ class ProfileBindingTests(base.BaseTestCase,
def setUp(self): def setUp(self):
super(ProfileBindingTests, self).setUp() super(ProfileBindingTests, self).setUp()
n1kv_db_v2.initialize() db.configure_db()
self.session = db.get_session() self.session = db.get_session()
def tearDown(self): def tearDown(self):

2
neutron/tests/unit/cisco/n1kv/test_n1kv_plugin.py
View File

@ -395,4 +395,4 @@ class TestN1kvNonDbTest(base.BaseTestCase):
""" """
def test_db(self): def test_db(self):
n1kv_db_v2.initialize() db.configure_db()

4
neutron/tests/unit/linuxbridge/test_lb_db.py
View File

@ -38,7 +38,7 @@ PLUGIN_NAME = ('neutron.plugins.linuxbridge.'
class NetworkStatesTest(base.BaseTestCase): class NetworkStatesTest(base.BaseTestCase):
def setUp(self): def setUp(self):
super(NetworkStatesTest, self).setUp() super(NetworkStatesTest, self).setUp()
lb_db.initialize() db.configure_db()
lb_db.sync_network_states(VLAN_RANGES) lb_db.sync_network_states(VLAN_RANGES)
self.session = db.get_session() self.session = db.get_session()
self.addCleanup(db.clear_db) self.addCleanup(db.clear_db)
@ -154,7 +154,7 @@ class NetworkBindingsTest(test_plugin.NeutronDbPluginV2TestCase):
cfg.CONF.set_override('network_vlan_ranges', ['physnet1:1000:2999'], cfg.CONF.set_override('network_vlan_ranges', ['physnet1:1000:2999'],
group='VLANS') group='VLANS')
super(NetworkBindingsTest, self).setUp(plugin=PLUGIN_NAME) super(NetworkBindingsTest, self).setUp(plugin=PLUGIN_NAME)
lb_db.initialize() db.configure_db()
self.session = db.get_session() self.session = db.get_session()
def test_add_network_binding(self): def test_add_network_binding(self):

5
neutron/tests/unit/ml2/test_type_gre.py
View File

@ -18,7 +18,6 @@ from testtools import matchers
from neutron.common import exceptions as exc from neutron.common import exceptions as exc
import neutron.db.api as db import neutron.db.api as db
from neutron.plugins.ml2 import db as ml2_db
from neutron.plugins.ml2 import driver_api as api from neutron.plugins.ml2 import driver_api as api
from neutron.plugins.ml2.drivers import type_gre from neutron.plugins.ml2.drivers import type_gre
from neutron.tests import base from neutron.tests import base
@ -35,7 +34,7 @@ class GreTypeTest(base.BaseTestCase):
def setUp(self): def setUp(self):
super(GreTypeTest, self).setUp() super(GreTypeTest, self).setUp()
ml2_db.initialize() db.configure_db()
self.driver = type_gre.GreTypeDriver() self.driver = type_gre.GreTypeDriver()
self.driver.gre_id_ranges = TUNNEL_RANGES self.driver.gre_id_ranges = TUNNEL_RANGES
self.driver._sync_gre_allocations() self.driver._sync_gre_allocations()
@ -187,7 +186,7 @@ class GreTypeMultiRangeTest(base.BaseTestCase):
def setUp(self): def setUp(self):
super(GreTypeMultiRangeTest, self).setUp() super(GreTypeMultiRangeTest, self).setUp()
ml2_db.initialize() db.configure_db()
self.driver = type_gre.GreTypeDriver() self.driver = type_gre.GreTypeDriver()
self.driver.gre_id_ranges = self.TUNNEL_MULTI_RANGES self.driver.gre_id_ranges = self.TUNNEL_MULTI_RANGES
self.driver._sync_gre_allocations() self.driver._sync_gre_allocations()

5
neutron/tests/unit/ml2/test_type_vxlan.py
View File

@ -21,7 +21,6 @@ from testtools import matchers
from neutron.common import exceptions as exc from neutron.common import exceptions as exc
from neutron.db import api as db from neutron.db import api as db
from neutron.plugins.common import constants as p_const from neutron.plugins.common import constants as p_const
from neutron.plugins.ml2 import db as ml2_db
from neutron.plugins.ml2 import driver_api as api from neutron.plugins.ml2 import driver_api as api
from neutron.plugins.ml2.drivers import type_vxlan from neutron.plugins.ml2.drivers import type_vxlan
from neutron.tests import base from neutron.tests import base
@ -42,7 +41,7 @@ VXLAN_UDP_PORT_TWO = 8888
class VxlanTypeTest(base.BaseTestCase): class VxlanTypeTest(base.BaseTestCase):
def setUp(self): def setUp(self):
super(VxlanTypeTest, self).setUp() super(VxlanTypeTest, self).setUp()
ml2_db.initialize() db.configure_db()
cfg.CONF.set_override('vni_ranges', [TUNNEL_RANGES], cfg.CONF.set_override('vni_ranges', [TUNNEL_RANGES],
group='ml2_type_vxlan') group='ml2_type_vxlan')
cfg.CONF.set_override('vxlan_group', MULTICAST_GROUP, cfg.CONF.set_override('vxlan_group', MULTICAST_GROUP,
@ -207,7 +206,7 @@ class VxlanTypeMultiRangeTest(base.BaseTestCase):
def setUp(self): def setUp(self):
super(VxlanTypeMultiRangeTest, self).setUp() super(VxlanTypeMultiRangeTest, self).setUp()
ml2_db.initialize() db.configure_db()
self.driver = type_vxlan.VxlanTypeDriver() self.driver = type_vxlan.VxlanTypeDriver()
self.driver.vxlan_vni_ranges = self.TUNNEL_MULTI_RANGES self.driver.vxlan_vni_ranges = self.TUNNEL_MULTI_RANGES
self.driver._sync_vxlan_allocations() self.driver._sync_vxlan_allocations()

4
neutron/tests/unit/mlnx/test_mlnx_db.py
View File

@ -35,7 +35,7 @@ TEST_NETWORK_ID = 'abcdefghijklmnopqrstuvwxyz'
class SegmentationIdAllocationTest(base.BaseTestCase): class SegmentationIdAllocationTest(base.BaseTestCase):
def setUp(self): def setUp(self):
super(SegmentationIdAllocationTest, self).setUp() super(SegmentationIdAllocationTest, self).setUp()
mlnx_db.initialize() db.configure_db()
mlnx_db.sync_network_states(VLAN_RANGES) mlnx_db.sync_network_states(VLAN_RANGES)
self.session = db.get_session() self.session = db.get_session()
self.addCleanup(db.clear_db) self.addCleanup(db.clear_db)
@ -158,7 +158,7 @@ class SegmentationIdAllocationTest(base.BaseTestCase):
class NetworkBindingsTest(test_plugin.NeutronDbPluginV2TestCase): class NetworkBindingsTest(test_plugin.NeutronDbPluginV2TestCase):
def setUp(self): def setUp(self):
super(NetworkBindingsTest, self).setUp() super(NetworkBindingsTest, self).setUp()
mlnx_db.initialize() db.configure_db()
self.session = db.get_session() self.session = db.get_session()
def test_add_network_binding(self): def test_add_network_binding(self):

3
neutron/tests/unit/nec/test_ofc_manager.py
View File

@ -18,6 +18,7 @@
import mock import mock
from neutron import context from neutron import context
from neutron.db import api as db
from neutron.openstack.common import uuidutils from neutron.openstack.common import uuidutils
from neutron.plugins.nec.common import config from neutron.plugins.nec.common import config
from neutron.plugins.nec.db import api as ndb from neutron.plugins.nec.db import api as ndb
@ -44,9 +45,9 @@ class OFCManagerTestBase(base.BaseTestCase):
def setUp(self): def setUp(self):
super(OFCManagerTestBase, self).setUp() super(OFCManagerTestBase, self).setUp()
db.configure_db()
driver = "neutron.tests.unit.nec.stub_ofc_driver.StubOFCDriver" driver = "neutron.tests.unit.nec.stub_ofc_driver.StubOFCDriver"
config.CONF.set_override('driver', driver, 'OFC') config.CONF.set_override('driver', driver, 'OFC')
ndb.initialize()
self.addCleanup(ndb.clear_db) self.addCleanup(ndb.clear_db)
self.ofc = ofc_manager.OFCManager() self.ofc = ofc_manager.OFCManager()
# NOTE: enable_autocheck() is a feature of StubOFCDriver # NOTE: enable_autocheck() is a feature of StubOFCDriver

6
neutron/tests/unit/openvswitch/test_ovs_db.py
View File

@ -48,7 +48,7 @@ PLUGIN_NAME = ('neutron.plugins.openvswitch.'
class VlanAllocationsTest(base.BaseTestCase): class VlanAllocationsTest(base.BaseTestCase):
def setUp(self): def setUp(self):
super(VlanAllocationsTest, self).setUp() super(VlanAllocationsTest, self).setUp()
ovs_db_v2.initialize() db.configure_db()
ovs_db_v2.sync_vlan_allocations(VLAN_RANGES) ovs_db_v2.sync_vlan_allocations(VLAN_RANGES)
self.session = db.get_session() self.session = db.get_session()
self.addCleanup(db.clear_db) self.addCleanup(db.clear_db)
@ -192,7 +192,7 @@ class VlanAllocationsTest(base.BaseTestCase):
class TunnelAllocationsTest(base.BaseTestCase): class TunnelAllocationsTest(base.BaseTestCase):
def setUp(self): def setUp(self):
super(TunnelAllocationsTest, self).setUp() super(TunnelAllocationsTest, self).setUp()
ovs_db_v2.initialize() db.configure_db()
ovs_db_v2.sync_tunnel_allocations(TUNNEL_RANGES) ovs_db_v2.sync_tunnel_allocations(TUNNEL_RANGES)
self.session = db.get_session() self.session = db.get_session()
self.addCleanup(db.clear_db) self.addCleanup(db.clear_db)
@ -302,7 +302,7 @@ class NetworkBindingsTest(test_plugin.NeutronDbPluginV2TestCase):
cfg.CONF.set_override('network_vlan_ranges', ['physnet1:1000:2999'], cfg.CONF.set_override('network_vlan_ranges', ['physnet1:1000:2999'],
group='OVS') group='OVS')
super(NetworkBindingsTest, self).setUp(plugin=PLUGIN_NAME) super(NetworkBindingsTest, self).setUp(plugin=PLUGIN_NAME)
ovs_db_v2.initialize() db.configure_db()
self.session = db.get_session() self.session = db.get_session()
def test_add_network_binding(self): def test_add_network_binding(self):

3
neutron/tests/unit/test_quota_ext.py
View File

@ -29,7 +29,6 @@ from neutron.common import exceptions
from neutron import context from neutron import context
from neutron.db import api as db from neutron.db import api as db
from neutron.db import quota_db from neutron.db import quota_db
from neutron.plugins.linuxbridge.db import l2network_db_v2
from neutron import quota from neutron import quota
from neutron.tests import base from neutron.tests import base
from neutron.tests.unit import test_api_v2 from neutron.tests.unit import test_api_v2
@ -73,7 +72,7 @@ class QuotaExtensionTestCase(testlib_api.WebTestCase):
# extra1 here is added later, so have to do it manually # extra1 here is added later, so have to do it manually
quota.QUOTAS.register_resource_by_name('extra1') quota.QUOTAS.register_resource_by_name('extra1')
ext_mgr = extensions.PluginAwareExtensionManager.get_instance() ext_mgr = extensions.PluginAwareExtensionManager.get_instance()
l2network_db_v2.initialize() db.configure_db()
app = config.load_paste_app('extensions_test_app') app = config.load_paste_app('extensions_test_app')
ext_middleware = extensions.ExtensionMiddleware(app, ext_mgr=ext_mgr) ext_middleware = extensions.ExtensionMiddleware(app, ext_mgr=ext_mgr)
self.api = webtest.TestApp(ext_middleware) self.api = webtest.TestApp(ext_middleware)