You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
85 lines
3.2 KiB
85 lines
3.2 KiB
# Copyright (c) 2015 Mellanox Technologies, Ltd |
|
# 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. |
|
|
|
from oslo_config import cfg |
|
from oslo_log import log |
|
import stevedore |
|
|
|
from neutron._i18n import _, _LE, _LI |
|
|
|
LOG = log.getLogger(__name__) |
|
|
|
|
|
L2_AGENT_EXT_MANAGER_NAMESPACE = 'neutron.agent.l2.extensions' |
|
L2_AGENT_EXT_MANAGER_OPTS = [ |
|
cfg.ListOpt('extensions', |
|
default=[], |
|
help=_('Extensions list to use')), |
|
] |
|
|
|
|
|
def register_opts(conf): |
|
conf.register_opts(L2_AGENT_EXT_MANAGER_OPTS, 'agent') |
|
|
|
|
|
class AgentExtensionsManager(stevedore.named.NamedExtensionManager): |
|
"""Manage agent extensions.""" |
|
|
|
def __init__(self, conf): |
|
super(AgentExtensionsManager, self).__init__( |
|
L2_AGENT_EXT_MANAGER_NAMESPACE, conf.agent.extensions, |
|
invoke_on_load=True, name_order=True) |
|
LOG.info(_LI("Loaded agent extensions: %s"), self.names()) |
|
|
|
def initialize(self, connection, driver_type): |
|
"""Initialize enabled L2 agent extensions. |
|
|
|
:param connection: RPC connection that can be reused by extensions to |
|
define their RPC endpoints |
|
:param driver_type: a string that defines the agent type to the |
|
extension. Can be used by the extension to choose |
|
the right backend implementation. |
|
""" |
|
# Initialize each agent extension in the list. |
|
for extension in self: |
|
LOG.info(_LI("Initializing agent extension '%s'"), extension.name) |
|
extension.obj.initialize(connection, driver_type) |
|
|
|
def handle_port(self, context, data): |
|
"""Notify all agent extensions to handle port.""" |
|
for extension in self: |
|
try: |
|
extension.obj.handle_port(context, data) |
|
# TODO(QoS) add agent extensions exception and catch them here |
|
except AttributeError: |
|
LOG.exception( |
|
_LE("Agent Extension '%(name)s' failed " |
|
"while handling port update"), |
|
{'name': extension.name} |
|
) |
|
|
|
def delete_port(self, context, data): |
|
"""Notify all agent extensions to delete port.""" |
|
for extension in self: |
|
try: |
|
extension.obj.delete_port(context, data) |
|
# TODO(QoS) add agent extensions exception and catch them here |
|
# instead of AttributeError |
|
except AttributeError: |
|
LOG.exception( |
|
_LE("Agent Extension '%(name)s' failed " |
|
"while handling port deletion"), |
|
{'name': extension.name} |
|
)
|
|
|