diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/vyos/configtree.py | 24 | ||||
| -rw-r--r-- | python/vyos/ifconfig/bridge.py | 34 | ||||
| -rw-r--r-- | python/vyos/qos/base.py | 9 | 
3 files changed, 59 insertions, 8 deletions
| diff --git a/python/vyos/configtree.py b/python/vyos/configtree.py index d048901f0..423fe01ed 100644 --- a/python/vyos/configtree.py +++ b/python/vyos/configtree.py @@ -20,10 +20,22 @@ from ctypes import cdll, c_char_p, c_void_p, c_int, c_bool  LIBPATH = '/usr/lib/libvyosconfig.so.0' +def replace_backslash(s, search, replace): +    """Modify quoted strings containing backslashes not of escape sequences""" +    def replace_method(match): +        result = match.group().replace(search, replace) +        return result +    p = re.compile(r'("[^"]*[\\][^"]*"\n|\'[^\']*[\\][^\']*\'\n)') +    return p.sub(replace_method, s) +  def escape_backslash(string: str) -> str: -    """Escape single backslashes in string that are not in escape sequence""" -    p = re.compile(r'(?<!\\)[\\](?!b|f|n|r|t|\\[^bfnrt])') -    result = p.sub(r'\\\\', string) +    """Escape single backslashes in quoted strings""" +    result = replace_backslash(string, '\\', '\\\\') +    return result + +def unescape_backslash(string: str) -> str: +    """Unescape backslashes in quoted strings""" +    result = replace_backslash(string, '\\\\', '\\')      return result  def extract_version(s): @@ -165,11 +177,14 @@ class ConfigTree(object):      def to_string(self, ordered_values=False):          config_string = self.__to_string(self.__config, ordered_values).decode() +        config_string = unescape_backslash(config_string)          config_string = "{0}\n{1}".format(config_string, self.__version)          return config_string      def to_commands(self, op="set"): -        return self.__to_commands(self.__config, op.encode()).decode() +        commands = self.__to_commands(self.__config, op.encode()).decode() +        commands = unescape_backslash(commands) +        return commands      def to_json(self):          return self.__to_json(self.__config).decode() @@ -362,6 +377,7 @@ def show_diff(left, right, path=[], commands=False, libpath=LIBPATH):          msg = __get_error().decode()          raise ConfigTreeError(msg) +    res = unescape_backslash(res)      return res  def union(left, right, libpath=LIBPATH): diff --git a/python/vyos/ifconfig/bridge.py b/python/vyos/ifconfig/bridge.py index b29e71394..7936e3da5 100644 --- a/python/vyos/ifconfig/bridge.py +++ b/python/vyos/ifconfig/bridge.py @@ -1,4 +1,4 @@ -# Copyright 2019-2021 VyOS maintainers and contributors <maintainers@vyos.io> +# Copyright 2019-2024 VyOS maintainers and contributors <maintainers@vyos.io>  #  # This library is free software; you can redistribute it and/or  # modify it under the terms of the GNU Lesser General Public @@ -14,12 +14,11 @@  # License along with this library.  If not, see <http://www.gnu.org/licenses/>.  from netifaces import interfaces -import json  from vyos.ifconfig.interface import Interface  from vyos.utils.assertion import assert_boolean +from vyos.utils.assertion import assert_list  from vyos.utils.assertion import assert_positive -from vyos.utils.process import cmd  from vyos.utils.dict import dict_search  from vyos.configdict import get_vlan_ids  from vyos.configdict import list_diff @@ -86,6 +85,10 @@ class BridgeIf(Interface):              'validate': assert_boolean,              'location': '/sys/class/net/{ifname}/bridge/vlan_filtering',          }, +        'vlan_protocol': { +            'validate': lambda v: assert_list(v, ['0x88a8', '0x8100']), +            'location': '/sys/class/net/{ifname}/bridge/vlan_protocol', +        },          'multicast_querier': {              'validate': assert_boolean,              'location': '/sys/class/net/{ifname}/bridge/multicast_querier', @@ -248,6 +251,26 @@ class BridgeIf(Interface):          """          return self.set_interface('del_port', interface) +    def set_vlan_protocol(self, protocol): +        """ +        Set protocol used for VLAN filtering. +        The valid values are 0x8100(802.1q) or 0x88A8(802.1ad). + +        Example: +        >>> from vyos.ifconfig import Interface +        >>> BridgeIf('br0').del_port('eth1') +        """ + +        if protocol not in ['802.1q', '802.1ad']: +            raise ValueError() + +        map = { +            '802.1ad': '0x88a8', +            '802.1q' : '0x8100' +        } + +        return self.set_interface('vlan_protocol', map[protocol]) +      def update(self, config):          """ General helper function which works on a dictionary retrived by          get_config_dict(). It's main intention is to consolidate the scattered @@ -294,10 +317,13 @@ class BridgeIf(Interface):              if member in interfaces():                  self.del_port(member) -        # enable/disable Vlan Filter +        # enable/disable VLAN Filter          tmp = '1' if 'enable_vlan' in config else '0'          self.set_vlan_filter(tmp) +        tmp = config.get('protocol') +        self.set_vlan_protocol(tmp) +          # add VLAN interfaces to local 'parent' bridge to allow forwarding          if 'enable_vlan' in config:              for vlan in config.get('vif_remove', {}): diff --git a/python/vyos/qos/base.py b/python/vyos/qos/base.py index 47318122b..c8e881ee2 100644 --- a/python/vyos/qos/base.py +++ b/python/vyos/qos/base.py @@ -324,6 +324,11 @@ class QoSBase:                              if 'burst' in cls_config:                                  burst = cls_config['burst']                                  filter_cmd += f' burst {burst}' + +                            if 'mtu' in cls_config: +                                mtu = cls_config['mtu'] +                                filter_cmd += f' mtu {mtu}' +                          cls = int(cls)                          filter_cmd += f' flowid {self._parent:x}:{cls:x}'                          self._cmd(filter_cmd) @@ -387,6 +392,10 @@ class QoSBase:                      burst = config['default']['burst']                      filter_cmd += f' burst {burst}' +                if 'mtu' in config['default']: +                    mtu = config['default']['mtu'] +                    filter_cmd += f' mtu {mtu}' +                  if 'class' in config:                      filter_cmd += f' flowid {self._parent:x}:{default_cls_id:x}' | 
