Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/129557/?format=api
{ "id": 129557, "url": "http://patchwork.dpdk.org/api/patches/129557/?format=api", "web_url": "http://patchwork.dpdk.org/project/dts/patch/20230716134416.3220611-4-yaqi.tang@intel.com/", "project": { "id": 3, "url": "http://patchwork.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": "<20230716134416.3220611-4-yaqi.tang@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20230716134416.3220611-4-yaqi.tang@intel.com", "date": "2023-07-16T13:44:16", "name": "[V1,3/3] tests/mev_cpfl_hairpin_queue: mev cpfl support hairpin queue", "commit_ref": null, "pull_url": null, "state": "new", "archived": false, "hash": "510f77658efbb4f73707d6640ba6425958700318", "submitter": { "id": 2357, "url": "http://patchwork.dpdk.org/api/people/2357/?format=api", "name": "Yaqi Tang", "email": "yaqi.tang@intel.com" }, "delegate": null, "mbox": "http://patchwork.dpdk.org/project/dts/patch/20230716134416.3220611-4-yaqi.tang@intel.com/mbox/", "series": [ { "id": 28945, "url": "http://patchwork.dpdk.org/api/series/28945/?format=api", "web_url": "http://patchwork.dpdk.org/project/dts/list/?series=28945", "date": "2023-07-16T13:44:13", "name": "MEV CPFL support hairpin queue", "version": 1, "mbox": "http://patchwork.dpdk.org/series/28945/mbox/" } ], "comments": "http://patchwork.dpdk.org/api/patches/129557/comments/", "check": "fail", "checks": "http://patchwork.dpdk.org/api/patches/129557/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 D6D7242E8C;\n\tSun, 16 Jul 2023 15:45:15 +0200 (CEST)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id D0F1E42BDA;\n\tSun, 16 Jul 2023 15:45:15 +0200 (CEST)", "from mga09.intel.com (mga09.intel.com [134.134.136.24])\n by mails.dpdk.org (Postfix) with ESMTP id 6D2614013F\n for <dts@dpdk.org>; Sun, 16 Jul 2023 15:45:14 +0200 (CEST)", "from fmsmga005.fm.intel.com ([10.253.24.32])\n by orsmga102.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 16 Jul 2023 06:45:13 -0700", "from dpdk-yaqi.sh.intel.com ([10.67.118.189])\n by fmsmga005.fm.intel.com with ESMTP; 16 Jul 2023 06:45:12 -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=1689515114; x=1721051114;\n h=from:to:cc:subject:date:message-id:in-reply-to:\n references:mime-version:content-transfer-encoding;\n bh=4fsTvdBDat3PVQIJ7VSlFETWJXnSEaGLenX1uoraLoY=;\n b=FpWx9UGNXt00ftHlUsunEQZdkwaHXtpHUc95KqEseD0ZiXkApg71C57X\n oeme1gvYdmq3hCX61A6M5podm0ohNHfAfoS9F/R5zsTZLV85h54YurWXA\n zgvmIWNwMd1BXOTAYAd150Aut3HQd1A8ojPvgW1cruNWXv0rXK5MnmHH+\n 5ysIqQMHdxVWJb0PZAztOfSg7qMsxKyJeeKqJjmmWCbUY01j3OoiXBWvc\n b/Baz9DvNuRvccRMg9c8sBmrFPWnp+9bua41AIEHGF8FNomZInTyNiw23\n tj2iAxnN5scIxTn3j38slwa3Hz7qPwnKVdQq+8k4/GK5Fcd77nX6VJJhi g==;", "X-IronPort-AV": [ "E=McAfee;i=\"6600,9927,10773\"; a=\"368400786\"", "E=Sophos;i=\"6.01,210,1684825200\"; d=\"scan'208\";a=\"368400786\"", "E=McAfee;i=\"6600,9927,10773\"; a=\"1053618703\"", "E=Sophos;i=\"6.01,210,1684825200\"; d=\"scan'208\";a=\"1053618703\"" ], "X-ExtLoop1": "1", "From": "Yaqi Tang <yaqi.tang@intel.com>", "To": "dts@dpdk.org", "Cc": "Yaqi Tang <yaqi.tang@intel.com>", "Subject": "[PATCH V1 3/3] tests/mev_cpfl_hairpin_queue: mev cpfl support hairpin\n queue", "Date": "Sun, 16 Jul 2023 13:44:16 +0000", "Message-Id": "<20230716134416.3220611-4-yaqi.tang@intel.com>", "X-Mailer": "git-send-email 2.25.1", "In-Reply-To": "<20230716134416.3220611-1-yaqi.tang@intel.com>", "References": "<20230716134416.3220611-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": "Enabling Port2Port forwarding as hairpin queue implementation in dpdk cpfl PMD.\n\nSigned-off-by: Yaqi Tang <yaqi.tang@intel.com>\n---\n tests/TestSuite_mev_cpfl_hairpin_queue.py | 281 ++++++++++++++++++++++\n 1 file changed, 281 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..d9cc71f7\n--- /dev/null\n+++ b/tests/TestSuite_mev_cpfl_hairpin_queue.py\n@@ -0,0 +1,281 @@\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 TestHairpinqueue(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+ print(qnum)\n+ return qnum\n+\n+ def start_testpmd(self):\n+ self.dut.send_expect(\"set verbose 1\", \"testpmd>\")\n+ self.dut.send_expect(\"start\", \"testpmd>\", 10)\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_session(self):\n+ self.imc_test_session = self.dut.new_session(suite=\"imc\")\n+ self.imc_test_session.send_expect(\"export TERM=linux-c-nc\", \"#\")\n+ out = self.imc_test_session.send_command(\n+ \"sudo minicom -D /dev/ttyUSB2 -b 460800 -w\"\n+ )\n+ if \"Device /dev/ttyUSB2 is locked\" in out:\n+ self.imc_test_session.send_command(\n+ \"ps -ef | grep 'minicom -D /dev/ttyUSB2' | grep -v grep | awk '{print $2}' | xargs kill -9\"\n+ )\n+ self.imc_test_session.send_command(\n+ \"sudo minicom -D /dev/ttyUSB2 -b 460800 -w\"\n+ )\n+ if \"mev-imc login:\" in self.imc_test_session.send_command(\"\\n\"):\n+ self.imc_test_session.send_expect(\"root\", \"mev-imc\")\n+ else:\n+ self.imc_test_session.send_expect(\"\\n\", \"mev-imc\")\n+ self.logger.info(\"create imc test session successfully\")\n+ return self.imc_test_session\n+\n+ def create_imc_rule(self, count, rules):\n+ self.create_imc_session()\n+ self.imc_test_session.send_expect(\n+ \"mkdir -p %s\" % (self.imc_rule_dir), \"mev-imc\"\n+ )\n+ self.imc_test_session.send_expect(\"cd %s\" % (self.imc_rule_dir), \"mev-imc\")\n+ self.imc_test_session.send_expect(\"rm *.txt\", \"mev-imc\")\n+ for i in range(count):\n+ rule = rules[\"rule_%d\" % (i + 1)]\n+ print(rule)\n+ time.sleep(2)\n+ self.imc_test_session.send_command(\"cat > rule_%d.txt\" % (i + 1))\n+ self.imc_test_session.send_command(\"%s\" % rule)\n+ self.imc_test_session.send_command(\"^d\")\n+ print(self.imc_test_session.send_expect(\"ls\", \"#\"))\n+ output = self.imc_test_session.send_command(\n+ \"cli_client -x -f rule_%d.txt\" % (i + 1), 10\n+ )\n+ print(output)\n+ time.sleep(2)\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.imc_test_session.send_expect(\"cd %s\" % (self.imc_rule_dir), \"mev-imc\")\n+ print(self.imc_test_session.send_expect(\"ls\", \"#\"))\n+ for i in range(count):\n+ self.imc_test_session.send_command(\n+ \"sed -i 's/opcode=0x1303/opcode=0x1305/g' rule_%d.txt\" % (i + 1), 2\n+ )\n+ output = self.imc_test_session.send_command(\n+ \"cli_client -x -f rule_%d.txt\" % (i + 1), 5\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):\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.dut.send_expect(\"clear port stats all\", \"testpmd>\", 10)\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.dut.send_expect(\"show port stats all\", \"testpmd>\", 10)\n+ time.sleep(2)\n+ p = self.tester.load_tcpdump_sniff_packets(inst)\n+ print(len(p))\n+ self.verify(\n+ len(p) == count,\n+ \"Send %d packets but received %d packets, not match\" % (count, 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)\n+ self.start_testpmd()\n+ self.check_tcpdump_pkts(mismatch_pkt, count=8)\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 data queue and single hairpin 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.dut.send_expect(\"stop\", \"testpmd> \", 10)\n+ self.dut.send_expect(\"quit\", \"# \", 10)\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: multi data queues and single hairpin 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: single data queue and multi hairpin queues ================\"\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.dut.send_expect(\"stop\", \"testpmd> \", 10)\n+ self.dut.send_expect(\"quit\", \"# \", 10)\n+\n+ self.logger.info(\n+ \"===================Test subcase 2: multi data queues and multi hairpin 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.dut.send_expect(\"stop\", \"testpmd> \", 10)\n+ self.dut.send_expect(\"quit\", \"# \", 10)\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": [ "V1", "3/3" ] }