Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/120457/?format=api
{ "id": 120457, "url": "https://patches.dpdk.org/api/patches/120457/?format=api", "web_url": "https://patches.dpdk.org/project/dts/patch/20221205145047.878054-4-yaqi.tang@intel.com/", "project": { "id": 3, "url": "https://patches.dpdk.org/api/projects/3/?format=api", "name": "DTS", "link_name": "dts", "list_id": "dts.dpdk.org", "list_email": "dts@dpdk.org", "web_url": "", "scm_url": "git://dpdk.org/tools/dts", "webscm_url": "http://git.dpdk.org/tools/dts/", "list_archive_url": "https://inbox.dpdk.org/dts", "list_archive_url_format": "https://inbox.dpdk.org/dts/{}", "commit_url_format": "" }, "msgid": "<20221205145047.878054-4-yaqi.tang@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20221205145047.878054-4-yaqi.tang@intel.com", "date": "2022-12-05T14:50:47", "name": "[V1,3/3] tests/ice_buffer_split: ice PF enable buffer split", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": false, "hash": "7dd6e2b0424078208c34a6dc255e8b8d4b88a0a5", "submitter": { "id": 2357, "url": "https://patches.dpdk.org/api/people/2357/?format=api", "name": "Yaqi Tang", "email": "yaqi.tang@intel.com" }, "delegate": null, "mbox": "https://patches.dpdk.org/project/dts/patch/20221205145047.878054-4-yaqi.tang@intel.com/mbox/", "series": [ { "id": 25999, "url": "https://patches.dpdk.org/api/series/25999/?format=api", "web_url": "https://patches.dpdk.org/project/dts/list/?series=25999", "date": "2022-12-05T14:50:44", "name": "ice PF enable buffer split", "version": 1, "mbox": "https://patches.dpdk.org/series/25999/mbox/" } ], "comments": "https://patches.dpdk.org/api/patches/120457/comments/", "check": "success", "checks": "https://patches.dpdk.org/api/patches/120457/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dts-bounces@dpdk.org>", "X-Original-To": "patchwork@inbox.dpdk.org", "Delivered-To": "patchwork@inbox.dpdk.org", "Received": [ "from mails.dpdk.org (mails.dpdk.org [217.70.189.124])\n\tby inbox.dpdk.org (Postfix) with ESMTP id 02C05A0547;\n\tMon, 5 Dec 2022 15:51:08 +0100 (CET)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id F1EFF40687;\n\tMon, 5 Dec 2022 15:51:07 +0100 (CET)", "from mga04.intel.com (mga04.intel.com [192.55.52.120])\n by mails.dpdk.org (Postfix) with ESMTP id 6286D4014F\n for <dts@dpdk.org>; Mon, 5 Dec 2022 15:51:04 +0100 (CET)", "from fmsmga002.fm.intel.com ([10.253.24.26])\n by fmsmga104.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 05 Dec 2022 06:51:03 -0800", "from dpdk-yaqi.sh.intel.com ([10.67.119.116])\n by fmsmga002.fm.intel.com with ESMTP; 05 Dec 2022 06:51:02 -0800" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/simple;\n d=intel.com; i=@intel.com; q=dns/txt; s=Intel;\n t=1670251865; x=1701787865;\n h=from:to:cc:subject:date:message-id:in-reply-to:\n references:mime-version:content-transfer-encoding;\n bh=4n3WkTB8i9D87h6mCD9t7ixWBRQvVcT7KniPRuKIhug=;\n b=FcTSwNrKR6anQP6+82Y0FSpidrPvsrP8slGJaw1qi+eHzxR7d4d/fQe6\n i7M6kaex1NL40yhKoiiRL+b+WBh6sgsyz/PmKscimYIkNIH4+fE5HOOsD\n JM5Zofb1p7eCbcshJiUyDw658EBJ6lptT4d7N3wkx+OMTwjRjDLRbrTr1\n bv1lghTTuiLagBFDrkxx2SLCyAs0KU4aWXnsuUnF9wm965PKGOHm5Tp9J\n 1uhVA4hVZBL3xElk0GPecgs42GPh3SZRgci1PtBa/STuYrktYkt4Q5n4V\n E2aWD9cHU6IJXnNej8SYkTgOIYCcg4Nq7VDAQ69qeZvhTIGaiFYYMuFXC g==;", "X-IronPort-AV": [ "E=McAfee;i=\"6500,9779,10552\"; a=\"315065666\"", "E=Sophos;i=\"5.96,219,1665471600\"; d=\"scan'208\";a=\"315065666\"", "E=McAfee;i=\"6500,9779,10552\"; a=\"752213229\"", "E=Sophos;i=\"5.96,219,1665471600\"; d=\"scan'208\";a=\"752213229\"" ], "X-ExtLoop1": "1", "From": "Yaqi Tang <yaqi.tang@intel.com>", "To": "dts@dpdk.org", "Cc": "Yaqi Tang <yaqi.tang@intel.com>", "Subject": "[dts][PATCH V1 3/3] tests/ice_buffer_split: ice PF enable buffer\n split", "Date": "Mon, 5 Dec 2022 14:50:47 +0000", "Message-Id": "<20221205145047.878054-4-yaqi.tang@intel.com>", "X-Mailer": "git-send-email 2.25.1", "In-Reply-To": "<20221205145047.878054-1-yaqi.tang@intel.com>", "References": "<20221205145047.878054-1-yaqi.tang@intel.com>", "MIME-Version": "1.0", "Content-Transfer-Encoding": "8bit", "X-BeenThere": "dts@dpdk.org", "X-Mailman-Version": "2.1.29", "Precedence": "list", "List-Id": "test suite reviews and discussions <dts.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dts>,\n <mailto:dts-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://mails.dpdk.org/archives/dts/>", "List-Post": "<mailto:dts@dpdk.org>", "List-Help": "<mailto:dts-request@dpdk.org?subject=help>", "List-Subscribe": "<https://mails.dpdk.org/listinfo/dts>,\n <mailto:dts-request@dpdk.org?subject=subscribe>", "Errors-To": "dts-bounces@dpdk.org" }, "content": "Packets received in ice scalar path can be devided into two mempools with expected hdr and payload length/content specified by protocol type.\n\nSigned-off-by: Yaqi Tang <yaqi.tang@intel.com>\n---\n tests/TestSuite_ice_buffer_split.py | 1584 +++++++++++++++++++++++++++\n 1 file changed, 1584 insertions(+)\n create mode 100644 tests/TestSuite_ice_buffer_split.py", "diff": "diff --git a/tests/TestSuite_ice_buffer_split.py b/tests/TestSuite_ice_buffer_split.py\nnew file mode 100644\nindex 00000000..8f37b355\n--- /dev/null\n+++ b/tests/TestSuite_ice_buffer_split.py\n@@ -0,0 +1,1584 @@\n+# SPDX-License-Identifier: BSD-3-Clause\n+# Copyright(c) 2022 Intel Corporation\n+#\n+\n+import copy\n+import os\n+import re\n+import time\n+\n+from framework.packet import Packet\n+from framework.pmd_output import PmdOutput\n+from framework.test_case import TestCase\n+from framework.utils import GREEN, RED\n+\n+from .rte_flow_common import FdirProcessing\n+\n+# define length\n+MAC_HEADER_LEN = 14\n+IPV4_HEADER_LEN = 20\n+IPV6_HEADER_LEN = 40\n+UDP_HEADER_LEN = 8\n+TCP_HEADER_LEN = 20\n+SCTP_HEADER_LEN = 12\n+GRE_HEADER_LEN = 4\n+VXLAN_HEADER_LEN = 8\n+PAY_LEN = 30\n+\n+port_buffer_split_mac_matched_pkts = {\n+ \"mac_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/(\"Y\"*30)',\n+ \"mac_ipv4_ipv6_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/IPv6()/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_mac_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/(\"Y\"*30)',\n+ \"mac_ipv6_udp_vxlan_ipv6_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/UDP(sport=200, dport=4790)/VXLAN()/IPv6()/(\"Y\"*30)',\n+ \"mac_ipv4_gre_mac_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/Ether(dst=\"00:11:22:33:44:66\")/(\"Y\"*30)',\n+ \"mac_ipv4_gre_ipv6_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/IPv6()/(\"Y\"*30)',\n+}\n+\n+port_buffer_split_inner_l3_matched_pkts = {\n+ \"mac_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/(\"Y\"*30)',\n+ \"mac_ipv6_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/IP()/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_mac_ipv6_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/IPv6()/(\"Y\"*30)',\n+ \"mac_ipv6_udp_vxlan_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/UDP(sport=200, dport=4790)/VXLAN()/IP()/(\"Y\"*30)',\n+ \"mac_ipv4_gre_mac_ipv6_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/Ether(dst=\"00:11:22:33:44:66\")/IPv6()/(\"Y\"*30)',\n+ \"mac_ipv6_gre_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/GRE()/IP()/(\"Y\"*30)',\n+}\n+\n+port_buffer_split_inner_l4_matched_pkts = {\n+ \"mac_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/(\"Y\"*30)',\n+ \"mac_ipv4_ipv6_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/IPv6()/UDP()/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/IP()/UDP()/(\"Y\"*30)',\n+ \"mac_ipv6_udp_vxlan_ipv6_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/UDP(sport=200, dport=4790)/VXLAN()/IPv6()/UDP()/(\"Y\"*30)',\n+ \"mac_ipv6_gre_mac_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/GRE()/Ether(dst=\"00:11:22:33:44:66\")/IP()/UDP()/(\"Y\"*30)',\n+ \"mac_ipv4_gre_ipv6_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/IPv6()/UDP()/(\"Y\"*30)',\n+ \"mac_ipv6_tcp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/TCP()/(\"Y\"*30)',\n+ \"mac_ipv6_ipv4_tcp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/IP()/TCP()/(\"Y\"*30)',\n+ \"mac_ipv6_udp_vxlan_mac_ipv6_tcp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/IPv6()/TCP()/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_ipv4_tcp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP(sport=200, dport=4790)/VXLAN()/IP()/TCP()/(\"Y\"*30)',\n+ \"mac_ipv4_gre_mac_ipv6_tcp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/Ether(dst=\"00:11:22:33:44:66\")/IPv6()/TCP()/(\"Y\"*30)',\n+ \"mac_ipv6_gre_ipv4_tcp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/GRE()/IP()/TCP()/(\"Y\"*30)',\n+}\n+\n+port_buffer_split_inner_l4_mismatched_pkts = {\n+ \"mac_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/(\"Y\"*30)',\n+ \"mac_ipv4_gre_mac_ipv4_sctp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/Ether(dst=\"00:11:22:33:44:66\")/IP()/SCTP()/(\"Y\"*30)',\n+}\n+\n+port_buffer_split_inner_sctp_matched_pkts = {\n+ \"mac_ipv4_sctp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/SCTP()/(\"Y\"*30)',\n+ \"mac_ipv4_ipv6_sctp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/IPv6()/SCTP()/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_sctp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/IP()/SCTP()/(\"Y\"*30)',\n+ \"mac_ipv6_udp_vxlan_ipv6_sctp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/UDP(sport=200, dport=4790)/VXLAN()/IPv6()/SCTP()/(\"Y\"*30)',\n+ \"mac_ipv6_gre_mac_ipv4_sctp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/GRE()/Ether(dst=\"00:11:22:33:44:66\")/IP()/SCTP()/(\"Y\"*30)',\n+ \"mac_ipv4_gre_ipv6_sctp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/IPv6()/SCTP()/(\"Y\"*30)',\n+}\n+\n+port_buffer_split_inner_sctp_mismatched_pkts = {\n+ \"mac_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/(\"Y\"*30)',\n+ \"mac_ipv4_gre_mac_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/Ether(dst=\"00:11:22:33:44:66\")/IP()/UDP()/(\"Y\"*30)',\n+ \"mac_ipv4_gre_mac_ipv4_tcp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/Ether(dst=\"00:11:22:33:44:66\")/IP()/TCP()/(\"Y\"*30)',\n+}\n+\n+port_buffer_split_tunnel_matched_pkts = {\n+ \"mac_ipv4_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/IP()/(\"Y\"*30)',\n+ \"mac_ipv6_ipv6_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/IPv6()/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/IP()/UDP()/(\"Y\"*30)',\n+ \"mac_ipv6_udp_vxlan_ipv6_tcp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/UDP(sport=200, dport=4790)/VXLAN()/IPv6()/TCP()/(\"Y\"*30)',\n+ \"mac_ipv4_gre_mac_ipv6_sctp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/GRE()/Ether(dst=\"00:11:22:33:44:66\")/IPv6()/SCTP()/(\"Y\"*30)',\n+ \"mac_ipv6_gre_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6()/GRE()/IP()/UDP()/(\"Y\"*30)',\n+}\n+\n+port_buffer_split_tunnel_mismatched_pkts = {\n+ \"mac_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/(\"Y\"*30)',\n+}\n+\n+queue_buffer_split_mac_matched_pkts = {\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/IP(src=\"192.168.0.1\",dst=\"192.168.0.2\")/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP(sport=200, dport=4790)/VXLAN()/IP(src=\"192.168.0.1\",dst=\"192.168.0.2\")/(\"Y\"*30)',\n+}\n+\n+queue_buffer_split_mac_mismatched_pkts = {\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/IP(src=\"192.168.1.1\",dst=\"192.168.0.2\")/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_ipv4_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP(sport=200, dport=4790)/VXLAN()/IP(src=\"192.168.0.1\",dst=\"192.168.1.2\")/(\"Y\"*30)',\n+}\n+\n+queue_buffer_split_inner_ipv6_matched_pkts = {\n+ \"mac_ipv6_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6(src=\"2001::1\",dst=\"2001::2\")/(\"Y\"*30)',\n+}\n+\n+queue_buffer_split_inner_ipv6_mismatched_pkts = {\n+ \"mac_ipv6_l3src_changed_pkt\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6(src=\"2001::8\",dst=\"2001::2\")/(\"Y\"*30)',\n+ \"mac_ipv6_l3dst_changed_pkt\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6(src=\"2001::1\",dst=\"2001::9\")/(\"Y\"*30)',\n+}\n+\n+queue_buffer_split_inner_ipv4_udp_matched_pkts = {\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/IP(src=\"192.168.0.1\",dst=\"192.168.0.2\")/UDP(dport=23)/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP(sport=200, dport=4790)/VXLAN()/IP(src=\"192.168.0.1\",dst=\"192.168.0.2\")/UDP(dport=23)/(\"Y\"*30)',\n+}\n+\n+queue_buffer_split_inner_ipv4_udp_mismatched_pkts = {\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP()/VXLAN()/Ether(dst=\"00:11:22:33:44:66\")/IP(src=\"192.168.0.3\",dst=\"192.168.0.2\")/UDP(dport=23)/(\"Y\"*30)',\n+ \"mac_ipv4_udp_vxlan_ipv4_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IP()/UDP(sport=200, dport=4790)/VXLAN()/IP(src=\"192.168.0.1\",dst=\"192.168.0.2\")/UDP(dport=24)/(\"Y\"*30)',\n+}\n+\n+queue_buffer_split_inner_ipv6_udp_matched_pkts = {\n+ \"mac_ipv6_udp_pay\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6(src=\"2001::1\",dst=\"2001::2\")/UDP(dport=23)/(\"Y\"*30)',\n+}\n+\n+queue_buffer_split_inner_ipv6_udp_mismatched_pkts = {\n+ \"mac_ipv6_udp_l3src_changed_pkt\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6(src=\"2001::8\",dst=\"2001::2\")/UDP(dport=23)/(\"Y\"*30)',\n+ \"mac_ipv6_udp_l4dst_changed_pkt\": 'Ether(dst=\"00:11:22:33:44:55\")/IPv6(src=\"2001::1\",dst=\"2001::2\")/UDP(dport=24)/(\"Y\"*30)',\n+}\n+\n+port_buffer_split_mac = {\n+ \"test\": [\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_ipv6_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_udp_vxlan_mac_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv6_udp_vxlan_ipv6_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_gre_mac_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_gre_ipv6_pay\"],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_seg_len\",\n+ },\n+ {\n+ \"port_id\": 1,\n+ \"send_packet\": [\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_ipv6_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_udp_vxlan_mac_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv6_udp_vxlan_ipv6_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_gre_mac_pay\"],\n+ port_buffer_split_mac_matched_pkts[\"mac_ipv4_gre_ipv6_pay\"],\n+ ],\n+ \"check_pkt_data\": False,\n+ \"action\": \"check_no_seg_len\",\n+ },\n+ ],\n+}\n+\n+port_buffer_split_inner_l3 = {\n+ \"test\": [\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv4_pay\"],\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv6_ipv4_pay\"],\n+ port_buffer_split_inner_l3_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv6_pay\"\n+ ],\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv6_udp_vxlan_ipv4_pay\"],\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv4_gre_mac_ipv6_pay\"],\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv6_gre_ipv4_pay\"],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_seg_len\",\n+ },\n+ {\n+ \"port_id\": 1,\n+ \"send_packet\": [\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv4_pay\"],\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv6_ipv4_pay\"],\n+ port_buffer_split_inner_l3_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv6_pay\"\n+ ],\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv6_udp_vxlan_ipv4_pay\"],\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv4_gre_mac_ipv6_pay\"],\n+ port_buffer_split_inner_l3_matched_pkts[\"mac_ipv6_gre_ipv4_pay\"],\n+ ],\n+ \"check_pkt_data\": False,\n+ \"action\": \"check_no_seg_len\",\n+ },\n+ ],\n+}\n+\n+port_buffer_split_inner_l4 = {\n+ \"test\": [\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv4_udp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv4_ipv6_udp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv6_udp_vxlan_ipv6_udp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv6_gre_mac_ipv4_udp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv4_gre_ipv6_udp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv6_tcp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv6_ipv4_tcp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv6_udp_vxlan_mac_ipv6_tcp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_ipv4_tcp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv4_gre_mac_ipv6_tcp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv6_gre_ipv4_tcp_pay\"],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_seg_len\",\n+ },\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ port_buffer_split_inner_l4_mismatched_pkts[\"mac_ipv4_pay\"],\n+ port_buffer_split_inner_l4_mismatched_pkts[\n+ \"mac_ipv4_gre_mac_ipv4_sctp_pay\"\n+ ],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_no_segment\",\n+ },\n+ {\n+ \"port_id\": 1,\n+ \"send_packet\": [\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv4_udp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv4_ipv6_udp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv6_udp_vxlan_ipv6_udp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv6_gre_mac_ipv4_udp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv4_gre_ipv6_udp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv6_tcp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv6_ipv4_tcp_pay\"],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv6_udp_vxlan_mac_ipv6_tcp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_ipv4_tcp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\n+ \"mac_ipv4_gre_mac_ipv6_tcp_pay\"\n+ ],\n+ port_buffer_split_inner_l4_matched_pkts[\"mac_ipv6_gre_ipv4_tcp_pay\"],\n+ ],\n+ \"check_pkt_data\": False,\n+ \"action\": \"check_no_seg_len\",\n+ },\n+ ],\n+}\n+\n+port_buffer_split_inner_sctp = {\n+ \"test\": [\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ port_buffer_split_inner_sctp_matched_pkts[\"mac_ipv4_sctp_pay\"],\n+ port_buffer_split_inner_sctp_matched_pkts[\"mac_ipv4_ipv6_sctp_pay\"],\n+ port_buffer_split_inner_sctp_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_sctp_pay\"\n+ ],\n+ port_buffer_split_inner_sctp_matched_pkts[\n+ \"mac_ipv6_udp_vxlan_ipv6_sctp_pay\"\n+ ],\n+ port_buffer_split_inner_sctp_matched_pkts[\n+ \"mac_ipv6_gre_mac_ipv4_sctp_pay\"\n+ ],\n+ port_buffer_split_inner_sctp_matched_pkts[\"mac_ipv4_gre_ipv6_sctp_pay\"],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_seg_len\",\n+ },\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ port_buffer_split_inner_sctp_mismatched_pkts[\"mac_ipv4_pay\"],\n+ port_buffer_split_inner_sctp_mismatched_pkts[\n+ \"mac_ipv4_gre_mac_ipv4_udp_pay\"\n+ ],\n+ port_buffer_split_inner_sctp_mismatched_pkts[\n+ \"mac_ipv4_gre_mac_ipv4_tcp_pay\"\n+ ],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_no_segment\",\n+ },\n+ {\n+ \"port_id\": 1,\n+ \"send_packet\": [\n+ port_buffer_split_inner_sctp_matched_pkts[\"mac_ipv4_sctp_pay\"],\n+ port_buffer_split_inner_sctp_matched_pkts[\"mac_ipv4_ipv6_sctp_pay\"],\n+ port_buffer_split_inner_sctp_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_sctp_pay\"\n+ ],\n+ port_buffer_split_inner_sctp_matched_pkts[\n+ \"mac_ipv6_udp_vxlan_ipv6_sctp_pay\"\n+ ],\n+ port_buffer_split_inner_sctp_matched_pkts[\n+ \"mac_ipv6_gre_mac_ipv4_sctp_pay\"\n+ ],\n+ port_buffer_split_inner_sctp_matched_pkts[\"mac_ipv4_gre_ipv6_sctp_pay\"],\n+ ],\n+ \"check_pkt_data\": False,\n+ \"action\": \"check_no_seg_len\",\n+ },\n+ ],\n+}\n+\n+port_buffer_split_tunnel = {\n+ \"test\": [\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ port_buffer_split_tunnel_matched_pkts[\"mac_ipv4_ipv4_pay\"],\n+ port_buffer_split_tunnel_matched_pkts[\"mac_ipv6_ipv6_pay\"],\n+ port_buffer_split_tunnel_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\"\n+ ],\n+ port_buffer_split_tunnel_matched_pkts[\n+ \"mac_ipv6_udp_vxlan_ipv6_tcp_pay\"\n+ ],\n+ port_buffer_split_tunnel_matched_pkts[\"mac_ipv4_gre_mac_ipv6_sctp_pay\"],\n+ port_buffer_split_tunnel_matched_pkts[\"mac_ipv6_gre_ipv4_udp_pay\"],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_seg_len\",\n+ },\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ port_buffer_split_tunnel_mismatched_pkts[\"mac_ipv4_pay\"],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_no_segment\",\n+ },\n+ {\n+ \"port_id\": 1,\n+ \"send_packet\": [\n+ port_buffer_split_tunnel_matched_pkts[\"mac_ipv4_ipv4_pay\"],\n+ port_buffer_split_tunnel_matched_pkts[\"mac_ipv6_ipv6_pay\"],\n+ port_buffer_split_tunnel_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\"\n+ ],\n+ port_buffer_split_tunnel_matched_pkts[\n+ \"mac_ipv6_udp_vxlan_ipv6_tcp_pay\"\n+ ],\n+ port_buffer_split_tunnel_matched_pkts[\"mac_ipv4_gre_mac_ipv6_sctp_pay\"],\n+ port_buffer_split_tunnel_matched_pkts[\"mac_ipv6_gre_ipv4_udp_pay\"],\n+ ],\n+ \"check_pkt_data\": False,\n+ \"action\": \"check_no_seg_len\",\n+ },\n+ ],\n+}\n+\n+queue_buffer_split_mac = {\n+ \"test\": [\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ queue_buffer_split_mac_matched_pkts[\"mac_ipv4_udp_vxlan_mac_ipv4_pay\"],\n+ queue_buffer_split_mac_matched_pkts[\"mac_ipv4_udp_vxlan_ipv4_pay\"],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_seg_len\",\n+ },\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ queue_buffer_split_mac_mismatched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_pay\"\n+ ],\n+ queue_buffer_split_mac_mismatched_pkts[\"mac_ipv4_udp_vxlan_ipv4_pay\"],\n+ ],\n+ \"check_pkt_data\": False,\n+ \"action\": \"check_no_seg_len\",\n+ },\n+ ],\n+}\n+\n+queue_buffer_split_inner_ipv6 = {\n+ \"test\": [\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ queue_buffer_split_inner_ipv6_matched_pkts[\"mac_ipv6_pay\"],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_seg_len\",\n+ },\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ queue_buffer_split_inner_ipv6_mismatched_pkts[\n+ \"mac_ipv6_l3src_changed_pkt\"\n+ ],\n+ queue_buffer_split_inner_ipv6_mismatched_pkts[\n+ \"mac_ipv6_l3dst_changed_pkt\"\n+ ],\n+ ],\n+ \"check_pkt_data\": False,\n+ \"action\": \"check_no_seg_len\",\n+ },\n+ ],\n+}\n+\n+queue_buffer_split_inner_ipv4_udp = {\n+ \"test\": [\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ queue_buffer_split_inner_ipv4_udp_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\"\n+ ],\n+ queue_buffer_split_inner_ipv4_udp_matched_pkts[\n+ \"mac_ipv4_udp_vxlan_ipv4_udp_pay\"\n+ ],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_seg_len\",\n+ },\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ queue_buffer_split_inner_ipv4_udp_mismatched_pkts[\n+ \"mac_ipv4_udp_vxlan_mac_ipv4_udp_pay\"\n+ ],\n+ queue_buffer_split_inner_ipv4_udp_mismatched_pkts[\n+ \"mac_ipv4_udp_vxlan_ipv4_udp_pay\"\n+ ],\n+ ],\n+ \"check_pkt_data\": False,\n+ \"action\": \"check_no_seg_len\",\n+ },\n+ ],\n+}\n+\n+queue_buffer_split_inner_ipv6_udp = {\n+ \"test\": [\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ queue_buffer_split_inner_ipv6_udp_matched_pkts[\"mac_ipv6_udp_pay\"],\n+ ],\n+ \"check_pkt_data\": True,\n+ \"action\": \"check_seg_len\",\n+ },\n+ {\n+ \"port_id\": 0,\n+ \"send_packet\": [\n+ queue_buffer_split_inner_ipv6_udp_mismatched_pkts[\n+ \"mac_ipv6_udp_l3src_changed_pkt\"\n+ ],\n+ queue_buffer_split_inner_ipv6_udp_mismatched_pkts[\n+ \"mac_ipv6_udp_l4dst_changed_pkt\"\n+ ],\n+ ],\n+ \"check_pkt_data\": False,\n+ \"action\": \"check_no_seg_len\",\n+ },\n+ ],\n+}\n+\n+queue_buffer_split_inner_ipv4_tcp = [\n+ eval(\n+ str(queue_buffer_split_inner_ipv4_udp)\n+ .replace(\"ipv4_udp\", \"ipv4_tcp\")\n+ .replace(\"UDP(dport\", \"TCP(dport\")\n+ )\n+]\n+\n+queue_buffer_split_inner_ipv6_tcp = [\n+ eval(\n+ str(queue_buffer_split_inner_ipv6_udp)\n+ .replace(\"ipv6_udp\", \"ipv6_tcp\")\n+ .replace(\"UDP(dport\", \"TCP(dport\")\n+ )\n+]\n+\n+\n+queue_buffer_split_inner_ipv4_sctp = [\n+ eval(\n+ str(queue_buffer_split_inner_ipv4_udp)\n+ .replace(\"ipv4_udp\", \"ipv4_sctp\")\n+ .replace(\"UDP(dport\", \"SCTP(dport\")\n+ )\n+]\n+\n+queue_buffer_split_inner_ipv6_sctp = [\n+ eval(\n+ str(queue_buffer_split_inner_ipv6_udp)\n+ .replace(\"ipv6_udp\", \"ipv6_sctp\")\n+ .replace(\"UDP(dport\", \"SCTP(dport\")\n+ )\n+]\n+\n+\n+class TestBufferSplit(TestCase):\n+ def set_up_all(self):\n+ \"\"\"\n+ Run at the start of each test suite.\n+ Generic filter Prerequistites\n+ \"\"\"\n+ self.verify(\n+ self.nic in [\"ICE_25G-E810C_SFP\", \"ICE_100G-E810C_QSFP\"],\n+ \"%s nic not support timestamp\" % self.nic,\n+ )\n+ self.dut_ports = self.dut.get_ports(self.nic)\n+ self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])\n+ # Verify that enough ports are available\n+ self.verify(len(self.dut_ports) >= 2, \"Insufficient ports\")\n+ self.tester_port0 = self.tester.get_local_port(self.dut_ports[0])\n+ self.tester_port1 = self.tester.get_local_port(self.dut_ports[1])\n+ self.tester_ifaces = [\n+ self.tester.get_interface(self.dut.ports_map[port])\n+ for port in self.dut_ports\n+ ]\n+ self.pf_pci0 = self.dut.ports_info[self.dut_ports[0]][\"pci\"]\n+ self.pf_pci1 = self.dut.ports_info[self.dut_ports[1]][\"pci\"]\n+\n+ self.rxq = 8\n+ self.pkt = Packet()\n+ self.pmdout = PmdOutput(self.dut)\n+ self.fdirprocess = FdirProcessing(\n+ self, self.pmdout, self.tester_ifaces[0], self.rxq\n+ )\n+\n+ def set_up(self):\n+ \"\"\"\n+ Run before each test case.\n+ \"\"\"\n+ pass\n+\n+ def launch_testpmd(self, allowlist, line_option=\"\"):\n+ \"\"\"\n+ start testpmd\n+ \"\"\"\n+ # Prepare testpmd EAL and parameters\n+ self.pmdout.start_testpmd(\n+ socket=self.ports_socket,\n+ eal_param=allowlist + \" --force-max-simd-bitwidth=64 \",\n+ param=\" --mbuf-size=2048,2048 \" + line_option,\n+ )\n+ # test link status\n+ res = self.pmdout.wait_link_status_up(\"all\", timeout=15)\n+ self.verify(res is True, \"there have port link is down\")\n+\n+ def launch_two_ports_testpmd_and_config_port_buffer_split(self):\n+ allowlist = f\"-a {self.pf_pci0} -a {self.pf_pci1}\"\n+ line_option = \"\"\n+ self.launch_testpmd(allowlist, line_option)\n+ self.dut.send_expect(\"port stop all\", \"testpmd> \")\n+ self.dut.send_expect(\"port config 0 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"show port 0 rx_offload configuration\", \"testpmd> \")\n+\n+ def launch_one_port_testpmd_with_multi_queues(self):\n+ allowlist = f\"-a {self.pf_pci0}\"\n+ line_option = \"--txq=8 --rxq=8\"\n+ self.launch_testpmd(allowlist, line_option)\n+ self.dut.send_expect(\"port stop all\", \"testpmd> \")\n+\n+ def start_testpmd(self):\n+ self.dut.send_expect(\"show config rxhdrs\", \"testpmd> \")\n+ self.dut.send_expect(\n+ \"port config 0 udp_tunnel_port add vxlan 4789\", \"testpmd> \"\n+ )\n+ self.dut.send_expect(\"port start all\", \"testpmd> \")\n+ self.dut.send_expect(\"start\", \"testpmd> \")\n+\n+ def check_pkt_data_same(self, pkt_data, expect_pkt_data):\n+ self.error_msgs = []\n+ for i in range(len(expect_pkt_data)):\n+ if pkt_data[i] != expect_pkt_data[i]:\n+ error_msg = \"The packet data should be same with expect packet data\"\n+ self.logger.error(error_msg)\n+ self.error_msgs.append(error_msg)\n+ self.verify(not self.error_msgs, \"Test failed\")\n+\n+ def check_seg_len(self, seg_len, expected_seg_len):\n+ if len(seg_len) == 0:\n+ error_msg = \"There is no segment\"\n+ self.logger.error(error_msg)\n+ self.error_msgs.append(error_msg)\n+ else:\n+ for i in range(len(expected_seg_len)):\n+ if seg_len[i] != expected_seg_len[i]:\n+ error_msg = (\n+ \"The segment length should be same with expected \"\n+ \"segment length {}\".format(expected_seg_len)\n+ )\n+ self.logger.error(error_msg)\n+ self.error_msgs.append(error_msg)\n+\n+ def check_no_seg_len(self, seg_len):\n+ if len(seg_len) != 0:\n+ error_msg = \"The segment length should be empty\"\n+ self.logger.error(error_msg)\n+ self.error_msgs.append(error_msg)\n+\n+ def check_no_segment(self, seg_len, expected_no_segment):\n+ if len(seg_len) == 0:\n+ error_msg = \"The segment length should not be empty\"\n+ self.logger.error(error_msg)\n+ self.error_msgs.append(error_msg)\n+ else:\n+ for i in range(len(expected_no_segment)):\n+ if seg_len[i] != expected_no_segment[i]:\n+ error_msg = (\n+ \"The segment length should be same with expected \"\n+ \"no segment length {}\".format(expected_no_segment)\n+ )\n+ self.logger.error(error_msg)\n+ self.error_msgs.append(error_msg)\n+\n+ def get_pkt_data(self, pkts):\n+ pkt_data_list = []\n+ self.logger.info(\"{}\".format(pkts))\n+ self.tester.send_expect(\"scapy\", \">>> \")\n+ time.sleep(1)\n+ for i in range(len(pkts)):\n+ self.tester.send_expect(\"p = %s\" % pkts[i], \">>>\")\n+ out = self.tester.send_expect(\"hexdump(p)\", \">>>\")\n+ time.sleep(1)\n+ pkt_pat = \"(?<=00\\S\\d )(.*)(?= )\"\n+ pkt_data = re.findall(pkt_pat, out, re.M)\n+ pkt_data = (\" \".join(map(str, pkt_data))).replace(\" \", \" \")\n+ pkt_data = pkt_data.strip()\n+ self.logger.info(\"pkt_data: {}\".format(pkt_data))\n+ if len(pkt_data) != 0:\n+ pkt_data_list.append(pkt_data)\n+ self.logger.info(\"pkt_data_list: {}\".format(pkt_data_list))\n+ return pkt_data_list\n+\n+ def send_pkt_get_output(self, pkts, port_id, count=1):\n+ pkt_data_list = []\n+ segment_len_list = []\n+ self.logger.info(\"----------send packet-------------\")\n+ self.logger.info(\"{}\".format(pkts))\n+ tx_port = self.tester_ifaces[port_id]\n+ for i in range(len(pkts)):\n+ self.pkt.update_pkt(pkts[i])\n+ time.sleep(2)\n+ self.pkt.send_pkt(crb=self.tester, tx_port=tx_port, count=count)\n+ out = self.pmdout.get_output(timeout=2)\n+ pkt_pat = \"(?<=: )(.*)(?= \\| )\"\n+ pkt_data = re.findall(pkt_pat, out, re.M)\n+ pkt_data = (\" \".join(map(str, pkt_data))).replace(\" \", \"\")\n+ self.logger.info(\"pkt_data: {}\".format(pkt_data))\n+ if len(pkt_data) != 0:\n+ pkt_data_list.append(pkt_data)\n+ segment_pat = \".*segment\\s+at\\s.*len=(\\d+)\"\n+ segment_infos = re.findall(segment_pat, out, re.M)\n+ segment_len = list(map(int, segment_infos))\n+ self.logger.info(\"segment_len: {}\".format(segment_len))\n+ if segment_len:\n+ segment_len_list.append(segment_len)\n+ self.logger.info(\"pkt_data_list: {}\".format(pkt_data_list))\n+ self.logger.info(\"segment_len_list: {}\".format(segment_len_list))\n+ return pkt_data_list, segment_len_list\n+\n+ def handle_buffer_split_case(\n+ self, case_info, expected_seg_len, expected_no_segment\n+ ):\n+ self.error_msgs = []\n+ seg_len = []\n+ # handle tests\n+ tests = case_info[\"test\"]\n+ for test in tests:\n+ if \"send_packet\" in test:\n+ pkt_data, seg_len = self.send_pkt_get_output(\n+ test[\"send_packet\"], port_id=test[\"port_id\"]\n+ )\n+ if test[\"check_pkt_data\"] == True:\n+ self.logger.info(\"action: check_pkt_data_same\")\n+ expect_pkt_data = self.get_pkt_data(test[\"send_packet\"])\n+ self.check_pkt_data_same(pkt_data, expect_pkt_data)\n+ if \"action\" in test:\n+ self.logger.info(\"action: {}\\n\".format(test[\"action\"]))\n+ if test[\"action\"] == \"check_seg_len\":\n+ self.check_seg_len(seg_len, expected_seg_len)\n+ elif test[\"action\"] == \"check_no_seg_len\":\n+ self.check_no_seg_len(seg_len)\n+ else:\n+ self.check_no_segment(seg_len, expected_no_segment)\n+ self.verify(not self.error_msgs, \"Test failed\")\n+\n+ def verify_port_buffer_split_outer_mac(self):\n+ self.launch_two_ports_testpmd_and_config_port_buffer_split()\n+ self.dut.send_expect(\"set rxhdrs eth\", \"testpmd> \")\n+ self.start_testpmd()\n+\n+ expected_seg_len = [\n+ [MAC_HEADER_LEN, IPV4_HEADER_LEN + PAY_LEN],\n+ [MAC_HEADER_LEN, IPV4_HEADER_LEN + IPV6_HEADER_LEN + PAY_LEN],\n+ [\n+ MAC_HEADER_LEN,\n+ IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN,\n+ IPV6_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN,\n+ IPV4_HEADER_LEN + GRE_HEADER_LEN + MAC_HEADER_LEN + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN,\n+ IPV4_HEADER_LEN + GRE_HEADER_LEN + IPV6_HEADER_LEN + PAY_LEN,\n+ ],\n+ ]\n+ expected_no_segment = []\n+\n+ self.handle_buffer_split_case(\n+ port_buffer_split_mac, expected_seg_len, expected_no_segment\n+ )\n+\n+ def verify_port_buffer_split_inner_mac(self):\n+ self.launch_two_ports_testpmd_and_config_port_buffer_split()\n+ self.dut.send_expect(\"set rxhdrs inner-eth\", \"testpmd> \")\n+ self.start_testpmd()\n+\n+ expected_seg_len = [\n+ [MAC_HEADER_LEN, IPV4_HEADER_LEN + PAY_LEN],\n+ [MAC_HEADER_LEN, IPV4_HEADER_LEN + IPV6_HEADER_LEN + PAY_LEN],\n+ [\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + UDP_HEADER_LEN + VXLAN_HEADER_LEN,\n+ MAC_HEADER_LEN + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN,\n+ IPV6_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + GRE_HEADER_LEN,\n+ MAC_HEADER_LEN + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN,\n+ IPV4_HEADER_LEN + GRE_HEADER_LEN + IPV6_HEADER_LEN + PAY_LEN,\n+ ],\n+ ]\n+ expected_no_segment = []\n+\n+ self.handle_buffer_split_case(\n+ port_buffer_split_mac, expected_seg_len, expected_no_segment\n+ )\n+\n+ def verify_port_buffer_split_inner_l3(self, ptype):\n+ self.launch_two_ports_testpmd_and_config_port_buffer_split()\n+ self.dut.send_expect(\"set rxhdrs %s\" % ptype, \"testpmd> \")\n+ self.start_testpmd()\n+\n+ expected_seg_len = [\n+ [MAC_HEADER_LEN + IPV4_HEADER_LEN, PAY_LEN],\n+ [MAC_HEADER_LEN + IPV6_HEADER_LEN + IPV4_HEADER_LEN, PAY_LEN],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV4_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN + IPV6_HEADER_LEN + GRE_HEADER_LEN + IPV4_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ ]\n+ expected_no_segment = []\n+\n+ self.handle_buffer_split_case(\n+ port_buffer_split_inner_l3, expected_seg_len, expected_no_segment\n+ )\n+ self.dut.send_expect(\"quit\", \"# \")\n+\n+ def verify_port_buffer_split_inner_l4(self, ptype):\n+ self.launch_two_ports_testpmd_and_config_port_buffer_split()\n+ self.dut.send_expect(\"set rxhdrs %s\" % ptype, \"testpmd> \")\n+ self.start_testpmd()\n+\n+ expected_seg_len = [\n+ [MAC_HEADER_LEN + IPV4_HEADER_LEN + UDP_HEADER_LEN, PAY_LEN],\n+ [\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + IPV6_HEADER_LEN + UDP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + UDP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + UDP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [MAC_HEADER_LEN + IPV6_HEADER_LEN + TCP_HEADER_LEN, PAY_LEN],\n+ [\n+ MAC_HEADER_LEN + IPV6_HEADER_LEN + IPV4_HEADER_LEN + TCP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + TCP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + TCP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + TCP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + TCP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ ]\n+ expected_no_segment = [\n+ [0, MAC_HEADER_LEN + IPV4_HEADER_LEN + PAY_LEN],\n+ [\n+ 0,\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + SCTP_HEADER_LEN\n+ + PAY_LEN,\n+ ],\n+ ]\n+\n+ self.handle_buffer_split_case(\n+ port_buffer_split_inner_l4, expected_seg_len, expected_no_segment\n+ )\n+ self.dut.send_expect(\"quit\", \"# \")\n+\n+ def verify_port_buffer_split_inner_sctp(self, ptype):\n+ self.launch_two_ports_testpmd_and_config_port_buffer_split()\n+ self.dut.send_expect(\"set rxhdrs %s\" % ptype, \"testpmd> \")\n+ self.start_testpmd()\n+\n+ expected_seg_len = [\n+ [MAC_HEADER_LEN + IPV4_HEADER_LEN + SCTP_HEADER_LEN, PAY_LEN],\n+ [\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + IPV6_HEADER_LEN + SCTP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + SCTP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + SCTP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + SCTP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + IPV6_HEADER_LEN\n+ + SCTP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ ]\n+ expected_no_segment = [\n+ [0, MAC_HEADER_LEN + IPV4_HEADER_LEN + PAY_LEN],\n+ [\n+ 0,\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + PAY_LEN,\n+ ],\n+ [\n+ 0,\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + GRE_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + TCP_HEADER_LEN\n+ + PAY_LEN,\n+ ],\n+ ]\n+\n+ self.handle_buffer_split_case(\n+ port_buffer_split_inner_sctp, expected_seg_len, expected_no_segment\n+ )\n+ self.dut.send_expect(\"quit\", \"# \")\n+\n+ def verify_port_buffer_split_tunnel(self):\n+ self.launch_two_ports_testpmd_and_config_port_buffer_split()\n+ self.dut.send_expect(\"set rxhdrs grenat\", \"testpmd> \")\n+ self.start_testpmd()\n+\n+ expected_seg_len = [\n+ [MAC_HEADER_LEN + IPV4_HEADER_LEN, IPV4_HEADER_LEN + PAY_LEN],\n+ [MAC_HEADER_LEN + IPV6_HEADER_LEN, IPV6_HEADER_LEN + PAY_LEN],\n+ [\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + UDP_HEADER_LEN + VXLAN_HEADER_LEN,\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + UDP_HEADER_LEN + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN + IPV6_HEADER_LEN + UDP_HEADER_LEN + VXLAN_HEADER_LEN,\n+ IPV6_HEADER_LEN + TCP_HEADER_LEN + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + GRE_HEADER_LEN,\n+ MAC_HEADER_LEN + IPV6_HEADER_LEN + SCTP_HEADER_LEN + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN + IPV6_HEADER_LEN + GRE_HEADER_LEN,\n+ IPV4_HEADER_LEN + UDP_HEADER_LEN + PAY_LEN,\n+ ],\n+ ]\n+ expected_no_segment = [\n+ [0, MAC_HEADER_LEN + IPV4_HEADER_LEN + UDP_HEADER_LEN + PAY_LEN],\n+ ]\n+\n+ self.handle_buffer_split_case(\n+ port_buffer_split_tunnel, expected_seg_len, expected_no_segment\n+ )\n+\n+ def verify_queue_buffer_split_outer_mac(self):\n+ self.launch_one_port_testpmd_with_multi_queues()\n+ self.dut.send_expect(\"port 0 rxq 1 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"show port 0 rx_offload configuration\", \"testpmd> \")\n+ self.dut.send_expect(\"set rxhdrs eth\", \"testpmd> \")\n+ self.start_testpmd()\n+\n+ fdir_rule = [\n+ \"flow create 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions queue index 1 / mark / end\",\n+ ]\n+\n+ expected_seg_len = [\n+ [\n+ MAC_HEADER_LEN,\n+ IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN,\n+ IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + PAY_LEN,\n+ ],\n+ ]\n+ expected_no_segment = []\n+\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[0])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_mac, expected_seg_len, expected_no_segment\n+ )\n+ self.fdirprocess.destroy_rule(port_id=0, rule_id=rule_li)\n+\n+ def verify_queue_buffer_split_inner_mac(self):\n+ self.launch_one_port_testpmd_with_multi_queues()\n+ self.dut.send_expect(\"port 0 rxq 2 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"port 0 rxq 3 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"show port 0 rx_offload configuration\", \"testpmd> \")\n+ self.dut.send_expect(\"set rxhdrs inner-eth\", \"testpmd> \")\n+ self.start_testpmd()\n+\n+ fdir_rule = [\n+ \"flow create 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions rss queues 2 3 end / mark / end\",\n+ ]\n+\n+ expected_seg_len = [\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN,\n+ IPV4_HEADER_LEN + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN,\n+ IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + PAY_LEN,\n+ ],\n+ ]\n+ expected_no_segment = []\n+\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[0])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_mac, expected_seg_len, expected_no_segment\n+ )\n+ self.fdirprocess.destroy_rule(port_id=0, rule_id=rule_li)\n+\n+ def verify_queue_buffer_split_inner_ipv4(self, ptype):\n+ self.launch_one_port_testpmd_with_multi_queues()\n+ self.dut.send_expect(\"port 0 rxq 2 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"show port 0 rx_offload configuration\", \"testpmd> \")\n+ self.dut.send_expect(\"set rxhdrs %s\" % ptype, \"testpmd> \")\n+ self.start_testpmd()\n+\n+ fdir_rule = [\n+ \"flow create 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / end actions queue index 2 / mark / end\",\n+ ]\n+\n+ expected_seg_len = [\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV4_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ ]\n+\n+ expected_no_segment = []\n+\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[0])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_mac, expected_seg_len, expected_no_segment\n+ )\n+ self.fdirprocess.destroy_rule(port_id=0, rule_id=rule_li)\n+ self.dut.send_expect(\"quit\", \"# \")\n+\n+ def verify_queue_buffer_split_inner_ipv6(self, ptype):\n+ self.launch_one_port_testpmd_with_multi_queues()\n+ self.dut.send_expect(\"port 0 rxq 4 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"port 0 rxq 5 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"show port 0 rx_offload configuration\", \"testpmd> \")\n+ self.dut.send_expect(\"set rxhdrs %s\" % ptype, \"testpmd> \")\n+ self.start_testpmd()\n+\n+ fdir_rule = [\n+ \"flow create 0 ingress pattern eth / ipv6 src is 2001::1 dst is 2001::2 / end actions rss queues 4 5 end / mark / end\",\n+ ]\n+\n+ expected_seg_len = [\n+ [MAC_HEADER_LEN + IPV6_HEADER_LEN, PAY_LEN],\n+ ]\n+\n+ expected_no_segment = []\n+\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[0])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_inner_ipv6, expected_seg_len, expected_no_segment\n+ )\n+ self.fdirprocess.destroy_rule(port_id=0, rule_id=rule_li)\n+ self.dut.send_expect(\"quit\", \"# \")\n+\n+ def verify_queue_buffer_split_inner_udp(self, ptype):\n+ self.launch_one_port_testpmd_with_multi_queues()\n+ self.dut.send_expect(\"port 0 rxq 3 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"show port 0 rx_offload configuration\", \"testpmd> \")\n+ self.dut.send_expect(\"set rxhdrs %s\" % ptype, \"testpmd> \")\n+ self.start_testpmd()\n+\n+ fdir_rule = [\n+ \"flow create 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / udp dst is 23 / end actions queue index 3 / mark / end\",\n+ \"flow create 0 ingress pattern eth / ipv6 src is 2001::1 dst is 2001::2 / udp dst is 23 / end actions queue index 3 / mark / end\",\n+ ]\n+\n+ expected_ipv4_pkts_seg_len = [\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ ]\n+\n+ expected_ipv6_pkts_seg_len = [\n+ [MAC_HEADER_LEN + IPV6_HEADER_LEN + UDP_HEADER_LEN, PAY_LEN],\n+ ]\n+ expected_no_segment = []\n+\n+ if ptype == \"ipv4-udp\" or ptype == \"inner-ipv4-udp\":\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[0])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_inner_ipv4_udp,\n+ expected_ipv4_pkts_seg_len,\n+ expected_no_segment,\n+ )\n+ else:\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[1])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_inner_ipv6_udp,\n+ expected_ipv6_pkts_seg_len,\n+ expected_no_segment,\n+ )\n+ self.fdirprocess.destroy_rule(port_id=0, rule_id=rule_li)\n+ self.dut.send_expect(\"quit\", \"# \")\n+\n+ def verify_queue_buffer_split_inner_tcp(self, ptype):\n+ self.launch_one_port_testpmd_with_multi_queues()\n+ self.dut.send_expect(\"port 0 rxq 2 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"port 0 rxq 3 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"show port 0 rx_offload configuration\", \"testpmd> \")\n+ self.dut.send_expect(\"set rxhdrs %s\" % ptype, \"testpmd> \")\n+ self.start_testpmd()\n+\n+ fdir_rule = [\n+ \"flow create 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / tcp dst is 23 / end actions rss queues 2 3 end / mark / end\",\n+ \"flow create 0 ingress pattern eth / ipv6 src is 2001::1 dst is 2001::2 / tcp dst is 23 / end actions rss queues 2 3 end / mark / end\",\n+ ]\n+\n+ expected_ipv4_pkts_seg_len = [\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + TCP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + TCP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ ]\n+\n+ expected_ipv6_pkts_seg_len = [\n+ [MAC_HEADER_LEN + IPV6_HEADER_LEN + TCP_HEADER_LEN, PAY_LEN],\n+ ]\n+ expected_no_segment = []\n+\n+ if ptype == \"ipv4-tcp\" or ptype == \"inner-ipv4-tcp\":\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[0])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_inner_ipv4_tcp[0],\n+ expected_ipv4_pkts_seg_len,\n+ expected_no_segment,\n+ )\n+ else:\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[1])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_inner_ipv6_tcp[0],\n+ expected_ipv6_pkts_seg_len,\n+ expected_no_segment,\n+ )\n+ self.fdirprocess.destroy_rule(port_id=0, rule_id=rule_li)\n+ self.dut.send_expect(\"quit\", \"# \")\n+\n+ def verify_queue_buffer_split_inner_sctp(self, ptype):\n+ self.launch_one_port_testpmd_with_multi_queues()\n+ self.dut.send_expect(\"port 0 rxq 5 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"show port 0 rx_offload configuration\", \"testpmd> \")\n+ self.dut.send_expect(\"set rxhdrs %s\" % ptype, \"testpmd> \")\n+ self.start_testpmd()\n+\n+ fdir_rule = [\n+ \"flow create 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / sctp dst is 23 / end actions queue index 5 / mark / end\",\n+ \"flow create 0 ingress pattern eth / ipv6 src is 2001::1 dst is 2001::2 / sctp dst is 23 / end actions queue index 5 / mark / end\",\n+ ]\n+\n+ expected_ipv4_pkts_seg_len = [\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + SCTP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + UDP_HEADER_LEN\n+ + VXLAN_HEADER_LEN\n+ + IPV4_HEADER_LEN\n+ + SCTP_HEADER_LEN,\n+ PAY_LEN,\n+ ],\n+ ]\n+\n+ expected_ipv6_pkts_seg_len = [\n+ [MAC_HEADER_LEN + IPV6_HEADER_LEN + SCTP_HEADER_LEN, PAY_LEN],\n+ ]\n+ expected_no_segment = []\n+\n+ if ptype == \"ipv4-sctp\" or ptype == \"inner-ipv4-sctp\":\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[0])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_inner_ipv4_sctp[0],\n+ expected_ipv4_pkts_seg_len,\n+ expected_no_segment,\n+ )\n+ else:\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[1])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_inner_ipv6_sctp[0],\n+ expected_ipv6_pkts_seg_len,\n+ expected_no_segment,\n+ )\n+ self.fdirprocess.destroy_rule(port_id=0, rule_id=rule_li)\n+ self.dut.send_expect(\"quit\", \"# \")\n+\n+ def verify_queue_buffer_split_tunnel(self):\n+ self.launch_one_port_testpmd_with_multi_queues()\n+ self.dut.send_expect(\"port 0 rxq 4 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"port 0 rxq 5 rx_offload buffer_split on\", \"testpmd> \")\n+ self.dut.send_expect(\"show port 0 rx_offload configuration\", \"testpmd> \")\n+ self.dut.send_expect(\"set rxhdrs grenat\", \"testpmd> \")\n+ self.start_testpmd()\n+\n+ fdir_rule = [\n+ \"flow create 0 ingress pattern eth / ipv4 / udp / vxlan / eth / ipv4 src is 192.168.0.1 dst is 192.168.0.2 / udp dst is 23 / end actions rss queues 4 5 end / mark / end\",\n+ ]\n+\n+ expected_seg_len = [\n+ [\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + UDP_HEADER_LEN + VXLAN_HEADER_LEN,\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + UDP_HEADER_LEN + PAY_LEN,\n+ ],\n+ [\n+ MAC_HEADER_LEN + IPV4_HEADER_LEN + UDP_HEADER_LEN + VXLAN_HEADER_LEN,\n+ IPV4_HEADER_LEN + UDP_HEADER_LEN + PAY_LEN,\n+ ],\n+ ]\n+ expected_no_segment = []\n+\n+ rule_li = self.fdirprocess.create_rule(fdir_rule[0])\n+ self.handle_buffer_split_case(\n+ queue_buffer_split_inner_ipv4_udp, expected_seg_len, expected_no_segment\n+ )\n+ self.fdirprocess.destroy_rule(port_id=0, rule_id=rule_li)\n+\n+ def test_port_buffer_split_outer_mac(self):\n+ self.verify_port_buffer_split_outer_mac()\n+\n+ def test_port_buffer_split_inner_mac(self):\n+ self.verify_port_buffer_split_inner_mac()\n+\n+ def test_port_buffer_split_inner_l3(self):\n+ self.logger.info(\n+ \"===================Test subcase 1: buffer split ipv4 ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l3(ptype=\"ipv4\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: buffer split ipv6 ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l3(ptype=\"ipv6\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 3: buffer split inner-ipv4 ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l3(ptype=\"inner-ipv4\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 4: buffer split inner-ipv6 ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l3(ptype=\"inner-ipv6\")\n+\n+ def test_port_buffer_split_inner_l4(self):\n+ self.logger.info(\n+ \"===================Test subcase 1: buffer split ipv4-udp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l4(ptype=\"ipv4-udp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: buffer split ipv6-udp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l4(ptype=\"ipv6-udp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 3: buffer split ipv4-tcp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l4(ptype=\"ipv4-tcp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 4: buffer split ipv6-tcp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l4(ptype=\"ipv6-tcp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 5: buffer split inner-ipv4-udp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l4(ptype=\"inner-ipv4-udp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 6: buffer split inner-ipv6-udp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l4(ptype=\"inner-ipv6-udp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 7: buffer split inner-ipv4-tcp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l4(ptype=\"inner-ipv4-tcp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 8: buffer split inner-ipv6-tcp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_l4(ptype=\"inner-ipv6-tcp\")\n+\n+ def test_port_buffer_split_inner_sctp(self):\n+ self.logger.info(\n+ \"===================Test subcase 1: buffer split ipv4-sctp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_sctp(ptype=\"ipv4-sctp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: buffer split ipv6-sctp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_sctp(ptype=\"ipv6-sctp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 3: buffer split inner-ipv4-sctp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_sctp(ptype=\"inner-ipv4-sctp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 4: buffer split inner-ipv6-sctp ================\"\n+ )\n+ self.verify_port_buffer_split_inner_sctp(ptype=\"inner-ipv6-sctp\")\n+\n+ def test_port_buffer_split_tunnel(self):\n+ self.verify_port_buffer_split_tunnel()\n+\n+ def test_queue_buffer_split_outer_mac(self):\n+ self.verify_queue_buffer_split_outer_mac()\n+\n+ def test_queue_buffer_split_inner_mac(self):\n+ self.verify_queue_buffer_split_inner_mac()\n+\n+ def test_queue_buffer_split_inner_ipv4(self):\n+ self.logger.info(\n+ \"===================Test subcase 1: buffer split ipv4 ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_ipv4(ptype=\"ipv4\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: buffer split inner-ipv4 ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_ipv4(ptype=\"inner-ipv4\")\n+\n+ def test_queue_buffer_split_inner_ipv6(self):\n+ self.logger.info(\n+ \"===================Test subcase 1: buffer split ipv6 ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_ipv6(ptype=\"ipv6\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: buffer split inner-ipv6 ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_ipv6(ptype=\"inner-ipv6\")\n+\n+ def test_queue_buffer_split_inner_udp(self):\n+ self.logger.info(\n+ \"===================Test subcase 1: buffer split ipv4-udp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_udp(ptype=\"ipv4-udp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: buffer split ipv6-udp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_udp(ptype=\"ipv6-udp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 3: buffer split inner-ipv4-udp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_udp(ptype=\"inner-ipv4-udp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 4: buffer split inner-ipv6-udp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_udp(ptype=\"inner-ipv6-udp\")\n+\n+ def test_queue_buffer_split_inner_tcp(self):\n+ self.logger.info(\n+ \"===================Test subcase 1: buffer split ipv4-tcp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_tcp(ptype=\"ipv4-tcp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: buffer split ipv6-tcp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_tcp(ptype=\"ipv6-tcp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 3: buffer split inner-ipv4-tcp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_tcp(ptype=\"inner-ipv4-tcp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 4: buffer split inner-ipv6-tcp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_tcp(ptype=\"inner-ipv6-tcp\")\n+\n+ def test_queue_buffer_split_inner_sctp(self):\n+ self.logger.info(\n+ \"===================Test subcase 1: buffer split ipv4-sctp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_sctp(ptype=\"ipv4-sctp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: buffer split ipv6-sctp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_sctp(ptype=\"ipv6-sctp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 3: buffer split inner-ipv4-sctp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_sctp(ptype=\"inner-ipv4-sctp\")\n+\n+ self.logger.info(\n+ \"===================Test subcase 4: buffer split inner-ipv6-sctp ================\"\n+ )\n+ self.verify_queue_buffer_split_inner_sctp(ptype=\"inner-ipv6-sctp\")\n+\n+ def test_queue_buffer_split_tunnel(self):\n+ self.verify_queue_buffer_split_tunnel()\n+\n+ def tear_down(self):\n+ \"\"\"\n+ Run after each test case.\n+ \"\"\"\n+ self.pmdout.quit()\n+\n+ def tear_down_all(self):\n+ \"\"\"\n+ Run after each test suite.\n+ \"\"\"\n+ self.dut.kill_all()\n", "prefixes": [ "V1", "3/3" ] }