Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/124053/?format=api
{ "id": 124053, "url": "http://patches.dpdk.org/api/patches/124053/?format=api", "web_url": "http://patches.dpdk.org/project/dts/patch/20230216082810.1026334-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": "<20230216082810.1026334-1-weix.ling@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20230216082810.1026334-1-weix.ling@intel.com", "date": "2023-02-16T08:28:10", "name": "[V4,3/4] tests/pvp_vhost_async_multi_paths_performance_dsa: add new testsuite", "commit_ref": null, "pull_url": null, "state": "accepted", "archived": false, "hash": "d3c298de9c1800b17fda396e737b4bde115ca07a", "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/20230216082810.1026334-1-weix.ling@intel.com/mbox/", "series": [ { "id": 27040, "url": "http://patches.dpdk.org/api/series/27040/?format=api", "web_url": "http://patches.dpdk.org/project/dts/list/?series=27040", "date": "2023-02-16T08:27:40", "name": "add pvp_vhost_async_multi_paths_performance_dsa", "version": 4, "mbox": "http://patches.dpdk.org/series/27040/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/124053/comments/", "check": "pending", "checks": "http://patches.dpdk.org/api/patches/124053/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 60A7641CAE;\n\tThu, 16 Feb 2023 09:41:52 +0100 (CET)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 5781E4114A;\n\tThu, 16 Feb 2023 09:41:52 +0100 (CET)", "from mga11.intel.com (mga11.intel.com [192.55.52.93])\n by mails.dpdk.org (Postfix) with ESMTP id 17A3A40E0F\n for <dts@dpdk.org>; Thu, 16 Feb 2023 09:41:49 +0100 (CET)", "from orsmga004.jf.intel.com ([10.7.209.38])\n by fmsmga102.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 16 Feb 2023 00:41:36 -0800", "from unknown (HELO localhost.localdomain) ([10.239.252.222])\n by orsmga004-auth.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 16 Feb 2023 00:41:34 -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=1676536910; x=1708072910;\n h=from:to:cc:subject:date:message-id:mime-version:\n content-transfer-encoding;\n bh=NtJ1lpguASzwymnx0WWGy74HGDBg5OjpcrutEN3+i1w=;\n b=kWpDSmUyHJjhOhohZvD3xdyAgHQrUKd4PHfQfJjpyxajOBatXAyJ5v9P\n lBDAKuUClbYfxA/s9bezMXgN0pBAYmfnsRT6bsJhOqfigVZP0tfGsj6Hj\n aweogvP3I0F3hI9Iivmf6RlB2P6kpU77EWsJSGc8fhp+cYF6Xk3lbq4YH\n 3BmdzLKKNmof6tnroJIKxvD3I2AoenfVcFfqSZJl4fh3u+SCgS39ZQYGe\n gEYySc5nnnj54jwidG9P9yhQvcMQ1uEuZdJg4G6ELKanOK+3pTbZ9b1y6\n P5idAqLw4oCGF7hNfcyraXopO5S8PkBjX17VqWnri7Kk6Y/5Hj3bkoo86 A==;", "X-IronPort-AV": [ "E=McAfee;i=\"6500,9779,10622\"; a=\"329382382\"", "E=Sophos;i=\"5.97,301,1669104000\"; d=\"scan'208\";a=\"329382382\"", "E=McAfee;i=\"6500,9779,10622\"; a=\"793948459\"", "E=Sophos;i=\"5.97,301,1669104000\"; d=\"scan'208\";a=\"793948459\"" ], "From": "Wei Ling <weix.ling@intel.com>", "To": "dts@dpdk.org", "Cc": "Wei Ling <weix.ling@intel.com>", "Subject": "[dts][PATCH V4 3/4]\n tests/pvp_vhost_async_multi_paths_performance_dsa: add new testsuite", "Date": "Thu, 16 Feb 2023 16:28:10 +0800", "Message-Id": "<20230216082810.1026334-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 pvp_vhost_async_multi_paths_performance_dsa testsuite to test pvp\nvhost/virtio multi-paths async data-path performance use DSA device \nwith dpdk and kernel driver.\n\nSigned-off-by: Wei Ling <weix.ling@intel.com>\n---\n ...vhost_async_multi_paths_performance_dsa.py | 920 ++++++++++++++++++\n 1 file changed, 920 insertions(+)\n create mode 100644 tests/TestSuite_pvp_vhost_async_multi_paths_performance_dsa.py", "diff": "diff --git a/tests/TestSuite_pvp_vhost_async_multi_paths_performance_dsa.py b/tests/TestSuite_pvp_vhost_async_multi_paths_performance_dsa.py\nnew file mode 100644\nindex 00000000..7b5077cb\n--- /dev/null\n+++ b/tests/TestSuite_pvp_vhost_async_multi_paths_performance_dsa.py\n@@ -0,0 +1,920 @@\n+# SPDX-License-Identifier: BSD-3-Clause\n+# Copyright(c) 2023 Intel Corporation\n+#\n+\n+import json\n+import os\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 UPDATE_EXPECTED, load_global_setting\n+from framework.test_case import TestCase\n+\n+from .virtio_common import dsa_common as DC\n+\n+\n+class TestPVPVhostAsyncMultiPathsPerformanceDsa(TestCase):\n+ def set_up_all(self):\n+ \"\"\"\n+ Run at the start of each test suite.\n+ \"\"\"\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.dut_ports = self.dut.get_ports()\n+ self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])\n+ self.core_list = self.dut.get_core_list(config=\"all\", socket=self.ports_socket)\n+ self.vhost_user_core = self.core_list[0:2]\n+ self.virtio_user_core = self.core_list[2:4]\n+ self.frame_sizes = [64, 128, 256, 512, 1024, 1518]\n+ self.number_of_ports = 1\n+ self.testpmd_path = self.dut.apps_name[\"test-pmd\"]\n+ self.testpmd_name = self.testpmd_path.split(\"/\")[-1]\n+ self.out_path = \"/tmp\"\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.base_dir = self.dut.base_dir.replace(\"~\", \"/root\")\n+ # create an instance to set stream field setting\n+ self.pktgen_helper = PacketGeneratorHelper()\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.dut.send_expect(\"killall -s INT %s\" % self.testpmd_name, \"#\")\n+ self.dut.send_expect(\"rm -rf %s/vhost-net*\" % self.base_dir, \"#\")\n+ self.DC.reset_all_work_queue()\n+ self.DC.bind_all_dsa_to_kernel()\n+ # Prepare the result table\n+ self.table_header = [\"Frame\"]\n+ self.table_header.append(\"Mode/RXD-TXD\")\n+ self.table_header.append(\"Mpps\")\n+ self.table_header.append(\"% linerate\")\n+ self.result_table_create(self.table_header)\n+\n+ # test parameters include: frames size, descriptor numbers\n+ self.test_parameters = self.get_suite_cfg()[\"test_parameters\"]\n+\n+ # traffic duraion in second\n+ self.test_duration = self.get_suite_cfg()[\"test_duration\"]\n+\n+ # initilize throughput attribution\n+ # {'$framesize':{\"$nb_desc\": 'throughput'}\n+ self.throughput = {}\n+\n+ # Accepted tolerance in Mpps\n+ self.gap = self.get_suite_cfg()[\"accepted_tolerance\"]\n+ self.test_result = {}\n+ self.nb_desc = self.test_parameters[64][0]\n+\n+ def start_vhost_user_testpmd(self, eal_param, param, ports, port_options=\"\"):\n+ \"\"\"\n+ start testpmd on vhost-user\n+ \"\"\"\n+ if port_options:\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=self.vhost_user_core,\n+ eal_param=eal_param,\n+ param=param,\n+ ports=ports,\n+ port_options=port_options,\n+ prefix=\"vhost-user\",\n+ fixed_prefix=True,\n+ )\n+ else:\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=self.vhost_user_core,\n+ eal_param=eal_param,\n+ param=param,\n+ ports=ports,\n+ prefix=\"vhost-user\",\n+ fixed_prefix=True,\n+ )\n+ self.vhost_user_pmd.execute_cmd(\"set fwd mac\")\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+\n+ def start_virtio_user_testpmd(self, eal_param, param):\n+ \"\"\"\n+ start testpmd on virtio-user\n+ \"\"\"\n+ if \"vectorized\" and \"packed\" in self.running_case:\n+ eal_param += \" --force-max-simd-bitwidth=512\"\n+ self.virtio_user_pmd.start_testpmd(\n+ cores=self.virtio_user_core,\n+ eal_param=eal_param,\n+ param=param,\n+ no_pci=True,\n+ prefix=\"virtio-user\",\n+ fixed_prefix=True,\n+ )\n+ self.virtio_user_pmd.execute_cmd(\"set fwd mac\")\n+ self.virtio_user_pmd.execute_cmd(\"start\")\n+\n+ def send_and_verify(self, case_info):\n+ \"\"\"\n+ Send packet with packet generator and verify\n+ \"\"\"\n+ for frame_size in self.frame_sizes:\n+ tgen_input = []\n+ self.throughput[frame_size] = dict()\n+ self.logger.info(\n+ \"Test running at parameters: \"\n+ + \"framesize: {}, rxd/txd: {}\".format(frame_size, self.nb_desc)\n+ )\n+ rx_port = self.tester.get_local_port(self.dut_ports[0])\n+ tx_port = self.tester.get_local_port(self.dut_ports[0])\n+ destination_mac = self.dut.get_mac_address(self.dut_ports[0])\n+ pkt = Packet(pkt_type=\"TCP\", pkt_len=frame_size)\n+ pkt.config_layer(\"ether\", {\"dst\": \"%s\" % destination_mac})\n+ pkt.save_pcapfile(\n+ self.tester, \"%s/multi_path_%s.pcap\" % (self.out_path, frame_size)\n+ )\n+ tgen_input.append(\n+ (\n+ tx_port,\n+ rx_port,\n+ \"%s/multi_path_%s.pcap\" % (self.out_path, frame_size),\n+ )\n+ )\n+ self.tester.pktgen.clear_streams()\n+ streams = self.pktgen_helper.prepare_stream_from_tginput(\n+ tgen_input, 100, None, self.tester.pktgen\n+ )\n+ _, pps = self.tester.pktgen.measure_throughput(stream_ids=streams)\n+ Mpps = pps / 1000000.0\n+ self.throughput[frame_size][self.nb_desc] = Mpps\n+ linerate = (\n+ Mpps\n+ * 100\n+ / float(self.wirespeed(self.nic, frame_size, self.number_of_ports))\n+ )\n+ results_row = [frame_size]\n+ results_row.append(case_info)\n+ results_row.append(Mpps)\n+ results_row.append(linerate)\n+ self.result_table_add(results_row)\n+\n+ def handle_expected(self):\n+ \"\"\"\n+ Update expected numbers to configurate file: $DTS_CFG_FOLDER/$suite_name.cfg\n+ \"\"\"\n+ if load_global_setting(UPDATE_EXPECTED) == \"yes\":\n+ for frame_size in self.test_parameters.keys():\n+ for nb_desc in self.test_parameters[frame_size]:\n+ self.expected_throughput[frame_size][nb_desc] = round(\n+ self.throughput[frame_size][nb_desc], 3\n+ )\n+\n+ def handle_results(self):\n+ \"\"\"\n+ results handled process:\n+ 1, save to self.test_results\n+ 2, create test results table\n+ 3, save to json file for Open Lab\n+ \"\"\"\n+ header = self.table_header\n+ header.append(\"Expected Throughput\")\n+ header.append(\"Throughput Difference\")\n+ for frame_size in self.test_parameters.keys():\n+ wirespeed = self.wirespeed(self.nic, frame_size, self.number_of_ports)\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]] = nb_desc\n+ ret_data[header[2]] = \"{:.3f} Mpps\".format(\n+ self.throughput[frame_size][nb_desc]\n+ )\n+ ret_data[header[3]] = \"{:.3f}%\".format(\n+ self.throughput[frame_size][nb_desc] * 100 / wirespeed\n+ )\n+ ret_data[header[4]] = \"{:.3f} Mpps\".format(\n+ self.expected_throughput[frame_size][nb_desc]\n+ )\n+ ret_data[header[5]] = \"{:.3f} Mpps\".format(\n+ self.throughput[frame_size][nb_desc]\n+ - self.expected_throughput[frame_size][nb_desc]\n+ )\n+ ret_datas[nb_desc] = deepcopy(ret_data)\n+ self.test_result[frame_size] = deepcopy(ret_datas)\n+ # Create test results table\n+ self.result_table_create(header)\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(self.test_result[frame_size][nb_desc][header[i]])\n+ self.result_table_add(table_row)\n+ # present test results to screen\n+ self.result_table_print()\n+ # save test results as a file\n+ if self.save_result_flag:\n+ self.save_result(self.test_result)\n+\n+ def save_result(self, data):\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 frame_size in self.test_parameters.keys():\n+ for nb_desc in self.test_parameters[frame_size]:\n+ row_in = self.test_result[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(row_in[\"Expected Throughput\"].split()[0])\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\", value=result_throughput, unit=\"Mpps\", delta=delta\n+ )\n+ row_dict2 = dict(\n+ name=\"Txd/Rxd\", value=row_in[\"Mode/RXD-TXD\"], unit=\"descriptor\"\n+ )\n+ row_dict3 = dict(name=\"frame_size\", value=row_in[\"Frame\"], unit=\"bytes\")\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 test_perf_pvp_split_ring_inorder_mergeable_idxd(self):\n+ \"\"\"\n+ Test Case 1: pvp vhost async test with split ring inorder mergeable path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=1,mrg_rxbuf=1\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_inorder_mergeable_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_split_ring_inorder_non_mergeable_idxd(self):\n+ \"\"\"\n+ Test Case 2: pvp vhost async test with split ring inorder non-mergeable path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=1,mrg_rxbuf=0,\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_inorder_non_mergeable_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_split_ring_mergeable_idxd(self):\n+ \"\"\"\n+ Test Case 3: pvp vhost async test with split ring mergeable path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=0,mrg_rxbuf=1,\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_mergeable_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_split_ring_non_mergeable_idxd(self):\n+ \"\"\"\n+ Test Case 4: pvp vhost async test with split ring non-mergeable path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=0,mrg_rxbuf=0,\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_non_mergeable_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_split_ring_vectorized_idxd(self):\n+ \"\"\"\n+ Test Case 5: pvp vhost async test with split ring vectorized path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=0,mrg_rxbuf=0,vectorized=1\"\n+ virtio_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_non_vectorized_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_inorder_mergeable_idxd(self):\n+ \"\"\"\n+ Test Case 6: pvp vhost async test with packed ring inorder mergeable path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=1,mrg_rxbuf=1\"\n+ virtio_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_inorder_mergeable_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_inorder_non_mergeable_idxd(self):\n+ \"\"\"\n+ Test Case 7: pvp vhost async test with packed ring inorder non-mergeable path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=1,mrg_rxbuf=0\"\n+ virtio_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_inorder_non_mergeable_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_mergeable_idxd(self):\n+ \"\"\"\n+ Test Case 8: pvp vhost async test with packed ring mergeable path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=0,mrg_rxbuf=1\"\n+ virtio_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_mergeable_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_non_mergeable_idxd(self):\n+ \"\"\"\n+ Test Case 9: pvp vhost async test with packed ring non-mergeable path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=0,mrg_rxbuf=0\"\n+ virtio_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_non_mergeable_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_vectorized_idxd(self):\n+ \"\"\"\n+ Test Case 10: pvp vhost async test with packed ring vectorized path using IDXD kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param, param=vhost_param, ports=ports\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=1,mrg_rxbuf=0,vectorized=1\"\n+ virtio_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_vectorized_idxd\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_split_ring_inorder_mergeable_vfio_pci(self):\n+ \"\"\"\n+ Test Case 11: pvp vhost async test with split ring inorder mergeable path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=1,mrg_rxbuf=1\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_inorder_mergeable_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_split_ring_inorder_non_mergeable_vfio_pci(self):\n+ \"\"\"\n+ Test Case 12: pvp vhost async test with split ring inorder non-mergeable path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=1,mrg_rxbuf=0\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_inorder_non_mergeable_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_split_ring_mergeable_vfio_pci(self):\n+ \"\"\"\n+ Test Case 13: pvp vhost async test with split ring mergeable path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=0,mrg_rxbuf=1\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_mergeable_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_split_ring_non_mergeable_vfio_pci(self):\n+ \"\"\"\n+ Test Case 14: pvp vhost async test with split ring non-mergeable path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=0,mrg_rxbuf=0\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_non_mergeable_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_split_ring_vectorized_vfio_pci(self):\n+ \"\"\"\n+ Test Case 15: pvp vhost async test with split ring vectorized_rx path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,in_order=0,mrg_rxbuf=0,vectorized=1\"\n+ virtio_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"split_ring_vectorized_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_inorder_mergeable_vfio_pci(self):\n+ \"\"\"\n+ Test Case 16: pvp vhost async test with packed ring inorder mergeable path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=1,mrg_rxbuf=1\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_inorder_mergeable_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_inorder_non_mergeable_vfio_pci(self):\n+ \"\"\"\n+ Test Case 17: pvp vhost async test with packed ring inorder non-mergeable path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=1,mrg_rxbuf=0\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_inorder_non_mergeable_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_mergeable_vfio_pci(self):\n+ \"\"\"\n+ Test Case 18: pvp vhost async test with packed ring mergeable path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=0,mrg_rxbuf=1\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_mergeable_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_non_mergeable_vfio_pci(self):\n+ \"\"\"\n+ Test Case 19: pvp vhost async test with packed ring non-mergeable path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=0,mrg_rxbuf=0\"\n+ virtio_param = \"--tx-offloads=0x0 --enable-hw-vlan-strip --nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_non_mergeable_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_pvp_packed_ring_vectorized_vfio_pci(self):\n+ \"\"\"\n+ Test Case 20: pvp vhost async test with split ring vectorized path using vfio-pci driver\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 = \"txq0@%s-q0;\" \"rxq0@%s-q1\" % (self.use_dsa_list[0], self.use_dsa_list[0])\n+ vhost_eal_param = (\n+ \"--vdev 'net_vhost0,iface=vhost-net,queues=1,dmas=[%s]'\" % dmas\n+ )\n+ vhost_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ ports.append(self.use_dsa_list[0])\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_user_testpmd(\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ )\n+ virtio_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,packed_vq=1,in_order=1,mrg_rxbuf=0,vectorized=1\"\n+ virtio_param = \"--nb-cores=1 --txd=1024 --rxd=1024\"\n+ self.start_virtio_user_testpmd(eal_param=virtio_eal_param, param=virtio_param)\n+\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.running_case\n+ ]\n+ case_info = \"packed_ring_vectorized_vfio_pci\"\n+ self.send_and_verify(case_info)\n+ self.result_table_print()\n+ self.quit_all_testpmd()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def quit_all_testpmd(self):\n+ self.virtio_user_pmd.quit()\n+ self.vhost_user_pmd.quit()\n+\n+ def tear_down(self):\n+ \"\"\"\n+ Run after each test case.\n+ \"\"\"\n+ self.dut.send_expect(\"killall -s INT %s\" % self.testpmd_name, \"#\")\n+ self.dut.send_expect(\"rm -rf %s/vhost-net*\" % self.base_dir, \"#\")\n+ self.DC.reset_all_work_queue()\n+ self.DC.bind_all_dsa_to_kernel()\n+\n+ def tear_down_all(self):\n+ \"\"\"\n+ Run after each test suite.\n+ \"\"\"\n+ self.dut.close_session(self.virtio_user)\n+ self.dut.close_session(self.vhost_user)\n", "prefixes": [ "V4", "3/4" ] }