Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/130746/?format=api
{ "id": 130746, "url": "https://patches.dpdk.org/api/patches/130746/?format=api", "web_url": "https://patches.dpdk.org/project/dts/patch/20230825161923.2832805-4-songx.jiale@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": "<20230825161923.2832805-4-songx.jiale@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20230825161923.2832805-4-songx.jiale@intel.com", "date": "2023-08-25T16:19:23", "name": "[V2,3/3] tests/mev_cpfl_hairpin_queue: mev cpfl support hairpin queue", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": false, "hash": "8865cf025817b6f0a980f5892a55652abf81eb7b", "submitter": { "id": 2352, "url": "https://patches.dpdk.org/api/people/2352/?format=api", "name": "Jiale, SongX", "email": "songx.jiale@intel.com" }, "delegate": null, "mbox": "https://patches.dpdk.org/project/dts/patch/20230825161923.2832805-4-songx.jiale@intel.com/mbox/", "series": [ { "id": 29339, "url": "https://patches.dpdk.org/api/series/29339/?format=api", "web_url": "https://patches.dpdk.org/project/dts/list/?series=29339", "date": "2023-08-25T16:19:20", "name": "MEV CPFL support hairpin queue", "version": 2, "mbox": "https://patches.dpdk.org/series/29339/mbox/" } ], "comments": "https://patches.dpdk.org/api/patches/130746/comments/", "check": "pending", "checks": "https://patches.dpdk.org/api/patches/130746/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 D676A430FE;\n\tFri, 25 Aug 2023 10:10:49 +0200 (CEST)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id D160C42D12;\n\tFri, 25 Aug 2023 10:10:49 +0200 (CEST)", "from mgamail.intel.com (mgamail.intel.com [192.55.52.43])\n by mails.dpdk.org (Postfix) with ESMTP id 24F6640695\n for <dts@dpdk.org>; Fri, 25 Aug 2023 10:10:47 +0200 (CEST)", "from orsmga008.jf.intel.com ([10.7.209.65])\n by fmsmga105.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 25 Aug 2023 01:10:47 -0700", "from unknown (HELO localhost.localdomain) ([10.239.252.96])\n by orsmga008-auth.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 25 Aug 2023 01:10:46 -0700" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/simple;\n d=intel.com; i=@intel.com; q=dns/txt; s=Intel;\n t=1692951048; x=1724487048;\n h=from:to:cc:subject:date:message-id:in-reply-to:\n references:mime-version:content-transfer-encoding;\n bh=4DatfW4XDl4KEmpVfM96qQXbUuO53S9NKcKfiE1IXHg=;\n b=kcU3TzCh0p6Bv5+twZj4fhgqqsLCap/yxYQfBtpUMfefNMrtWAml4A9Z\n 8OX45JcUoQxuBYUpZWCqg9wOWbO6xaRRq3dCYoN/YJBfIF26yHMAA3aMh\n +gBHJB8WN+q5/d8exAaGezdh/rwbzr6U/qj3AAV278Ar9ssM1Sesp9u6n\n MrxJFqEvwlc38BB7YDk6GNzbhXusycbQ2cQsR17s3HTWbkOIxR0EefnXf\n ZCHBmc4Edf3sOD9HdoTKWO5kJrJctut1evtWt+fLZZUgG/zXsSVzYzdW0\n kpbij7BQKQiAYb/+Gz2ZGO3h3OxvU+49qwEyLg9rJ9BLCp2NugWI20sNi Q==;", "X-IronPort-AV": [ "E=McAfee;i=\"6600,9927,10812\"; a=\"461023460\"", "E=Sophos;i=\"6.02,195,1688454000\"; d=\"scan'208\";a=\"461023460\"", "E=McAfee;i=\"6600,9927,10812\"; a=\"766879836\"", "E=Sophos;i=\"6.02,195,1688454000\"; d=\"scan'208\";a=\"766879836\"" ], "X-ExtLoop1": "1", "From": "Jiale Song <songx.jiale@intel.com>", "To": "dts@dpdk.org", "Cc": "Jiale Song <songx.jiale@intel.com>", "Subject": "[dts] [PATCH V2 3/3] tests/mev_cpfl_hairpin_queue: mev cpfl support\n hairpin queue", "Date": "Fri, 25 Aug 2023 16:19:23 +0000", "Message-Id": "<20230825161923.2832805-4-songx.jiale@intel.com>", "X-Mailer": "git-send-email 2.25.1", "In-Reply-To": "<20230825161923.2832805-1-songx.jiale@intel.com>", "References": "<20230825161923.2832805-1-songx.jiale@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": "enabling Port2Port forwarding as hairpin queue implementation in dpdk cpfl PMD.\n\nSigned-off-by: Jiale Song <songx.jiale@intel.com>\n---\n tests/TestSuite_mev_cpfl_hairpin_queue.py | 257 ++++++++++++++++++++++\n 1 file changed, 257 insertions(+)\n create mode 100644 tests/TestSuite_mev_cpfl_hairpin_queue.py", "diff": "diff --git a/tests/TestSuite_mev_cpfl_hairpin_queue.py b/tests/TestSuite_mev_cpfl_hairpin_queue.py\nnew file mode 100644\nindex 00000000..b2909e3d\n--- /dev/null\n+++ b/tests/TestSuite_mev_cpfl_hairpin_queue.py\n@@ -0,0 +1,257 @@\n+# SPDX-License-Identifier: BSD-3-Clause\n+# Copyright(c) 2023 Intel Corporation\n+#\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+\n+match_pkts = {\n+ \"rule_1_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"de:ad:be:ef:20:24\")/IP(src=\"10.2.29.100\", dst=\"10.2.29.2\")/UDP()',\n+ \"rule_2_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"00:06:00:00:02:18\")/IP(src=\"133.133.10.20\", dst=\"133.133.10.10\")/UDP()',\n+ \"rule_3_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"de:ad:be:ef:05:34\")/IP(src=\"10.2.28.10\", dst=\"10.2.28.20\")/UDP()',\n+ \"rule_4_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"de:ad:be:ef:10:14\")/IP(src=\"10.2.28.10\", dst=\"10.2.28.20\")/TCP()',\n+ \"rule_5_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"00:05:00:00:03:17\")/IP(src=\"133.133.10.60\", dst=\"133.133.10.20\")/UDP()',\n+ \"rule_6_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"de:ad:be:ef:08:84\")/IP(src=\"10.2.28.19\", dst=\"10.2.28.29\")/UDP()',\n+ \"rule_7_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"00:05:00:00:03:18\")/IP(src=\"133.133.10.60\", dst=\"133.133.10.10\")/TCP()',\n+ \"rule_8_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"dc:ad:be:ef:04:29\")/IP(src=\"10.2.28.39\", dst=\"10.2.28.49\")/UDP()',\n+ \"rule_9_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"de:ad:be:ef:10:14\")/IP(src=\"10.2.28.10\", dst=\"10.2.28.20\")/TCP()',\n+ \"rule_10_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"00:08:00:00:03:19\")/IP(src=\"133.133.10.60\", dst=\"133.133.10.30\")/TCP()',\n+ \"rule_11_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"00:06:00:00:02:18\")/IP(src=\"10.2.29.100\", dst=\"10.2.29.2\")/TCP()',\n+ \"rule_12_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"00:07:00:00:05:19\")/IP(src=\"133.133.10.20\", dst=\"133.133.10.10\")/TCP()',\n+ \"rule_13_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"00:05:00:00:03:17\")/IP(src=\"133.133.10.60\", dst=\"133.133.10.20\")/TCP()',\n+ \"rule_14_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"dc:ad:be:ef:04:29\")/IP(src=\"10.2.28.39\", dst=\"10.2.28.49\")/TCP()',\n+ \"rule_15_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"de:ad:be:ef:08:84\")/IP(src=\"10.2.28.19\", dst=\"10.2.28.29\")/TCP()',\n+ \"rule_16_match_pkt\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"da:ad:be:ef:06:19\")/IP(src=\"10.2.28.29\", dst=\"10.2.28.39\")/TCP()',\n+}\n+\n+hairpin_rules = {\n+ \"rule_1\": \"opcode=0x1303 prof_id=0x34 sub_prof_id=0x0 cookie=0xa2b87 key=0x18,0x0,00,00,00,00,0xde,0xad,0xbe,0xef,0x20,0x24,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1d,0x64,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1d,0x2,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_2\": \"opcode=0x1303 prof_id=0x34 sub_prof_id=0x0 cookie=0xa2b87 key=0x18,0x0,00,00,00,00,00,0x06,0x00,0x00,0x02,0x18,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0x85,0x85,0xa,0x14,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0x85,0x85,0xa,0xa,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_3\": \"opcode=0x1303 prof_id=0x34 sub_prof_id=0x0 cookie=0xa2b87 key=0x18,0x0,00,00,00,00,0xde,0xad,0xbe,0xef,0x05,0x34,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1c,0xa,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1c,0x14,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_4\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,0xde,0xad,0xbe,0xef,0x10,0x14,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1c,0xa,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1c,0x14,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_5\": \"opcode=0x1303 prof_id=0x34 sub_prof_id=0x0 cookie=0xa2b87 key=0x18,0x0,00,00,00,00,00,0x05,0x00,0x00,0x03,0x17,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0x85,0x85,0xa,0x3c,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0x85,0x85,0xa,0x14,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_6\": \"opcode=0x1303 prof_id=0x34 sub_prof_id=0x0 cookie=0xa2b87 key=0x18,0x0,00,00,00,00,0xde,0xad,0xbe,0xef,0x08,0x84,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1c,0x13,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1c,0x1d,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_7\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,00,0x05,0x00,0x00,0x03,0x18,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0x85,0x85,0xa,0x3c,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0x85,0x85,0xa,0xa,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_8\": \"opcode=0x1303 prof_id=0x34 sub_prof_id=0x0 cookie=0xa2b87 key=0x18,0x0,00,00,00,00,0xdc,0xad,0xbe,0xef,0x04,0x29,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1c,0x27,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1c,0x31,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_9\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,0xde,0xad,0xbe,0xef,0x10,0x14,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1c,0xa,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1c,0x14,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_10\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,00,0x08,0x00,0x00,0x03,0x19,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0x85,0x85,0xa,0x3c,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0x85,0x85,0xa,0x1e,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_11\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,00,0x06,0x00,0x00,0x02,0x18,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1d,0x64,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1d,0x2,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_12\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,00,0x07,0x00,0x00,0x05,0x19,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0x85,0x85,0xa,0x14,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0x85,0x85,0xa,0xa,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_13\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,00,0x05,0x00,0x00,0x03,0x17,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0x85,0x85,0xa,0x3c,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0x85,0x85,0xa,0x14,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_14\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,0xdc,0xad,0xbe,0xef,0x04,0x29,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1c,0x27,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1c,0x31,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_15\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,0xde,0xad,0xbe,0xef,0x08,0x84,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1c,0x13,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1c,0x1d,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+ \"rule_16\": \"opcode=0x1303 prof_id=0x32 sub_prof_id=0x0 cookie=0xa2b87 key=0x1a,0x0,00,00,00,00,0xda,0xad,0xbe,0xef,0x06,0x19,0x0,0x0,0x0,0x0,00,00,00,00,00,00,0xa,0x2,0x1c,0x1d,00,00,00,00,00,00,00,00,00,00,00,00,\\\n+0xa,0x2,0x1c,0x27,00,00,00,00,00,00,00,00,00,00,00,00 act=set_vsi{act_val=0 val_type=2 dst_pe=0 slot=0x0}\",\n+}\n+\n+mismatch_pkts = {\n+ \"mac_ipv4\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"02:70:80:C6:67:CE\")/IP(src=\"192.168.0.2\",dst=\"192.168.0.3\")/(\"X\"*480)',\n+ \"mac_ipv6\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"02:70:80:C6:67:CE\")/IPv6(src=\"2001::2\",dst=\"2001::3\")/(\"X\"*480)',\n+ \"mac_ipv4_udp\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"02:70:80:C6:67:CE\")/IP(src=\"10.2.28.12\", dst=\"10.2.28.22\")/UDP(sport=1026, dport=1027)/(\"X\"*480)',\n+ \"mac_ipv4_tcp\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"02:70:80:C6:67:CE\")/IP(src=\"10.2.28.12\", dst=\"10.2.28.22\")/TCP(sport=1026, dport=1027)/(\"X\"*480)',\n+ \"mac_ipv4_sctp\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"02:70:80:C6:67:CE\")/IP(src=\"10.2.28.12\", dst=\"10.2.28.22\")/SCTP(sport=1026, dport=1027)/(\"X\"*480)',\n+ \"mac_ipv6_udp\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"02:70:80:C6:67:CE\")/IPv6(src=\"2001::2\",dst=\"2001::3\")/UDP(sport=1026, dport=1027)/(\"X\"*480)',\n+ \"mac_ipv6_tcp\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"02:70:80:C6:67:CE\")/IPv6(src=\"2001::2\",dst=\"2001::3\")/TCP(sport=1026, dport=1027)/(\"X\"*480)',\n+ \"mac_ipv6_sctp\": 'Ether(src=\"00:11:22:33:44:55\", dst=\"02:70:80:C6:67:CE\")/IPv6(src=\"2001::2\",dst=\"2001::3\")/SCTP(sport=1026, dport=1027)/(\"X\"*480)',\n+}\n+\n+\n+class TestMevHairpinQueue(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 [\"mev-cpfl\"],\n+ \"%s nic not support hairpin queue\" % 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) >= 1, \"Insufficient ports\")\n+ self.tester_port0 = self.tester.get_local_port(self.dut_ports[0])\n+ self.tester_iface0 = self.tester.get_interface(self.tester_port0)\n+ self.pkt = Packet()\n+ self.pmdout = PmdOutput(self.dut)\n+ self.pf_pci = self.dut.ports_info[self.dut_ports[0]][\"pci\"]\n+ self.imc_rule_dir = \"/home/rule/\"\n+\n+ def set_up(self):\n+ \"\"\"\n+ Run before each test case.\n+ \"\"\"\n+ pass\n+\n+ def launch_testpmd(self, rxq, txq, hairpinq):\n+ \"\"\"\n+ start testpmd\n+ \"\"\"\n+ # Prepare testpmd EAL and parameters\n+ out = self.pmdout.start_testpmd(\n+ \"Default\",\n+ param=\"--rxq=%d --txq=%d --hairpinq=%d --hairpin-mode=0\"\n+ % (rxq, txq, hairpinq),\n+ )\n+ qnum = re.findall(\"hairpin: vport 0, Rxq id (\\w+)\", out)\n+ return qnum\n+\n+ def start_testpmd(self):\n+ self.pmdout.execute_cmd(\"set verbose 1\")\n+ self.pmdout.execute_cmd(\"start\")\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 create_imc_rule(self, count, rules):\n+ self.dut.imc_session.send_expect(\"mkdir -p %s\" % (self.imc_rule_dir), \"# \")\n+ self.dut.imc_session.send_expect(\"cd %s\" % (self.imc_rule_dir), \"# \")\n+ self.dut.imc_session.send_expect(\"rm rule_*.txt\", \"# \")\n+ for i in range(count):\n+ rule = rules[\"rule_%d\" % (i + 1)]\n+ self.dut.imc_session.send_expect(\n+ \"echo '%s' > rule_%d.txt\" % (rule, i + 1), \"# \"\n+ )\n+ output = self.dut.imc_session.send_expect(\n+ \"cli_client -x -f rule_%d.txt\" % (i + 1), \"# \"\n+ )\n+ self.verify(\"WARNING\" not in output, \"Found bad key in rule\")\n+ self.verify(\"File successfully processed\" in output, \"Create rule failed\")\n+\n+ def delete_imc_rule(self, count):\n+ self.dut.imc_session.send_expect(\"cd %s\" % (self.imc_rule_dir), \"# \")\n+ self.dut.imc_session.send_expect(\"ls\", \"# \")\n+ for i in range(count):\n+ self.dut.imc_session.send_expect(\n+ \"sed -i 's/opcode=0x1303/opcode=0x1305/g' rule_%d.txt\" % (i + 1), \"# \"\n+ )\n+ output = self.dut.imc_session.send_expect(\n+ \"cli_client -x -f rule_%d.txt\" % (i + 1), \"# \"\n+ )\n+ self.verify(\"WARNING\" not in output, \"Found bad key in rule\")\n+ self.verify(\"File successfully processed\" in output, \"Create rule failed\")\n+\n+ def send_packets(self, packets, tx_port, count=1):\n+ self.pkt.update_pkt(packets)\n+ self.pkt.send_pkt(crb=self.tester, tx_port=tx_port, count=count)\n+\n+ def check_tcpdump_pkts(self, pkts, count, receive=True):\n+ filters = [{\"layer\": \"ether\", \"config\": {\"src\": \"00:11:22:33:44:55\"}}]\n+ inst = self.tester.tcpdump_sniff_packets(self.tester_iface0, filters=filters)\n+ self.pmdout.execute_cmd(\"clear port stats all\")\n+ for i in range(len(pkts)):\n+ pkt = pkts[i]\n+ self.pkt.update_pkt(pkt)\n+ self.pkt.send_pkt(crb=self.tester, tx_port=self.tester_iface0, count=1)\n+ self.pmdout.execute_cmd(\"show port stats all\")\n+ p = self.tester.load_tcpdump_sniff_packets(inst)\n+ if receive:\n+ self.verify(\n+ len(p) == count,\n+ \"Expected to receive %d packages, but received %d packages\"\n+ % (count, len(p)),\n+ )\n+ else:\n+ self.verify(\n+ len(p) == 0,\n+ \"Expected to receive 0 packages, but received %d packages\" % (len(p)),\n+ )\n+\n+ def validate_hairpin_queue(self, count, rules, match_pkts):\n+ mismatch_pkt = list(mismatch_pkts.values())\n+ self.create_imc_rule(count, rules)\n+ self.check_tcpdump_pkts(match_pkts, count, receive=True)\n+ self.check_tcpdump_pkts(mismatch_pkt, count, receive=False)\n+ self.start_testpmd()\n+ self.check_tcpdump_pkts(mismatch_pkt, count=8, receive=True)\n+ self.delete_imc_rule(count)\n+\n+ def test_single_hairpin_queue(self):\n+ \"\"\"\n+ Test Case 1: Launch 1 hairpin queue\n+ \"\"\"\n+ self.logger.info(\n+ \"====================Test subcase 1: single_hairpin_queue_single_data_queue====================\"\n+ )\n+ qnum = self.launch_testpmd(rxq=1, txq=1, hairpinq=1)\n+ rules = {}\n+ match_pkt = [match_pkts[\"rule_4_match_pkt\"]]\n+ rules[\"rule_1\"] = (\n+ hairpin_rules[\"rule_4\"]\n+ + \" act=set_q{qnum=%s no_implicit_vsi=1 prec=5}\" % qnum[0]\n+ )\n+ self.validate_hairpin_queue(count=1, rules=rules, match_pkts=match_pkt)\n+ self.pmdout.execute_cmd(\"stop\")\n+ self.pmdout.quit()\n+\n+ self.logger.info(\n+ \"====================Test subcase 2: single_hairpin_queue_multi_data_queue====================\"\n+ )\n+ qnum = self.launch_testpmd(rxq=16, txq=16, hairpinq=1)\n+ match_pkt = [match_pkts[\"rule_1_match_pkt\"]]\n+ rules[\"rule_1\"] = (\n+ hairpin_rules[\"rule_1\"]\n+ + \" act=set_q{qnum=%s no_implicit_vsi=1 prec=5}\" % qnum[0]\n+ )\n+ self.validate_hairpin_queue(count=1, rules=rules, match_pkts=match_pkt)\n+\n+ def test_multi_hairpin_queues(self):\n+ \"\"\"\n+ Test Case 2: Launch 16 hairpin queues\n+ \"\"\"\n+ self.logger.info(\n+ \"====================Test subcase 1: multi_hairpin_queue_single_data_queue====================\"\n+ )\n+ qnum = self.launch_testpmd(rxq=1, txq=1, hairpinq=16)\n+ match_pkt = list(match_pkts.values())\n+ rules = {}\n+ for i in range(16):\n+ rules[\"rule_%d\" % (i + 1)] = (\n+ hairpin_rules[\"rule_%d\" % (i + 1)]\n+ + \" act=set_q{qnum=%s no_implicit_vsi=1 prec=5}\" % qnum[i]\n+ )\n+ self.validate_hairpin_queue(count=16, rules=rules, match_pkts=match_pkt)\n+ self.pmdout.execute_cmd(\"stop\")\n+ self.pmdout.quit()\n+\n+ self.logger.info(\n+ \"====================Test subcase 2: multi_hairpin_queue_multi_data_queues====================\"\n+ )\n+ qnum = self.launch_testpmd(rxq=16, txq=16, hairpinq=16)\n+ for i in range(16):\n+ rules[\"rule_%d\" % (i + 1)] = (\n+ hairpin_rules[\"rule_%d\" % (i + 1)]\n+ + \" act=set_q{qnum=%s no_implicit_vsi=1 prec=5}\" % qnum[i]\n+ )\n+ self.validate_hairpin_queue(count=16, rules=rules, match_pkts=match_pkt)\n+\n+ def tear_down(self):\n+ \"\"\"\n+ Run after each test case.\n+ \"\"\"\n+ self.pmdout.quit()\n+ self.dut.kill_all()\n+\n+ def tear_down_all(self):\n+ \"\"\"\n+ Run after each test suite.\n+ \"\"\"\n+ self.dut.kill_all()\n", "prefixes": [ "V2", "3/3" ] }