Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/109176/?format=api
{ "id": 109176, "url": "http://patches.dpdk.org/api/patches/109176/?format=api", "web_url": "http://patches.dpdk.org/project/dts/patch/20220406082153.25440-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": "<20220406082153.25440-1-weix.ling@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20220406082153.25440-1-weix.ling@intel.com", "date": "2022-04-06T08:21:53", "name": "[V1,4/5] tests/vm2vm_virtio_net_perf_cbdma: add DPDK22.03 new feature", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": false, "hash": "f478d9f7ceb1212bcdef2ce9f7f6dfc40fab6183", "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/20220406082153.25440-1-weix.ling@intel.com/mbox/", "series": [ { "id": 22361, "url": "http://patches.dpdk.org/api/series/22361/?format=api", "web_url": "http://patches.dpdk.org/project/dts/list/?series=22361", "date": "2022-04-06T08:20:59", "name": "migrate cbdma case in new testsuite", "version": 1, "mbox": "http://patches.dpdk.org/series/22361/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/109176/comments/", "check": "pending", "checks": "http://patches.dpdk.org/api/patches/109176/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 5E182A0509;\n\tWed, 6 Apr 2022 10:22:07 +0200 (CEST)", "from [217.70.189.124] (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 58F4F40DF6;\n\tWed, 6 Apr 2022 10:22:07 +0200 (CEST)", "from mga11.intel.com (mga11.intel.com [192.55.52.93])\n by mails.dpdk.org (Postfix) with ESMTP id 7933240689\n for <dts@dpdk.org>; Wed, 6 Apr 2022 10:22:04 +0200 (CEST)", "from fmsmga001.fm.intel.com ([10.253.24.23])\n by fmsmga102.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 06 Apr 2022 01:22:03 -0700", "from unknown (HELO localhost.localdomain) ([10.239.251.222])\n by fmsmga001-auth.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 06 Apr 2022 01:22:01 -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=1649233324; x=1680769324;\n h=from:to:cc:subject:date:message-id:mime-version:\n content-transfer-encoding;\n bh=QxBv3hdQxRmGBrjS5AdHWuyh5M1YGss5wyYK+eVQ6OQ=;\n b=GkIAmpd/ocoqYQ7F2bBu1T+2SdhAT/OcAx+o6Cbz20FCZdzhhQUxKRzi\n QZ/T2HXTEWvnA7iZmTRtMif+HtOU4+fTKtcfIUqoNSyJNrmZIWhcTf7Bd\n 0M7xsrHa16D3U91zbnbtTdCkQqCe6VgomLi3q7l9LPstq7p6v894iMTct\n Sg3HuR1c75xrd90Q+cgfdbD57Gy8myXwTys/+6VAX4aXOMRHfbREpACO1\n Kk9njPrRA9zkPHnXUcV5h1jvCOXLrOlJoP+loFuMrKcKoB39P9Ax/RbKx\n kZazw4uhtD9yMItT7pEpHSOzDNN3VQWC+JyiFK1eibiaRskaCg0b/rwIX g==;", "X-IronPort-AV": [ "E=McAfee;i=\"6200,9189,10308\"; a=\"258573132\"", "E=Sophos;i=\"5.90,239,1643702400\"; d=\"scan'208\";a=\"258573132\"", "E=Sophos;i=\"5.90,239,1643702400\"; d=\"scan'208\";a=\"697282982\"" ], "From": "Wei Ling <weix.ling@intel.com>", "To": "dts@dpdk.org", "Cc": "Wei Ling <weix.ling@intel.com>", "Subject": "[dts][PATCH V1 4/5] tests/vm2vm_virtio_net_perf_cbdma: add DPDK22.03\n new feature", "Date": "Wed, 6 Apr 2022 16:21:53 +0800", "Message-Id": "<20220406082153.25440-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": "As commit 53d3f4778c(vhost: integrate dmadev in asynchronous data-path),\nadd new tests/vm2vm_virtio_net_perf_cbdma.\n\nSigned-off-by: Wei Ling <weix.ling@intel.com>\n---\n .../TestSuite_vm2vm_virtio_net_perf_cbdma.py | 744 ++++++++++++++++++\n 1 file changed, 744 insertions(+)\n create mode 100644 tests/TestSuite_vm2vm_virtio_net_perf_cbdma.py", "diff": "diff --git a/tests/TestSuite_vm2vm_virtio_net_perf_cbdma.py b/tests/TestSuite_vm2vm_virtio_net_perf_cbdma.py\nnew file mode 100644\nindex 00000000..a5994005\n--- /dev/null\n+++ b/tests/TestSuite_vm2vm_virtio_net_perf_cbdma.py\n@@ -0,0 +1,744 @@\n+# BSD LICENSE\n+#\n+# Copyright(c) <2022> Intel Corporation.\n+# All rights reserved.\n+#\n+# Redistribution and use in source and binary forms, with or without\n+# modification, are permitted provided that the following conditions\n+# are met:\n+#\n+# * Redistributions of source code must retain the above copyright\n+# notice, this list of conditions and the following disclaimer.\n+# * Redistributions in binary form must reproduce the above copyright\n+# notice, this list of conditions and the following disclaimer in\n+# the documentation and/or other materials provided with the\n+# distribution.\n+# * Neither the name of Intel Corporation nor the names of its\n+# contributors may be used to endorse or promote products derived\n+# from this software without specific prior written permission.\n+#\n+# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS\n+# \"AS IS\" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT\n+# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR\n+# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT\n+# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,\n+# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT\n+# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,\n+# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY\n+# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT\n+# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE\n+# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.\n+\n+\"\"\"\n+DPDK Test suite.\n+\n+vm2vm split ring and packed ring with tx offload (TSO and UFO) with non-mergeable path.\n+vm2vm split ring and packed ring with UFO about virtio-net device capability with non-mergeable path.\n+vm2vm split ring and packed ring vhost-user/virtio-net check the payload of large packet is valid with\n+mergeable and non-mergeable dequeue zero copy.\n+please use qemu version greater 4.1.94 which support packed feathur to test this suite.\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+\n+class TestVM2VMVirtioNetPerfCbdma(TestCase):\n+ def set_up_all(self):\n+ self.dut_ports = self.dut.get_ports()\n+ self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])\n+ self.cores_list = self.dut.get_core_list(config=\"all\", socket=self.ports_socket)\n+ self.vhost_core_list = self.cores_list[0:9]\n+ self.vm_num = 2\n+ self.virtio_ip1 = \"1.1.1.1\"\n+ self.virtio_ip2 = \"1.1.1.2\"\n+ self.virtio_mac1 = \"52:54:00:00:00:01\"\n+ self.virtio_mac2 = \"52:54:00:00:00:02\"\n+ self.base_dir = self.dut.base_dir.replace('~', '/root')\n+ self.random_string = string.ascii_letters + string.digits\n+ socket_num = len(set([int(core['socket']) for core in self.dut.cores]))\n+ self.socket_mem = ','.join(['2048']*socket_num)\n+ self.vhost = self.dut.new_session(suite=\"vhost\")\n+ self.pmdout_vhost_user = PmdOutput(self.dut, self.vhost)\n+ self.app_testpmd_path = self.dut.apps_name['test-pmd']\n+\n+ def set_up(self):\n+ \"\"\"\n+ run before each test case.\n+ \"\"\"\n+ self.dut.send_expect(\"rm -rf %s/vhost-net*\" % self.base_dir, \"#\")\n+ self.vm_dut = []\n+ self.vm = []\n+\n+ def get_cbdma_ports_info_and_bind_to_dpdk(self, cbdma_num, allow_diff_socket=False):\n+ \"\"\"\n+ get and bind cbdma ports into DPDK driver\n+ \"\"\"\n+ self.all_cbdma_list = []\n+ self.cbdma_list = []\n+ self.cbdma_str = \"\"\n+ out = self.dut.send_expect('./usertools/dpdk-devbind.py --status-dev dma', '# ', 30)\n+ device_info = out.split('\\n')\n+ for device in device_info:\n+ pci_info = re.search('\\s*(0000:\\S*:\\d*.\\d*)', device)\n+ if pci_info is not None:\n+ dev_info = pci_info.group(1)\n+ # the numa id of ioat dev, only add the device which on same socket with nic dev\n+ bus = int(dev_info[5:7], base=16)\n+ if bus >= 128:\n+ cur_socket = 1\n+ else:\n+ cur_socket = 0\n+ if allow_diff_socket:\n+ self.all_cbdma_list.append(pci_info.group(1))\n+ else:\n+ if self.ports_socket == cur_socket:\n+ self.all_cbdma_list.append(pci_info.group(1))\n+ self.verify(len(self.all_cbdma_list) >= cbdma_num, 'There no enough cbdma device')\n+ self.cbdma_list = self.all_cbdma_list[0:cbdma_num]\n+ self.cbdma_str = ' '.join(self.cbdma_list)\n+ self.dut.send_expect('./usertools/dpdk-devbind.py --force --bind=%s %s' % (self.drivername, self.cbdma_str), '# ', 60)\n+\n+ @staticmethod\n+ def generate_dms_param(queues):\n+ das_list = []\n+ for i in range(queues):\n+ das_list.append(\"txq{}\".format(i))\n+ das_param = \"[{}]\".format(\";\".join(das_list))\n+ return das_param\n+\n+ @staticmethod\n+ def generate_lcore_dma_param(cbdma_list, core_list):\n+ group_num = int(len(cbdma_list) / len(core_list))\n+ lcore_dma_list = []\n+ if len(cbdma_list) == 1:\n+ for core in core_list:\n+ lcore_dma_list.append(\"lcore{}@{}\".format(core, cbdma_list[0]))\n+ elif len(core_list) == 1:\n+ for cbdma in cbdma_list:\n+ lcore_dma_list.append(\"lcore{}@{}\".format(core_list[0], cbdma))\n+ else:\n+ for cbdma in cbdma_list:\n+ core_list_index = int(cbdma_list.index(cbdma) / group_num)\n+ lcore_dma_list.append(\"lcore{}@{}\".format(core_list[core_list_index], cbdma))\n+ lcore_dma_param = \"[{}]\".format(\",\".join(lcore_dma_list))\n+ return lcore_dma_param\n+\n+ def bind_cbdma_device_to_kernel(self):\n+ self.dut.send_expect('modprobe ioatdma', '# ')\n+ self.dut.send_expect('./usertools/dpdk-devbind.py -u %s' % self.cbdma_str, '# ', 30)\n+ self.dut.send_expect('./usertools/dpdk-devbind.py --force --bind=ioatdma %s' % self.cbdma_str, '# ', 60)\n+\n+ @property\n+ def check_2M_env(self):\n+ out = self.dut.send_expect(\"cat /proc/meminfo |grep Hugepagesize|awk '{print($2)}'\", \"# \")\n+ return True if out == '2048' else False\n+\n+ def start_vhost_testpmd(self, cores, param=\"\", eal_param=\"\", ports = \"\", iova_mode=''):\n+ if iova_mode:\n+ eal_param += \" --iova=\" + iova_mode\n+ self.pmdout_vhost_user.start_testpmd(cores=cores, param=param, eal_param=eal_param, ports=ports, prefix=\"vhost\")\n+ self.pmdout_vhost_user.execute_cmd('start')\n+\n+ def start_vms(self, server_mode=False, vm_queue=1, vm_config='vhost_sample'):\n+ \"\"\"\n+ start two VM, each VM has one virtio device\n+ \"\"\"\n+ for i in range(self.vm_num):\n+ vm_dut = None\n+ vm_info = VM(self.dut, 'vm%d' % i, vm_config)\n+ vm_params = {}\n+ vm_params['driver'] = 'vhost-user'\n+ if not server_mode:\n+ vm_params['opt_path'] = self.base_dir + '/vhost-net%d' % i\n+ else:\n+ vm_params['opt_path'] = self.base_dir + '/vhost-net%d' % i + ',server'\n+ vm_params['opt_queue'] = vm_queue\n+ vm_params['opt_mac'] = \"52:54:00:00:00:0%d\" % (i+1)\n+ vm_params['opt_settings'] = self.vm_args\n+ vm_info.set_vm_device(**vm_params)\n+ try:\n+ vm_dut = vm_info.start(set_target=False)\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+ self.verify(vm_dut is not None, \"start vm failed\")\n+ self.vm_dut.append(vm_dut)\n+ self.vm.append(vm_info)\n+\n+ def config_vm_ip(self):\n+ \"\"\"\n+ set virtio device IP and run arp protocal\n+ \"\"\"\n+ vm1_intf = self.vm_dut[0].ports_info[0]['intf']\n+ vm2_intf = self.vm_dut[1].ports_info[0]['intf']\n+ self.vm_dut[0].send_expect(\"ifconfig %s %s\" % (vm1_intf, self.virtio_ip1), \"#\", 10)\n+ self.vm_dut[1].send_expect(\"ifconfig %s %s\" % (vm2_intf, self.virtio_ip2), \"#\", 10)\n+ self.vm_dut[0].send_expect(\"arp -s %s %s\" % (self.virtio_ip2, self.virtio_mac2), \"#\", 10)\n+ self.vm_dut[1].send_expect(\"arp -s %s %s\" % (self.virtio_ip1, self.virtio_mac1), \"#\", 10)\n+\n+ def config_vm_combined(self, combined=1):\n+ \"\"\"\n+ set virtio device combined\n+ \"\"\"\n+ vm1_intf = self.vm_dut[0].ports_info[0]['intf']\n+ vm2_intf = self.vm_dut[1].ports_info[0]['intf']\n+ self.vm_dut[0].send_expect(\"ethtool -L %s combined %d\" % (vm1_intf, combined), \"#\", 10)\n+ self.vm_dut[1].send_expect(\"ethtool -L %s combined %d\" % (vm2_intf, combined), \"#\", 10)\n+\n+ def check_ping_between_vms(self):\n+ ping_out = self.vm_dut[0].send_expect(\"ping {} -c 4\".format(self.virtio_ip2), \"#\" , 20)\n+ self.logger.info(ping_out)\n+\n+ def start_iperf(self):\n+ \"\"\"\n+ run perf command between to vms\n+ \"\"\"\n+ self.vhost.send_expect(\"clear port xstats all\", \"testpmd> \", 10)\n+\n+ server = \"iperf -s -i 1\"\n+ client = \"iperf -c {} -i 1 -t 60\".format(self.virtio_ip1)\n+ self.vm_dut[0].send_expect(\"{} > iperf_server.log &\".format(server), \"\", 10)\n+ self.vm_dut[1].send_expect(\"{} > iperf_client.log &\".format(client), \"\", 10)\n+ time.sleep(60)\n+\n+ def get_perf_result(self):\n+ \"\"\"\n+ get the iperf test result\n+ \"\"\"\n+ self.table_header = ['Mode', '[M|G]bits/sec']\n+ self.result_table_create(self.table_header)\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+\n+ # put the result to table\n+ results_row = [\"vm2vm\", iperfdata[-1]]\n+ self.result_table_add(results_row)\n+\n+ # print iperf resut\n+ self.result_table_print()\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+\n+ def verify_xstats_info_on_vhost(self):\n+ \"\"\"\n+ check both 2VMs can receive and send big packets to each other\n+ \"\"\"\n+ self.vhost.send_expect(\"show port stats all\", \"testpmd> \", 20)\n+ out_tx = self.vhost.send_expect(\"show port xstats 0\", \"testpmd> \", 20)\n+ out_rx = self.vhost.send_expect(\"show port xstats 1\", \"testpmd> \", 20)\n+\n+ tx_info = re.search(\"tx_size_1523_to_max_packets:\\s*(\\d*)\", out_tx)\n+ rx_info = re.search(\"rx_size_1523_to_max_packets:\\s*(\\d*)\", out_rx)\n+\n+ self.verify(int(rx_info.group(1)) > 0,\n+ \"Port 1 not receive packet greater than 1522\")\n+ self.verify(int(tx_info.group(1)) > 0,\n+ \"Port 0 not forward packet greater than 1522\")\n+\n+ def offload_capbility_check(self, vm_client):\n+ \"\"\"\n+ check UFO and TSO offload status on for the Virtio-net driver in VM\n+ \"\"\"\n+ vm_intf = vm_client.ports_info[0]['intf']\n+ vm_client.send_expect('ethtool -k %s > offload.log' % vm_intf, '#', 10)\n+ fmsg = vm_client.send_expect(\"cat ./offload.log\", \"#\")\n+ udp_info = re.search(\"udp-fragmentation-offload:\\s*(\\S*)\", fmsg)\n+ tcp_info = re.search(\"tx-tcp-segmentation:\\s*(\\S*)\", fmsg)\n+ tcp_enc_info = re.search(\"tx-tcp-ecn-segmentation:\\s*(\\S*)\", fmsg)\n+ tcp6_info = re.search(\"tx-tcp6-segmentation:\\s*(\\S*)\", fmsg)\n+\n+ self.verify(udp_info is not None and udp_info.group(1) == \"on\",\n+ \"the udp-fragmentation-offload in vm not right\")\n+ self.verify(tcp_info is not None and tcp_info.group(1) == \"on\",\n+ \"tx-tcp-segmentation in vm not right\")\n+ self.verify(tcp_enc_info is not None and tcp_enc_info.group(1) == \"on\",\n+ \"tx-tcp-ecn-segmentation in vm not right\")\n+ self.verify(tcp6_info is not None and tcp6_info.group(1) == \"on\",\n+ \"tx-tcp6-segmentation in vm not right\")\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 char 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('scp root@%s:/tmp/payload /root' % self.virtio_ip1, timeout=5)\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(md5_send == md5_revd, 'the received file is different with send file')\n+\n+ def test_vm2vm_split_ring_iperf_with_tso_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 1: VM2VM split ring vhost-user/virtio-net CBDMA enable test with tcp traffic\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(2)\n+ dmas = self.generate_dms_param(1)\n+ lcore_dma = self.generate_lcore_dma_param(cbdma_list=self.cbdma_list, core_list=self.vhost_core_list[1:3])\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=1,dmas={},dma_ring_size=2048'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,queues=1,dmas={},dma_ring_size=2048'\".format(dmas)\n+ param = \" --nb-cores=2 --txd=1024 --rxd=1024 --txq=1 --rxq=1\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode='va')\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=on,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on\"\n+ self.start_vms(server_mode=False, vm_queue=1)\n+ self.config_vm_ip()\n+ self.check_ping_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+ self.verify_xstats_info_on_vhost()\n+\n+ def test_vm2vm_split_ring_with_mergeable_path_8queue_check_large_packet_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 2: VM2VM split ring vhost-user/virtio-net mergeable 8 queues CBDMA enable test with large packet payload valid check\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(cbdma_num=16, allow_diff_socket=True)\n+ dmas = self.generate_dms_param(8)\n+ core1 = self.vhost_core_list[1]\n+ core2 = self.vhost_core_list[2]\n+ core3 = self.vhost_core_list[3]\n+ core4 = self.vhost_core_list[4]\n+ cbdma1 = self.cbdma_list[0]\n+ cbdma2 = self.cbdma_list[1]\n+ cbdma3 = self.cbdma_list[2]\n+ cbdma4 = self.cbdma_list[3]\n+ cbdma5 = self.cbdma_list[4]\n+ cbdma6 = self.cbdma_list[5]\n+ cbdma7 = self.cbdma_list[6]\n+ cbdma8 = self.cbdma_list[7]\n+ cbdma9 = self.cbdma_list[8]\n+ cbdma10 = self.cbdma_list[9]\n+ cbdma11 = self.cbdma_list[10]\n+ cbdma12 = self.cbdma_list[11]\n+ cbdma13 = self.cbdma_list[12]\n+ cbdma14 = self.cbdma_list[13]\n+ cbdma15 = self.cbdma_list[14]\n+ cbdma16 = self.cbdma_list[15]\n+ lcore_dma = f\"[lcore{core1}@{cbdma1},lcore{core1}@{cbdma2},lcore{core1}@{cbdma3},\" \\\n+ f\"lcore{core1}@{cbdma4},lcore{core1}@{cbdma5},lcore{core1}@{cbdma6},\" \\\n+ f\"lcore{core2}@{cbdma7},lcore{core2}@{cbdma8},\" \\\n+ f\"lcore{core3}@{cbdma9},lcore{core3}@{cbdma10},lcore{core3}@{cbdma11},lcore{core3}@{cbdma12},\" \\\n+ f\"lcore{core3}@{cbdma13},lcore{core3}@{cbdma14},lcore{core3}@{cbdma15},\" \\\n+ f\"lcore{core4}@{cbdma16}]\"\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=8,dmas={}'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=8,dmas={}'\".format(dmas)\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=8 --rxq=8\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode='va')\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=on,mq=on,vectors=40,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,guest_ufo=on,host_ufo=on\"\n+ self.start_vms(server_mode=True, vm_queue=8)\n+ self.config_vm_ip()\n+ self.config_vm_combined(combined=8)\n+ self.check_ping_between_vms()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ self.logger.info(\"Quit and relaunch vhost w/ diff CBDMA channels\")\n+ self.pmdout_vhost_user.execute_cmd(\"quit\", \"#\")\n+ lcore_dma = f\"[lcore{core1}@{cbdma1},lcore{core1}@{cbdma2},\" \\\n+ f\"lcore{core1}@{cbdma3},lcore{core1}@{cbdma4},\" \\\n+ f\"lcore{core2}@{cbdma1},lcore{core2}@{cbdma3},lcore{core2}@{cbdma5},\" \\\n+ f\"lcore{core2}@{cbdma6},lcore{core2}@{cbdma7},lcore{core2}@{cbdma8},\" \\\n+ f\"lcore{core3}@{cbdma2},lcore{core3}@{cbdma4},lcore{core3}@{cbdma9},\" \\\n+ f\"lcore{core3}@{cbdma10},lcore{core3}@{cbdma11},lcore{core3}@{cbdma12},\" \\\n+ f\"lcore{core3}@{cbdma13},lcore{core3}@{cbdma14},lcore{core3}@{cbdma15},\" \\\n+ f\"lcore{core4}@{cbdma16}]\"\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=8,dmas=[txq0;txq1;txq2;txq3;txq4;txq5;txq6]'\" + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=8,dmas=[txq1;txq2;txq3;txq4;txq5;txq6;txq7]'\"\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=8 --rxq=8\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode='va')\n+ self.check_ping_between_vms()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ if not self.check_2M_env:\n+ self.logger.info(\"Quit and relaunch vhost w/ iova=pa\")\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=8,dmas=[txq0;txq1;txq2;txq3;txq4;txq5;txq6]'\" + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=8,dmas=[txq0;txq1;txq2;txq3;txq4;txq5;txq6]'\"\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=8 --rxq=8\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.pmdout_vhost_user.execute_cmd(\"quit\", \"#\")\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode=\"pa\")\n+ self.check_ping_between_vms()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ self.logger.info(\"Quit and relaunch vhost w/o CBDMA channels\")\n+ self.pmdout_vhost_user.execute_cmd(\"quit\", \"#\")\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=4'\" + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=4'\"\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=4 --rxq=4\"\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param)\n+ self.config_vm_combined(combined=4)\n+ self.check_ping_between_vms()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ self.logger.info(\"Quit and relaunch vhost w/o CBDMA channels with 1 queue\")\n+ self.pmdout_vhost_user.execute_cmd(\"quit\", \"#\")\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=4'\" + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=4'\"\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --rxq=1 --txq=1\"\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param)\n+ self.config_vm_combined(combined=1)\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ def test_vm2vm_split_ring_with_non_mergeable_path_8queue_check_large_packet_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 3: VM2VM split ring vhost-user/virtio-net non-mergeable 8 queues CBDMA enable test with large packet payload valid check\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(cbdma_num=16, allow_diff_socket=True)\n+ dmas = self.generate_dms_param(8)\n+ core1 = self.vhost_core_list[1]\n+ core2 = self.vhost_core_list[2]\n+ core3 = self.vhost_core_list[3]\n+ core4 = self.vhost_core_list[4]\n+ cbdma1 = self.cbdma_list[0]\n+ cbdma2 = self.cbdma_list[1]\n+ cbdma3 = self.cbdma_list[2]\n+ cbdma4 = self.cbdma_list[3]\n+ cbdma5 = self.cbdma_list[4]\n+ cbdma6 = self.cbdma_list[5]\n+ cbdma7 = self.cbdma_list[6]\n+ cbdma8 = self.cbdma_list[7]\n+ cbdma9 = self.cbdma_list[8]\n+ cbdma10 = self.cbdma_list[9]\n+ cbdma11 = self.cbdma_list[10]\n+ cbdma12 = self.cbdma_list[11]\n+ cbdma13 = self.cbdma_list[12]\n+ cbdma14 = self.cbdma_list[13]\n+ cbdma15 = self.cbdma_list[14]\n+ cbdma16 = self.cbdma_list[15]\n+ lcore_dma = f\"[lcore{core1}@{cbdma1},lcore{core1}@{cbdma2},lcore{core1}@{cbdma3},\" \\\n+ f\"lcore{core1}@{cbdma4},lcore{core1}@{cbdma5},lcore{core1}@{cbdma6},\" \\\n+ f\"lcore{core2}@{cbdma7},lcore{core2}@{cbdma8},\" \\\n+ f\"lcore{core3}@{cbdma9},lcore{core3}@{cbdma10},lcore{core3}@{cbdma11},lcore{core3}@{cbdma12},\" \\\n+ f\"lcore{core3}@{cbdma13},lcore{core3}@{cbdma14},lcore{core3}@{cbdma15},\" \\\n+ f\"lcore{core4}@{cbdma16}]\"\n+\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=8,dmas={}'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=8,dmas={}'\".format(dmas)\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=8 --rxq=8\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode='va')\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=off,mq=on,vectors=40,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,guest_ufo=on,host_ufo=on\"\n+ self.start_vms(server_mode=True, vm_queue=8)\n+ self.config_vm_ip()\n+ self.config_vm_combined(combined=8)\n+ self.check_ping_between_vms()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ self.logger.info(\"Quit and relaunch vhost w/ diff CBDMA channels\")\n+ self.pmdout_vhost_user.execute_cmd(\"quit\", \"#\")\n+ lcore_dma = f\"[lcore{core1}@{cbdma1},lcore{core1}@{cbdma2},\" \\\n+ f\"lcore{core1}@{cbdma3},lcore{core1}@{cbdma4},\" \\\n+ f\"lcore{core2}@{cbdma1},lcore{core2}@{cbdma3},lcore{core2}@{cbdma5},\" \\\n+ f\"lcore{core2}@{cbdma6},lcore{core2}@{cbdma7},lcore{core2}@{cbdma8},\" \\\n+ f\"lcore{core3}@{cbdma2},lcore{core3}@{cbdma4},lcore{core3}@{cbdma9},\" \\\n+ f\"lcore{core3}@{cbdma10},lcore{core3}@{cbdma11},lcore{core3}@{cbdma12},\" \\\n+ f\"lcore{core3}@{cbdma13},lcore{core3}@{cbdma14},lcore{core3}@{cbdma15},\" \\\n+ f\"lcore{core4}@{cbdma16}]\"\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=8,dmas=[txq0;txq1;txq2;txq3;txq4;txq5;txq6]'\" + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=8,dmas=[txq1;txq2;txq3;txq4;txq5;txq6]'\"\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=8 --rxq=8\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode='va')\n+ self.check_scp_file_valid_between_vms()\n+ self.check_ping_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ self.logger.info(\"Quit and relaunch vhost w/o CBDMA channels\")\n+ self.pmdout_vhost_user.execute_cmd(\"quit\", \"#\")\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=8'\" + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=8'\"\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=8 --rxq=8\"\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode='va')\n+ self.config_vm_combined(combined=4)\n+ self.check_ping_between_vms()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ self.logger.info(\"Quit and relaunch vhost w/o CBDMA channels with 1 queue\")\n+ self.pmdout_vhost_user.execute_cmd(\"quit\", \"#\")\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=8'\" + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=8'\"\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=1 --rxq=1\"\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param)\n+ self.config_vm_combined(combined=1)\n+ self.check_ping_between_vms()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ def test_vm2vm_split_ring_with_mergeable_path_16queue_check_large_packet_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 4: VM2VM split ring vhost-user/virtio-net mergeable 16 queues CBDMA enable test with large packet payload valid check\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(cbdma_num=16, allow_diff_socket=True)\n+ dmas = self.generate_dms_param(16)\n+ lcore_dma = self.generate_lcore_dma_param(cbdma_list=self.cbdma_list, core_list=self.vhost_core_list[1:9])\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,client=1,queues=16,dmas={}'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,client=1,queues=16,dmas={}'\".format(dmas)\n+ param = \" --nb-cores=8 --txd=1024 --rxd=1024 --txq=16 --rxq=16\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode='va')\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=on,mq=on,vectors=40,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,guest_ufo=on,host_ufo=on\"\n+ self.start_vms(server_mode=True, vm_queue=16)\n+ self.config_vm_ip()\n+ self.config_vm_combined(combined=16)\n+ self.check_ping_between_vms()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ def test_vm2vm_packed_ring_iperf_with_tso_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 5: VM2VM packed ring vhost-user/virtio-net CBDMA enable test with tcp traffic\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(2)\n+ dmas = self.generate_dms_param(1)\n+ lcore_dma = self.generate_lcore_dma_param(cbdma_list=self.cbdma_list, core_list=self.vhost_core_list[1:3])\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=1,dmas={}'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,queues=1,dmas={}'\".format(dmas)\n+ param = \" --nb-cores=2 --txd=1024 --rxd=1024 --txq=1 --rxq=1\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode='va')\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=on,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,packed=on\"\n+ self.start_vms(server_mode=False, vm_queue=1)\n+ self.config_vm_ip()\n+ self.check_ping_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+ self.verify_xstats_info_on_vhost()\n+\n+ def test_vm2vm_packed_ring_with_mergeable_path_8queue_check_large_packet_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 6: VM2VM virtio-net packed ring mergeable 8 queues CBDMA enable test with large packet payload valid check\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(16, allow_diff_socket=True)\n+ dmas = self.generate_dms_param(7)\n+ core1 = self.vhost_core_list[1]\n+ core2 = self.vhost_core_list[2]\n+ core3 = self.vhost_core_list[3]\n+ core4 = self.vhost_core_list[4]\n+ cbdma1 = self.cbdma_list[0]\n+ cbdma2 = self.cbdma_list[1]\n+ cbdma3 = self.cbdma_list[2]\n+ cbdma4 = self.cbdma_list[3]\n+ cbdma5 = self.cbdma_list[4]\n+ cbdma6 = self.cbdma_list[5]\n+ cbdma7 = self.cbdma_list[6]\n+ cbdma8 = self.cbdma_list[7]\n+ cbdma9 = self.cbdma_list[8]\n+ cbdma10 = self.cbdma_list[9]\n+ cbdma11 = self.cbdma_list[10]\n+ cbdma12 = self.cbdma_list[11]\n+ cbdma13 = self.cbdma_list[12]\n+ cbdma14 = self.cbdma_list[13]\n+ cbdma15 = self.cbdma_list[14]\n+ cbdma16 = self.cbdma_list[15]\n+ lcore_dma = f\"[lcore{core1}@{cbdma1},lcore{core1}@{cbdma2},lcore{core1}@{cbdma3},lcore{core1}@{cbdma4},\" \\\n+ f\"lcore{core2}@{cbdma1},lcore{core2}@{cbdma3},lcore{core2}@{cbdma5},lcore{core2}@{cbdma6},lcore{core2}@{cbdma7},lcore{core2}@{cbdma8},\" \\\n+ f\"lcore{core3}@{cbdma2},lcore{core3}@{cbdma4},lcore{core3}@{cbdma9},lcore{core3}@{cbdma10},lcore{core3}@{cbdma11},lcore{core3}@{cbdma12},lcore{core3}@{cbdma13},lcore{core3}@{cbdma14},lcore{core3}@{cbdma15},\" \\\n+ f\"lcore{core4}@{cbdma16}]\"\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas={}'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,queues=8,dmas={}'\".format(dmas)\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=8 --rxq=8\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param, iova_mode='va')\n+ # self.vm_args = \"disable-modern=false,mrg_rxbuf=on,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,packed=on\"\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=on,mq=on,vectors=40,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,guest_ufo=on,host_ufo=on,packed=on\"\n+ self.start_vms(server_mode=False, vm_queue=8)\n+ self.config_vm_ip()\n+ self.check_ping_between_vms()\n+ self.config_vm_combined(combined=8)\n+ for _ in range(6):\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ def test_vm2vm_packed_ring_with_non_mergeable_path_8queue_check_large_packet_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 7: VM2VM virtio-net packed ring non-mergeable 8 queues CBDMA enable test with large packet payload valid check\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(16, allow_diff_socket=True)\n+ dmas = self.generate_dms_param(8)\n+ core1 = self.vhost_core_list[1]\n+ core2 = self.vhost_core_list[2]\n+ core3 = self.vhost_core_list[3]\n+ core4 = self.vhost_core_list[4]\n+ cbdma1 = self.cbdma_list[0]\n+ cbdma2 = self.cbdma_list[1]\n+ cbdma3 = self.cbdma_list[2]\n+ cbdma4 = self.cbdma_list[3]\n+ cbdma5 = self.cbdma_list[4]\n+ cbdma6 = self.cbdma_list[5]\n+ cbdma7 = self.cbdma_list[6]\n+ cbdma8 = self.cbdma_list[7]\n+ cbdma9 = self.cbdma_list[8]\n+ cbdma10 = self.cbdma_list[9]\n+ cbdma11 = self.cbdma_list[10]\n+ cbdma12 = self.cbdma_list[11]\n+ cbdma13 = self.cbdma_list[12]\n+ cbdma14 = self.cbdma_list[13]\n+ cbdma15 = self.cbdma_list[14]\n+ cbdma16 = self.cbdma_list[15]\n+ lcore_dma = f\"[lcore{core1}@{cbdma1},lcore{core1}@{cbdma2},lcore{core1}@{cbdma3},\" \\\n+ f\"lcore{core1}@{cbdma4},lcore{core1}@{cbdma5},lcore{core1}@{cbdma6},\" \\\n+ f\"lcore{core2}@{cbdma7},lcore{core2}@{cbdma8},\" \\\n+ f\"lcore{core3}@{cbdma9},lcore{core3}@{cbdma10},lcore{core3}@{cbdma11},lcore{core3}@{cbdma12},\" \\\n+ f\"lcore{core3}@{cbdma13},lcore{core3}@{cbdma14},lcore{core3}@{cbdma15},\" \\\n+ f\"lcore{core4}@{cbdma16}]\"\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas={}'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,queues=8,dmas={}'\".format(dmas)\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=8 --rxq=8\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param,\n+ iova_mode='va')\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=off,mq=on,vectors=40,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,guest_ufo=on,host_ufo=on,packed=on\"\n+ self.start_vms(server_mode=False, vm_queue=8)\n+ self.config_vm_ip()\n+ self.config_vm_combined(combined=8)\n+ self.check_ping_between_vms()\n+ for _ in range(6):\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ def test_vm2vm_packed_ring_with_mergeable_path_16queue_check_large_packet_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 8: VM2VM virtio-net packed ring mergeable 16 queues CBDMA enabled test with large packet payload valid check\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(16, allow_diff_socket=True)\n+ dmas = self.generate_dms_param(16)\n+ lcore_dma = self.generate_lcore_dma_param(cbdma_list=self.cbdma_list, core_list=self.vhost_core_list[1:9])\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=16,dmas={}'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,queues=16,dmas={}'\".format(dmas)\n+ param = \" --nb-cores=8 --txd=1024 --rxd=1024 --txq=16 --rxq=16\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param,\n+ iova_mode='va')\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=on,mq=on,vectors=40,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,guest_ufo=on,host_ufo=on,packed=on\"\n+ self.start_vms(server_mode=False, vm_queue=16)\n+ self.config_vm_ip()\n+ self.config_vm_combined(combined=16)\n+ self.check_ping_between_vms()\n+ for _ in range(6):\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ def test_vm2vm_packed_ring_iperf_with_tso_when_set_ivoa_pa_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 9: VM2VM packed ring vhost-user/virtio-net CBDMA enable test with tcp traffic when set iova=pa\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(2)\n+ dmas = self.generate_dms_param(1)\n+ lcore_dma = self.generate_lcore_dma_param(cbdma_list=self.cbdma_list, core_list=self.vhost_core_list[1:3])\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=1,dmas={}'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,queues=1,dmas={}'\".format(dmas)\n+ param = \" --nb-cores=2 --txd=1024 --rxd=1024 --txq=1 --rxq=1\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param,\n+ iova_mode='pa')\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=on,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,packed=on\"\n+ self.start_vms(server_mode=False, vm_queue=1)\n+ self.config_vm_ip()\n+ self.check_ping_between_vms()\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+ self.verify_xstats_info_on_vhost()\n+\n+ def test_vm2vm_packed_ring_with_mergeable_path_8queue_check_large_packet_when_set_ivoa_pa_and_cbdma_enable(self):\n+ \"\"\"\n+ Test Case 10: VM2VM virtio-net packed ring mergeable 8 queues CBDMA enable and PA mode test with large packet payload valid check\n+ \"\"\"\n+ self.get_cbdma_ports_info_and_bind_to_dpdk(cbdma_num=16, allow_diff_socket=True)\n+ dmas = self.generate_dms_param(7)\n+ core1 = self.vhost_core_list[1]\n+ core2 = self.vhost_core_list[2]\n+ core3 = self.vhost_core_list[3]\n+ core4 = self.vhost_core_list[4]\n+ cbdma1 = self.cbdma_list[0]\n+ cbdma2 = self.cbdma_list[1]\n+ cbdma3 = self.cbdma_list[2]\n+ cbdma4 = self.cbdma_list[3]\n+ cbdma5 = self.cbdma_list[4]\n+ cbdma6 = self.cbdma_list[5]\n+ cbdma7 = self.cbdma_list[6]\n+ cbdma8 = self.cbdma_list[7]\n+ cbdma9 = self.cbdma_list[8]\n+ cbdma10 = self.cbdma_list[9]\n+ cbdma11 = self.cbdma_list[10]\n+ cbdma12 = self.cbdma_list[11]\n+ cbdma13 = self.cbdma_list[12]\n+ cbdma14 = self.cbdma_list[13]\n+ cbdma15 = self.cbdma_list[14]\n+ cbdma16 = self.cbdma_list[15]\n+ lcore_dma = f\"[lcore{core1}@{cbdma1},lcore{core1}@{cbdma2},lcore{core1}@{cbdma3},\" \\\n+ f\"lcore{core1}@{cbdma4},lcore{core1}@{cbdma5},lcore{core1}@{cbdma6},\" \\\n+ f\"lcore{core2}@{cbdma7},lcore{core2}@{cbdma8},\" \\\n+ f\"lcore{core3}@{cbdma9},lcore{core3}@{cbdma10},lcore{core3}@{cbdma11},lcore{core3}@{cbdma12},\" \\\n+ f\"lcore{core3}@{cbdma13},lcore{core3}@{cbdma14},lcore{core3}@{cbdma15},\" \\\n+ f\"lcore{core4}@{cbdma16}]\"\n+ eal_param = \"--vdev 'net_vhost0,iface=vhost-net0,queues=8,dmas={}'\".format(dmas) + \\\n+ \" --vdev 'net_vhost1,iface=vhost-net1,queues=8,dmas={}'\".format(dmas)\n+ param = \" --nb-cores=4 --txd=1024 --rxd=1024 --txq=8 --rxq=8\" + \" --lcore-dma={}\".format(lcore_dma)\n+ self.start_vhost_testpmd(cores=self.vhost_core_list, ports=self.cbdma_list, eal_param=eal_param, param=param,\n+ iova_mode='pa')\n+ self.vm_args = \"disable-modern=false,mrg_rxbuf=on,mq=on,vectors=40,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on,guest_ufo=on,host_ufo=on,packed=on\"\n+ self.start_vms(server_mode=False, vm_queue=8)\n+ self.config_vm_ip()\n+ self.check_ping_between_vms()\n+ for _ in range(1):\n+ self.check_scp_file_valid_between_vms()\n+ self.start_iperf()\n+ self.get_perf_result()\n+\n+ def stop_all_apps(self):\n+ for i in range(len(self.vm)):\n+ self.vm[i].stop()\n+ self.pmdout_vhost_user.quit()\n+\n+ def tear_down(self):\n+ \"\"\"\n+ run after each test case.\n+ \"\"\"\n+ self.stop_all_apps()\n+ self.dut.kill_all()\n+ self.bind_cbdma_device_to_kernel()\n+\n+ def tear_down_all(self):\n+ \"\"\"\n+ Run after each test suite.\n+ \"\"\"\n+ self.dut.close_session(self.vhost)\n", "prefixes": [ "V1", "4/5" ] }