Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/121337/?format=api
{ "id": 121337, "url": "http://patches.dpdk.org/api/patches/121337/?format=api", "web_url": "http://patches.dpdk.org/project/dts/patch/20221223031207.753486-1-weix.ling@intel.com/", "project": { "id": 3, "url": "http://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": "<20221223031207.753486-1-weix.ling@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20221223031207.753486-1-weix.ling@intel.com", "date": "2022-12-23T03:12:07", "name": "[V1,3/4] tests/vhost_dsa: add new testsuite", "commit_ref": null, "pull_url": null, "state": "accepted", "archived": false, "hash": "80a53bcd8a044de1f76cf705e3eac3a2cee989c6", "submitter": { "id": 1828, "url": "http://patches.dpdk.org/api/people/1828/?format=api", "name": "Ling, WeiX", "email": "weix.ling@intel.com" }, "delegate": null, "mbox": "http://patches.dpdk.org/project/dts/patch/20221223031207.753486-1-weix.ling@intel.com/mbox/", "series": [ { "id": 26254, "url": "http://patches.dpdk.org/api/series/26254/?format=api", "web_url": "http://patches.dpdk.org/project/dts/list/?series=26254", "date": "2022-12-23T03:11:40", "name": "add vhost_dsa testplan and testsuite", "version": 1, "mbox": "http://patches.dpdk.org/series/26254/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/121337/comments/", "check": "pending", "checks": "http://patches.dpdk.org/api/patches/121337/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 06A24A0093;\n\tFri, 23 Dec 2022 04:20:57 +0100 (CET)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 00E35427EB;\n\tFri, 23 Dec 2022 04:20:57 +0100 (CET)", "from mga12.intel.com (mga12.intel.com [192.55.52.136])\n by mails.dpdk.org (Postfix) with ESMTP id 0369540685\n for <dts@dpdk.org>; Fri, 23 Dec 2022 04:20:54 +0100 (CET)", "from orsmga001.jf.intel.com ([10.7.209.18])\n by fmsmga106.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 22 Dec 2022 19:20:53 -0800", "from unknown (HELO localhost.localdomain) ([10.239.252.222])\n by orsmga001-auth.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 22 Dec 2022 19:20:51 -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=1671765655; x=1703301655;\n h=from:to:cc:subject:date:message-id:mime-version:\n content-transfer-encoding;\n bh=kLLUjydC00bQa5SunQelKrHctYNwCJt0xPCWrGpUGYQ=;\n b=Sx70iTixwLJPNdGhHZY2mcCYlOos8KjqWZzDy9pWSOen9wY2/GfTxCNI\n spfhr5AvXAdhCkKT8dR7rM672GetkrOK7206/GVskdvXerOUXw5+90h52\n eAS6Ni4P+sWBPkeSN5W7dZYZpcEeNMom+nUQSwrh06B9ws50Mmrf5DLBK\n LqQyU0h0oT4azuNdS1Abe8668+Ol36i5DcJjDmAVzoIhA5UGVvd0OdWz6\n WuFcSI42TUXC9k8vUh7d9MiULdDzasML2qkLB3+R+WCA6qnOzrGL1S3bH\n fhoghz0o0R+WCnzcPdajXK2I4sK66/iC+qGw5Sv7+o0rGED+vLRUKYC+g g==;", "X-IronPort-AV": [ "E=McAfee;i=\"6500,9779,10569\"; a=\"299937595\"", "E=Sophos;i=\"5.96,267,1665471600\"; d=\"scan'208\";a=\"299937595\"", "E=McAfee;i=\"6500,9779,10569\"; a=\"684404562\"", "E=Sophos;i=\"5.96,267,1665471600\"; d=\"scan'208\";a=\"684404562\"" ], "From": "Wei Ling <weix.ling@intel.com>", "To": "dts@dpdk.org", "Cc": "Wei Ling <weix.ling@intel.com>", "Subject": "[dts][PATCH V1 3/4] tests/vhost_dsa: add new testsuite", "Date": "Fri, 23 Dec 2022 11:12:07 +0800", "Message-Id": "<20221223031207.753486-1-weix.ling@intel.com>", "X-Mailer": "git-send-email 2.25.1", "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": "Add vhost_dsa testsuite to test the PVP topo with split ring and packed\nring all path with DSA dirver.\n\nSigned-off-by: Wei Ling <weix.ling@intel.com>\n---\n tests/TestSuite_vhost_dsa.py | 2326 ++++++++++++++++++++++++++++++++++\n 1 file changed, 2326 insertions(+)\n create mode 100644 tests/TestSuite_vhost_dsa.py", "diff": "diff --git a/tests/TestSuite_vhost_dsa.py b/tests/TestSuite_vhost_dsa.py\nnew file mode 100644\nindex 00000000..1477eb6c\n--- /dev/null\n+++ b/tests/TestSuite_vhost_dsa.py\n@@ -0,0 +1,2326 @@\n+# SPDX-License-Identifier: BSD-3-Clause\n+# Copyright(c) 2022 Intel Corporation\n+#\n+\n+import json\n+import os\n+import re\n+from copy import deepcopy\n+\n+import framework.rst as rst\n+from framework.packet import Packet\n+from framework.pktgen import PacketGeneratorHelper\n+from framework.pmd_output import PmdOutput\n+from framework.settings import HEADER_SIZE, UPDATE_EXPECTED, load_global_setting\n+from framework.test_case import TestCase\n+\n+from .virtio_common import dsa_common as DC\n+\n+SPLIT_RING_PATH = {\n+ \"inorder_mergeable\": \"mrg_rxbuf=1,in_order=1\",\n+ \"mergeable\": \"mrg_rxbuf=1,in_order=0\",\n+ \"inorder_non_mergeable\": \"mrg_rxbuf=0,in_order=1\",\n+ \"non_mergeable\": \"mrg_rxbuf=0,in_order=0\",\n+ \"vectorized\": \"mrg_rxbuf=0,in_order=0,vectorized=1\",\n+}\n+\n+PACKED_RING_PATH = {\n+ \"inorder_mergeable\": \"mrg_rxbuf=1,in_order=1,packed_vq=1\",\n+ \"mergeable\": \"mrg_rxbuf=1,in_order=0,packed_vq=1\",\n+ \"inorder_non_mergeable\": \"mrg_rxbuf=0,in_order=1,packed_vq=1\",\n+ \"non_mergeable\": \"mrg_rxbuf=0,in_order=0,packed_vq=1\",\n+ \"vectorized\": \"mrg_rxbuf=0,in_order=0,vectorized=1,packed_vq=1\",\n+ \"vectorized_path_not_power_of_2\": \"mrg_rxbuf=0,in_order=0,vectorized=1,packed_vq=1,queue_size=1025\",\n+}\n+\n+\n+class TestVhostDsa(TestCase):\n+ def set_up_all(self):\n+ self.dut_ports = self.dut.get_ports()\n+ self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])\n+ self.number_of_ports = 1\n+ self.vhost_user = self.dut.new_session(suite=\"vhost-user\")\n+ self.virtio_user = self.dut.new_session(suite=\"virtio-user\")\n+ self.vhost_user_pmd = PmdOutput(self.dut, self.vhost_user)\n+ self.virtio_user_pmd = PmdOutput(self.dut, self.virtio_user)\n+ self.virtio_mac = \"00:01:02:03:04:05\"\n+ self.headers_size = HEADER_SIZE[\"eth\"] + HEADER_SIZE[\"ip\"] + HEADER_SIZE[\"tcp\"]\n+ self.pci_info = self.dut.ports_info[0][\"pci\"]\n+ self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])\n+ self.cores_list = self.dut.get_core_list(config=\"all\", socket=self.ports_socket)\n+ self.vhost_core_list = self.cores_list[0:9]\n+ self.virtio_core_list = self.cores_list[10:15]\n+ self.out_path = \"/tmp/%s\" % self.suite_name\n+ out = self.tester.send_expect(\"ls -d %s\" % self.out_path, \"# \")\n+ if \"No such file or directory\" in out:\n+ self.tester.send_expect(\"mkdir -p %s\" % self.out_path, \"# \")\n+ self.pktgen_helper = PacketGeneratorHelper()\n+ self.base_dir = self.dut.base_dir.replace(\"~\", \"/root\")\n+ self.testpmd_name = self.dut.apps_name[\"test-pmd\"].split(\"/\")[-1]\n+ self.save_result_flag = True\n+ self.json_obj = {}\n+ self.DC = DC(self)\n+\n+ def set_up(self):\n+ \"\"\"\n+ Run before each test case.\n+ \"\"\"\n+ self.table_header = [\"Frame\", \"Mode/RXD-TXD\", \"Mpps\", \"% linerate\"]\n+ self.result_table_create(self.table_header)\n+ self.test_parameters = self.get_suite_cfg()[\"test_parameters\"]\n+ self.test_duration = self.get_suite_cfg()[\"test_duration\"]\n+ self.throughput = {}\n+ self.gap = self.get_suite_cfg()[\"accepted_tolerance\"]\n+ self.test_result = {}\n+ self.nb_desc = self.test_parameters.get(list(self.test_parameters.keys())[0])[0]\n+ self.dut.send_expect(\"killall -I %s\" % self.testpmd_name, \"#\", 20)\n+ self.dut.send_expect(\"rm -rf %s/vhost-net*\" % self.base_dir, \"#\")\n+ self.mode_list = []\n+ self.DC.reset_all_work_queue()\n+ self.DC.bind_all_dsa_to_kernel()\n+\n+ def get_vhost_port_num(self):\n+ out = self.vhost_user.send_expect(\"show port summary all\", \"testpmd> \", 60)\n+ port_num = re.search(\"Number of available ports:\\s*(\\d*)\", out)\n+ return int(port_num.group(1))\n+\n+ def check_each_queue_of_port_packets(self, queues):\n+ \"\"\"\n+ check each queue of each port has receive packets\n+ \"\"\"\n+ self.logger.info(self.vhost_user_pmd.execute_cmd(\"show port stats all\"))\n+ out = self.vhost_user_pmd.execute_cmd(\"stop\")\n+ self.logger.info(out)\n+ port_num = self.get_vhost_port_num()\n+ for port in range(port_num):\n+ for queue in range(queues):\n+ if queues == 1:\n+ reg = \"Forward statistics for port %d\" % port\n+ else:\n+ reg = \"Port= %d/Queue= %d\" % (port, queue)\n+ index = out.find(reg)\n+ rx = re.search(\"RX-packets:\\s*(\\d*)\", out[index:])\n+ tx = re.search(\"TX-packets:\\s*(\\d*)\", out[index:])\n+ rx_packets = int(rx.group(1))\n+ tx_packets = int(tx.group(1))\n+ self.verify(\n+ rx_packets > 0 and tx_packets > 0,\n+ \"The port %d/queue %d rx-packets or tx-packets is 0 about \"\n+ % (port, queue)\n+ + \"rx-packets: %d, tx-packets: %d\" % (rx_packets, tx_packets),\n+ )\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+\n+ @property\n+ def check_2M_env(self):\n+ out = self.dut.send_expect(\n+ \"cat /proc/meminfo |grep Hugepagesize|awk '{print($2)}'\", \"# \"\n+ )\n+ return True if out == \"2048\" else False\n+\n+ def start_vhost_testpmd(\n+ self,\n+ cores=\"Default\",\n+ param=\"\",\n+ eal_param=\"\",\n+ ports=\"\",\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ ):\n+ eal_param += \" --iova=\" + iova_mode\n+ if port_options != \"\":\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=cores,\n+ param=param,\n+ eal_param=eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ prefix=\"vhost\",\n+ )\n+ else:\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=cores,\n+ param=param,\n+ eal_param=eal_param,\n+ ports=ports,\n+ prefix=\"vhost\",\n+ )\n+ if self.nic == \"I40E_40G-QSFP_A\":\n+ self.vhost_user_pmd.execute_cmd(\"port config all rss ipv4-tcp\")\n+ self.vhost_user_pmd.execute_cmd(\"set fwd mac\")\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+\n+ def start_virtio_testpmd(self, cores=\"Default\", param=\"\", eal_param=\"\"):\n+ if self.check_2M_env:\n+ eal_param += \" --single-file-segments\"\n+ self.virtio_user_pmd.start_testpmd(\n+ cores=cores, param=param, eal_param=eal_param, no_pci=True, prefix=\"virtio\"\n+ )\n+ # self.virtio_user_pmd.execute_cmd(\"set fwd csum\")\n+ self.virtio_user_pmd.execute_cmd(\"set fwd mac\")\n+ self.virtio_user_pmd.execute_cmd(\"start\")\n+\n+ def test_perf_pvp_split_ring_vhost_async_operation_test_with_each_tx_rx_queue_using_1_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 1: PVP split ring vhost async operation test with each tx/rx queue using one DSA dpdk driver channel\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q1;\"\n+ \"rxq0@%s-q2;\"\n+ \"rxq1@%s-q3\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=2,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ for i in self.use_dsa_list:\n+ ports.append(i)\n+ port_options = {self.use_dsa_list[0]: \"max_queues=4\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ virtio_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+ for key, path in SPLIT_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=2'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"non_mergeable\":\n+ new_virtio_param = \"--enable-hw-vlan-strip \" + virtio_param\n+ else:\n+ new_virtio_param = virtio_param\n+\n+ mode = key + \"_VA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=new_virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ mode += \"_RestartVhost\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+ self.virtio_user_pmd.quit()\n+\n+ if not self.check_2M_env:\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q1;\"\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q1\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ )\n+ vhost_param = \"--nb-cores=2 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=2,dmas=[%s]'\" % dmas\n+ )\n+ port_options = {\n+ self.use_dsa_list[0]: \"max_queues=2\",\n+ self.use_dsa_list[1]: \"max_queues=2\",\n+ }\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"pa\",\n+ )\n+ for key, path in SPLIT_RING_PATH.items():\n+ if key == \"inorder_mergeable\":\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=./vhost-net0,%s,queues=2'\"\n+ % (self.virtio_mac, path)\n+ )\n+\n+ mode = key + \"_PA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ mode += \"_RestartVhost\"\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+ self.virtio_user_pmd.quit()\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_split_ring_vhost_async_operation_test_with_dpdk_driver_being_shared_among_multi_tx_rx_queue(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 2: PVP split ring vhost async operations test with one DSA dpdk driver channel being shared among multiple tx/rx queues\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q0;\"\n+ \"txq3@%s-q0;\"\n+ \"txq4@%s-q1;\"\n+ \"txq5@%s-q1;\"\n+ \"txq6@%s-q1;\"\n+ \"txq7@%s-q1;\"\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q0;\"\n+ \"rxq2@%s-q0;\"\n+ \"rxq3@%s-q0;\"\n+ \"rxq4@%s-q1;\"\n+ \"rxq5@%s-q1;\"\n+ \"rxq6@%s-q1;\"\n+ \"rxq7@%s-q1\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ for i in self.use_dsa_list:\n+ ports.append(i)\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in SPLIT_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"non_mergeable\":\n+ new_virtio_param = \"--enable-hw-vlan-strip \" + virtio_param\n+ else:\n+ new_virtio_param = virtio_param\n+\n+ mode = key + \"_VA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=new_virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ mode += \"_RestartVhost\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+ self.virtio_user_pmd.quit()\n+\n+ if not self.check_2M_env:\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q1;\"\n+ \"txq2@%s-q2;\"\n+ \"txq3@%s-q3;\"\n+ \"txq4@%s-q4;\"\n+ \"txq5@%s-q5;\"\n+ \"txq6@%s-q6;\"\n+ \"txq7@%s-q7;\"\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q1;\"\n+ \"rxq2@%s-q2;\"\n+ \"rxq3@%s-q3;\"\n+ \"rxq4@%s-q4;\"\n+ \"rxq5@%s-q5;\"\n+ \"rxq6@%s-q6;\"\n+ \"rxq7@%s-q7\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=6 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=8\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"pa\",\n+ )\n+ for key, path in SPLIT_RING_PATH.items():\n+ if key == \"mergeable\":\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=./vhost-net0,%s,queues=8'\"\n+ % (self.virtio_mac, path)\n+ )\n+\n+ mode = key + \"_PA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ mode += \"_RestartVhost\"\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+ self.virtio_user_pmd.quit()\n+\n+ if not self.check_2M_env:\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q0;\"\n+ \"txq3@%s-q0;\"\n+ \"txq4@%s-q0;\"\n+ \"txq5@%s-q0;\"\n+ \"txq6@%s-q0;\"\n+ \"txq7@%s-q0;\"\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q0;\"\n+ \"rxq2@%s-q0;\"\n+ \"rxq3@%s-q0;\"\n+ \"rxq4@%s-q0;\"\n+ \"rxq5@%s-q0;\"\n+ \"rxq6@%s-q0;\"\n+ \"rxq7@%s-q0\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=6 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=1\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"pa\",\n+ )\n+ for key, path in SPLIT_RING_PATH.items():\n+ if key == \"inorder_non_mergeable\":\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=./vhost-net0,%s,queues=8'\"\n+ % (self.virtio_mac, path)\n+ )\n+\n+ mode = key + \"_PA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ mode += \"_RestartVhost\"\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+ self.virtio_user_pmd.quit()\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_split_ring_dynamic_queues_vhost_async_operation_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 3: PVP split ring dynamic queues vhost async operation with dsa dpdk driver channels\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q1;\"\n+ \"txq2@%s-q2;\"\n+ \"txq3@%s-q2\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=4 --rxq=4 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ for i in self.use_dsa_list:\n+ ports.append(i)\n+ port_options = {self.use_dsa_list[0]: \"max_queues=4\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in SPLIT_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8,server=1'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"inorder_mergeable\":\n+ mode = key + \"_VA_4_queue\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ self.vhost_user_pmd.quit()\n+ vhost_eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,'\"\n+ vhost_param = \"--nb-cores=2 --txq=1 --rxq=1 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=[self.dut.ports_info[0][\"pci\"]],\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_1_queue_wo_dsa\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=1)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q1;\"\n+ \"rxq2@%s-q1;\"\n+ \"rxq3@%s-q0\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=4 --rxq=4 --txd=1024 --rxd=1024\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=4\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_4_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=4)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q0;\"\n+ \"txq3@%s-q0;\"\n+ \"txq4@%s-q1;\"\n+ \"txq5@%s-q2;\"\n+ \"rxq2@%s-q0;\"\n+ \"rxq3@%s-q1;\"\n+ \"rxq4@%s-q2;\"\n+ \"rxq5@%s-q2;\"\n+ \"rxq6@%s-q2;\"\n+ \"rxq7@%s-q2\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ port_options = {\n+ self.use_dsa_list[0]: \"max_queues=4\",\n+ self.use_dsa_list[1]: \"max_queues=4\",\n+ }\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_8_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.virtio_user_pmd.quit()\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in SPLIT_RING_PATH.items():\n+ if key == \"non_mergeable\":\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8,server=1'\"\n+ % (self.virtio_mac, path)\n+ )\n+ mode = key + \"_VA_8_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q0;\"\n+ \"rxq1@%s-q1;\"\n+ \"rxq2@%s-q1;\"\n+ \"rxq3@%s-q1\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=5 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"pa\",\n+ )\n+ mode = \"non_mergeable\" + \"_PA_4_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_packed_ring_vhost_async_operation_test_with_each_tx_rx_queue_using_1_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 4: PVP packed ring vhost async operation test with each tx/rx queue using one DSA dpdk driver channel\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q1;\"\n+ \"rxq0@%s-q2;\"\n+ \"rxq1@%s-q2\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=2,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ for i in self.use_dsa_list:\n+ ports.append(i)\n+ port_options = {self.use_dsa_list[0]: \"max_queues=4\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ for key, path in PACKED_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=2'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if \"vectorized\" in key:\n+ virtio_eal_param = \"--force-max-simd-bitwidth=512 \" + virtio_eal_param\n+ if key == \"vectorized_path_not_power_of_2\":\n+ virtio_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1025 --rxd=1025\"\n+ else:\n+ virtio_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+\n+ mode = key + \"_VA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ mode += \"_RestartVhost\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+ self.virtio_user_pmd.quit()\n+\n+ if not self.check_2M_env:\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q1;\"\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q1\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=2,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=2 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"pa\",\n+ )\n+ virtio_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+ for key, path in PACKED_RING_PATH.items():\n+ if key == \"inorder_mergeable\":\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=./vhost-net0,%s,queues=2'\"\n+ % (self.virtio_mac, path)\n+ )\n+\n+ mode = key + \"_PA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ mode += \"_RestartVhost\"\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+ self.virtio_user_pmd.quit()\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_packed_ring_vhost_async_operation_test_with_1_dpdk_driver_being_shared_among_multi_tx_rx_queue(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 5: PVP packed ring vhost async operation test with one DSA dpdk driver channel being shared among multiple tx/rx queues\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q0;\"\n+ \"txq3@%s-q0;\"\n+ \"txq4@%s-q1;\"\n+ \"txq5@%s-q1;\"\n+ \"txq6@%s-q1;\"\n+ \"txq7@%s-q1;\"\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q0;\"\n+ \"rxq2@%s-q0;\"\n+ \"rxq3@%s-q0;\"\n+ \"rxq4@%s-q1;\"\n+ \"rxq5@%s-q1;\"\n+ \"rxq6@%s-q1;\"\n+ \"rxq7@%s-q1\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ for i in self.use_dsa_list:\n+ ports.append(i)\n+ port_options = {self.use_dsa_list[0]: \"max_queues=4\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ for key, path in PACKED_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if \"vectorized\" in key:\n+ virtio_eal_param = \"--force-max-simd-bitwidth=512 \" + virtio_eal_param\n+ if key == \"vectorized_path_not_power_of_2\":\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1025 --rxd=1025\"\n+ else:\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+\n+ mode = key + \"_VA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ mode += \"_RestartVhost\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+ self.virtio_user_pmd.quit()\n+\n+ if not self.check_2M_env:\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q0;\"\n+ \"txq3@%s-q0;\"\n+ \"txq4@%s-q0;\"\n+ \"txq5@%s-q0;\"\n+ \"txq6@%s-q0;\"\n+ \"txq7@%s-q0;\"\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q0;\"\n+ \"rxq2@%s-q0;\"\n+ \"rxq3@%s-q0;\"\n+ \"rxq4@%s-q0;\"\n+ \"rxq5@%s-q0;\"\n+ \"rxq6@%s-q0;\"\n+ \"rxq7@%s-q0\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"pa\",\n+ )\n+ virtio_param = \"--nb-cores=2 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in PACKED_RING_PATH.items():\n+ if key == \"inorder_non_mergeable\":\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=./vhost-net0,%s,queues=8'\"\n+ % (self.virtio_mac, path)\n+ )\n+\n+ mode = key + \"_PA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ mode += \"_RestartVhost\"\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+ self.virtio_user_pmd.quit()\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_packed_ring_dynamic_queues_vhost_async_operation_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 6: PVP packed ring dynamic queues vhost async operation with dsa dpdk driver channels\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q1\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=4 --rxq=4 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ for i in self.use_dsa_list:\n+ ports.append(i)\n+ port_options = {\n+ self.use_dsa_list[0]: \"max_queues=4\",\n+ self.use_dsa_list[1]: \"max_queues=4\",\n+ }\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in PACKED_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8,server=1'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"inorder_mergeable\":\n+ mode = key + \"_VA_4_queue\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ self.vhost_user_pmd.quit()\n+ vhost_eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,'\"\n+ vhost_param = \"--nb-cores=2 --txq=1 --rxq=1 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=[self.dut.ports_info[0][\"pci\"]],\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_1_queue_wo_dsa\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=1)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q1;\"\n+ \"rxq2@%s-q1\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=4 --rxq=4 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_4_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=4)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q0;\"\n+ \"txq3@%s-q0;\"\n+ \"txq4@%s-q1;\"\n+ \"txq5@%s-q2;\"\n+ \"rxq2@%s-q0;\"\n+ \"rxq3@%s-q1;\"\n+ \"rxq4@%s-q2;\"\n+ \"rxq5@%s-q2;\"\n+ \"rxq6@%s-q2;\"\n+ \"rxq7@%s-q2\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=2 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_8_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.virtio_user_pmd.quit()\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in PACKED_RING_PATH.items():\n+ if key == \"non_mergeable\":\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8,server=1'\"\n+ % (self.virtio_mac, path)\n+ )\n+ mode = key + \"_VA_8_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q0;\"\n+ \"rxq1@%s-q1;\"\n+ \"rxq2@%s-q1;\"\n+ \"rxq3@%s-q1\"\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=5 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"pa\",\n+ )\n+ mode = \"non_mergeable\" + \"_PA_4_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_split_ring_vhost_async_operation_test_with_each_tx_rx_queue_using_1_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 7: PVP split ring vhost async operation test with each tx/rx queue using one DSA kernel driver channel\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=4, dsa_index=0)\n+ dmas = \"txq0@wq0.0;\" \"txq1@wq0.1;\" \"rxq0@wq0.2;\" \"rxq1@wq0.3\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=2,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ virtio_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+ for key, path in SPLIT_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=2'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"non_mergeable\":\n+ new_virtio_param = \"--enable-hw-vlan-strip \" + virtio_param\n+ else:\n+ new_virtio_param = virtio_param\n+\n+ mode = key + \"_VA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=new_virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ mode += \"_RestartVhost\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+ self.virtio_user_pmd.quit()\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_split_ring_vhost_async_operation_test_with_1_kernel_driver_being_shared_among_multi_tx_rx_queue(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 8: PVP split ring all path multi-queues vhost async operation test with one DSA kernel driver channel being shared among multiple tx/rx queues\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=4, dsa_index=0)\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.0;\"\n+ \"txq2@wq0.0;\"\n+ \"txq3@wq0.0;\"\n+ \"txq4@wq0.1;\"\n+ \"txq5@wq0.1;\"\n+ \"txq6@wq0.1;\"\n+ \"txq7@wq0.1;\"\n+ \"rxq0@wq0.0;\"\n+ \"rxq1@wq0.0;\"\n+ \"rxq2@wq0.0;\"\n+ \"rxq3@wq0.0;\"\n+ \"rxq4@wq0.1;\"\n+ \"rxq5@wq0.1;\"\n+ \"rxq6@wq0.1;\"\n+ \"rxq7@wq0.1\"\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in SPLIT_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"non_mergeable\":\n+ new_virtio_param = \"--enable-hw-vlan-strip \" + virtio_param\n+ else:\n+ new_virtio_param = virtio_param\n+\n+ mode = key + \"_VA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=new_virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ mode += \"_RestartVhost\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+ self.virtio_user_pmd.quit()\n+\n+ if not self.check_2M_env:\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.0;\"\n+ \"txq2@wq0.1;\"\n+ \"txq3@wq0.1;\"\n+ \"txq4@wq0.2;\"\n+ \"txq5@wq0.2;\"\n+ \"txq6@wq0.3;\"\n+ \"txq7@wq0.3;\"\n+ \"rxq0@wq0.0;\"\n+ \"rxq1@wq0.0;\"\n+ \"rxq2@wq0.1;\"\n+ \"rxq3@wq0.1;\"\n+ \"rxq4@wq0.2;\"\n+ \"rxq5@wq0.2;\"\n+ \"rxq6@wq0.3;\"\n+ \"rxq7@wq0.3\"\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=6 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"pa\",\n+ )\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_split_ring_dynamic_queue_vhost_async_operation_with_dsa_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 9: PVP split ring dynamic queues vhost async operation with dsa kernel driver channels\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=0)\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=1)\n+ dmas = \"txq0@wq0.0;\" \"txq1@wq0.1;\" \"txq2@wq0.2;\" \"txq3@wq0.2\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=4 --rxq=4 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in SPLIT_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8,server=1'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"inorder_mergeable\":\n+ mode = key + \"_VA_4_queue\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ self.vhost_user_pmd.quit()\n+ vhost_eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,'\"\n+ vhost_param = \"--nb-cores=2 --txq=1 --rxq=1 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=[self.dut.ports_info[0][\"pci\"]],\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_1_queue_wo_dsa\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=1)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = \"rxq0@wq0.0;\" \"rxq1@wq0.1;\" \"rxq2@wq0.1;\" \"rxq3@wq0.0\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=4 --rxq=4 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_4_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=4)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.0;\"\n+ \"txq2@wq0.0;\"\n+ \"txq3@wq0.0;\"\n+ \"txq4@wq0.1;\"\n+ \"txq5@wq0.2;\"\n+ \"rxq2@wq1.0;\"\n+ \"rxq3@wq1.1;\"\n+ \"rxq4@wq1.2;\"\n+ \"rxq5@wq1.2;\"\n+ \"rxq6@wq1.2;\"\n+ \"rxq7@wq1.2\"\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_8_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.1;\"\n+ \"txq2@wq0.2;\"\n+ \"txq3@wq0.3;\"\n+ \"txq4@wq0.4;\"\n+ \"txq5@wq0.5;\"\n+ \"rxq2@wq1.2;\"\n+ \"rxq3@wq1.3;\"\n+ \"rxq4@wq1.4;\"\n+ \"rxq5@wq1.5;\"\n+ \"rxq6@wq1.6;\"\n+ \"rxq7@wq1.7\"\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=5 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_8_queue_diff_1\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.virtio_user_pmd.quit()\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in SPLIT_RING_PATH.items():\n+ if key == \"non_mergeable\":\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8,server=1'\"\n+ % (self.virtio_mac, path)\n+ )\n+ mode = key + \"_VA_8_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_packed_ring_vhost_async_operation_test_with_each_tx_rx_queue_using_1_dsa_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 10: PVP packed ring all path multi-queues vhost async operation test with each tx/rx queue using one DSA kernel driver channel\n+\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=1)\n+ dmas = \"txq0@wq0.0;\" \"txq1@wq0.1;\" \"rxq0@wq1.0;\" \"rxq1@wq1.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=2,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ for key, path in PACKED_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=2'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if \"vectorized\" in key:\n+ virtio_eal_param = \"--force-max-simd-bitwidth=512 \" + virtio_eal_param\n+ if key == \"vectorized_path_not_power_of_2\":\n+ virtio_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1025 --rxd=1025\"\n+ else:\n+ virtio_param = \"--nb-cores=1 --txq=2 --rxq=2 --txd=1024 --rxd=1024\"\n+\n+ mode = key + \"_VA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ mode += \"_RestartVhost\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+ self.virtio_user_pmd.quit()\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_packed_ring_vhost_async_operation_test_with_1_kernel_driver_being_shared_among_multi_tx_rx_queue(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 11: PVP packed ring all path multi-queues vhost async operation test with one DSA kernel driver channel being shared among multiple tx/rx queues\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.0;\"\n+ \"txq2@wq0.0;\"\n+ \"txq3@wq0.0;\"\n+ \"txq4@wq0.1;\"\n+ \"txq5@wq0.1;\"\n+ \"txq6@wq0.1;\"\n+ \"txq7@wq0.1;\"\n+ \"rxq0@wq0.0;\"\n+ \"rxq1@wq0.0;\"\n+ \"rxq2@wq0.0;\"\n+ \"rxq3@wq0.0;\"\n+ \"rxq4@wq0.1;\"\n+ \"rxq5@wq0.1;\"\n+ \"rxq6@wq0.1;\"\n+ \"rxq7@wq0.1\"\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ for key, path in PACKED_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if \"vectorized\" in key:\n+ virtio_eal_param = \"--force-max-simd-bitwidth=512 \" + virtio_eal_param\n+ if key == \"vectorized_path_not_power_of_2\":\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1025 --rxd=1025\"\n+ else:\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+\n+ mode = key + \"_VA\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ mode += \"_RestartVhost\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+ self.virtio_user_pmd.quit()\n+\n+ if not self.check_2M_env:\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.0;\"\n+ \"txq2@wq0.0;\"\n+ \"txq3@wq0.0;\"\n+ \"txq4@wq0.1;\"\n+ \"txq5@wq0.1;\"\n+ \"txq6@wq0.1;\"\n+ \"txq7@wq0.1;\"\n+ \"rxq0@wq0.0;\"\n+ \"rxq1@wq0.0;\"\n+ \"rxq2@wq0.0;\"\n+ \"rxq3@wq0.0;\"\n+ \"rxq4@wq0.1;\"\n+ \"rxq5@wq0.1;\"\n+ \"rxq6@wq0.1;\"\n+ \"rxq7@wq0.1\"\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=6 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"pa\",\n+ )\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_packed_ring_dynamic_queues_vhost_async_operation_with_dsa_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 12: PVP packed ring dynamic queues vhost async operation with dsa kernel driver channels\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=0)\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=1)\n+ dmas = \"txq0@wq0.0;\" \"txq1@wq0.1;\" \"txq2@wq0.2;\" \"txq3@wq0.2\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=4 --rxq=4 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in PACKED_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8,server=1'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"inorder_mergeable\":\n+ mode = key + \"_VA_4_queue\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=2)\n+\n+ self.vhost_user_pmd.quit()\n+ vhost_eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,'\"\n+ vhost_param = \"--nb-cores=1 --txq=1 --rxq=1 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=[self.dut.ports_info[0][\"pci\"]],\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_1_queue_wo_dsa\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=1)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = \"rxq0@wq0.0;\" \"rxq1@wq0.1;\" \"rxq2@wq0.1;\" \"rxq3@wq0.0\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=4 --rxq=4 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_4_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=4)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.0;\"\n+ \"txq2@wq0.0;\"\n+ \"txq3@wq0.0;\"\n+ \"txq4@wq0.1;\"\n+ \"txq5@wq0.2;\"\n+ \"rxq2@wq1.0;\"\n+ \"rxq3@wq1.1;\"\n+ \"rxq4@wq1.2;\"\n+ \"rxq5@wq1.2;\"\n+ \"rxq6@wq1.2;\"\n+ \"rxq7@wq1.2\"\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=2 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_8_queue_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.1;\"\n+ \"txq2@wq0.2;\"\n+ \"txq3@wq0.3;\"\n+ \"txq4@wq0.4;\"\n+ \"txq5@wq0.5;\"\n+ \"rxq2@wq1.2;\"\n+ \"rxq3@wq1.3;\"\n+ \"rxq4@wq1.4;\"\n+ \"rxq5@wq1.5;\"\n+ \"rxq6@wq1.6;\"\n+ \"rxq7@wq1.7\"\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_8_queue_diff_1\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.virtio_user_pmd.quit()\n+ virtio_eal_param = \"--force-max-simd-bitwidth=512 --vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=vhost-net0,mrg_rxbuf=0,in_order=1,packed_vq=1,vectorized=1,queues=8,server=1,queue_size=1025\"\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1025 --rxd=1025\"\n+ mode = \"vectorized_path_not_power_of_2\" + \"_VA_8_queue_diff\"\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def test_perf_pvp_split_and_packed_ring_dynamic_queues_vhost_async_operation_with_dsa_dpdk_and_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 13: PVP split and packed ring dynamic queues vhost async operation with dsa dpdk and kernel driver channels\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=0)\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=1)\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2,\n+ driver_name=\"vfio-pci\",\n+ dsa_index_list=[2, 3],\n+ socket=self.ports_socket,\n+ )\n+ dmas = \"txq0@wq0.0;\" \"txq1@wq0.0\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ )\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in SPLIT_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8,server=1'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"inorder_mergeable\":\n+ mode = key + \"_VA_kernel_driver\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@%s-q0;\"\n+ \"txq1@%s-q0;\"\n+ \"txq2@%s-q1;\"\n+ \"txq3@%s-q1;\"\n+ \"rxq0@%s-q0;\"\n+ \"rxq1@%s-q0;\"\n+ \"rxq2@%s-q1;\"\n+ \"rxq3@%s-q2\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ for i in self.use_dsa_list:\n+ ports.append(i)\n+ port_options = {\n+ self.use_dsa_list[0]: \"max_queues=2\",\n+ self.use_dsa_list[1]: \"max_queues=4\",\n+ }\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_dpdk_driver\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.1;\"\n+ \"txq2@wq0.2;\"\n+ \"txq3@wq0.3;\"\n+ \"txq4@wq0.4;\"\n+ \"txq5@wq0.5;\"\n+ \"txq6@wq0.6;\"\n+ \"rxq2@%s-q0;\"\n+ \"rxq3@%s-q1;\"\n+ \"rxq4@%s-q0;\"\n+ \"rxq5@%s-q1;\"\n+ \"rxq6@%s-q2;\"\n+ \"rxq7@%s-q3\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ for i in self.use_dsa_list:\n+ ports.append(i)\n+ port_options = {\n+ self.use_dsa_list[0]: \"max_queues=2\",\n+ self.use_dsa_list[1]: \"max_queues=4\",\n+ }\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_kernel_dpdk_driver\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.virtio_user_pmd.quit()\n+ virtio_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ for key, path in PACKED_RING_PATH.items():\n+ virtio_eal_param = (\n+ \"--vdev 'net_virtio_user0,mac=%s,path=vhost-net0,%s,queues=8,server=1'\"\n+ % (self.virtio_mac, path)\n+ )\n+ if key == \"inorder_mergeable\":\n+ mode = key + \"_VA_kernel_dpdk_driver_packed\"\n+ self.mode_list.append(mode)\n+ self.start_virtio_testpmd(\n+ cores=self.virtio_core_list,\n+ param=virtio_param,\n+ eal_param=virtio_eal_param,\n+ )\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.vhost_user_pmd.quit()\n+ dmas = (\n+ \"txq0@wq0.0;\"\n+ \"txq1@wq0.1;\"\n+ \"txq2@wq0.2;\"\n+ \"txq3@wq0.3;\"\n+ \"txq4@wq0.4;\"\n+ \"txq5@wq0.5;\"\n+ \"txq6@wq0.6;\"\n+ \"rxq2@%s-q0;\"\n+ \"rxq3@%s-q1;\"\n+ \"rxq4@%s-q0;\"\n+ \"rxq5@%s-q1;\"\n+ \"rxq6@%s-q2;\"\n+ \"rxq7@%s-q3\"\n+ % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,client=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=4 --txq=8 --rxq=8 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ for i in self.use_dsa_list:\n+ ports.append(i)\n+ port_options = {\n+ self.use_dsa_list[0]: \"max_queues=2\",\n+ self.use_dsa_list[1]: \"max_queues=4\",\n+ }\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ param=vhost_param,\n+ eal_param=vhost_eal_param,\n+ ports=ports,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ mode = \"inorder_mergeable\" + \"_VA_kernel_dpdk_driver_packed_diff\"\n+ self.mode_list.append(mode)\n+ self.send_imix_packets(mode=mode)\n+ self.check_each_queue_of_port_packets(queues=8)\n+\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ self.handle_expected(mode_list=self.mode_list)\n+ self.handle_results(mode_list=self.mode_list)\n+ self.vhost_user_pmd.quit()\n+\n+ def send_imix_packets(self, mode):\n+ \"\"\"\n+ Send imix packet with packet generator and verify\n+ \"\"\"\n+ frame_sizes = [64, 128, 256, 512, 1024, 1518]\n+ tgenInput = []\n+ for frame_size in frame_sizes:\n+ payload_size = frame_size - self.headers_size\n+ port = self.tester.get_local_port(self.dut_ports[0])\n+ fields_config = {\n+ \"ip\": {\n+ \"src\": {\"action\": \"random\"},\n+ },\n+ }\n+ pkt = Packet()\n+ pkt.assign_layers([\"ether\", \"ipv4\", \"tcp\", \"raw\"])\n+ pkt.config_layers(\n+ [\n+ (\"ether\", {\"dst\": \"%s\" % self.virtio_mac}),\n+ (\"ipv4\", {\"src\": \"1.1.1.1\"}),\n+ (\"raw\", {\"payload\": [\"01\"] * int(\"%d\" % payload_size)}),\n+ ]\n+ )\n+ pkt.save_pcapfile(\n+ self.tester,\n+ \"%s/%s_%s.pcap\" % (self.out_path, self.suite_name, frame_size),\n+ )\n+ tgenInput.append(\n+ (\n+ port,\n+ port,\n+ \"%s/%s_%s.pcap\" % (self.out_path, self.suite_name, frame_size),\n+ )\n+ )\n+\n+ self.tester.pktgen.clear_streams()\n+ streams = self.pktgen_helper.prepare_stream_from_tginput(\n+ tgenInput, 100, fields_config, self.tester.pktgen\n+ )\n+ trans_options = {\"delay\": 5, \"duration\": self.test_duration}\n+ bps, pps = self.tester.pktgen.measure_throughput(\n+ stream_ids=streams, options=trans_options\n+ )\n+ Mpps = pps / 1000000.0\n+ Mbps = bps / 1000000.0\n+ self.verify(\n+ Mbps > 0,\n+ f\"{self.running_case} can not receive packets of frame size {frame_sizes}\",\n+ )\n+ bps_linerate = self.wirespeed(self.nic, 64, 1) * 8 * (64 + 20)\n+ throughput = Mbps * 100 / float(bps_linerate)\n+ self.throughput[mode] = {\n+ \"imix\": {\n+ self.nb_desc: [Mbps, Mpps],\n+ }\n+ }\n+ results_row = [\"imix\"]\n+ results_row.append(mode)\n+ results_row.append(Mpps)\n+ results_row.append(throughput)\n+ self.result_table_add(results_row)\n+\n+ def handle_expected(self, mode_list):\n+ \"\"\"\n+ Update expected numbers to configurate file: conf/$suite_name.cfg\n+ \"\"\"\n+ if load_global_setting(UPDATE_EXPECTED) == \"yes\":\n+ for mode in mode_list:\n+ for frame_size in self.test_parameters.keys():\n+ for nb_desc in self.test_parameters[frame_size]:\n+ if frame_size == \"imix\":\n+ self.expected_throughput[mode][frame_size][nb_desc] = round(\n+ self.throughput[mode][frame_size][nb_desc][1], 3\n+ )\n+ else:\n+ self.expected_throughput[mode][frame_size][nb_desc] = round(\n+ self.throughput[mode][frame_size][nb_desc], 3\n+ )\n+\n+ def handle_results(self, mode_list):\n+ \"\"\"\n+ results handled process:\n+ \"\"\"\n+ header = self.table_header\n+ header.append(\"nb_desc\")\n+ header.append(\"Expected Throughput\")\n+ header.append(\"Throughput Difference\")\n+ for mode in mode_list:\n+ self.test_result[mode] = dict()\n+ for frame_size in self.test_parameters.keys():\n+ ret_datas = {}\n+ if frame_size == \"imix\":\n+ bps_linerate = self.wirespeed(self.nic, 64, 1) * 8 * (64 + 20)\n+ ret_datas = {}\n+ for nb_desc in self.test_parameters[frame_size]:\n+ ret_data = {}\n+ ret_data[header[0]] = frame_size\n+ ret_data[header[1]] = mode\n+ ret_data[header[2]] = \"{:.3f} Mpps\".format(\n+ self.throughput[mode][frame_size][nb_desc][1]\n+ )\n+ ret_data[header[3]] = \"{:.3f}%\".format(\n+ self.throughput[mode][frame_size][nb_desc][0]\n+ * 100\n+ / bps_linerate\n+ )\n+ ret_data[header[4]] = nb_desc\n+ ret_data[header[5]] = \"{:.3f} Mpps\".format(\n+ self.expected_throughput[mode][frame_size][nb_desc]\n+ )\n+ ret_data[header[6]] = \"{:.3f} Mpps\".format(\n+ self.throughput[mode][frame_size][nb_desc][1]\n+ - self.expected_throughput[mode][frame_size][nb_desc]\n+ )\n+ ret_datas[nb_desc] = deepcopy(ret_data)\n+ else:\n+ wirespeed = self.wirespeed(\n+ self.nic, frame_size, self.number_of_ports\n+ )\n+ for nb_desc in self.test_parameters[frame_size]:\n+ ret_data = {}\n+ ret_data[header[0]] = frame_size\n+ ret_data[header[1]] = mode\n+ ret_data[header[2]] = \"{:.3f} Mpps\".format(\n+ self.throughput[mode][frame_size][nb_desc]\n+ )\n+ ret_data[header[3]] = \"{:.3f}%\".format(\n+ self.throughput[mode][frame_size][nb_desc] * 100 / wirespeed\n+ )\n+ ret_data[header[4]] = nb_desc\n+ ret_data[header[5]] = \"{:.3f} Mpps\".format(\n+ self.expected_throughput[mode][frame_size][nb_desc]\n+ )\n+ ret_data[header[6]] = \"{:.3f} Mpps\".format(\n+ self.throughput[mode][frame_size][nb_desc]\n+ - self.expected_throughput[mode][frame_size][nb_desc]\n+ )\n+ ret_datas[nb_desc] = deepcopy(ret_data)\n+ self.test_result[mode][frame_size] = deepcopy(ret_datas)\n+ self.result_table_create(header)\n+ for mode in mode_list:\n+ for frame_size in self.test_parameters.keys():\n+ for nb_desc in self.test_parameters[frame_size]:\n+ table_row = list()\n+ for i in range(len(header)):\n+ table_row.append(\n+ self.test_result[mode][frame_size][nb_desc][header[i]]\n+ )\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+ if self.save_result_flag:\n+ self.save_result(self.test_result, mode_list)\n+\n+ def save_result(self, data, mode_list):\n+ \"\"\"\n+ Saves the test results as a separated file named with\n+ self.nic+_perf_virtio_user_pvp.json in output folder\n+ if self.save_result_flag is True\n+ \"\"\"\n+ case_name = self.running_case\n+ self.json_obj[case_name] = list()\n+ status_result = []\n+ for mode in mode_list:\n+ for frame_size in self.test_parameters.keys():\n+ for nb_desc in self.test_parameters[frame_size]:\n+ row_in = self.test_result[mode][frame_size][nb_desc]\n+ row_dict0 = dict()\n+ row_dict0[\"performance\"] = list()\n+ row_dict0[\"parameters\"] = list()\n+ row_dict0[\"parameters\"] = list()\n+ result_throughput = float(row_in[\"Mpps\"].split()[0])\n+ expected_throughput = float(\n+ row_in[\"Expected Throughput\"].split()[0]\n+ )\n+ # delta value and accepted tolerance in percentage\n+ delta = result_throughput - expected_throughput\n+ gap = expected_throughput * -self.gap * 0.01\n+ delta = float(delta)\n+ gap = float(gap)\n+ self.logger.info(\"Accept tolerance are (Mpps) %f\" % gap)\n+ self.logger.info(\"Throughput Difference are (Mpps) %f\" % delta)\n+ if result_throughput > expected_throughput + gap:\n+ row_dict0[\"status\"] = \"PASS\"\n+ else:\n+ row_dict0[\"status\"] = \"FAIL\"\n+ row_dict1 = dict(\n+ name=\"Throughput\",\n+ value=result_throughput,\n+ unit=\"Mpps\",\n+ delta=delta,\n+ )\n+ row_dict2 = dict(\n+ name=\"Txd/Rxd\", value=row_in[\"Mode/RXD-TXD\"], unit=\"descriptor\"\n+ )\n+ row_dict3 = dict(\n+ name=\"frame_size\", value=row_in[\"Frame\"], unit=\"bytes\"\n+ )\n+ row_dict0[\"performance\"].append(row_dict1)\n+ row_dict0[\"parameters\"].append(row_dict2)\n+ row_dict0[\"parameters\"].append(row_dict3)\n+ self.json_obj[case_name].append(row_dict0)\n+ status_result.append(row_dict0[\"status\"])\n+ with open(\n+ os.path.join(\n+ rst.path2Result, \"{0:s}_{1}.json\".format(self.nic, self.suite_name)\n+ ),\n+ \"w\",\n+ ) as fp:\n+ json.dump(self.json_obj, fp)\n+ self.verify(\"FAIL\" not in status_result, \"Exceeded Gap\")\n+\n+ def tear_down(self):\n+ \"\"\"\n+ Run after each test case.\n+ \"\"\"\n+ self.dut.send_expect(\"killall -I %s\" % self.testpmd_name, \"#\", 20)\n+\n+ def tear_down_all(self):\n+ \"\"\"\n+ Run after each test suite.\n+ \"\"\"\n+ self.dut.close_session(self.vhost_user)\n+ self.dut.close_session(self.virtio_user)\n+ self.dut.kill_all()\n", "prefixes": [ "V1", "3/4" ] }