Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/125523/?format=api
{ "id": 125523, "url": "http://patches.dpdk.org/api/patches/125523/?format=api", "web_url": "http://patches.dpdk.org/project/dts/patch/20230327073016.3204523-4-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": "<20230327073016.3204523-4-weix.ling@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20230327073016.3204523-4-weix.ling@intel.com", "date": "2023-03-27T07:30:16", "name": "[V2,3/3] tests/vswitch_sample_dsa: add new testsuite", "commit_ref": null, "pull_url": null, "state": "accepted", "archived": false, "hash": "776b4ad7a2ae7bd5269700d9900d63b0101a7e92", "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/20230327073016.3204523-4-weix.ling@intel.com/mbox/", "series": [ { "id": 27546, "url": "http://patches.dpdk.org/api/series/27546/?format=api", "web_url": "http://patches.dpdk.org/project/dts/list/?series=27546", "date": "2023-03-27T07:30:13", "name": "add vswitch_sample_dsa", "version": 2, "mbox": "http://patches.dpdk.org/series/27546/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/125523/comments/", "check": "warning", "checks": "http://patches.dpdk.org/api/patches/125523/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 606224284F;\n\tMon, 27 Mar 2023 09:33:38 +0200 (CEST)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 592FE427F2;\n\tMon, 27 Mar 2023 09:33:38 +0200 (CEST)", "from mga11.intel.com (mga11.intel.com [192.55.52.93])\n by mails.dpdk.org (Postfix) with ESMTP id CAF9340ED5\n for <dts@dpdk.org>; Mon, 27 Mar 2023 09:33:36 +0200 (CEST)", "from orsmga001.jf.intel.com ([10.7.209.18])\n by fmsmga102.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 27 Mar 2023 00:33:36 -0700", "from unknown (HELO localhost.localdomain) ([10.239.252.222])\n by orsmga001-auth.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 27 Mar 2023 00:33:35 -0700" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/simple;\n d=intel.com; i=@intel.com; q=dns/txt; s=Intel;\n t=1679902417; x=1711438417;\n h=from:to:cc:subject:date:message-id:in-reply-to:\n references:mime-version:content-transfer-encoding;\n bh=zBXmLM0XGP6Di11dER0kzyER9lSwnzR2z01SsY8y94w=;\n b=APk9Tx3vAN5IapJHxeYY4ga+I06mdXMAjHk0jBquZrlNSmwNdU1nLYgu\n SStl0EulqEXfQs7gkvg4Iy91lic0nAs4yxRtXvUXB2QqDovI7jSbkN3YG\n UbTOWYkcPiVtJovQp16NYFn3EYbrhYo09MdY1I+KVtXjypMt1UnDJqMl/\n iYU0IIEOUsHM3hzPSr8YRbSe/zMiTa81ShKvJON6PEUKcBwOI+ocXjCcx\n gkVHDf3Y1uJnXh48ZJAOQv5peODfJCy/2FN+j4W1Ygz5Uo8RIzu37vE2h\n 1FK7wrS4X7nOZrNWHMok8w0AtkFxTzI+jcboP8+bo++Dv1u8DC6ZZRw/Q g==;", "X-IronPort-AV": [ "E=McAfee;i=\"6600,9927,10661\"; a=\"337702945\"", "E=Sophos;i=\"5.98,294,1673942400\"; d=\"scan'208\";a=\"337702945\"", "E=McAfee;i=\"6600,9927,10661\"; a=\"715982996\"", "E=Sophos;i=\"5.98,294,1673942400\"; d=\"scan'208\";a=\"715982996\"" ], "X-ExtLoop1": "1", "From": "Wei Ling <weix.ling@intel.com>", "To": "dts@dpdk.org", "Cc": "Wei Ling <weix.ling@intel.com>", "Subject": "[dts][PATCH V2 3/3] tests/vswitch_sample_dsa: add new testsuite", "Date": "Mon, 27 Mar 2023 15:30:16 +0800", "Message-Id": "<20230327073016.3204523-4-weix.ling@intel.com>", "X-Mailer": "git-send-email 2.25.1", "In-Reply-To": "<20230327073016.3204523-1-weix.ling@intel.com>", "References": "<20230327073016.3204523-1-weix.ling@intel.com>", "MIME-Version": "1.0", "Content-Transfer-Encoding": "8bit", "X-BeenThere": "dts@dpdk.org", "X-Mailman-Version": "2.1.29", "Precedence": "list", "List-Id": "test suite reviews and discussions <dts.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dts>,\n <mailto:dts-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://mails.dpdk.org/archives/dts/>", "List-Post": "<mailto:dts@dpdk.org>", "List-Help": "<mailto:dts-request@dpdk.org?subject=help>", "List-Subscribe": "<https://mails.dpdk.org/listinfo/dts>,\n <mailto:dts-request@dpdk.org?subject=subscribe>", "Errors-To": "dts-bounces@dpdk.org" }, "content": "Add vswitch_sample_dsa testsuite to test dpdk-vhost APP with host DMA \noperation callbacks for DSA PMD and vhost async data-path.\n\nSigned-off-by: Wei Ling <weix.ling@intel.com>\n---\n tests/TestSuite_vswitch_sample_dsa.py | 1033 +++++++++++++++++++++++++\n 1 file changed, 1033 insertions(+)\n create mode 100644 tests/TestSuite_vswitch_sample_dsa.py", "diff": "diff --git a/tests/TestSuite_vswitch_sample_dsa.py b/tests/TestSuite_vswitch_sample_dsa.py\nnew file mode 100644\nindex 00000000..bf1e0f25\n--- /dev/null\n+++ b/tests/TestSuite_vswitch_sample_dsa.py\n@@ -0,0 +1,1033 @@\n+# SPDX-License-Identifier: BSD-3-Clause\n+# Copyright(c) 2023 Intel Corporation\n+#\n+\n+\"\"\"\n+DPDK Test suite.\n+\"\"\"\n+\n+import random\n+import re\n+import string\n+import time\n+\n+import framework.utils as utils\n+from framework.pmd_output import PmdOutput\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 TestVswitchSampleDSA(TestCase):\n+ def set_up_all(self):\n+ \"\"\"\n+ Run at the start of each test suite.\n+ \"\"\"\n+ out = self.dut.build_dpdk_apps(\"./examples/vhost\")\n+ self.verify(\"Error\" not in out, \"compilation vhost error\")\n+ self.vhost_path = self.dut.apps_name[\"vhost\"]\n+ self.tester_tx_port_num = 1\n+ self.dut_ports = self.dut.get_ports()\n+ self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])\n+ self.cores = self.dut.get_core_list(\"all\", socket=self.ports_socket)\n+ self.vhost_core_list = self.cores[0:2]\n+ self.vhost_core_range = \"%s-%s\" % (\n+ self.vhost_core_list[0],\n+ self.vhost_core_list[-1],\n+ )\n+ self.vuser0_core_list = self.cores[2:4]\n+ self.vuser1_core_list = self.cores[4:6]\n+ self.mem_channels = self.dut.get_memory_channels()\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.virtio_dst_mac0 = \"00:11:22:33:44:10\"\n+ self.virtio_dst_mac1 = \"00:11:22:33:44:11\"\n+ self.vm_dst_mac0 = \"52:54:00:00:00:01\"\n+ self.vm_dst_mac1 = \"52:54:00:00:00:02\"\n+ self.vm_num = 2\n+ # create an instance to set stream field setting\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.virtio_user0_pmd = PmdOutput(self.dut, self.virtio_user0)\n+ self.virtio_user1_pmd = PmdOutput(self.dut, self.virtio_user1)\n+ self.random_string = string.ascii_letters + string.digits\n+ self.virtio_ip0 = \"1.1.1.2\"\n+ self.virtio_ip1 = \"1.1.1.3\"\n+ self.rerun_times = 5\n+ self.DC = DC(self)\n+\n+ def set_up(self):\n+ \"\"\"\n+ Run before each test case.\n+ \"\"\"\n+ self.table_header = [\"Frame Size(Byte)\", \"Mode\", \"Throughput(Mpps)\"]\n+ self.result_table_create(self.table_header)\n+ self.dut.send_expect(\"rm -rf %s/vhost-net*\" % self.base_dir, \"#\")\n+ self.dut.send_expect(\"killall -I dpdk-vhost\", \"#\", 20)\n+ self.dut.send_expect(\"killall -I qemu-system-x86_64\", \"#\", 20)\n+ self.vm_dut = []\n+ self.vm = []\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 launch_vhost_app(\n+ self, eal_params, vdev_num, dmas, mergeable=True, tso=False, client_mode=True\n+ ):\n+ \"\"\"\n+ launch the vhost app on vhost side\n+ \"\"\"\n+ vdev_param = \"\"\n+ for i in range(vdev_num):\n+ vdev_param += \"--socket-file ./vhost-net{} \".format(i)\n+ mergeable_param = \"--mergeable 1\" if mergeable else \"\"\n+ tso_param = \"--tso 1\" if tso else \"\"\n+ client_param = \"--client\" if client_mode else \"\"\n+ cmd = (\n+ \"%s %s -- -p 0x1 %s %s --vm2vm 1 --stats 1 \\\n+ %s --dmas [%s] \\\n+ %s --total-num-mbufs 600000\"\n+ % (\n+ self.vhost_path,\n+ eal_params,\n+ tso_param,\n+ mergeable_param,\n+ vdev_param,\n+ dmas,\n+ client_param,\n+ )\n+ )\n+ self.vhost_user.send_command(cmd)\n+ time.sleep(3)\n+\n+ def start_virtio_testpmd_with_vhost_net0(self, 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=self.vuser0_core_list,\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_virtio_testpmd_with_vhost_net1(self, 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=self.vuser1_core_list,\n+ eal_param=eal_param,\n+ param=param,\n+ no_pci=True,\n+ prefix=\"virtio-user1\",\n+ fixed_prefix=True,\n+ )\n+\n+ def start_vms(\n+ self,\n+ moderns=[\"true\", \"true\"],\n+ mrg_rxbuf=True,\n+ packed=False,\n+ server_mode=False,\n+ set_target=True,\n+ bind_dev=True,\n+ ):\n+ \"\"\"\n+ start two VM, each VM has one virtio device\n+ \"\"\"\n+ mrg_rxbuf = \"on\" if mrg_rxbuf else \"off\"\n+ packed = \",packed=on\" if packed else \"\"\n+ for i in range(self.vm_num):\n+ vm_dut = None\n+ setting_format = \"disable-modern=%s,mrg_rxbuf=%s,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on%s\"\n+ setting_args = setting_format % (moderns[i], mrg_rxbuf, packed)\n+ vm_info = VM(self.dut, \"vm%d\" % i, \"vhost_sample\")\n+ vm_params = {}\n+ vm_params[\"driver\"] = \"vhost-user\"\n+ if server_mode:\n+ vm_params[\"opt_path\"] = \"./vhost-net%d\" % i + \",server\"\n+ else:\n+ vm_params[\"opt_path\"] = \"./vhost-net%d\" % i\n+ vm_params[\"opt_mac\"] = \"52:54:00:00:00:0%d\" % (i + 1)\n+ vm_params[\"opt_settings\"] = setting_args\n+ vm_info.set_vm_device(**vm_params)\n+ time.sleep(3)\n+ try:\n+ vm_dut = vm_info.start(set_target=set_target, bind_dev=bind_dev)\n+ if vm_dut is None:\n+ raise Exception(\"Set up VM ENV failed\")\n+ except Exception as e:\n+ print((utils.RED(\"Failure for %s\" % str(e))))\n+ raise e\n+ self.vm_dut.append(vm_dut)\n+ self.vm.append(vm_info)\n+\n+ def start_vm_testpmd(self, pmd_session):\n+ \"\"\"\n+ launch the testpmd in vm\n+ \"\"\"\n+ self.vm_cores = [1, 2]\n+ param = \"--rxq=1 --txq=1 --nb-cores=1 --txd=1024 --rxd=1024\"\n+ pmd_session.start_testpmd(cores=self.vm_cores, param=param)\n+\n+ def repeat_bind_driver(self, dut, repeat_times=50):\n+ i = 0\n+ while i < repeat_times:\n+ dut.unbind_interfaces_linux()\n+ dut.bind_interfaces_linux(driver=\"virtio-pci\")\n+ dut.bind_interfaces_linux(driver=\"vfio-pci\")\n+ i += 1\n+\n+ def let_vswitch_know_mac(self, virtio_pmd, relaunch=False):\n+ if not relaunch:\n+ virtio_pmd.execute_cmd(\"set fwd mac\")\n+ virtio_pmd.execute_cmd(\"start tx_first\")\n+ else:\n+ virtio_pmd.execute_cmd(\"stop\")\n+ virtio_pmd.execute_cmd(\"start tx_first\")\n+\n+ def get_receive_throughput(self, pmd_session, count=10):\n+ i = 0\n+ while i < count:\n+ pmd_session.execute_cmd(\"show port stats all\")\n+ i += 1\n+ else:\n+ out = pmd_session.execute_cmd(\"show port stats all\")\n+ pmd_session.execute_cmd(\"stop\")\n+ rx_throughput = re.compile(\"Rx-pps: \\s+(.*?)\\s+?\").findall(out, re.S)\n+ return float(rx_throughput[0]) / 1000000.0\n+\n+ def set_testpmd0_param(self, pmd_session, eth_peer_mac):\n+ pmd_session.execute_cmd(\"set fwd mac\")\n+ pmd_session.execute_cmd(\"start tx_first\")\n+ pmd_session.execute_cmd(\"stop\")\n+ pmd_session.execute_cmd(\"set eth-peer 0 %s\" % eth_peer_mac)\n+ pmd_session.execute_cmd(\"start\")\n+\n+ def set_testpmd1_param(self, pmd_session, eth_peer_mac):\n+ pmd_session.execute_cmd(\"set fwd mac\")\n+ pmd_session.execute_cmd(\"set eth-peer 0 %s\" % eth_peer_mac)\n+\n+ def send_pkts_from_testpmd1(self, pmd_session, pkt_len):\n+ if pkt_len in [64, 2000]:\n+ pmd_session.execute_cmd(\"set txpkts %s\" % pkt_len)\n+ elif pkt_len == 8000:\n+ pmd_session.execute_cmd(\"set txpkts 2000,2000,2000,2000\")\n+ elif pkt_len == \"imix\":\n+ pmd_session.execute_cmd(\"set txpkts 64,256,2000,64,256,2000\")\n+ pmd_session.execute_cmd(\"start tx_first\")\n+\n+ def vm2vm_check_with_two_dsa(self):\n+ frame_sizes = [64, 2000, 8000, \"imix\"]\n+ self.set_testpmd0_param(self.virtio_user0_pmd, self.virtio_dst_mac1)\n+ self.set_testpmd1_param(self.virtio_user1_pmd, self.virtio_dst_mac0)\n+\n+ rx_throughput = {}\n+ for frame_size in frame_sizes:\n+ self.send_pkts_from_testpmd1(\n+ pmd_session=self.virtio_user1_pmd, pkt_len=frame_size\n+ )\n+ rx_pps = self.get_receive_throughput(pmd_session=self.virtio_user1_pmd)\n+ rx_throughput[frame_size] = rx_pps\n+ return rx_throughput\n+\n+ def test_vm2vm_virtio_user_forwarding_test_using_dsa_dpdk_driver(self):\n+ \"\"\"\n+ Test Case 1: VM2VM virtio-user forwarding test when vhost async operation using DSA dpdk driver\n+ \"\"\"\n+ perf_result = []\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ ports = dsas\n+ ports.append(self.dut.ports_info[0][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=4\"}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports, port_options=port_options\n+ )\n+ dmas = \"txd0@%s-q0,rxd0@%s-q1,txd1@%s-q2,rxd1@%s-q3\" % (\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ )\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:11:22:33:44:10,path=./vhost-net0,queues=1,server=1,mrg_rxbuf=1,in_order=0,packed_vq=1\"\n+ virtio0_param = \"--rxq=1 --txq=1 --txd=1024 --rxd=1024 --nb-cores=1\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ eal_param=virtio0_eal_param, param=virtio0_param\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user0,mac=00:11:22:33:44:11,path=./vhost-net1,queues=1,server=1,mrg_rxbuf=1,in_order=1,vectorized=1\"\n+ virtio1_param = \"--rxq=1 --txq=1 --txd=1024 --rxd=1024 --nb-cores=1\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ eal_param=virtio1_eal_param, param=virtio1_param\n+ )\n+ before_relunch_result = self.vm2vm_check_with_two_dsa()\n+\n+ self.vhost_user.send_expect(\"^C\", \"# \", 20)\n+ dmas = \"txd0@%s-q0,rxd1@%s-q1\" % (dsas[0], dsas[0])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ after_relunch_result = self.vm2vm_check_with_two_dsa()\n+\n+ for key in before_relunch_result.keys():\n+ perf_result.append(\n+ [key, \"Before Re-launch vhost\", before_relunch_result[key]]\n+ )\n+ for key in after_relunch_result.keys():\n+ perf_result.append(\n+ [key, \"After Re-launch vhost \", after_relunch_result[key]]\n+ )\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ def vm2vm_check_with_two_vhost_device(self):\n+ rx_throughput = {}\n+ self.frame_sizes = [64, 2000, 8000, \"imix\"]\n+ for frame_size in self.frame_sizes:\n+ self.send_pkts_from_testpmd1(pmd_session=self.vm1_pmd, pkt_len=frame_size)\n+ rx_pps = self.get_receive_throughput(pmd_session=self.vm1_pmd)\n+ rx_throughput[frame_size] = rx_pps\n+ return rx_throughput\n+\n+ def start_vms_testpmd_and_test(\n+ self, moderns=[\"true\", \"true\"], mrg_rxbuf=True, need_start_vm=True, packed=False\n+ ):\n+ if need_start_vm:\n+ self.start_vms(\n+ moderns=moderns,\n+ mrg_rxbuf=mrg_rxbuf,\n+ packed=packed,\n+ server_mode=True,\n+ set_target=True,\n+ bind_dev=True,\n+ )\n+ self.vm0_pmd = PmdOutput(self.vm_dut[0])\n+ self.vm1_pmd = PmdOutput(self.vm_dut[1])\n+ self.start_vm_testpmd(self.vm0_pmd)\n+ self.start_vm_testpmd(self.vm1_pmd)\n+ self.set_testpmd0_param(self.vm0_pmd, self.vm_dst_mac1)\n+ self.set_testpmd1_param(self.vm1_pmd, self.vm_dst_mac0)\n+ perf_result = self.vm2vm_check_with_two_vhost_device()\n+ self.vm0_pmd.quit()\n+ self.vm1_pmd.quit()\n+ return perf_result\n+\n+ def test_vm2vm_virtio_pmd_split_ring_test_with_dsa_dpdk_driver_register_and_unregister_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 2: VM2VM virtio-pmd split ring test with DSA dpdk driver register/unregister stable check\n+ \"\"\"\n+ perf_result = []\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ ports = dsas\n+ ports.append(self.dut.ports_info[0][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=4\"}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports, port_options=port_options\n+ )\n+ dmas = \"txd0@%s-q0,rxd0@%s-q1,txd1@%s-q2,rxd1@%s-q3\" % (\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ )\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ before_rebind = self.start_vms_testpmd_and_test(\n+ moderns=[\"true\", \"false\"], mrg_rxbuf=True, need_start_vm=True, packed=False\n+ )\n+\n+ # repeat bind 50 time from virtio-pci to vfio-pci\n+ self.repeat_bind_driver(dut=self.vm_dut[0], repeat_times=50)\n+ self.repeat_bind_driver(dut=self.vm_dut[1], repeat_times=50)\n+\n+ self.vhost_user.send_expect(\"^C\", \"# \", 20)\n+ dmas = \"txd0@%s-q0,rxd1@%s-q3\" % (dsas[0], dsas[0])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ after_rebind = self.start_vms_testpmd_and_test(need_start_vm=False)\n+\n+ for key in before_rebind.keys():\n+ perf_result.append([key, \"Before rebind driver\", before_rebind[key]])\n+\n+ for key in after_rebind.keys():\n+ perf_result.append([key, \"After rebind driver\", after_rebind[key]])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ for i in perf_result:\n+ self.verify(i[2] > 0, \"%s Frame Size(Byte) is less than 0 Mpps\" % i[0])\n+\n+ def test_vm2vm_virtio_pmd_packed_ring_test_with_dsa_dpdk_driver_register_and_unregister_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 3: VM2VM virtio-pmd packed ring test with DSA dpdk driver register/unregister stable check\n+ \"\"\"\n+ perf_result = []\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ ports = dsas\n+ ports.append(self.dut.ports_info[0][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=4\"}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports, port_options=port_options\n+ )\n+ dmas = \"txd0@%s-q0,rxd0@%s-q1,txd1@%s-q2,rxd1@%s-q3\" % (\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ )\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ before_rebind = self.start_vms_testpmd_and_test(\n+ moderns=[\"false\", \"false\"], mrg_rxbuf=True, need_start_vm=True, packed=True\n+ )\n+\n+ # repeat bind 50 time from virtio-pci to vfio-pci\n+ self.repeat_bind_driver(dut=self.vm_dut[0], repeat_times=50)\n+ self.repeat_bind_driver(dut=self.vm_dut[1], repeat_times=50)\n+\n+ after_rebind = self.start_vms_testpmd_and_test(need_start_vm=False)\n+\n+ for key in before_rebind.keys():\n+ perf_result.append([key, \"Before rebind driver\", before_rebind[key]])\n+\n+ for key in after_rebind.keys():\n+ perf_result.append([key, \"After rebind driver\", after_rebind[key]])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ for i in perf_result:\n+ self.verify(i[2] > 0, \"%s Frame Size(Byte) is less than 0 Mpps\" % i[0])\n+\n+ def config_vm_env(self):\n+ \"\"\"\n+ set virtio device IP and run arp protocal\n+ \"\"\"\n+ vm0_intf = self.vm_dut[0].ports_info[0][\"intf\"]\n+ vm1_intf = self.vm_dut[1].ports_info[0][\"intf\"]\n+ self.vm_dut[0].send_expect(\n+ \"ifconfig %s %s\" % (vm0_intf, self.virtio_ip0), \"#\", 10\n+ )\n+ self.vm_dut[1].send_expect(\n+ \"ifconfig %s %s\" % (vm1_intf, self.virtio_ip1), \"#\", 10\n+ )\n+ self.vm_dut[0].send_expect(\n+ \"arp -s %s %s\" % (self.virtio_ip1, self.vm_dst_mac1), \"#\", 10\n+ )\n+ self.vm_dut[1].send_expect(\n+ \"arp -s %s %s\" % (self.virtio_ip0, self.vm_dst_mac0), \"#\", 10\n+ )\n+\n+ def start_iperf_test(self):\n+ \"\"\"\n+ run perf command between to vms\n+ \"\"\"\n+ iperf_server = \"iperf -f g -s -i 1\"\n+ iperf_client = \"iperf -f g -c 1.1.1.2 -i 1 -t 60\"\n+ self.vm_dut[0].send_expect(\"%s > iperf_server.log &\" % iperf_server, \"\", 10)\n+ self.vm_dut[1].send_expect(\"%s > iperf_client.log &\" % iperf_client, \"\", 60)\n+ time.sleep(90)\n+\n+ def get_iperf_result(self):\n+ \"\"\"\n+ get the iperf test result\n+ \"\"\"\n+ self.vm_dut[0].send_expect(\"pkill iperf\", \"# \")\n+ self.vm_dut[1].session.copy_file_from(\"%s/iperf_client.log\" % self.dut.base_dir)\n+ fp = open(\"./iperf_client.log\")\n+ fmsg = fp.read()\n+ fp.close()\n+ # remove the server report info from msg\n+ index = fmsg.find(\"Server Report\")\n+ if index != -1:\n+ fmsg = fmsg[:index]\n+ iperfdata = re.compile(\"\\S*\\s*[M|G]bits/sec\").findall(fmsg)\n+ # the last data of iperf is the ave data from 0-30 sec\n+ self.verify(len(iperfdata) != 0, \"The iperf data between to vms is 0\")\n+ self.logger.info(\"The iperf data between vms is %s\" % iperfdata[-1])\n+ self.verify(\n+ (iperfdata[-1].split()[1]) == \"Gbits/sec\"\n+ and float(iperfdata[-1].split()[0]) >= 1,\n+ \"the throughput must be above 1Gbits/sec\",\n+ )\n+ # rm the iperf log file in vm\n+ self.vm_dut[0].send_expect(\"rm iperf_server.log\", \"#\", 10)\n+ self.vm_dut[1].send_expect(\"rm iperf_client.log\", \"#\", 10)\n+ return float(iperfdata[-1].split()[0])\n+\n+ def check_scp_file_valid_between_vms(self, file_size=1024):\n+ \"\"\"\n+ scp file form VM1 to VM2, check the data is valid\n+ \"\"\"\n+ # default file_size=1024K\n+ data = \"\"\n+ for _ in range(file_size * 1024):\n+ data += random.choice(self.random_string)\n+ self.vm_dut[0].send_expect('echo \"%s\" > /tmp/payload' % data, \"# \")\n+ # scp this file to vm1\n+ out = self.vm_dut[1].send_command(\n+ \"scp root@%s:/tmp/payload /root\" % self.virtio_ip0, timeout=5\n+ )\n+ if \"Are you sure you want to continue connecting\" in out:\n+ self.vm_dut[1].send_command(\"yes\", timeout=3)\n+ self.vm_dut[1].send_command(self.vm[0].password, timeout=3)\n+ # get the file info in vm1, and check it valid\n+ md5_send = self.vm_dut[0].send_expect(\"md5sum /tmp/payload\", \"# \")\n+ md5_revd = self.vm_dut[1].send_expect(\"md5sum /root/payload\", \"# \")\n+ md5_send = md5_send[: md5_send.find(\" \")]\n+ md5_revd = md5_revd[: md5_revd.find(\" \")]\n+ self.verify(\n+ md5_send == md5_revd, \"the received file is different with send file\"\n+ )\n+\n+ def start_iperf_and_scp_test_in_vms(\n+ self,\n+ moderns=[\"true\", \"true\"],\n+ mrg_rxbuf=False,\n+ need_start_vm=True,\n+ packed=False,\n+ server_mode=False,\n+ ):\n+ if need_start_vm:\n+ self.start_vms(\n+ moderns=moderns,\n+ mrg_rxbuf=mrg_rxbuf,\n+ server_mode=server_mode,\n+ set_target=True,\n+ bind_dev=False,\n+ )\n+ self.vm0_pmd = PmdOutput(self.vm_dut[0])\n+ self.vm1_pmd = PmdOutput(self.vm_dut[1])\n+ self.config_vm_env()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf_test()\n+ iperfdata = self.get_iperf_result()\n+ return iperfdata\n+\n+ def test_vm2vm_virtio_net_split_ring_test_with_dsa_dpdk_driver_and_iperf_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 4: VM2VM virtio-net split ring test with DSA dpdk driver and iperf stable check\n+ \"\"\"\n+ perf_result = []\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ ports = dsas\n+ ports.append(self.dut.ports_info[0][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=2\"}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports, port_options=port_options\n+ )\n+ dmas = \"txd0@%s-q0,rxd0@%s-q1,txd1@%s-q0,rxd1@%s-q1\" % (\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ )\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ before_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"true\", \"false\"],\n+ mrg_rxbuf=False,\n+ need_start_vm=True,\n+ packed=False,\n+ server_mode=True,\n+ )\n+ perf_result.append([\"split ring\", \"Before relaunch test\", before_relaunch])\n+\n+ self.vhost_user.send_expect(\"^C\", \"# \", 20)\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ for _ in range(self.rerun_times):\n+ rerun_result = self.start_iperf_and_scp_test_in_vms(need_start_vm=False)\n+ perf_result.append([\"split ring\", \"Before relaunch test\", rerun_result])\n+\n+ self.vhost_user.send_expect(\"^C\", \"# \", 20)\n+ dmas = \"txd0@%s-q0,rxd1@%s-q1\" % (dsas[0], dsas[0])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ after_relaunch = self.start_iperf_and_scp_test_in_vms(need_start_vm=False)\n+\n+ perf_result.append([\"split ring\", \"After relaunch test\", after_relaunch])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ def test_vm2vm_virtio_net_packed_ring_test_with_dsa_dpdk_driver_and_iperf_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 5: VM2VM virtio-net packed ring test with DSA dpdk driver and iperf stable check\n+ \"\"\"\n+ perf_result = []\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ ports = dsas\n+ ports.append(self.dut.ports_info[0][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=2\"}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports, port_options=port_options\n+ )\n+ dmas = \"txd0@%s-q0,rxd0@%s-q1,txd1@%s-q0,rxd1@%s-q1\" % (\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ dsas[0],\n+ )\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ before_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"false\", \"false\"],\n+ mrg_rxbuf=False,\n+ need_start_vm=True,\n+ packed=True,\n+ server_mode=True,\n+ )\n+ perf_result.append([\"packed ring\", \"Before relaunch test\", before_relaunch])\n+\n+ for _ in range(self.rerun_times):\n+ rerun_result = self.start_iperf_and_scp_test_in_vms(need_start_vm=False)\n+ perf_result.append([\"packed ring\", \"Before relaunch test\", rerun_result])\n+\n+ self.stop_vms()\n+ after_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"false\", \"false\"],\n+ mrg_rxbuf=True,\n+ need_start_vm=True,\n+ packed=True,\n+ server_mode=True,\n+ )\n+\n+ perf_result.append([\"packed ring\", \"After relaunch test\", after_relaunch])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ def test_vm2vm_virtio_net_packed_ring_test_with_2_dsa_wq_with_dpdk_driver_and_iperf_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 6: VM2VM virtio-net packed ring test with 2 DSA WQ with dpdk driver and iperf stable check\n+ \"\"\"\n+ perf_result = []\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ ports = dsas\n+ ports.append(self.dut.ports_info[0][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=2\"}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports, port_options=port_options\n+ )\n+ dmas = \"txd0@%s-q0,rxd1@%s-q1\" % (dsas[0], dsas[0])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ before_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"false\", \"false\"],\n+ mrg_rxbuf=False,\n+ need_start_vm=True,\n+ packed=True,\n+ server_mode=True,\n+ )\n+ perf_result.append([\"packed ring\", \"Before relaunch test\", before_relaunch])\n+\n+ for _ in range(self.rerun_times):\n+ rerun_result = self.start_iperf_and_scp_test_in_vms(need_start_vm=False)\n+ perf_result.append([\"packed ring\", \"Before relaunch test\", rerun_result])\n+\n+ self.stop_vms()\n+ after_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"false\", \"false\"],\n+ mrg_rxbuf=True,\n+ need_start_vm=True,\n+ packed=True,\n+ server_mode=True,\n+ )\n+ perf_result.append([\"packed ring\", \"After relaunch test\", after_relaunch])\n+\n+ for _ in range(self.rerun_times):\n+ rerun_result = self.start_iperf_and_scp_test_in_vms(need_start_vm=False)\n+ perf_result.append([\"packed ring\", \"After relaunch test\", rerun_result])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ def test_vm2vm_virtio_user_forwarding_test_using_dsa_kernel_driver(self):\n+ \"\"\"\n+ Test Case 7: VM2VM virtio-user forwarding test when vhost async operation using DSA kernel driver\n+ \"\"\"\n+ perf_result = []\n+ wqs = self.DC.create_wq(wq_num=4, dsa_idxs=[0])\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports\n+ )\n+ dmas = \"txd0@%s,rxd0@%s,txd1@%s,rxd1@%s\" % (wqs[0], wqs[1], wqs[2], wqs[3])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+ virtio0_eal_param = \"--vdev=net_virtio_user0,mac=00:11:22:33:44:10,path=./vhost-net0,queues=1,server=1,mrg_rxbuf=1,in_order=0,packed_vq=1\"\n+ virtio0_param = \"--rxq=1 --txq=1 --txd=1024 --rxd=1024 --nb-cores=1\"\n+ self.start_virtio_testpmd_with_vhost_net0(\n+ eal_param=virtio0_eal_param, param=virtio0_param\n+ )\n+\n+ virtio1_eal_param = \"--vdev=net_virtio_user0,mac=00:11:22:33:44:11,path=./vhost-net1,queues=1,server=1,mrg_rxbuf=1,in_order=1,vectorized=1\"\n+ virtio1_param = \"--rxq=1 --txq=1 --txd=1024 --rxd=1024 --nb-cores=1\"\n+ self.start_virtio_testpmd_with_vhost_net1(\n+ eal_param=virtio1_eal_param, param=virtio1_param\n+ )\n+ before_relunch_result = self.vm2vm_check_with_two_dsa()\n+\n+ self.vhost_user.send_expect(\"^C\", \"# \", 20)\n+ dmas = \"txd0@wq0.0,rxd1@wq0.1\"\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+ self.virtio_user0_pmd.execute_cmd(\"stop\")\n+ after_relunch_result = self.vm2vm_check_with_two_dsa()\n+\n+ for key in before_relunch_result.keys():\n+ perf_result.append(\n+ [key, \"Before Re-launch vhost\", before_relunch_result[key]]\n+ )\n+ for key in after_relunch_result.keys():\n+ perf_result.append(\n+ [key, \"After Re-launch vhost \", after_relunch_result[key]]\n+ )\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ def test_vm2vm_virtio_pmd_split_ring_test_with_dsa_kernle_driver_register_and_unregister_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 8: VM2VM virtio-pmd split ring test with DSA kernel driver register/unregister stable check\n+ \"\"\"\n+ perf_result = []\n+ wqs = self.DC.create_wq(wq_num=4, dsa_idxs=[0])\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports\n+ )\n+ dmas = \"txd0@%s,rxd0@%s,txd1@%s,rxd1@%s\" % (wqs[0], wqs[1], wqs[2], wqs[3])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ before_rebind = self.start_vms_testpmd_and_test(\n+ moderns=[\"false\", \"true\"], mrg_rxbuf=True, need_start_vm=True, packed=False\n+ )\n+\n+ # repeat bind 50 time from virtio-pci to vfio-pci\n+ self.repeat_bind_driver(dut=self.vm_dut[0], repeat_times=50)\n+ self.repeat_bind_driver(dut=self.vm_dut[1], repeat_times=50)\n+\n+ self.vhost_user.send_expect(\"^C\", \"# \", 20)\n+ dmas = \"txd0@%s,rxd1@%s\" % (wqs[0], wqs[3])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ after_rebind = self.start_vms_testpmd_and_test(need_start_vm=False)\n+\n+ for key in before_rebind.keys():\n+ perf_result.append([key, \"Before rebind driver\", before_rebind[key]])\n+\n+ for key in after_rebind.keys():\n+ perf_result.append([key, \"After rebind driver\", after_rebind[key]])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ for i in perf_result:\n+ self.verify(i[2] > 0, \"%s Frame Size(Byte) is less than 0 Mpps\" % i[0])\n+\n+ def test_vm2vm_virtio_pmd_packed_ring_test_with_dsa_kernel_driver_register_and_unregister_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 9: VM2VM virtio-pmd packed ring test with DSA kernel driver register/unregister stable check\n+ \"\"\"\n+ perf_result = []\n+ wqs = self.DC.create_wq(wq_num=2, dsa_idxs=[0, 1])\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports\n+ )\n+ dmas = \"txd0@%s,rxd0@%s,txd1@%s,rxd1@%s\" % (wqs[0], wqs[1], wqs[2], wqs[3])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ before_rebind = self.start_vms_testpmd_and_test(\n+ moderns=[\"false\", \"false\"], mrg_rxbuf=True, need_start_vm=True, packed=True\n+ )\n+\n+ # repeat bind 50 time from virtio-pci to vfio-pci\n+ self.repeat_bind_driver(dut=self.vm_dut[0], repeat_times=50)\n+ self.repeat_bind_driver(dut=self.vm_dut[1], repeat_times=50)\n+\n+ after_rebind = self.start_vms_testpmd_and_test(need_start_vm=False)\n+\n+ for key in before_rebind.keys():\n+ perf_result.append([key, \"Before rebind driver\", before_rebind[key]])\n+\n+ for key in after_rebind.keys():\n+ perf_result.append([key, \"After rebind driver\", after_rebind[key]])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ for i in perf_result:\n+ self.verify(i[2] > 0, \"%s Frame Size(Byte) is less than 0 Mpps\" % i[0])\n+\n+ def test_vm2vm_virtio_net_split_ring_test_with_dsa_kernel_driver_and_iperf_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 10: VM2VM virtio-net split ring test with DSA kernel driver and iperf stable check\n+ \"\"\"\n+ perf_result = []\n+ wqs = self.DC.create_wq(wq_num=2, dsa_idxs=[0, 1])\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports\n+ )\n+ dmas = \"txd0@%s,rxd0@%s,txd1@%s,rxd1@%s\" % (wqs[0], wqs[1], wqs[2], wqs[3])\n+ self.launch_vhost_app(\n+ eal_params=eal_params,\n+ vdev_num=2,\n+ dmas=dmas,\n+ mergeable=False,\n+ tso=True,\n+ client_mode=True,\n+ )\n+\n+ before_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"true\", \"false\"],\n+ mrg_rxbuf=False,\n+ need_start_vm=True,\n+ packed=False,\n+ server_mode=True,\n+ )\n+ perf_result.append([\"split ring\", \"Before relaunch test\", before_relaunch])\n+\n+ self.vhost_user.send_expect(\"^C\", \"# \", 20)\n+ self.launch_vhost_app(\n+ eal_params=eal_params,\n+ vdev_num=2,\n+ dmas=dmas,\n+ mergeable=False,\n+ tso=True,\n+ client_mode=True,\n+ )\n+\n+ for _ in range(self.rerun_times):\n+ rerun_result = self.start_iperf_and_scp_test_in_vms(need_start_vm=False)\n+ perf_result.append([\"split ring\", \"Before relaunch test\", rerun_result])\n+\n+ self.vhost_user.send_expect(\"^C\", \"# \", 20)\n+ dmas = \"txd0@%s,rxd1@%s\" % (wqs[0], wqs[1])\n+ self.launch_vhost_app(\n+ eal_params=eal_params,\n+ vdev_num=2,\n+ dmas=dmas,\n+ mergeable=False,\n+ tso=True,\n+ client_mode=True,\n+ )\n+\n+ after_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"true\", \"false\"],\n+ mrg_rxbuf=False,\n+ need_start_vm=False,\n+ packed=False,\n+ server_mode=True,\n+ )\n+\n+ perf_result.append([\"split ring\", \"After relaunch test\", after_relaunch])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ def test_vm2vm_virtio_net_packed_ring_test_with_dsa_kernel_driver_and_iperf_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 11: VM2VM virtio-net packed ring test with DSA kenrel driver and iperf stable check\n+ \"\"\"\n+ perf_result = []\n+ wqs = self.DC.create_wq(wq_num=2, dsa_index=[0, 1])\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports\n+ )\n+ dmas = \"txd0@%s,rxd0@%s,txd1@%s,rxd1@%s\" % (wqs[0], wqs[1], wqs[2], wqs[3])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, tso=True, client_mode=True\n+ )\n+\n+ before_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"false\", \"false\"],\n+ mrg_rxbuf=False,\n+ need_start_vm=True,\n+ packed=True,\n+ server_mode=True,\n+ )\n+ perf_result.append([\"packed ring\", \"Before relaunch test\", before_relaunch])\n+\n+ for _ in range(self.rerun_times):\n+ rerun_result = self.start_iperf_and_scp_test_in_vms(need_start_vm=False)\n+ perf_result.append([\"packed ring\", \"Before relaunch test\", rerun_result])\n+\n+ self.stop_vms()\n+ after_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"false\", \"false\"],\n+ mrg_rxbuf=True,\n+ need_start_vm=True,\n+ packed=True,\n+ server_mode=True,\n+ )\n+\n+ perf_result.append([\"packed ring\", \"After relaunch test\", after_relaunch])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ def test_vm2vm_virtio_net_packed_ring_test_with_2_dsa_wq_with_kernel_driver_and_iperf_stable_check(\n+ self,\n+ ):\n+ \"\"\"\n+ Test Case 12: VM2VM virtio-net packed ring test with 2 DSA WQ with kernel driver and iperf stable check\n+ \"\"\"\n+ perf_result = []\n+ wqs = self.DC.create_wq(wq_num=2, dsa_idxs=[0])\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.vhost_core_list, ports=ports\n+ )\n+ dmas = \"txd0@%s,rxd1@%s\" % (wqs[0], wqs[1])\n+ self.launch_vhost_app(\n+ eal_params=eal_params, vdev_num=2, dmas=dmas, client_mode=True\n+ )\n+\n+ before_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"false\", \"false\"],\n+ mrg_rxbuf=False,\n+ need_start_vm=True,\n+ packed=True,\n+ server_mode=True,\n+ )\n+ perf_result.append([\"packed ring\", \"Before relaunch test\", before_relaunch])\n+\n+ for _ in range(self.rerun_times):\n+ rerun_result = self.start_iperf_and_scp_test_in_vms(need_start_vm=False)\n+ perf_result.append([\"packed ring\", \"Before relaunch test\", rerun_result])\n+\n+ self.stop_vms()\n+ after_relaunch = self.start_iperf_and_scp_test_in_vms(\n+ moderns=[\"false\", \"false\"],\n+ mrg_rxbuf=True,\n+ need_start_vm=True,\n+ packed=True,\n+ server_mode=True,\n+ )\n+ perf_result.append([\"packed ring\", \"After relaunch test\", after_relaunch])\n+\n+ for _ in range(self.rerun_times):\n+ rerun_result = self.start_iperf_and_scp_test_in_vms(need_start_vm=False)\n+ perf_result.append([\"packed ring\", \"After relaunch test\", rerun_result])\n+\n+ for table_row in perf_result:\n+ self.result_table_add(table_row)\n+ self.result_table_print()\n+\n+ def stop_vms(self):\n+ for i in range(len(self.vm)):\n+ self.vm[i].stop()\n+ self.vm_dut = []\n+ self.vm = []\n+\n+ def close_all_session(self):\n+ if getattr(self, \"vhost_user\", None):\n+ self.dut.close_session(self.vhost_user)\n+ if getattr(self, \"virtio-user0\", None):\n+ self.dut.close_session(self.virtio_user0)\n+ if getattr(self, \"virtio-user1\", None):\n+ self.dut.close_session(self.virtio_user1)\n+\n+ def tear_down(self):\n+ \"\"\"\n+ Run after each test case.\n+ \"\"\"\n+ self.stop_vms()\n+ self.vhost_user.send_expect(\"^C\", \"# \", 20)\n+ self.dut.kill_all()\n+\n+ def tear_down_all(self):\n+ \"\"\"\n+ Run after each test suite.\n+ \"\"\"\n+ self.close_all_session()\n", "prefixes": [ "V2", "3/3" ] }