From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id 1942246055; Fri, 10 Jan 2025 16:49:13 +0100 (CET) Received: from mails.dpdk.org (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 5D0C04279E; Fri, 10 Jan 2025 16:49:11 +0100 (CET) Received: from foss.arm.com (foss.arm.com [217.140.110.172]) by mails.dpdk.org (Postfix) with ESMTP id 667604279D for ; Fri, 10 Jan 2025 16:49:10 +0100 (CET) Received: from usa-sjc-imap-foss1.foss.arm.com (unknown [10.121.207.14]) by usa-sjc-mx-foss1.foss.arm.com (Postfix) with ESMTP id 968181477; Fri, 10 Jan 2025 07:49:37 -0800 (PST) Received: from localhost.localdomain (unknown [10.57.73.232]) by usa-sjc-imap-foss1.foss.arm.com (Postfix) with ESMTPA id 76B1F3F59E; Fri, 10 Jan 2025 07:49:08 -0800 (PST) From: Paul Szczepanek To: dev@dpdk.org Cc: Jeremy Spewock , Paul Szczepanek , Luca Vizzarro Subject: [PATCH v9] dts: add offload version of buffer scatter test Date: Fri, 10 Jan 2025 15:48:56 +0000 Message-Id: <20250110154856.1703191-1-paul.szczepanek@arm.com> X-Mailer: git-send-email 2.39.2 In-Reply-To: <20240827172255.10468-2-jspewock@iol.unh.edu> References: <20240827172255.10468-2-jspewock@iol.unh.edu> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org From: Jeremy Spewock Some NICs tested in DPDK allow for the scattering of packets without an offload and others enforce that you enable the scattered_rx offload in testpmd. The current version of the suite for testing support of scattering packets only tests the case where the NIC supports testing without the offload, so an expansion of coverage is needed to cover the second case as well. Signed-off-by: Jeremy Spewock Signed-off-by: Paul Szczepanek Reviewed-by: Luca Vizzarro --- dts/tests/TestSuite_pmd_buffer_scatter.py | 49 ++++++++++++++--------- 1 file changed, 30 insertions(+), 19 deletions(-) diff --git a/dts/tests/TestSuite_pmd_buffer_scatter.py b/dts/tests/TestSuite_pmd_buffer_scatter.py index b2f42425d4..a8c111eea7 100644 --- a/dts/tests/TestSuite_pmd_buffer_scatter.py +++ b/dts/tests/TestSuite_pmd_buffer_scatter.py @@ -19,7 +19,7 @@ from scapy.layers.inet import IP from scapy.layers.l2 import Ether -from scapy.packet import Raw +from scapy.packet import Packet, Raw from scapy.utils import hexstr from framework.params.testpmd import SimpleForwardingModes @@ -61,65 +61,70 @@ def set_up_suite(self) -> None: self.tg_node.main_session.configure_port_mtu(9000, self._tg_port_egress) self.tg_node.main_session.configure_port_mtu(9000, self._tg_port_ingress) - def scatter_pktgen_send_packet(self, pktsize: int) -> str: + def scatter_pktgen_send_packet(self, pkt_size: int) -> list[Packet]: """Generate and send a packet to the SUT then capture what is forwarded back. Generate an IP packet of a specific length and send it to the SUT, - then capture the resulting received packet and extract its payload. - The desired length of the packet is met by packing its payload + then capture the resulting received packets and filter them down to the ones that have the + correct layers. The desired length of the packet is met by packing its payload with the letter "X" in hexadecimal. Args: - pktsize: Size of the packet to generate and send. + pkt_size: Size of the packet to generate and send. Returns: - The payload of the received packet as a string. + The filtered down list of received packets. """ packet = Ether() / IP() / Raw() if layer2 := packet.getlayer(2): layer2.load = "" - payload_len = pktsize - len(packet) - 4 + payload_len = pkt_size - len(packet) - 4 payload = ["58"] * payload_len # pack the payload for X_in_hex in payload: packet.load += struct.pack("=B", int("%s%s" % (X_in_hex[0], X_in_hex[1]), 16)) received_packets = self.send_packet_and_capture(packet) + # filter down the list to packets that have the appropriate structure + received_packets = [p for p in received_packets if Ether in p and IP in p and Raw in p] + self.verify(len(received_packets) > 0, "Did not receive any packets.") layer2 = received_packets[0].getlayer(2) self.verify(layer2 is not None, "The received packet is invalid.") assert layer2 is not None - load = hexstr(layer2, onlyhex=1) - return load + return received_packets - def pmd_scatter(self, mbsize: int) -> None: + def pmd_scatter(self, mb_size: int, enable_offload: bool = False) -> None: """Testpmd support of receiving and sending scattered multi-segment packets. Support for scattered packets is shown by sending 5 packets of differing length where the length of the packet is calculated by taking mbuf-size + an offset. The offsets used in the test are -1, 0, 1, 4, 5 respectively. + Args: + mb_size: Size to set memory buffers to when starting testpmd. + enable_offload: Whether or not to offload the scattering functionality in testpmd. + Test: - Start testpmd and run functional test with preset mbsize. + Start testpmd and run functional test with preset `mb_size`. """ with TestPmdShell( self.sut_node, forward_mode=SimpleForwardingModes.mac, mbcache=200, - mbuf_size=[mbsize], + mbuf_size=[mb_size], max_pkt_len=9000, tx_offloads=0x00008000, + enable_scatter=True if enable_offload else None, ) as testpmd: testpmd.start() for offset in [-1, 0, 1, 4, 5]: - recv_payload = self.scatter_pktgen_send_packet(mbsize + offset) - self._logger.debug( - f"Payload of scattered packet after forwarding: \n{recv_payload}" - ) + recv_packets = self.scatter_pktgen_send_packet(mb_size + offset) + self._logger.debug(f"Relevant captured packets: \n{recv_packets}") self.verify( - ("58 " * 8).strip() in recv_payload, + any(" ".join(["58"] * 8) in hexstr(pkt, onlyhex=1) for pkt in recv_packets), "Payload of scattered packet did not match expected payload with offset " f"{offset}.", ) @@ -127,8 +132,14 @@ def pmd_scatter(self, mbsize: int) -> None: @requires(NicCapability.SCATTERED_RX_ENABLED) @func_test def test_scatter_mbuf_2048(self) -> None: - """Run the :meth:`pmd_scatter` test with `mbsize` set to 2048.""" - self.pmd_scatter(mbsize=2048) + """Run the :meth:`pmd_scatter` test with `mb_size` set to 2048.""" + self.pmd_scatter(mb_size=2048) + + @requires(NicCapability.RX_OFFLOAD_SCATTER) + @func_test + def test_scatter_mbuf_2048_with_offload(self) -> None: + """Run the :meth:`pmd_scatter` test with `mb_size` set to 2048 and rx_scatter offload.""" + self.pmd_scatter(mb_size=2048, enable_offload=True) def tear_down_suite(self) -> None: """Tear down the test suite. -- 2.39.2