Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/124040/?format=api
{ "id": 124040, "url": "http://patches.dpdk.org/api/patches/124040/?format=api", "web_url": "http://patches.dpdk.org/project/dts/patch/20230216074623.1024421-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": "<20230216074623.1024421-1-weix.ling@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20230216074623.1024421-1-weix.ling@intel.com", "date": "2023-02-16T07:46:23", "name": "[V2,3/4] tests/pvp_vhost_async_virtio_pmd_perf_dsa: add new testsuite", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": false, "hash": "59f6ba94f918fc03055be58e353e3f71bc0561e2", "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/20230216074623.1024421-1-weix.ling@intel.com/mbox/", "series": [ { "id": 27037, "url": "http://patches.dpdk.org/api/series/27037/?format=api", "web_url": "http://patches.dpdk.org/project/dts/list/?series=27037", "date": "2023-02-16T07:45:45", "name": "add pvp_vhost_async_virtio_pmd_perf_dsa", "version": 2, "mbox": "http://patches.dpdk.org/series/27037/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/124040/comments/", "check": "pending", "checks": "http://patches.dpdk.org/api/patches/124040/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 1EA8741CAE;\n\tThu, 16 Feb 2023 08:59:53 +0100 (CET)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 116A5410FB;\n\tThu, 16 Feb 2023 08:59:53 +0100 (CET)", "from mga07.intel.com (mga07.intel.com [134.134.136.100])\n by mails.dpdk.org (Postfix) with ESMTP id BEB394113F\n for <dts@dpdk.org>; Thu, 16 Feb 2023 08:59:50 +0100 (CET)", "from orsmga008.jf.intel.com ([10.7.209.65])\n by orsmga105.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 15 Feb 2023 23:59:50 -0800", "from unknown (HELO localhost.localdomain) ([10.239.252.222])\n by orsmga008-auth.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 15 Feb 2023 23:59:48 -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=1676534390; x=1708070390;\n h=from:to:cc:subject:date:message-id:mime-version:\n content-transfer-encoding;\n bh=FpasUKPuP92KIppIeQSlOGO4B8CDo3kQHG5Y8myxkTs=;\n b=gPBBomKouUW0uJlDJxgUiqpbaTN837WzdDneCTJEg7KVuiCgVngvreOh\n /nhoa5Am+c9vNeO7N7Dckv1AFV61yuy/VpEJpLWmbp/rYg4UzIVaKBZ/w\n dJsteRPCX7gEdOQ4l4JELMnDr9LVh5RKcxVL5LPgK9UFm/myGVAwpuqdU\n ViP8i8iOHcfZkezqOtOAU8gU/yvqwMLcs8wz9AOiT58Aq79K8B+imf6yL\n JaoRLApqCpblFMNeHYb/XwZKl64OaWd1OYkUf3Ya5h4UY03vTw+r0uvit\n CECHPiMtVDrdNe3S19U4i7nEx0UIcGSVBRIRWA717RiEwLhePtBSpdTZI w==;", "X-IronPort-AV": [ "E=McAfee;i=\"6500,9779,10622\"; a=\"396294238\"", "E=Sophos;i=\"5.97,301,1669104000\"; d=\"scan'208\";a=\"396294238\"", "E=McAfee;i=\"6500,9779,10622\"; a=\"700409941\"", "E=Sophos;i=\"5.97,301,1669104000\"; d=\"scan'208\";a=\"700409941\"" ], "From": "Wei Ling <weix.ling@intel.com>", "To": "dts@dpdk.org", "Cc": "Wei Ling <weix.ling@intel.com>", "Subject": "[dts][PATCH V2 3/4] tests/pvp_vhost_async_virtio_pmd_perf_dsa: add\n new testsuite", "Date": "Thu, 16 Feb 2023 15:46:23 +0800", "Message-Id": "<20230216074623.1024421-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_virtio_pmd_perf_dsa testsuite to test pvp \nvhost/virtio-pmd async data-path performance use DSA device \nwith dpdk and kernel driver.\n\nSigned-off-by: Wei Ling <weix.ling@intel.com>\n---\n ...ite_pvp_vhost_async_virtio_pmd_perf_dsa.py | 999 ++++++++++++++++++\n 1 file changed, 999 insertions(+)\n create mode 100644 tests/TestSuite_pvp_vhost_async_virtio_pmd_perf_dsa.py", "diff": "diff --git a/tests/TestSuite_pvp_vhost_async_virtio_pmd_perf_dsa.py b/tests/TestSuite_pvp_vhost_async_virtio_pmd_perf_dsa.py\nnew file mode 100644\nindex 00000000..053a5e62\n--- /dev/null\n+++ b/tests/TestSuite_pvp_vhost_async_virtio_pmd_perf_dsa.py\n@@ -0,0 +1,999 @@\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 HEADER_SIZE, UPDATE_EXPECTED, load_global_setting\n+from framework.test_case import TestCase\n+from framework.virt_common import VM\n+\n+from .virtio_common import dsa_common as DC\n+\n+\n+class TestPVPVhostAsyncVirtioPmdPerfDsa(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.vhost_user_pmd = PmdOutput(self.dut, self.vhost_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.headers_size = HEADER_SIZE[\"eth\"] + HEADER_SIZE[\"ip\"] + HEADER_SIZE[\"tcp\"]\n+ self.virtio_mac = \"00:11:22:33:44:55\"\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+ self.logger.info(self.base_dir)\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(\"killall -s INT qemu-system-x86_64\", \"#\")\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, cores, eal_param, param, ports):\n+ \"\"\"\n+ start testpmd on vhost-user\n+ \"\"\"\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=cores,\n+ eal_param=eal_param,\n+ param=param,\n+ ports=ports,\n+ prefix=\"vhost-user\",\n+ fixed_prefix=True,\n+ )\n+\n+ def start_one_vm(self, packed=False):\n+ \"\"\"\n+ start qemus\n+ \"\"\"\n+ self.vm = VM(self.dut, \"vm0\", \"vhost_sample\")\n+ self.vm.load_config()\n+ vm_params = {}\n+ vm_params[\"driver\"] = \"vhost-user\"\n+ vm_params[\"opt_path\"] = \"%s/vhost-net\" % self.base_dir\n+ vm_params[\"opt_mac\"] = \"%s\" % self.virtio_mac\n+ vm_params[\"opt_queue\"] = self.queues\n+ packed_param = \",packed=on\" if packed else \"\"\n+ mq_param = (\n+ \"mq=on,vectors=%s,\" % (2 + self.queues * 2) if self.queues > 1 else \"\"\n+ )\n+ vm_params[\"opt_settings\"] = (\n+ \"disable-modern=false,mrg_rxbuf=on,%srx_queue_size=1024,tx_queue_size=1024,csum=off,guest_csum=off,gso= off,host_tso4=off,guest_tso4=off,guest_ecn=off%s\"\n+ % (mq_param, packed_param)\n+ )\n+ self.vm.set_vm_device(**vm_params)\n+ try:\n+ self.vm_dut = self.vm.start(load_config=False)\n+ if self.vm_dut is None:\n+ raise Exception(\"Set up VM ENV failed\")\n+ except Exception as e:\n+ self.logger.error(\"ERROR: Failure for %s\" % str(e))\n+\n+ def start_vm_testpmd(self):\n+ \"\"\"\n+ start testpmd in VM\n+ \"\"\"\n+ self.vm0_pmd = PmdOutput(self.vm_dut)\n+ param = \"--nb-cores=%d --txq=%d --rxq=%d --txd=2048 --rxd=2048\" % (\n+ self.nb_cores,\n+ self.queues,\n+ self.queues,\n+ )\n+ cores = self.vm_dut.get_core_list(config=\"all\")[0 : (self.nb_cores + 1)]\n+ self.vm0_pmd.start_testpmd(cores=cores, param=param)\n+ self.vm0_pmd.execute_cmd(\"set fwd csum\")\n+ self.vm0_pmd.execute_cmd(\"start\")\n+\n+ def send_and_verify(self, case_info):\n+ \"\"\"\n+ Send packet with packet generator and verify\n+ \"\"\"\n+ if \"4c_4q\" or \"4c_8q\" not in self.running_case:\n+ frame_sizes = [64, 128, 256, 512, 1024, 1280, 1518]\n+ else:\n+ frame_sizes = [64, 128, 256, 512, 1024, 1280, 1518, 2048, 4096]\n+ for frame_size in frame_sizes:\n+ payload_size = frame_size - self.headers_size\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+ fields_config = {\n+ \"ip\": {\n+ \"src\": {\"action\": \"random\"},\n+ \"dst\": {\"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\", \"dst\": \"2.2.2.2\"}),\n+ (\"raw\", {\"payload\": [\"01\"] * int(\"%d\" % payload_size)}),\n+ ]\n+ )\n+ pkt.save_pcapfile(\n+ self.tester,\n+ \"%s/pvp_virtio_pmd_perf_dsa_%s.pcap\" % (self.out_path, frame_size),\n+ )\n+ tgen_input.append(\n+ (\n+ tx_port,\n+ rx_port,\n+ \"%s/pvp_virtio_pmd_perf_dsa_%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, fields_config, self.tester.pktgen\n+ )\n+ # set traffic option\n+ traffic_opt = {\"delay\": 10, \"duration\": 30}\n+ _, pps = self.tester.pktgen.measure_throughput(\n+ stream_ids=streams, options=traffic_opt\n+ )\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 perf_test(self, case_info, ports, packed=False, port_options=\"\"):\n+ self.test_target = self.running_case\n+ self.expected_throughput = self.get_suite_cfg()[\"expected_throughput\"][\n+ self.test_target\n+ ]\n+ vhost_eal_param = (\n+ \"--socket-mem 8192 --vdev 'net_vhost0,iface=vhost-net,queues=%d,dmas=[%s]'\"\n+ % (self.queues, self.dmas)\n+ )\n+ if \"4c_4q\" or \"4c_8q\" not in self.running_case:\n+ max_len_param = \"\"\n+ else:\n+ max_len_param = \"--max-pkt-len=5200 --tx-offloads=0x00008000\"\n+ vhost_param = (\n+ \"--nb-cores=%d --txq=%d --rxq=%d --txd=2048 --rxd=2048 %s --forward-mode=mac -a\"\n+ % (self.nb_cores, self.queues, self.queues, max_len_param)\n+ )\n+ cores = self.core_list[0 : (self.nb_cores + 1)]\n+ if not port_options:\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=cores,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ prefix=\"vhost-user\",\n+ fixed_prefix=True,\n+ )\n+ else:\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=cores,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ ports=ports,\n+ port_options=port_options,\n+ prefix=\"vhost-user\",\n+ fixed_prefix=True,\n+ )\n+\n+ self.start_one_vm(packed=packed)\n+ self.start_vm_testpmd()\n+ self.send_and_verify(case_info=case_info)\n+ self.result_table_print()\n+ self.handle_expected()\n+ self.handle_results()\n+\n+ def test_perf_virtio_pmd_split_ring_1c_1q_idxd(self):\n+ \"\"\"\n+ Test Case 1: pvp split ring vhost async test with 1core 1queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ self.queues = 1\n+ self.dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ self.nb_cores = 1\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=False, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_1c_2q_idxd(self):\n+ \"\"\"\n+ Test Case 2: pvp split ring vhost async test with 1core 2queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=4, dsa_index=0)\n+ self.queues = 2\n+ self.dmas = \"txq0@wq0.0;rxq0@wq0.1;txq1@wq0.2;rxq1@wq0.3\"\n+ self.nb_cores = 1\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=False, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_2c_2q_idxd(self):\n+ \"\"\"\n+ Test Case 3: pvp split ring vhost async test with 2core 2queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=4, dsa_index=0)\n+ self.queues = 2\n+ self.dmas = \"txq0@wq0.0;rxq0@wq0.1;txq1@wq0.2;rxq1@wq0.3\"\n+ self.nb_cores = 2\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=False, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_2c_4q_idxd(self):\n+ \"\"\"\n+ Test Case 4: pvp split ring vhost async test with 2core 4queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=0)\n+ self.queues = 4\n+ self.dmas = (\n+ \"txq0@wq0.0;\"\n+ \"rxq0@wq0.1;\"\n+ \"txq1@wq0.2;\"\n+ \"rxq1@wq0.3;\"\n+ \"txq2@wq0.4;\"\n+ \"rxq2@wq0.5;\"\n+ \"txq3@wq0.6;\"\n+ \"rxq3@wq0.7\"\n+ )\n+ self.nb_cores = 2\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=False, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_4c_4q_idxd(self):\n+ \"\"\"\n+ Test Case 5: pvp split ring vhost async test with 4core 4queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=0)\n+ self.queues = 4\n+ self.dmas = (\n+ \"txq0@wq0.0;\"\n+ \"rxq0@wq0.1;\"\n+ \"txq1@wq0.2;\"\n+ \"rxq1@wq0.3;\"\n+ \"txq2@wq0.4;\"\n+ \"rxq2@wq0.5;\"\n+ \"txq3@wq0.6;\"\n+ \"rxq3@wq0.7\"\n+ )\n+ self.nb_cores = 4\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=False, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_4c_8q_idxd(self):\n+ \"\"\"\n+ Test Case 6: pvp split ring vhost async test with 4core 8queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=0)\n+ self.queues = 8\n+ self.dmas = (\n+ \"txq0@wq0.0;\"\n+ \"rxq0@wq0.0;\"\n+ \"txq1@wq0.1;\"\n+ \"rxq1@wq0.1;\"\n+ \"txq2@wq0.2;\"\n+ \"rxq2@wq0.2;\"\n+ \"txq3@wq0.3;\"\n+ \"rxq3@wq0.3;\"\n+ \"txq4@wq0.4;\"\n+ \"rxq4@wq0.4;\"\n+ \"txq5@wq0.5;\"\n+ \"rxq5@wq0.5;\"\n+ \"txq6@wq0.6;\"\n+ \"rxq6@wq0.6;\"\n+ \"txq7@wq0.7;\"\n+ \"rxq7@wq0.7\"\n+ )\n+ self.nb_cores = 4\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=False, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_1c_1q_idxd(self):\n+ \"\"\"\n+ Test Case 7: pvp packed ring vhost async test with 1core 1queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ self.queues = 1\n+ self.dmas = \"txq0@wq0.0;rxq0@wq0.1\"\n+ self.nb_cores = 1\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=True, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_1c_2q_idxd(self):\n+ \"\"\"\n+ Test Case 8: pvp packed ring vhost async test with 1core 2queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=4, dsa_index=0)\n+ self.queues = 2\n+ self.dmas = \"txq0@wq0.0;rxq0@wq0.1;txq1@wq0.2;rxq1@wq0.3\"\n+ self.nb_cores = 1\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=True, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_2c_2q_idxd(self):\n+ \"\"\"\n+ Test Case 9: pvp packed ring vhost async test with 2core 2queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=4, dsa_index=0)\n+ self.queues = 2\n+ self.dmas = \"txq0@wq0.0;rxq0@wq0.1;txq1@wq0.2;rxq1@wq0.3\"\n+ self.nb_cores = 2\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=True, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_2c_4q_idxd(self):\n+ \"\"\"\n+ Test Case 10: pvp packed ring vhost async test with 2core 4queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=0)\n+ self.queues = 4\n+ self.dmas = (\n+ \"txq0@wq0.0;\"\n+ \"rxq0@wq0.1;\"\n+ \"txq1@wq0.2;\"\n+ \"rxq1@wq0.3;\"\n+ \"txq2@wq0.4;\"\n+ \"rxq2@wq0.5;\"\n+ \"txq3@wq0.6;\"\n+ \"rxq3@wq0.7\"\n+ )\n+ self.nb_cores = 2\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=True, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_4c_4q_idxd(self):\n+ \"\"\"\n+ Test Case 11: pvp packed ring vhost async test with 4core 4queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=0)\n+ self.queues = 4\n+ self.dmas = (\n+ \"txq0@wq0.0;\"\n+ \"rxq0@wq0.1;\"\n+ \"txq1@wq0.2;\"\n+ \"rxq1@wq0.3;\"\n+ \"txq2@wq0.4;\"\n+ \"rxq2@wq0.5;\"\n+ \"txq3@wq0.6;\"\n+ \"rxq3@wq0.7\"\n+ )\n+ self.nb_cores = 4\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=True, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_4c_8q_idxd(self):\n+ \"\"\"\n+ Test Case 12: pvp packed ring vhost async test with 4core 8queue using idxd kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=8, dsa_index=0)\n+ self.queues = 8\n+ self.dmas = (\n+ \"txq0@wq0.0;\"\n+ \"rxq0@wq0.0;\"\n+ \"txq1@wq0.1;\"\n+ \"rxq1@wq0.1;\"\n+ \"txq2@wq0.2;\"\n+ \"rxq2@wq0.2;\"\n+ \"txq3@wq0.3;\"\n+ \"rxq3@wq0.3;\"\n+ \"txq4@wq0.4;\"\n+ \"rxq4@wq0.4;\"\n+ \"txq5@wq0.5;\"\n+ \"rxq5@wq0.5;\"\n+ \"txq6@wq0.6;\"\n+ \"rxq6@wq0.6;\"\n+ \"txq7@wq0.7;\"\n+ \"rxq7@wq0.7\"\n+ )\n+ self.nb_cores = 4\n+ ports = [self.dut.ports_info[self.dut_ports[0]][\"pci\"]]\n+ self.perf_test(\n+ case_info=self.running_case, ports=ports, packed=True, port_options=\"\"\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_1c_1q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 13: pvp split ring vhost async test with 1core 1queue 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+ self.queues = 1\n+ self.dmas = \"txq0@%s-q0;rxq0@%s-q1\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ self.nb_cores = 1\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.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=False,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_1c_2q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 14: pvp split ring vhost async test with 1core 2queue 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+ self.queues = 2\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%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+ self.nb_cores = 1\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=4\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=False,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_2c_2q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 15: pvp split ring vhost async test with 2core 2queue 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+ self.queues = 2\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%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+ self.nb_cores = 2\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=4\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=False,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_2c_4q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 16: pvp split ring vhost async test with 2core 4queue 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+ self.queues = 4\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%s-q2;\"\n+ \"rxq1@%s-q3;\"\n+ \"txq2@%s-q4;\"\n+ \"rxq2@%s-q5;\"\n+ \"txq3@%s-q6;\"\n+ \"rxq3@%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+ )\n+ )\n+ self.nb_cores = 2\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=8\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=False,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_4c_4q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 17: pvp split ring vhost async test with 4core 4queue 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+ self.queues = 4\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%s-q2;\"\n+ \"rxq1@%s-q3;\"\n+ \"txq2@%s-q4;\"\n+ \"rxq2@%s-q5;\"\n+ \"txq3@%s-q6;\"\n+ \"rxq3@%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+ )\n+ )\n+ self.nb_cores = 4\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=8\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=False,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_split_ring_4c_8q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 18: pvp split ring vhost async test with 4core 8queue 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+ self.queues = 8\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%s-q2;\"\n+ \"rxq1@%s-q3;\"\n+ \"txq2@%s-q4;\"\n+ \"rxq2@%s-q5;\"\n+ \"txq3@%s-q6;\"\n+ \"rxq3@%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+ )\n+ )\n+ self.nb_cores = 4\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=8\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=False,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_1c_1q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 19: pvp packed ring vhost async test with 1core 1queue 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+ self.queues = 1\n+ self.dmas = \"txq0@%s-q0;rxq0@%s-q1\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ self.nb_cores = 1\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.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=True,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_1c_2q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 20: pvp packed ring vhost async test with 1core 2queue 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+ self.queues = 2\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%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+ self.nb_cores = 1\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=4\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=True,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_2c_2q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 21: pvp packed ring vhost async test with 2core 2queue 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+ self.queues = 2\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%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+ self.nb_cores = 2\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=4\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=True,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_2c_4q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 22: pvp packed ring vhost async test with 2core 4queue 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+ self.queues = 4\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%s-q2;\"\n+ \"rxq1@%s-q3;\"\n+ \"txq2@%s-q4;\"\n+ \"rxq2@%s-q5;\"\n+ \"txq3@%s-q6;\"\n+ \"rxq3@%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+ )\n+ )\n+ self.nb_cores = 2\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=8\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=True,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_4c_4q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 23: pvp packed ring vhost async test with 4core 4queue 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+ self.queues = 4\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%s-q2;\"\n+ \"rxq1@%s-q3;\"\n+ \"txq2@%s-q4;\"\n+ \"rxq2@%s-q5;\"\n+ \"txq3@%s-q6;\"\n+ \"rxq3@%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+ )\n+ )\n+ self.nb_cores = 4\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=8\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=True,\n+ port_options=port_options,\n+ )\n+\n+ def test_perf_virtio_pmd_packed_ring_4c_8q_vfio_pci(self):\n+ \"\"\"\n+ Test Case 24: pvp packed ring vhost async test with 4core 8queue 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+ self.queues = 8\n+ self.dmas = (\n+ \"txq0@%s-q0;\"\n+ \"rxq0@%s-q1;\"\n+ \"txq1@%s-q2;\"\n+ \"rxq1@%s-q3;\"\n+ \"txq2@%s-q4;\"\n+ \"rxq2@%s-q5;\"\n+ \"txq3@%s-q6;\"\n+ \"rxq3@%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+ )\n+ )\n+ self.nb_cores = 4\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=8\"}\n+ self.perf_test(\n+ case_info=self.running_case,\n+ ports=ports,\n+ packed=True,\n+ port_options=port_options,\n+ )\n+\n+ def stop_vm_and_quit_testpmd(self):\n+ self.vm.stop()\n+ out = self.vhost_user_pmd.execute_cmd(\"stop\")\n+ self.logger.info(out)\n+ self.vhost_user_pmd.quit()\n+\n+ def tear_down(self):\n+ \"\"\"\n+ Run after each test case.\n+ \"\"\"\n+ self.stop_vm_and_quit_testpmd()\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.vhost_user)\n", "prefixes": [ "V2", "3/4" ] }