"""Manage flooding/learning on datapaths."""
# Copyright (C) 2013 Nippon Telegraph and Telephone Corporation.
# Copyright (C) 2015 Brad Cowie, Christopher Lorier and Joe Stringer.
# Copyright (C) 2015 Research and Education Advanced Network New Zealand Ltd.
# Copyright (C) 2015--2019 The Contributors
#
# 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 faucet.valve_switch_standalone import (
ValveSwitchManager, ValveSwitchFlowRemovedManager)
from faucet.valve_switch_stack import (
ValveSwitchStackManagerNoReflection, ValveSwitchStackManagerReflection)
[docs]def valve_switch_factory(logger, dp, pipeline, acl_manager): # pylint: disable=invalid-name
"""Return switch flood/learning manager based on datapath configuration.
Args:
logger: logger instance.
dp: DP instance.
pipeline: ValvePipeline instance.
acl_manager: AclManager instance.
Returns:
switch manager instance.
"""
restricted_bcast_arpnd = bool(dp.restricted_bcast_arpnd_ports())
eth_dst_hairpin_table = dp.tables.get('eth_dst_hairpin', None)
vlan_acl_table = dp.tables.get('vlan_acl', None)
switch_args = {
'logger': logger,
'ports': dp.ports,
'vlans': dp.vlans,
'vlan_table': dp.tables['vlan'],
'vlan_acl_table': vlan_acl_table,
'eth_src_table': dp.tables['eth_src'],
'eth_dst_table': dp.tables['eth_dst'],
'eth_dst_hairpin_table': eth_dst_hairpin_table,
'flood_table': dp.tables['flood'],
'classification_table': dp.classification_table,
'pipeline': pipeline,
'use_group_table': dp.group_table,
'groups': dp.groups,
'combinatorial_port_flood': dp.combinatorial_port_flood,
'canonical_port_order': dp.canonical_port_order,
'restricted_bcast_arpnd': restricted_bcast_arpnd,
'has_externals': dp.has_externals,
'learn_ban_timeout': dp.learn_ban_timeout,
'learn_timeout': dp.timeout,
'learn_jitter': dp.learn_jitter,
'cache_update_guard_time': dp.cache_update_guard_time,
'idle_dst': dp.idle_dst,
'dp_high_priority': dp.high_priority,
'dp_highest_priority': dp.highest_priority,
'faucet_dp_mac': dp.faucet_dp_mac,
}
if dp.stack_graph:
switch_class = ValveSwitchStackManagerNoReflection
if dp.stack_root_flood_reflection:
switch_class = ValveSwitchStackManagerReflection
logger.info('Using stacking root flood reflection')
else:
logger.info('Not using stacking root flood reflection')
switch_args.update({
'stack_ports': dp.stack_ports,
'dp_shortest_path_to_root': dp.shortest_path_to_root,
'shortest_path': dp.shortest_path,
'shortest_path_port': dp.shortest_path_port,
'is_stack_root': dp.is_stack_root,
'is_stack_root_candidate': dp.is_stack_root_candidate,
'is_stack_edge': dp.is_stack_edge,
'dp_name': dp.name,
'graph': dp.stack_graph,
'tunnel_acls': dp.tunnel_acls,
'acl_manager': acl_manager,
})
return switch_class(**switch_args)
switch_class = ValveSwitchManager
if dp.use_idle_timeout:
switch_class = ValveSwitchFlowRemovedManager
return switch_class(**switch_args) # pytype: disable=wrong-keyword-args