openstack/neutron
Code Issues Proposed changes

Call the "tc qdisc" command for ingress qdisc without parent

Browse Source 
The "tc qdisc" command to create an ingress qdisc does not require
to define a parent qdisc [1]. The ingress qdisc "differs from other
qdiscs in that it does not occupy the root of a device".

The previous command was replacing the default root egress qdisc:
  root@dev20:~# ip netns exec ns01 tc qdisc show
  qdisc noqueue 0: dev dummy root refcnt 2

This operation is now not permitted with the new kernel.

This patch is also changing how the TC funtional tests interact with
the namespace interface created. Now the interface is set to UP before
the test starts. That changes the "tc qdisc show" command because now
the default qdisc (see the aforementioned CLI output) is now present,
as it should be in a live environment (where the interfaces are UP).

Closes-Bug: #2034540

[1]https://tldp.org/HOWTO/Adv-Routing-HOWTO/lartc.adv-qdisc.ingress.html

Change-Id: I2f8130dc3cf3244be2a44a4ecbdbaa9c7f865731
This commit is contained in:
Rodolfo Alonso Hernandez 2023-09-06 15:58:31 +00:00
parent 37c4998699
commit 8cba9a2ee8
1 changed files with 30 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
neutron/tests/functional/privileged/agent/linux/test_tc_lib.py
View File

@ -34,6 +34,7 @@ class TcQdiscTestCase(functional_base.BaseSudoTestCase):
self.addCleanup(self._remove_ns, self.namespace)
self.device = 'int_dummy'
priv_ip_lib.create_interface(self.device, self.namespace, 'dummy')
priv_ip_lib.set_link_attribute(self.device, self.namespace, state='up')
def _remove_ns(self, namespace):
priv_ip_lib.remove_netns(namespace)
@ -53,7 +54,9 @@ class TcQdiscTestCase(functional_base.BaseSudoTestCase):
namespace=self.namespace)
qdiscs = priv_tc_lib.list_tc_qdiscs(self.device,
namespace=self.namespace)
self.assertEqual(0, len(qdiscs))
self.assertEqual(1, len(qdiscs))
self.assertEqual('noqueue',
linux_utils.get_attr(qdiscs[0], 'TCA_KIND'))
def test_add_tc_qdisc_htb_no_handle(self):
priv_tc_lib.add_tc_qdisc(
@ -70,7 +73,9 @@ class TcQdiscTestCase(functional_base.BaseSudoTestCase):
namespace=self.namespace)
qdiscs = priv_tc_lib.list_tc_qdiscs(self.device,
namespace=self.namespace)
self.assertEqual(0, len(qdiscs))
self.assertEqual(1, len(qdiscs))
self.assertEqual('noqueue',
linux_utils.get_attr(qdiscs[0], 'TCA_KIND'))
def test_add_tc_qdisc_tbf(self):
burst = 192000
@ -96,24 +101,30 @@ class TcQdiscTestCase(functional_base.BaseSudoTestCase):
namespace=self.namespace)
qdiscs = priv_tc_lib.list_tc_qdiscs(self.device,
namespace=self.namespace)
self.assertEqual(0, len(qdiscs))
self.assertEqual(1, len(qdiscs))
self.assertEqual('noqueue',
linux_utils.get_attr(qdiscs[0], 'TCA_KIND'))
def test_add_tc_qdisc_ingress(self):
priv_tc_lib.add_tc_qdisc(self.device, kind='ingress',
namespace=self.namespace)
qdiscs = priv_tc_lib.list_tc_qdiscs(self.device,
namespace=self.namespace)
self.assertEqual(1, len(qdiscs))
self.assertEqual('ingress', linux_utils.get_attr(qdiscs[0],
self.assertEqual(2, len(qdiscs))
self.assertEqual('noqueue',
linux_utils.get_attr(qdiscs[0], 'TCA_KIND'))
self.assertEqual('ingress', linux_utils.get_attr(qdiscs[1],
'TCA_KIND'))
self.assertEqual(rtnl.TC_H_INGRESS, qdiscs[0]['parent'])
self.assertEqual(0xffff0000, qdiscs[0]['handle'])
self.assertEqual(rtnl.TC_H_INGRESS, qdiscs[1]['parent'])
self.assertEqual(0xffff0000, qdiscs[1]['handle'])
priv_tc_lib.delete_tc_qdisc(self.device, kind='ingress',
namespace=self.namespace)
qdiscs = priv_tc_lib.list_tc_qdiscs(self.device,
namespace=self.namespace)
self.assertEqual(0, len(qdiscs))
self.assertEqual(1, len(qdiscs))
self.assertEqual('noqueue',
linux_utils.get_attr(qdiscs[0], 'TCA_KIND'))
def test_delete_tc_qdisc_no_device(self):
self.assertRaises(
@ -140,15 +151,19 @@ class TcQdiscTestCase(functional_base.BaseSudoTestCase):
namespace=self.namespace)
qdiscs = priv_tc_lib.list_tc_qdiscs(self.device,
namespace=self.namespace)
self.assertEqual(1, len(qdiscs))
self.assertEqual('ingress', linux_utils.get_attr(qdiscs[0],
self.assertEqual(2, len(qdiscs))
self.assertEqual('noqueue',
linux_utils.get_attr(qdiscs[0], 'TCA_KIND'))
self.assertEqual('ingress', linux_utils.get_attr(qdiscs[1],
'TCA_KIND'))
self.assertIsNone(
priv_tc_lib.delete_tc_qdisc(self.device, kind='ingress',
namespace=self.namespace))
qdiscs = priv_tc_lib.list_tc_qdiscs(self.device,
namespace=self.namespace)
self.assertEqual(0, len(qdiscs))
self.assertEqual(1, len(qdiscs))
self.assertEqual('noqueue',
linux_utils.get_attr(qdiscs[0], 'TCA_KIND'))
self.assertEqual(
errno.EINVAL,
priv_tc_lib.delete_tc_qdisc(self.device, kind='ingress',
@ -170,6 +185,7 @@ class TcPolicyClassTestCase(functional_base.BaseSudoTestCase):
self.addCleanup(self._remove_ns, self.namespace)
self.device = 'int_dummy'
priv_ip_lib.create_interface('int_dummy', self.namespace, 'dummy')
priv_ip_lib.set_link_attribute(self.device, self.namespace, state='up')
def _remove_ns(self, namespace):
priv_ip_lib.remove_netns(namespace)
@ -251,6 +267,7 @@ class TcFilterClassTestCase(functional_base.BaseSudoTestCase):
self.addCleanup(self._remove_ns, self.namespace)
self.device = 'int_dummy'
priv_ip_lib.create_interface('int_dummy', self.namespace, 'dummy')
priv_ip_lib.set_link_attribute(self.device, self.namespace, state='up')
def _remove_ns(self, namespace):
priv_ip_lib.remove_netns(namespace)
@ -277,9 +294,8 @@ class TcFilterClassTestCase(functional_base.BaseSudoTestCase):
self.assertEqual(value, filter_keys[index])
def test_add_tc_filter_policy(self):
priv_tc_lib.add_tc_qdisc(
self.device, parent=rtnl.TC_H_ROOT, kind='ingress',
namespace=self.namespace)
priv_tc_lib.add_tc_qdisc(self.device, kind='ingress',
namespace=self.namespace)
# NOTE(ralonsoh):
# - rate: 320000 bytes/sec (pyroute2 units) = 2560 kbits/sec (OS units)