Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/121263/?format=api
http://patches.dpdk.org/api/patches/121263/?format=api", "web_url": "http://patches.dpdk.org/project/dts/patch/20221222054320.178238-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": "<20221222054320.178238-1-weix.ling@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20221222054320.178238-1-weix.ling@intel.com", "date": "2022-12-22T05:43:20", "name": "[V3,2/2] tests/vm2vm_virtio_user_dsa: add new testsuite", "commit_ref": null, "pull_url": null, "state": "accepted", "archived": false, "hash": "282dd612b52d9341d1a015e020ef81b2421ab280", "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/20221222054320.178238-1-weix.ling@intel.com/mbox/", "series": [ { "id": 26240, "url": "http://patches.dpdk.org/api/series/26240/?format=api", "web_url": "http://patches.dpdk.org/project/dts/list/?series=26240", "date": "2022-12-22T05:43:04", "name": "modify dsa parameter by DPDK changed", "version": 3, "mbox": "http://patches.dpdk.org/series/26240/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/121263/comments/", "check": "warning", "checks": "http://patches.dpdk.org/api/patches/121263/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 CCA90A034C;\n\tThu, 22 Dec 2022 06:52:01 +0100 (CET)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id C534640A7F;\n\tThu, 22 Dec 2022 06:52:01 +0100 (CET)", "from mga02.intel.com (mga02.intel.com [134.134.136.20])\n by mails.dpdk.org (Postfix) with ESMTP id 79BF0400D7\n for <dts@dpdk.org>; Thu, 22 Dec 2022 06:51:59 +0100 (CET)", "from fmsmga006.fm.intel.com ([10.253.24.20])\n by orsmga101.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 21 Dec 2022 21:51:58 -0800", "from unknown (HELO localhost.localdomain) ([10.239.252.222])\n by fmsmga006-auth.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 21 Dec 2022 21:51:56 -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=1671688319; x=1703224319;\n h=from:to:cc:subject:date:message-id:mime-version:\n content-transfer-encoding;\n bh=zRQ3DbBlY+VlMwiDRPcKQSWum4DV2DbjypddjyIjrwE=;\n b=ATolH8HlK2nIy0Mm4wajfXXvpMnV10h1yHP/reZNlHdcCf4uMGY40CAh\n ry5Pmz+PKa+w7asvYndGqvJp41ck9PeBfSSSvbEKdQqH9rr69LWTr8e4R\n MNnLe5o9F+fjwBW7TQ05ondkbJoz5wTXw5hP6fZXhNUJif0SEyNoJ9+uQ\n mCiSQk3ZTCusUE2yL/27+57fdi7TTzUTffOYE99LmiVuRK5f5Aie38zwZ\n 4jGbg5srnoBlkpoxqVAIjdjeufOesFFtoxDJN5wV7oEW9NNYPLJoHR5T8\n 5wHnhvB/s2DPCuTMenjlXMo/cyZsdz3tA3+Srm81HRSyhQdYDsyAwXdY8 Q==;", "X-IronPort-AV": [ "E=McAfee;i=\"6500,9779,10568\"; a=\"307737198\"", "E=Sophos;i=\"5.96,264,1665471600\"; d=\"scan'208\";a=\"307737198\"", "E=McAfee;i=\"6500,9779,10568\"; a=\"897099266\"", "E=Sophos;i=\"5.96,264,1665471600\"; d=\"scan'208\";a=\"897099266\"" ], "From": "Wei Ling <weix.ling@intel.com>", "To": "dts@dpdk.org", "Cc": "Wei Ling <weix.ling@intel.com>", "Subject": "[dts][PATCH V3 2/2] tests/vm2vm_virtio_user_dsa: add new testsuite", "Date": "Thu, 22 Dec 2022 13:43:20 +0800", "Message-Id": "<20221222054320.178238-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 new tests/TestSuite_vm2vm_virtio_user_dsa.py to test the\nvm2vm_virtio_user with DSA driver.\n\nSigned-off-by: Wei Ling <weix.ling@intel.com>\n---\n tests/TestSuite_vm2vm_virtio_user_dsa.py | 2079 ++++++++++++++++++++++\n 1 file changed, 2079 insertions(+)\n create mode 100644 tests/TestSuite_vm2vm_virtio_user_dsa.py", "diff": "diff --git a/tests/TestSuite_vm2vm_virtio_user_dsa.py b/tests/TestSuite_vm2vm_virtio_user_dsa.py\nnew file mode 100644\nindex 00000000..7e359f3b\n--- /dev/null\n+++ b/tests/TestSuite_vm2vm_virtio_user_dsa.py\n@@ -0,0 +1,2079 @@\n+# SPDX-License-Identifier: BSD-3-Clause\n+# Copyright(c) 2022 Intel Corporation\n+#\n+\n+import re\n+\n+from framework.packet import Packet\n+from framework.pmd_output import PmdOutput\n+from framework.test_case import TestCase\n+\n+from .virtio_common import dsa_common as DC\n+\n+\n+class TestVM2VMVirtioUserDsa(TestCase):\n+ def set_up_all(self):\n+ self.dut_ports = self.dut.get_ports()\n+ self.port_socket = self.dut.get_numa_id(self.dut_ports[0])\n+ self.cores_list = self.dut.get_core_list(config=\"all\", socket=self.port_socket)\n+ self.vhost_core_list = self.cores_list[0:2]\n+ self.virtio0_core_list = self.cores_list[2:4]\n+ self.virtio1_core_list = self.cores_list[4:6]\n+ self.vhost_user = self.dut.new_session(suite=\"vhost-user\")\n+ self.virtio_user0 = self.dut.new_session(suite=\"virtio-user0\")\n+ self.virtio_user1 = self.dut.new_session(suite=\"virtio-user1\")\n+ self.pdump_user = self.dut.new_session(suite=\"pdump-user\")\n+ self.vhost_user_pmd = PmdOutput(self.dut, self.vhost_user)\n+ self.virtio_user0_pmd = PmdOutput(self.dut, self.virtio_user0)\n+ self.virtio_user1_pmd = PmdOutput(self.dut, self.virtio_user1)\n+ self.path = self.dut.apps_name[\"test-pmd\"]\n+ self.testpmd_name = self.path.split(\"/\")[-1]\n+ self.app_pdump = self.dut.apps_name[\"pdump\"]\n+ self.pdump_name = self.app_pdump.split(\"/\")[-1]\n+ self.dump_virtio_pcap = \"/tmp/pdump-virtio-rx.pcap\"\n+ self.dump_vhost_pcap = \"/tmp/pdump-vhost-rx.pcap\"\n+\n+ self.DC = DC(self)\n+\n+ def set_up(self):\n+ self.path = self.dut.apps_name[\"test-pmd\"]\n+ self.testpmd_name = self.path.split(\"/\")[-1]\n+ self.app_pdump = self.dut.apps_name[\"pdump\"]\n+ self.pdump_name = self.app_pdump.split(\"/\")[-1]\n+\n+ self.dut.send_expect(\"rm -rf ./vhost-net*\", \"#\")\n+ self.dut.send_expect(\"rm -rf %s\" % self.dump_virtio_pcap, \"#\")\n+ self.dut.send_expect(\"rm -rf %s\" % self.dump_vhost_pcap, \"#\")\n+ self.dut.send_expect(\"killall -s INT %s\" % self.testpmd_name, \"#\")\n+ self.dut.send_expect(\"killall -s INT %s\" % self.pdump_name, \"#\")\n+ self.use_dsa_list = []\n+\n+ self.DC.reset_all_work_queue()\n+ self.DC.bind_all_dsa_to_kernel()\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,\n+ eal_param=\"\",\n+ param=\"\",\n+ no_pci=False,\n+ ports=\"\",\n+ port_options=\"\",\n+ iova_mode=\"va\",\n+ ):\n+ if iova_mode:\n+ eal_param += \" --iova=\" + iova_mode\n+ if not no_pci and port_options != \"\":\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=cores,\n+ eal_param=eal_param,\n+ param=param,\n+ port_options=port_options,\n+ ports=ports,\n+ prefix=\"vhost\",\n+ fixed_prefix=True,\n+ )\n+ elif not no_pci and port_options == \"\":\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=cores,\n+ eal_param=eal_param,\n+ param=param,\n+ ports=ports,\n+ prefix=\"vhost\",\n+ fixed_prefix=True,\n+ )\n+ else:\n+ self.vhost_user_pmd.start_testpmd(\n+ cores=cores,\n+ eal_param=eal_param,\n+ param=param,\n+ no_pci=no_pci,\n+ prefix=\"vhost\",\n+ fixed_prefix=True,\n+ )\n+\n+ def start_virtio_testpmd_with_vhost_net1(self, cores, eal_param=\"\", param=\"\"):\n+ \"\"\"\n+ launch the testpmd as virtio with vhost_net1\n+ \"\"\"\n+ if self.check_2M_env:\n+ eal_param += \" --single-file-segments\"\n+ self.virtio_user1_pmd.start_testpmd(\n+ cores=cores,\n+ eal_param=eal_param,\n+ param=param,\n+ no_pci=True,\n+ prefix=\"virtio-user1\",\n+ fixed_prefix=True,\n+ )\n+ self.virtio_user1_pmd.execute_cmd(\"set fwd rxonly\")\n+ self.virtio_user1_pmd.execute_cmd(\"start\")\n+\n+ def start_virtio_testpmd_with_vhost_net0(self, cores, eal_param=\"\", param=\"\"):\n+ \"\"\"\n+ launch the testpmd as virtio with vhost_net0\n+ \"\"\"\n+ if self.check_2M_env:\n+ eal_param += \" --single-file-segments\"\n+ self.virtio_user0_pmd.start_testpmd(\n+ cores=cores,\n+ eal_param=eal_param,\n+ param=param,\n+ no_pci=True,\n+ prefix=\"virtio-user0\",\n+ fixed_prefix=True,\n+ )\n+\n+ def start_pdump_to_capture_pkt(self):\n+ \"\"\"\n+ launch pdump app with dump_port and file_prefix\n+ the pdump app should start after testpmd started\n+ if dump the vhost-testpmd, the vhost-testpmd should started before launch pdump\n+ if dump the virtio-testpmd, the virtio-testpmd should started before launch pdump\n+ \"\"\"\n+ command_line = (\n+ self.app_pdump\n+ + \"-l 1-2 -n 4 --file-prefix=virtio-user1 -v -- \"\n+ + \"--pdump 'device_id=net_virtio_user1,queue=*,rx-dev=%s,mbuf-size=8000'\"\n+ )\n+ self.pdump_user.send_expect(command_line % (self.dump_virtio_pcap), \"Port\")\n+\n+ def check_virtio_user1_stats(self, check_dict):\n+ \"\"\"\n+ check the virtio-user1 show port stats\n+ \"\"\"\n+ out = self.virtio_user1_pmd.execute_cmd(\"show port stats all\")\n+ self.logger.info(out)\n+ rx_packets = re.search(\"RX-packets:\\s*(\\d*)\", out)\n+ rx_bytes = re.search(\"RX-bytes:\\s*(\\d*)\", out)\n+ rx_num = int(rx_packets.group(1))\n+ byte_num = int(rx_bytes.group(1))\n+ packet_count = 0\n+ byte_count = 0\n+ for key, value in check_dict.items():\n+ packet_count += value\n+ byte_count += key * value\n+ self.verify(\n+ rx_num == packet_count,\n+ \"receive pakcet number: {} is not equal as send:{}\".format(\n+ rx_num, packet_count\n+ ),\n+ )\n+ self.verify(\n+ byte_num == byte_count,\n+ \"receive pakcet byte:{} is not equal as send:{}\".format(\n+ byte_num, byte_count\n+ ),\n+ )\n+\n+ def check_packet_payload_valid(self, check_dict):\n+ \"\"\"\n+ check the payload is valid\n+ \"\"\"\n+ self.pdump_user.send_expect(\"^c\", \"# \", 60)\n+ self.dut.session.copy_file_from(\n+ src=self.dump_virtio_pcap, dst=self.dump_virtio_pcap\n+ )\n+ pkt = Packet()\n+ pkts = pkt.read_pcapfile(self.dump_virtio_pcap)\n+ for key, value in check_dict.items():\n+ count = 0\n+ for i in range(len(pkts)):\n+ if len(pkts[i]) == key:\n+ count += 1\n+ self.verify(\n+ value == count,\n+ \"pdump file: {} have not include enough packets {}\".format(count, key),\n+ )\n+\n+ def clear_virtio_user1_stats(self):\n+ self.virtio_user1_pmd.execute_cmd(\"stop\")\n+ self.virtio_user1_pmd.execute_cmd(\"clear port stats all\")\n+ self.virtio_user1_pmd.execute_cmd(\"start\")\n+ out = self.virtio_user1_pmd.execute_cmd(\"show port stats all\")\n+ self.logger.info(out)\n+\n+ def send_502_960byte_and_64_64byte_pkts(self):\n+ \"\"\"\n+ send 251 960byte and 32 64byte length packets from virtio_user0 testpmd\n+ \"\"\"\n+ self.virtio_user0_pmd.execute_cmd(\"set burst 1\")\n+ self.virtio_user0_pmd.execute_cmd(\"set txpkts 64,128,256,512\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 27\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.virtio_user0_pmd.execute_cmd(\"set burst 32\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 7\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.virtio_user0_pmd.execute_cmd(\"set txpkts 64\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 1\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.vhost_user_pmd.execute_cmd(\"show port stats all\")\n+\n+ def send_502_64byte_and_64_8000byte_pkts(self):\n+ \"\"\"\n+ send 54 4640byte and 448 64byte length packets from virtio_user0 testpmd\n+ \"\"\"\n+ self.virtio_user0_pmd.execute_cmd(\"set burst 1\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 27\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.virtio_user0_pmd.execute_cmd(\"set burst 32\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 7\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.virtio_user0_pmd.execute_cmd(\"set txpkts 2000,2000,2000,2000\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 1\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.vhost_user_pmd.execute_cmd(\"show port stats all\")\n+\n+ def send_54_4640byte_and_448_64byte_pkts(self):\n+ \"\"\"\n+ send 54 4640byte and 448 64byte length packets from virtio_user0 testpmd\n+ \"\"\"\n+ self.virtio_user0_pmd.execute_cmd(\"set burst 1\")\n+ self.virtio_user0_pmd.execute_cmd(\"set txpkts 64,256,2000,64,256,2000\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 27\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.virtio_user0_pmd.execute_cmd(\"set burst 32\")\n+ self.virtio_user0_pmd.execute_cmd(\"set txpkts 64\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 7\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.vhost_user_pmd.execute_cmd(\"show port stats all\")\n+\n+ def send_448_64byte_and_54_4640byte_pkts(self):\n+ \"\"\"\n+ send 448 64byte and 54 4640byte length packets from virtio_user0 testpmd\n+ \"\"\"\n+ self.virtio_user0_pmd.execute_cmd(\"set burst 32\")\n+ self.virtio_user0_pmd.execute_cmd(\"set txpkts 64\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 7\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.virtio_user0_pmd.execute_cmd(\"set burst 1\")\n+ self.virtio_user0_pmd.execute_cmd(\"set txpkts 64,256,2000,64,256,2000\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 27\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.vhost_user_pmd.execute_cmd(\"show port stats all\")\n+\n+ def send_1_64byte_pkts(self):\n+ \"\"\"\n+ send 1 64byte length packets from virtio_user0 testpmd\n+ \"\"\"\n+ self.virtio_user0_pmd.execute_cmd(\"set burst 1\")\n+ self.virtio_user0_pmd.execute_cmd(\"start tx_first 1\")\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ self.vhost_user_pmd.execute_cmd(\"start\")\n+ self.vhost_user_pmd.execute_cmd(\"show port stats all\")\n+\n+ def test_split_non_mergeable_multi_queues_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 1: VM2VM vhost-user/virtio-user split ring non-mergeable path and multi-queues payload check with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@%s-q1;rxq1@%s-q1\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list[0:1],\n+ iova_mode=\"va\",\n+ )\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=0,in_order=0,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=0,in_order=0,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.clear_virtio_user1_stats()\n+ dmas1 = \"txq0@%s-q1;txq1@%s-q1;rxq0@%s-q1;rxq1@%s-q1\" % (\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+ dmas2 = \"txq0@%s-q1;txq1@%s-q1;rxq1@%s-q1;rxq1@%s-q1\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\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+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_inorder_non_mergeable_multi_queues_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 2: VM2VM split ring inorder non-mergeable path and multi-queues payload check with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;rxq1@%s-q1\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@%s-q2;rxq1@%s-q3\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=4\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list[0:1],\n+ iova_mode=\"va\",\n+ )\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=0,in_order=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=0,in_order=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.clear_virtio_user1_stats()\n+ dmas1 = \"txq0@%s-q1;txq1@%s-q1;rxq0@%s-q1;rxq1@%s-q1\" % (\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+ dmas2 = \"txq0@%s-q1;txq1@%s-q1;rxq1@%s-q1;rxq1@%s-q1\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\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+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_inorder_mergeable_multi_queues_non_indirect_descriptor_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 3: VM2VM split ring inorder mergeable path and multi-queues test non-indirect descriptor and payload check with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;rxq1@%s-q1\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@%s-q0;rxq1@%s-q1\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list[0:1],\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=1,in_order=1,queue_size=256\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=1,in_order=1,queue_size=256\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 2}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.virtio_user0_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.virtio_user1_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ dmas1 = \"txq0@%s-q0;txq1@%s-q1;rxq0@%s-q2;rxq1@%s-q3\" % (\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+ dmas2 = \"txq0@%s-q0;txq1@%s-q1;rxq1@%s-q2;rxq1@%s-q3\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\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+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 2}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_mergeable_multi_queues_indirect_descriptor_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 4: VM2VM split ring mergeable path and multi-queues test indirect descriptor and payload check with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@%s-q0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=1\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list[0:1],\n+ iova_mode=\"va\",\n+ )\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=1,in_order=0,queue_size=256\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=1,in_order=0,queue_size=256\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 10}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.virtio_user0_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.virtio_user1_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ dmas1 = \"txq0@%s-q0;txq1@%s-q1;rxq0@%s-q2;rxq1@%s-q3\" % (\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+ dmas2 = \"txq0@%s-q0;txq1@%s-q1;rxq1@%s-q2;rxq1@%s-q3\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\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+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 10}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_vectorized_multi_queues_payload_check_with_vhost_async_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 5: VM2VM split ring vectorized path and multi-queues payload check with vhost async operation and dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;rxq0@%s-q0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@%s-q1;rxq0@%s-q1;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=0,in_order=0,vectorized=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=0,in_order=0,vectorized=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.clear_virtio_user1_stats()\n+ dmas1 = \"txq0@%s-q3;txq1@%s-q3;rxq0@%s-q1;rxq1@%s-q1\" % (\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+ dmas2 = \"txq0@%s-q1;txq1@%s-q1;rxq1@%s-q3;rxq1@%s-q3\" % (\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\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+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_non_mergeable_multi_queues_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 6: VM2VM packed ring non-mergeable path and multi-queues payload check with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q1;rxq1@%s-q1\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@%s-q1;rxq1@%s-q1\" % (\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=0,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=0,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.clear_virtio_user1_stats()\n+ dmas1 = \"txq0@%s-q0;txq1@%s-q1;rxq0@%s-q0;rxq1@%s-q1\" % (\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+ dmas2 = \"txq0@%s-q0;txq1@%s-q1;rxq1@%s-q0;rxq1@%s-q1\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\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+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list[0:1],\n+ iova_mode=\"va\",\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_inorder_non_mergeable_multi_queues_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 7: VM2VM packed ring inorder non-mergeable path and multi-queues payload check with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;rxq1@%s-q1\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@%s-q0;rxq1@%s-q1\" % (\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\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+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.clear_virtio_user1_stats()\n+ dmas1 = \"txq0@%s-q5;txq1@%s-q6;rxq0@%s-q5;rxq1@%s-q6\" % (\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+ dmas2 = \"txq0@%s-q5;txq1@%s-q6;rxq1@%s-q5;rxq1@%s-q6\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_mergeable_multi_queues_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 8: VM2VM packed ring mergeable path and multi-queues payload check with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@%s-q0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=1\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ port_options=port_options,\n+ ports=self.use_dsa_list[0:1],\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=0,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=0,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_54_4640byte_and_448_64byte_pkts()\n+ check_dict = {4640: 54, 64: 448}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.clear_virtio_user1_stats()\n+ dmas1 = \"txq0@%s-q0;txq1@%s-q1;rxq0@%s-q2;rxq1@%s-q3\" % (\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+ dmas2 = \"txq0@%s-q4;txq1@%s-q5;rxq1@%s-q6;rxq1@%s-q7\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list[0:1],\n+ iova_mode=\"va\",\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.send_54_4640byte_and_448_64byte_pkts()\n+ check_dict = {4640: 54, 64: 448}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_inorder_mergeable_multi_queues_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 9: VM2VM packed ring inorder mergeable path and multi-queues payload check with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;rxq0@%s-q0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@%s-q0;txq1@%s-q0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_54_4640byte_and_448_64byte_pkts()\n+ check_dict = {4640: 54, 64: 448}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.clear_virtio_user1_stats()\n+ dmas1 = \"txq0@%s-q0;txq1@%s-q1;rxq0@%s-q0;rxq1@%s-q1\" % (\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+ dmas2 = \"txq0@%s-q0;txq1@%s-q1;rxq1@%s-q0;rxq1@%s-q1\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list,\n+ iova_mode=\"va\",\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.send_54_4640byte_and_448_64byte_pkts()\n+ check_dict = {4640: 54, 64: 448}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_vectorized_tx_multi_queues_indirect_descriptor_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 10: VM2VM packed ring vectorized-tx path and multi-queues test indirect descriptor and payload check with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;txq1@%s-q0;rxq0@%s-q0;rxq1@%s-q0\" % (\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+ dmas2 = \"txq0@%s-q1;txq1@%s-q1;rxq0@%s-q1;rxq1@%s-q1\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list[0:1],\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--force-max-simd-bitwidth=512 --vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,vectorized=1,queue_size=256\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--force-max-simd-bitwidth=512 --vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,vectorized=1,queue_size=256\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 10}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ self.virtio_user0_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.virtio_user1_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ dmas1 = \"txq0@%s-q0;txq1@%s-q1;rxq0@%s-q2;rxq1@%s-q3\" % (\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+ dmas2 = \"txq0@%s-q0;txq1@%s-q1\" % (\n+ self.use_dsa_list[1],\n+ self.use_dsa_list[1],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ port_options = {\n+ self.use_dsa_list[0]: \"max_queues=4\",\n+ self.use_dsa_list[1]: \"max_queues=2\",\n+ }\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+ self.start_pdump_to_capture_pkt()\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 10}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_vectorized_multi_queues_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 11: VM2VM packed ring vectorized path and payload check test with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;txq1@%s-q0;rxq0@%s-q0;rxq1@%s-q0\" % (\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+ dmas2 = \"txq0@%s-q1;txq1@%s-q1;rxq0@%s-q1;rxq1@%s-q1\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list[0:1],\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--force-max-simd-bitwidth=512 --vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--force-max-simd-bitwidth=512 --vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_448_64byte_and_54_4640byte_pkts()\n+ check_dict = {64: 448, 4640: 0}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_vectorized_ringsize_not_powerof_2_multi_queues_payload_check_with_dpdk_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 12: VM2VM packed ring vectorized path payload check test with ring size is not power of 2 with dsa dpdk driver\n+ \"\"\"\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=2, driver_name=\"vfio-pci\", socket=self.port_socket\n+ )\n+ dmas1 = \"txq0@%s-q0;txq1@%s-q0;rxq0@%s-q1;rxq1@%s-q1\" % (\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+ dmas2 = \"txq0@%s-q0;txq1@%s-q0;rxq0@%s-q1;rxq1@%s-q1\" % (\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=2\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list[0:1],\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--force-max-simd-bitwidth=512 --vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1,queue_size=4097\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4097 --rxd=4097\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--force-max-simd-bitwidth=512 --vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1,queue_size=4097\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4097 --rxd=4097\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_448_64byte_and_54_4640byte_pkts()\n+ check_dict = {64: 448, 4640: 0}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_non_mergeable_multi_queues_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 13: VM2VM split ring non-mergeable path and multi-queues payload check with dsa kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;rxq1@wq0.0]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq0.1;rxq1@wq0.1]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=0,in_order=0,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=0,in_order=0,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_inorder_non_mergeable_multi_queues_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 14: VM2VM split ring inorder non-mergeable path and multi-queues payload check with dsa kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=4, dsa_index=0)\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;rxq1@wq0.1]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq0.2;rxq1@wq0.3]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=0,in_order=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=0,in_order=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_inorder_mergeable_multi_queues_non_indirect_descriptor_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 15: VM2VM split ring inorder mergeable path and multi-queues test non-indirect descriptor and payload check with dsa kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=4, dsa_index=0)\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;rxq1@wq0.1]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq0.2;rxq1@wq0.3]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=1,in_order=1,queue_size=256\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=1,in_order=1,queue_size=256\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 2}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_mergeable_multi_queues_indirect_descriptor_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 16: VM2VM split ring mergeable path and multi-queues test indirect descriptor and payload check with dsa kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;txq1@wq0.0;rxq0@wq0.0;rxq0@wq0.0]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq0.1;txq1@wq0.1;rxq0@wq0.1;rxq0@wq0.1]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=1,in_order=0,queue_size=256\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=1,in_order=0,queue_size=256\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 10}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_vectorized_multi_queues_payload_check_with_vhost_async_operation_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 17: VM2VM split ring vectorized path and multi-queues payload check with vhost async operation and dsa kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=4, dsa_index=0)\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;txq1@wq0.0;rxq0@wq0.0;rxq1@wq0.0]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq0.0;txq1@wq0.0;rxq0@wq0.0;rxq1@wq0.0]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=0,in_order=0,vectorized=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=0,in_order=0,vectorized=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_non_mergeable_multi_queues_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 18: VM2VM packed ring non-mergeable path and multi-queues payload check with dsa kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;rxq1@wq0.0]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq0.1;rxq1@wq0.1]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=0,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=0,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_inorder_non_mergeable_multi_queues_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 19: VM2VM packed ring inorder non-mergeable path and multi-queues payload check with dsa kernel driver\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;rxq1@wq0.1]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq1.0;rxq1@wq1.1]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_mergeable_multi_queues_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 20: VM2VM packed ring mergeable path and multi-queues payload check with dsa kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;txq1@wq0.0;rxq0@wq0.1;rxq1@wq0.1]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq0.1;txq1@wq0.1;rxq0@wq0.0;rxq1@wq0.0]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=0,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=0,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_inorder_mergeable_multi_queues_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 21: VM2VM packed ring inorder mergeable path and multi-queues payload check with dsa kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=0)\n+ self.DC.create_work_queue(work_queue_number=1, dsa_index=1)\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;rxq0@wq0.0;rxq1@wq0.0]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq1.0;txq1@wq1.0;rxq1@wq1.0]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_960byte_and_64_64byte_pkts()\n+ check_dict = {960: 502, 64: 64}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_vectorized_tx_multi_queues_indirect_descriptor_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 22: VM2VM packed ring vectorized-tx path and multi-queues test indirect descriptor and payload check with dsa kernel driver\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;txq1@wq0.0;rxq0@wq0.1;rxq1@wq0.1]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq1.0;txq1@wq1.0;rxq0@wq1.1;rxq1@wq1.1]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,vectorized=1,queue_size=256\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,vectorized=1,queue_size=256\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 10}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_vectorized_multi_queues_indirect_descriptor_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 23: VM2VM packed ring vectorized path and multi-queues test indirect descriptor and payload check with dsa kernel driver\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;txq1@wq0.0;rxq0@wq0.1;rxq1@wq0.1]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq1.0;txq1@wq1.0;rxq0@wq1.1;rxq1@wq1.1]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 0}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_vectorized_ringsize_not_powerof_2_multi_queues_payload_check_with_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 24: VM2VM packed ring vectorized path payload check test with ring size is not power of 2 with dsa kernel driver\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+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@wq0.0;txq1@wq0.0;rxq0@wq0.1;rxq1@wq0.1]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@wq1.0;txq1@wq1.0;rxq0@wq1.1;rxq1@wq1.1]'\"\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=True,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1,queue_size=4097\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4097 --rxd=4097\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1,queue_size=4097\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4097 --rxd=4097\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 0}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_split_mergeable_multi_queues_indirect_descriptor_payload_check_with_dpdk_and_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 25: VM2VM split ring mergeable path and multi-queues test indirect descriptor with dsa dpdk and kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=1,\n+ driver_name=\"vfio-pci\",\n+ dsa_index_list=[1],\n+ socket=self.port_socket,\n+ )\n+ dmas1 = \"txq0@wq0.0;rxq0@wq0.0;rxq1@wq0.0\"\n+ dmas2 = \"txq0@%s-q0;txq1@%s-q0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=1\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,mrg_rxbuf=1,in_order=0,queue_size=256\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,mrg_rxbuf=1,in_order=0,queue_size=256\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_502_64byte_and_64_8000byte_pkts()\n+ check_dict = {64: 502, 8000: 10}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_inorder_mergeable_multi_queues_payload_check_with_dpdk_and_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 26: VM2VM packed ring inorder mergeable path and multi-queues payload check with dsa dpdk and kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=1,\n+ driver_name=\"vfio-pci\",\n+ dsa_index_list=[1],\n+ socket=self.port_socket,\n+ )\n+ dmas1 = \"txq0@%s-q0;txq1@wq0.0;rxq0@%s-q0;rxq1@wq0.0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@wq0.0;txq1@%s-q0;rxq0@wq0.0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=1\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,queue_size=4096\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,queue_size=4096\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_54_4640byte_and_448_64byte_pkts()\n+ check_dict = {4640: 54, 64: 448}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def test_packed_vectorized_tx_batch_processing_with_dpdk_and_kernel_driver(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 27: VM2VM packed ring vectorized-tx path test batch processing with dsa dpdk and kernel driver\n+ \"\"\"\n+ self.DC.create_work_queue(work_queue_number=2, dsa_index=0)\n+ self.use_dsa_list = self.DC.bind_dsa_to_dpdk(\n+ dsa_number=1,\n+ driver_name=\"vfio-pci\",\n+ dsa_index_list=[1],\n+ socket=self.port_socket,\n+ )\n+ dmas1 = \"txq0@%s-q0;txq1@wq0.0;rxq0@%s-q0;rxq1@wq0.0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ dmas2 = \"txq0@wq0.0;txq1@%s-q0;rxq0@wq0.0;rxq1@%s-q0\" % (\n+ self.use_dsa_list[0],\n+ self.use_dsa_list[0],\n+ )\n+ vhost_eal_param = (\n+ \"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[%s]' \"\n+ \"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[%s]'\"\n+ % (dmas1, dmas2)\n+ )\n+ vhost_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=4096 --rxd=4096 --no-flush-rx\"\n+ port_options = {self.use_dsa_list[0]: \"max_queues=1\"}\n+ self.start_vhost_testpmd(\n+ cores=self.vhost_core_list,\n+ eal_param=vhost_eal_param,\n+ param=vhost_param,\n+ no_pci=False,\n+ ports=self.use_dsa_list,\n+ port_options=port_options,\n+ iova_mode=\"va\",\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,vectorized=1,queue_size=256\"\n+ virtio1_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ cores=self.virtio1_core_list,\n+ eal_param=virtio1_eal_param,\n+ param=virtio1_param,\n+ )\n+\n+ self.start_pdump_to_capture_pkt()\n+\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=2,server=1,packed_vq=1,mrg_rxbuf=1,in_order=1,vectorized=1,queue_size=256\"\n+ virtio0_param = \"--nb-cores=1 --rxq=2 --txq=2 --txd=256 --rxd=256\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ cores=self.virtio0_core_list,\n+ eal_param=virtio0_eal_param,\n+ param=virtio0_param,\n+ )\n+\n+ self.send_1_64byte_pkts()\n+ check_dict = {64: 2}\n+ self.check_virtio_user1_stats(check_dict)\n+ self.check_packet_payload_valid(check_dict)\n+\n+ def quit_all_testpmd(self):\n+ self.vhost_user_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.virtio_user0_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.virtio_user1_pmd.execute_cmd(\"quit\", \"#\", 60)\n+ self.pdump_user.send_expect(\"^c\", \"# \", 60)\n+\n+ def tear_down(self):\n+ self.quit_all_testpmd()\n+ self.dut.send_expect(\"killall -s INT %s\" % self.testpmd_name, \"#\")\n+ self.dut.send_expect(\"killall -s INT %s\" % self.pdump_name, \"#\")\n+ self.DC.reset_all_work_queue()\n+ self.DC.bind_all_dsa_to_kernel()\n+\n+ def tear_down_all(self):\n+ pass\n", "prefixes": [ "V3", "2/2" ] }{ "id": 121263, "url": "