diff options
Diffstat (limited to 'networking_sfc/extensions/flowclassifier.py')
| -rw-r--r-- | networking_sfc/extensions/flowclassifier.py | 304 |
1 files changed, 0 insertions, 304 deletions
diff --git a/networking_sfc/extensions/flowclassifier.py b/networking_sfc/extensions/flowclassifier.py deleted file mode 100644 index 93d2284..0000000 --- a/networking_sfc/extensions/flowclassifier.py +++ /dev/null @@ -1,304 +0,0 @@ -# Copyright 2015 Futurewei. 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 abc import ABCMeta -from abc import abstractmethod - -import six - -from oslo_config import cfg - -from neutron.api import extensions as neutron_ext -from neutron.api.v2 import attributes as attr -from neutron.api.v2 import resource_helper -from neutron.common import constants as const -from neutron.common import exceptions as neutron_exc -from neutron.services import service_base - -import networking_sfc - - -cfg.CONF.import_opt('api_extensions_path', 'neutron.common.config') -neutron_ext.append_api_extensions_path(networking_sfc.extensions.__path__) -FLOW_CLASSIFIER_EXT = "flow_classifier" -FLOW_CLASSIFIER_PREFIX = "/sfc" - -fc_supported_protocols = [const.PROTO_NAME_TCP, - const.PROTO_NAME_UDP, const.PROTO_NAME_ICMP] -fc_supported_ethertypes = ['IPv4', 'IPv6'] -SUPPORTED_L7_PARAMETERS = [] -DEFAULT_L7_PARAMETER = {} - - -# Flow Classifier Exceptions -class FlowClassifierNotFound(neutron_exc.NotFound): - message = _("Flow Classifier %(id)s not found.") - - -class FlowClassifierPortNotFound(neutron_exc.NotFound): - message = _("Flow Classifier Neutron Port %(id)s not found.") - - -class FlowClassifierInvalidPortRange(neutron_exc.InvalidInput): - message = _("Invalid IP protocol port range. min_port_range=" - "%(port_range_min)s must be lesser or equal to " - "max_port_range=%(port_range_max)s.") - - -class FlowClassifierInvalidPortValue(neutron_exc.InvalidInput): - message = _("Flow Classifier has invalid port value %(port)s") - - -class FlowClassiferDuplicateInformation(neutron_exc.InvalidInput): - message = _("Flow Classfier has duplicate information: " - "Neutron Port id %(port_id)s and ip prefix %(ip_prefix)s") - - -class FlowClassifierInUse(neutron_exc.InUse): - message = _("Flow Classifier %(id)s in use.") - - -class FlowClassifierInvalidProtocol(neutron_exc.InvalidInput): - message = _("Flow Classifier does not support protocol %(protocol)s. " - "Supported protocol values are %(values)s.") - - -class FlowClassifierInvalidEthertype(neutron_exc.InvalidInput): - message = _("Flow Classifier does not support ethertype %(ethertype)s. " - "Supported ethertype values are %(values)s.") - - -class FlowClassifierProtocolRequiredWithPorts(neutron_exc.InvalidInput): - message = _("IP protocol must be TCP or UDP, if port range is given.") - - -class FlowClassifierInvalidL7Parameter(neutron_exc.InvalidInput): - message = _( - "Flow classifier does not support L7 parameter " - "(%%(key)s, %%(value)s). Supported L7 parameters are " - "%(supported_parameters)s." - ) % {'supported_parameters': SUPPORTED_L7_PARAMETERS} - - -def normalize_protocol(value): - if value is None: - return None - if isinstance(value, six.string_types): - if value.lower() in fc_supported_protocols: - return value.lower() - raise FlowClassifierInvalidProtocol( - protocol=value, values=fc_supported_protocols) - - -def normalize_ethertype(value): - if value is None: - return 'IPv4' - if isinstance(value, six.string_types): - for ether_type in fc_supported_ethertypes: - if value.lower() == ether_type.lower(): - return ether_type - raise FlowClassifierInvalidEthertype( - ethertype=value, values=fc_supported_ethertypes) - - -def normalize_string(value): - if value is None: - return '' - return value - - -def normalize_port_value(port): - if port is None: - return None - try: - val = int(port) - except (ValueError, TypeError): - raise FlowClassifierInvalidPortValue(port=port) - - if 0 <= val <= 65535: - return val - else: - raise FlowClassifierInvalidPortValue(port=port) - - -def normalize_l7parameters(parameters): - parameters = attr.convert_none_to_empty_dict(parameters) - if not parameters: - return DEFAULT_L7_PARAMETER - for key, value in six.iteritems(parameters): - if (key, value) not in SUPPORTED_L7_PARAMETERS: - raise FlowClassifierInvalidL7Parameter(key=key, value=value) - return parameters - - -# Attribute Map -RESOURCE_ATTRIBUTE_MAP = { - 'flow_classifiers': { - 'id': { - 'allow_post': False, 'allow_put': False, - 'is_visible': True, - 'validate': {'type:uuid': None}, - 'primary_key': True}, - 'name': { - 'allow_post': True, 'allow_put': True, - 'is_visible': True, 'default': None, - 'validate': {'type:string': attr.NAME_MAX_LEN}, - 'convert_to': normalize_string}, - 'description': { - 'allow_post': True, 'allow_put': True, - 'is_visible': True, 'default': None, - 'validate': {'type:string': attr.DESCRIPTION_MAX_LEN}, - 'convert_to': normalize_string}, - 'tenant_id': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, - 'validate': {'type:string': attr.TENANT_ID_MAX_LEN}, - 'required_by_policy': True}, - 'ethertype': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, 'default': None, - 'convert_to': normalize_ethertype}, - 'protocol': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, 'default': None, - 'convert_to': normalize_protocol}, - 'source_port_range_min': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, 'default': None, - 'convert_to': normalize_port_value}, - 'source_port_range_max': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, 'default': None, - 'convert_to': normalize_port_value}, - 'destination_port_range_min': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, 'default': None, - 'convert_to': normalize_port_value}, - 'destination_port_range_max': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, 'default': None, - 'convert_to': normalize_port_value}, - 'source_ip_prefix': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, 'default': None, - 'validate': {'type:subnet_or_none': None}}, - 'destination_ip_prefix': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, 'default': None, - 'validate': {'type:subnet_or_none': None}}, - 'logical_source_port': { - 'allow_post': True, 'allow_put': False, - 'is_visible': False, 'default': None, - 'validate': {'type:uuid_or_none': None}}, - 'logical_destination_port': { - 'allow_post': True, 'allow_put': False, - 'is_visible': False, 'default': None, - 'validate': {'type:uuid_or_none': None}}, - 'l7_parameters': { - 'allow_post': True, 'allow_put': False, - 'is_visible': True, 'default': None, - 'validate': {'type:dict': None}, - 'convert_to': normalize_l7parameters}, - }, -} - -flow_classifier_quota_opts = [ - cfg.IntOpt('quota_flow_classifier', - default=100, - help=_('Maximum number of flow classifiers per tenant. ' - 'A negative value means unlimited.')), -] -cfg.CONF.register_opts(flow_classifier_quota_opts, 'QUOTAS') - - -class Flowclassifier(neutron_ext.ExtensionDescriptor): - """Flow Classifier extension.""" - - @classmethod - def get_name(cls): - return FLOW_CLASSIFIER_EXT - - @classmethod - def get_alias(cls): - return FLOW_CLASSIFIER_EXT - - @classmethod - def get_description(cls): - return "Flow Classifier Extension." - - @classmethod - def get_plugin_interface(cls): - return FlowClassifierPluginBase - - @classmethod - def get_updated(cls): - return "2015-10-05T10:00:00-00:00" - - def update_attributes_map(self, attributes): - super(Flowclassifier, self).update_attributes_map( - attributes, extension_attrs_map=RESOURCE_ATTRIBUTE_MAP) - - @classmethod - def get_resources(cls): - """Returns Ext Resources.""" - plural_mappings = resource_helper.build_plural_mappings( - {}, RESOURCE_ATTRIBUTE_MAP) - plural_mappings['flow_classifiers'] = 'flow_classifier' - attr.PLURALS.update(plural_mappings) - return resource_helper.build_resource_info( - plural_mappings, - RESOURCE_ATTRIBUTE_MAP, - FLOW_CLASSIFIER_EXT, - register_quota=True) - - def get_extended_resources(self, version): - if version == "2.0": - return RESOURCE_ATTRIBUTE_MAP - else: - return {} - - -@six.add_metaclass(ABCMeta) -class FlowClassifierPluginBase(service_base.ServicePluginBase): - - def get_plugin_name(self): - return FLOW_CLASSIFIER_EXT - - def get_plugin_type(self): - return FLOW_CLASSIFIER_EXT - - def get_plugin_description(self): - return 'Flow classifier plugin' - - @abstractmethod - def create_flow_classifier(self, context, flow_classifier): - pass - - @abstractmethod - def update_flow_classifier(self, context, id, flow_classifier): - pass - - @abstractmethod - def delete_flow_classifier(self, context, id): - pass - - @abstractmethod - def get_flow_classifiers(self, context, filters=None, fields=None, - sorts=None, limit=None, marker=None, - page_reverse=False): - pass - - @abstractmethod - def get_flow_classifier(self, context, id, fields=None): - pass |