* [PATCH v1] Initial implementation queue start stop suite
@ 2024-06-12 20:03 Dean Marx
0 siblings, 0 replies; only message in thread
From: Dean Marx @ 2024-06-12 20:03 UTC (permalink / raw)
To: Honnappa.Nagarahalli, juraj.linkes, probb, paul.szczepanek,
yoan.picchi, jspewock, bruce.richardson, luca.vizzarro
Cc: dev, Dean Marx
diff --git a/dts/tests/TestSuite_queue_start_stop.py b/dts/tests/TestSuite_queue_start_stop.py
new file mode 100644
index 0000000000..8c60687d1b
--- /dev/null
+++ b/dts/tests/TestSuite_queue_start_stop.py
@@ -0,0 +1,88 @@
+# 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 testpmd to start and stop
+either the Rx or Tx queue 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 TestPmdForwardingModes, TestPmdShell
+from framework.test_suite import TestSuite
+
+class TestQueueStartStop(TestSuite):
+ """DPDK Queue start/stop test suite.
+
+ Ensures Rx/Tx queue can be disabled and enabled during testpmd runtime.
+ Verifies packets are not received when either queue is disabled.
+ """
+
+ def set_up_suite(self) -> None:
+ """Set up the test suite.
+
+ Setup:
+ Create a testpmd session and set up tg nodes
+ 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
+ """
+ packet = Ether()/IP()/Raw()
+ received = self.send_packet_and_capture(packet)
+ if should_receive:
+ self.verify(len(received) == 1, "Packet was dropped when it should have been received")
+ else:
+ self.verify(len(received) == 0, "Packet was received when it should have been dropped")
+
+ def test_all_queues_enabled(self) -> None:
+ """Ensure packets are received when both Tx and Rx queues are enabled.
+
+ Test:
+ Create a testpmd session and verify packets are received."""
+ testpmd = self.sut_node.create_interactive_shell(TestPmdShell, privileged=True)
+ testpmd.set_forward_mode(TestPmdForwardingModes.mac)
+ testpmd.send_command("set verbose 1", "testpmd>")
+ testpmd.start()
+
+ self.send_packet_and_verify(True)
+ testpmd.close()
+
+ def test_queue_start_stop(self) -> None:
+ """Ensure packets are not received when either Rx/Tx queue is disabled.
+
+ Test:
+ Create an interactive testpmd session, stop Rx queue on port 0, verify
+ packets are dropped. Then start port 0 Rx queue, stop port 1 Tx queue, and
+ verify packets are dropped."""
+ testpmd = self.sut_node.create_interactive_shell(TestPmdShell, privileged=True)
+ testpmd.set_forward_mode(TestPmdForwardingModes.mac)
+ testpmd.send_command("set verbose 1", "testpmd>")
+ testpmd.send_command("port 0 rxq 0 stop", "testpmd>")
+
+ testpmd.start()
+ self.send_packet_and_verify(False)
+ testpmd.close()
+
+ testpmd.send_command("port 0 rxq 0 start", "testpmd>")
+ testpmd.send_command("port 1 txq 0 stop", "testpmd>")
+
+ testpmd.start()
+ self.send_packet_and_verify(False)
+ testpmd.close()
+
+ def tear_down_suite(self) -> None:
+ """Tear down the suite."""
\ No newline at end of file
--
2.44.0
^ permalink raw reply [flat|nested] only message in thread
only message in thread, other threads:[~2024-06-12 20:04 UTC | newest]
Thread overview: (only message) (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2024-06-12 20:03 [PATCH v1] Initial implementation queue start stop suite Dean Marx
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).