On Fri, Jun 28, 2024 at 12:20 PM Dean Marx <[email protected]> wrote:
>
> This suite tests the ability of the Poll Mode Driver to enable
> and disable Rx/Tx queues on a port.
>
> Signed-off-by: Dean Marx <[email protected]>
> ---
> dts/tests/TestSuite_queue_start_stop.py | 95 +++++++++++++++++++++++++
> 1 file changed, 95 insertions(+)
> create mode 100644 dts/tests/TestSuite_queue_start_stop.py
>
> diff --git a/dts/tests/TestSuite_queue_start_stop.py
> b/dts/tests/TestSuite_queue_start_stop.py
> new file mode 100644
> index 0000000000..48306cf03c
> --- /dev/null
> +++ b/dts/tests/TestSuite_queue_start_stop.py
> @@ -0,0 +1,95 @@
> +# SPDX-License-Identifier: BSD-3-Clause
> +# Copyright(c) 2024 University of New Hampshire
> +
> +"""Rx/Tx queue start and stop functionality suite.
> +
> +This suite tests the ability of the poll mode driver to start and
> +stop either the Rx or Tx queue (depending on the port) during runtime,
> +and verify that packets are not received when one is disabled.
> +
> +Given a paired port topology, the Rx queue will be disabled on port 0,
> +and the Tx queue will be disabled on port 1.
> +
> +"""
> +
> +from scapy.layers.inet import IP # type: ignore[import]
> +from scapy.layers.l2 import Ether # type: ignore[import]
> +from scapy.packet import Raw # type: ignore[import]
> +
> +from framework.remote_session.testpmd_shell import SimpleForwardingModes,
> TestPmdShell
> +from framework.test_suite import TestSuite
> +
> +
> +class TestQueueStartStop(TestSuite):
> + """DPDK Queue start/stop test suite.
> +
> + Ensures Rx/Tx queue on a port can be disabled and enabled.
> + Verifies packets are not received when either queue is disabled.
> + The suite contains two test cases, Rx queue start/stop and
> + Tx queue start/stop, which each disable the corresponding
> + queue and verify that packets are not received/forwarded.
> + """
> +
> + def set_up_suite(self) -> None:
> + """Set up the test suite.
> +
> + Setup:
> + Verify that at least two ports are open for session.
> + """
> + self.verify(len(self._port_links) > 1, "Not enough ports")
> +
> + def send_packet_and_verify(self, should_receive: bool = True):
> + """Generate a packet, send to the DUT, and verify it is forwarded
> back.
> +
> + Args:
> + should_receive: Indicate whether the packet should be received.
> + queue_type: Indicate which port should be verified (True for Rx,
> False for Tx.)
This arg doesn't seem to be part of this method anymore, we should
pull it from the documentation too.
> + """
> + packet = Ether() / IP() / Raw(load="xxxxx")
> + received = self.send_packet_and_capture(packet)
> + contains_packet = any(
> + packet.haslayer(Raw) and b"xxxxx" in packet.load for packet in
> received
> + )
> + self.verify(
> + should_receive == contains_packet,
> + f"Packet was {'dropped' if should_receive else 'received'}",
> + )
> +
<snip>
> --
> 2.44.0
>
