From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id A0015A034D; Thu, 10 Feb 2022 08:37:17 +0100 (CET) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 56DA941169; Thu, 10 Feb 2022 08:37:17 +0100 (CET) Received: from mga11.intel.com (mga11.intel.com [192.55.52.93]) by mails.dpdk.org (Postfix) with ESMTP id 67ABD40041 for ; Thu, 10 Feb 2022 07:13:19 +0100 (CET) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=intel.com; i=@intel.com; q=dns/txt; s=Intel; t=1644473599; x=1676009599; h=from:to:cc:subject:date:message-id:in-reply-to: references:mime-version:content-transfer-encoding; bh=xvnNyx0HoZrmF5U/jPilV3vpWmT078QQrEGh3bStFcM=; b=UUz/7qTTmhnA3cSjlurSi04OqrUmiIGh9JNjDqgezFxvLSnqPJlYIA0P Bdlc4zoAfuyRkOZqZjXezY6LxPAiMsFGoi3E9q9Gik8J56sNpYiVYVxP7 evnGWU+zMAxrclfHaPj2c24cOxC0st/wBV08/ra6P7oIxQmTggxnObNq+ 47frlJmC8S086Ya8iwoehtUlPm7NCSM9Cq/ZlRYQUg9DTVxr5vUV3itaa 9rA0MebGXmMEI9ygdAe4suQY6b5AZTn5A2vxqRR8NLuuTDcpJ+1m8yocp g+glnjGeUKF5aXUIMAWRuI3mVnIfVhpVFg0bkFXM4dLQM3d7nWcCJzBdv w==; X-IronPort-AV: E=McAfee;i="6200,9189,10253"; a="247003004" X-IronPort-AV: E=Sophos;i="5.88,357,1635231600"; d="scan'208";a="247003004" Received: from orsmga008.jf.intel.com ([10.7.209.65]) by fmsmga102.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 09 Feb 2022 22:13:18 -0800 X-IronPort-AV: E=Sophos;i="5.88,357,1635231600"; d="scan'208";a="541473688" Received: from unknown (HELO localhost.localdomain) ([10.239.251.222]) by orsmga008-auth.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 09 Feb 2022 22:13:16 -0800 From: Lingli Chen To: dts@dpdk.org Cc: xingguang.he@intel.com, Lingli Chen Subject: [dts][PATCH V1 2/2] tests/vm2vm_virtio_user: Modify case sync with testplan Date: Thu, 10 Feb 2022 14:13:09 +0800 Message-Id: <20220210061309.3928461-2-linglix.chen@intel.com> X-Mailer: git-send-email 2.25.1 In-Reply-To: <20220210061309.3928461-1-linglix.chen@intel.com> References: <20220210061309.3928461-1-linglix.chen@intel.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-Mailman-Approved-At: Thu, 10 Feb 2022 08:37:16 +0100 X-BeenThere: dts@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: test suite reviews and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dts-bounces@dpdk.org 1.To cover all paths, four cases related to split ring (test cases 14, 15, 16, 17) and four cases related to packed ring (test cases 20, 21, 22, 23) are added. 2.Cbdma related cases(case 12, 13, 18, 19), the iova = PA step is added. 3.Case 24: to test the indirect feature when choose packed vectorized-tx path, and we have no relevant cases before. Signed-off-by: Lingli Chen --- tests/TestSuite_vm2vm_virtio_user.py | 635 ++++++++++++++++++++++----- 1 file changed, 518 insertions(+), 117 deletions(-) diff --git a/tests/TestSuite_vm2vm_virtio_user.py b/tests/TestSuite_vm2vm_virtio_user.py index 2b66af77..437471ac 100644 --- a/tests/TestSuite_vm2vm_virtio_user.py +++ b/tests/TestSuite_vm2vm_virtio_user.py @@ -72,6 +72,7 @@ class TestVM2VMVirtioUser(TestCase): self.virtio_user0_pmd = PmdOutput(self.dut, self.virtio_user0) self.virtio_user1_pmd = PmdOutput(self.dut, self.virtio_user1) self.dut.restore_interfaces() + self.dump_port = 'device_id=net_virtio_user1' def set_up(self): """ @@ -107,6 +108,15 @@ class TestVM2VMVirtioUser(TestCase): no_pci=no_pci, ports=[],prefix=self.vhost_prefix, fixed_prefix=fixed_prefix) self.vhost_user_pmd.execute_cmd('set fwd %s' % fwd_mode) + def lanuch_vhost_testpmd_with_cbdma(self, vdevs=None, iova='va'): + """ + start testpmd with cbdma + """ + eal_params = vdevs + " --iova={}".format(iova) + param = "--nb-cores=1 --rxq={} --txq={} --txd={} --rxd={} --no-flush-rx".format(self.queue_num, self.queue_num, self.txd_num, self.txd_num) + self.vhost_user_pmd.start_testpmd(cores=self.core_list_vhost, param=param, no_pci=False, ports=[], eal_param=eal_params, prefix='vhost', fixed_prefix=True) + self.vhost_user_pmd.execute_cmd('vhost enable tx all') + @property def check_2M_env(self): out = self.dut.send_expect("cat /proc/meminfo |grep Hugepagesize|awk '{print($2)}'", "# ") @@ -151,27 +161,28 @@ class TestVM2VMVirtioUser(TestCase): def start_virtio_testpmd_with_vhost_net0_cbdma(self, path_mode, extern_params, ringsize): """ launch the testpmd as virtio with vhost_net0 - and start to send 251 small packets with diff burst """ eal_params = ' --socket-mem {} --vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues={},' \ '{},queue_size={} '.format(self.socket_mem, self.queue_num, path_mode, ringsize) if self.check_2M_env: eal_params += " --single-file-segments " + if 'vectorized_path' in self.running_case: + eal_params += " --force-max-simd-bitwidth=512" params = "--nb-cores=1 --txd={} --rxd={} {}".format(ringsize, ringsize, extern_params) self.virtio_user0_pmd.start_testpmd(cores=self.core_list_virtio0, param=params, eal_param=eal_params, \ no_pci=True, ports=[],prefix=self.virtio_prefix_0, fixed_prefix=True) - def check_packet_payload_valid_with_cbdma(self, filename, total_pkts_num, large_4640_pkts_num, large_64_pkts_num): + def check_packet_payload_valid_with_cbdma(self, filename, total_pkts_num, pkts_64_num=0, pkts_960_num=0, pkts_4640_num=0, pkts_8k_num=0): """ check the payload is valid """ # stop pdump actual_4640_pkt_num = 0 actual_64_pkt_num = 0 + actual_960_pkt_num = 0 + actual_8k_pkt_num =0 time.sleep(20) self.pdump_user.send_expect('^c', '# ', 60) - # quit testpmd - self.quit_all_testpmd() time.sleep(2) self.dut.session.copy_file_from(src="%s" % filename, dst="%s" % filename) pkt = Packet() @@ -182,22 +193,29 @@ class TestVM2VMVirtioUser(TestCase): for i in range(len(pkts)): if len(pkts[i]) == 4640: actual_4640_pkt_num += 1 + elif len(pkts[i]) == 960: + actual_960_pkt_num += 1 elif len(pkts[i]) == 64: actual_64_pkt_num += 1 - self.verify(large_4640_pkts_num == actual_4640_pkt_num, f"4640byte packet quantity error,expected value:{large_4640_pkts_num}" + elif len(pkts[i]) == 8000: + actual_8k_pkt_num += 1 + + self.verify(pkts_4640_num == actual_4640_pkt_num, f"4640byte packet quantity error,expected value:{pkts_4640_num}" f", actual value : {actual_4640_pkt_num}") - self.verify(large_64_pkts_num == actual_64_pkt_num, f"64byte packet quantity error,expected value:{large_64_pkts_num}" - f", actual value : {actual_64_pkt_num}") - def get_dump_file_of_virtio_user_cbdma(self, path_mode, extern_param, ringsize, vdevs=None, no_pci=True, cbdma=False, pdump=True): - dump_port = 'device_id=net_virtio_user1' - self.launch_vhost_testpmd(vdev_num=2, vdevs=vdevs, no_pci=no_pci) - if cbdma is True: - self.vhost_user_pmd.execute_cmd('vhost enable tx all') + self.verify(pkts_960_num == actual_960_pkt_num, f"960byte packet quantity error,expected value:{pkts_960_num}" + f", actual value : {actual_960_pkt_num}") + self.verify(pkts_64_num == actual_64_pkt_num, f"64byte packet quantity error,expected value:{pkts_64_num}" + f", actual value : {actual_64_pkt_num}") + + self.verify(pkts_8k_num == actual_8k_pkt_num, f"8k packet quantity error,expected value:{pkts_8k_num}" + f", actual value : {actual_8k_pkt_num}") + + def get_dump_file_of_virtio_user_cbdma(self, path_mode, extern_param, ringsize): + + self.lanuch_vhost_testpmd_with_cbdma(vdevs=self.vdevs) self.start_virtio_testpmd_with_vhost_net1(path_mode, extern_param, ringsize) - if pdump is True: - self.launch_pdump_to_capture_pkt(dump_port, self.virtio_prefix_1, self.dump_virtio_pcap) - # the virtio0 will send 251 small pkts + self.launch_pdump_to_capture_pkt(self.dump_port, self.virtio_prefix_1, self.dump_virtio_pcap) self.start_virtio_testpmd_with_vhost_net0_cbdma(path_mode, extern_param, ringsize) def send_32_2k_pkts_from_virtio0(self): @@ -209,47 +227,24 @@ class TestVM2VMVirtioUser(TestCase): self.virtio_user0_pmd.execute_cmd('set txpkts 2000') self.virtio_user0_pmd.execute_cmd('start tx_first 1') - def send_27_8k_and_224_2k_pkts(self): - self.virtio_user0_pmd.execute_cmd('set burst 1') - self.virtio_user0_pmd.execute_cmd('set txpkts 2000,2000,2000,2000') - self.virtio_user0_pmd.execute_cmd('start tx_first 27') - self.virtio_user0_pmd.execute_cmd('stop') - self.virtio_user0_pmd.execute_cmd('set burst 32') - self.virtio_user0_pmd.execute_cmd('set txpkts 2000') - self.virtio_user0_pmd.execute_cmd('start tx_first 7') - self.vhost_user_pmd.execute_cmd('start') - - def send_251_8k_pkts(self): + def send_251_64_and_32_8k_pkts(self): """ - send 251 8k length packets from virtio_user0 testpmd + send 251 small packets and 32 8K packets from virtio_user0 testpmd """ self.virtio_user0_pmd.execute_cmd('set burst 1') - self.virtio_user0_pmd.execute_cmd('set txpkts 2000,2000,2000,2000') - self.virtio_user0_pmd.execute_cmd('start tx_first 27') - self.virtio_user0_pmd.execute_cmd('stop') - self.virtio_user0_pmd.execute_cmd('set burst 32') - self.virtio_user0_pmd.execute_cmd('set txpkts 2000,2000,2000,2000') - self.virtio_user0_pmd.execute_cmd('start tx_first 7') - self.vhost_user_pmd.execute_cmd('start') - - def send_251_8k_and_32_2k_pkts(self): - """ - send 251 8k and 32 2k length packets from virtio_user0 testpmd - """ - self.virtio_user0_pmd.execute_cmd('set burst 1') - self.virtio_user0_pmd.execute_cmd('set txpkts 2000,2000,2000,2000') self.virtio_user0_pmd.execute_cmd('start tx_first 27') self.virtio_user0_pmd.execute_cmd('stop') self.virtio_user0_pmd.execute_cmd('set burst 32') self.virtio_user0_pmd.execute_cmd('start tx_first 7') self.virtio_user0_pmd.execute_cmd('stop') - self.virtio_user0_pmd.execute_cmd('set txpkts 2000') + self.virtio_user0_pmd.execute_cmd('set txpkts 2000,2000,2000,2000') self.virtio_user0_pmd.execute_cmd('start tx_first 1') - self.vhost_user_pmd.execute_cmd('start') + self.virtio_user0_pmd.execute_cmd('stop') def send_251_960byte_and_32_64byte_pkts(self): """ - send 251 960byte and 32 64byte length packets from virtio_user0 testpmd + imix small pkts + send 960byte and 64byte length packets from virtio_user0 testpmd """ self.virtio_user0_pmd.execute_cmd('set burst 1') self.virtio_user0_pmd.execute_cmd('set txpkts 64,128,256,512') @@ -260,7 +255,7 @@ class TestVM2VMVirtioUser(TestCase): self.virtio_user0_pmd.execute_cmd('stop') self.virtio_user0_pmd.execute_cmd('set txpkts 64') self.virtio_user0_pmd.execute_cmd('start tx_first 1') - self.vhost_user_pmd.execute_cmd('start') + self.virtio_user0_pmd.execute_cmd('stop') def send_27_4640byte_and_224_64byte_pkts(self): """ @@ -273,23 +268,20 @@ class TestVM2VMVirtioUser(TestCase): self.virtio_user0_pmd.execute_cmd('set burst 32') self.virtio_user0_pmd.execute_cmd('set txpkts 64') self.virtio_user0_pmd.execute_cmd('start tx_first 7') - self.vhost_user_pmd.execute_cmd('start') + self.virtio_user0_pmd.execute_cmd('stop') - def send_27_8k_and_256_2k_pkts(self): + def send_224_64byte_and_27_4640byte_pkts(self): """ - send 27 8k and 256 2k length packets from virtio_user0 testpmd + send 224 64byte and 27 4640byte length packets from virtio_user0 testpmd """ - self.virtio_user0_pmd.execute_cmd('set burst 1') - self.virtio_user0_pmd.execute_cmd('set txpkts 2000,2000,2000,2000') - self.virtio_user0_pmd.execute_cmd('start tx_first 27') - self.virtio_user0_pmd.execute_cmd('stop') self.virtio_user0_pmd.execute_cmd('set burst 32') - self.virtio_user0_pmd.execute_cmd('set txpkts 2000') + self.virtio_user0_pmd.execute_cmd('set txpkts 64') self.virtio_user0_pmd.execute_cmd('start tx_first 7') self.virtio_user0_pmd.execute_cmd('stop') - self.virtio_user0_pmd.execute_cmd('set txpkts 2000') - self.virtio_user0_pmd.execute_cmd('start tx_first 1') - self.vhost_user_pmd.execute_cmd('start') + self.virtio_user0_pmd.execute_cmd('set burst 1') + self.virtio_user0_pmd.execute_cmd('set txpkts 64,256,2000,64,256,2000') + self.virtio_user0_pmd.execute_cmd('start tx_first 27') + self.virtio_user0_pmd.execute_cmd('stop') def launch_pdump_to_capture_pkt(self, dump_port, file_prefix, filename): """ @@ -417,7 +409,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_packed_virtqueue_mergeable_path(self): """ - packed virtqueue vm2vm mergeable path test + Test Case 1: packed virtqueue vm2vm mergeable path test about packed virtqueue path, the 8k length pkt will occupies 1 ring since indirect feature enabled """ small_pkts_num = 251 @@ -445,10 +437,8 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_packed_virtqueue_inorder_mergeable_path(self): """ - packed virtqueue vm2vm inorder mergeable path test - about packed virtqueue path, the 8k length pkt will occupies 5 ring, - 2000,2000,2000,2000 will need 4 consequent ring, still need one ring put header - so, as the rxt=256, if received pkts include 8k chain pkt, it will received up to 252 pkts + Test Case 2: packed virtqueue vm2vm inorder mergeable path test + about packed inorder mergeable path, the 8k length pkt will occupies 1 ring since indirect feature enabled """ small_pkts_num = 251 large_8k_pkts_num = 5 @@ -457,7 +447,7 @@ class TestVM2VMVirtioUser(TestCase): ringsize = 256 extern_params = '' # get dump pcap file of virtio - # the virtio0 will send 283 pkts, but the virtio only will received 252 pkts + # the virtio0 will send 283 pkts, but the virtio only will received 256 pkts self.logger.info('check pcap file info about virtio') self.get_dump_file_of_virtio_user(path_mode, extern_params, ringsize) self.check_packet_payload_valid(self.dump_virtio_pcap, small_pkts_num, large_8k_pkts_num, large_2k_pkts_num) @@ -472,7 +462,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_packed_virtqueue_no_mergeable_path(self): """ - packed virtqueue vm2vm non-mergeable path test + Test Case 3: packed virtqueue vm2vm non-mergeable path test about non-mergeable path, it can not received large pkts """ small_pkts_num = 251 @@ -498,7 +488,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_packed_virtqueue_inorder_no_mergeable_path(self): """ - packed virtqueue vm2vm inorder non-mergeable path test + Test Case 4: packed virtqueue vm2vm inorder non-mergeable path test about non-mergeable path, it can not received large pkts """ small_pkts_num = 251 @@ -524,7 +514,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_packed_virtqueue_vectorized_path(self): """ - packed virtqueue vm2vm inorder non-mergeable path test + Test Case 10: packed virtqueue vm2vm inorder non-mergeable path test about non-mergeable path, it can not received large pkts """ small_pkts_num = 251 @@ -550,7 +540,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_packed_virtqueue_vectorized_path_ringsize_not_powerof_2(self): """ - packed virtqueue vm2vm inorder non-mergeable path test + Test Case 11: packed virtqueue vm2vm inorder non-mergeable path test about non-mergeable path, it can not received large pkts """ small_pkts_num = 251 @@ -576,7 +566,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_split_virtqueue_mergeable_path(self): """ - split virtqueue vm2vm mergeable path test + Test Case 5: split virtqueue vm2vm mergeable path test about split virtqueue path, the 8k length pkt will occupies 1 ring, so, as the rxt=256, if received pkts include 8k chain pkt, also will received up to 256 pkts """ @@ -605,7 +595,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_split_virtqueue_inorder_mergeable_path(self): """ - split virtqueue vm2vm inorder mergeable path test + Test Case 6: split virtqueue vm2vm inorder mergeable path test about split virtqueue path, the 8k length pkt will occupies 5 ring, 2000,2000,2000,2000 will need 4 consequent ring, still need one ring put header so, as the rxt=256, if received pkts include 8k chain pkt, it will received up to 252 pkts @@ -632,7 +622,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_split_virtqueue_no_mergeable_path(self): """ - split virtqueue vm2vm non-mergeable path test + Test Case 7: split virtqueue vm2vm non-mergeable path test about non-mergeable path, it can not received large pkts """ small_pkts_num = 251 @@ -657,7 +647,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_split_virtqueue_inorder_no_mergeable_path(self): """ - split virtqueue vm2vm inorder non-mergeable path test + Test Case 8: split virtqueue vm2vm inorder non-mergeable path test about non-mergeable path, it can not received large pkts """ small_pkts_num = 251 @@ -682,7 +672,7 @@ class TestVM2VMVirtioUser(TestCase): def test_vm2vm_virtio_user_split_virtqueue_vector_rx_path(self): """ - split virtqueue vm2vm vector_rx path test + Test Case 9: split virtqueue vm2vm vector_rx path test about vector_rx path, it can not received large pkts """ small_pkts_num = 251 @@ -734,36 +724,63 @@ class TestVM2VMVirtioUser(TestCase): self.dut.send_expect('./usertools/dpdk-devbind.py -u %s' % self.device_str, '# ', 30) self.dut.send_expect('./usertools/dpdk-devbind.py --force --bind=ioatdma %s' % self.device_str, '# ', 60) - def test_vm2vm_virtio_user_split_virtqueue_inorder_mergeable_path_with_cbdma(self): + def relanuch_vhost_testpmd_iova_pa(self): + + self.vhost_user_pmd.execute_cmd("quit", "#", 60) + self.lanuch_vhost_testpmd_with_cbdma(vdevs=self.vdevs, iova='pa') + self.launch_pdump_to_capture_pkt(self.dump_port, self.virtio_prefix_1, self.dump_virtio_pcap) + + def relanuch_vhost_iova_pa_and_virtio(self, path_mode, extern_param, ringsize): + + self.quit_all_testpmd() + self.lanuch_vhost_testpmd_with_cbdma(vdevs=self.vdevs, iova='pa') + self.start_virtio_testpmd_with_vhost_net1(path_mode, extern_param, ringsize) + self.launch_pdump_to_capture_pkt(self.dump_port, self.virtio_prefix_1, self.dump_virtio_pcap) + self.start_virtio_testpmd_with_vhost_net0_cbdma(path_mode, extern_param, ringsize) + + def test_vm2vm_virtio_user_split_virtqueue_non_mergeable_path_multi_queues_check_chain_pkts_with_cbdma(self): """ - Test Case 12: split virtqueue vm2vm inorder mergeable path multi-queues payload check with cbdma enabled + Test Case 12: split virtqueue vm2vm non-mergeable path multi-queues payload check with cbdma enabled """ self.cbdma_nic_dev_num = 4 self.get_cbdma_ports_info_and_bind_to_dpdk() - large_8k_pkts_num = 502 - large_2k_pkts_num = 64 - total_pkts_num = large_8k_pkts_num + large_2k_pkts_num - self.queue_num=2 - self.nopci=False + pkts_64_num = 64 + pkts_960_num = 502 + total_pkts_num = pkts_64_num + pkts_960_num + self.queue_num =2 + self.txd_num = 4096 path_mode = 'server=1,packed_vq=0,mrg_rxbuf=0,in_order=0' ringsize = 4096 - extern_params = '--rxq=2 --txq=2' + extern_params = '--rxq=2 --txq=2 --enable-hw-vlan-strip ' # get dump pcap file of virtio - # the virtio0 will send 283 pkts, but the virtio only will received 252 pkts + # the virtio0 will send imix small pkts self.logger.info('check pcap file info about virtio') - vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" - self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize, vdevs, no_pci=False, cbdma=True, pdump=False) + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) self.send_251_960byte_and_32_64byte_pkts() + self.vhost_user_pmd.execute_cmd('start') # execute stop and port stop all to avoid testpmd tail_pkts issue. self.vhost_user_pmd.execute_cmd('stop') self.vhost_user_pmd.execute_cmd('port stop all') out = self.virtio_user1_pmd.execute_cmd('show port stats all') self.verify('RX-packets: 566' in out and 'RX-bytes: 486016' in out, 'expect: virtio-user1 RX-packets is 566 and RX-bytes is 486016') - self.quit_all_testpmd() - - def test_vm2vm_virtio_user_split_virtqueue_mergeable_path_with_cbdma(self): + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num, pkts_960_num) + + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_251_960byte_and_32_64byte_pkts() + self.virtio_user1_pmd.execute_cmd('clear port stats all') + self.virtio_user1_pmd.execute_cmd('show port stats all') + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 566' in out and 'RX-bytes: 486016' in out, 'expect: virtio-user1 RX-packets is 566 and RX-bytes is 486016') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num, pkts_960_num) + + def test_vm2vm_virtio_user_split_virtqueue_mergeable_path_multi_queues_check_chain_pkts_with_cbdma(self): """ Test Case 13: split virtqueue vm2vm mergeable path multi-queues payload check with cbdma enabled """ @@ -772,58 +789,244 @@ class TestVM2VMVirtioUser(TestCase): large_4640_pkts_num = 54 large_64_pkts_num = 448 total_pkts_num = large_4640_pkts_num + large_64_pkts_num - self.queue_num=2 - self.nopci=False + self.queue_num =2 + self.txd_num = 4096 path_mode = 'server=1,packed_vq=0,mrg_rxbuf=1,in_order=0' ringsize = 4096 extern_params = '--rxq=2 --txq=2' - # get dump pcap file of virtio - # the virtio0 will send 283 pkts, but the virtio only will received 252 pkts + self.logger.info('check pcap file info about virtio') - vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" - self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize, vdevs, no_pci=False, cbdma=True, pdump=True) - # self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize, vdevs, no_pci=False) - # self.vhost_user_pmd.execute_cmd('vhost enable tx all') + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) self.send_27_4640byte_and_224_64byte_pkts() + self.vhost_user_pmd.execute_cmd('start') # execute stop and port stop all to avoid testpmd tail_pkts issue. self.vhost_user_pmd.execute_cmd('stop') self.vhost_user_pmd.execute_cmd('port stop all') - self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, large_4640_pkts_num, large_64_pkts_num) - self.logger.info('check pcap file info about vhost') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 502' in out and 'RX-bytes: 279232' in out, 'expect: virtio-user1 RX-packets is 502 and RX-bytes is 279232') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num = large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_27_4640byte_and_224_64byte_pkts() + self.virtio_user1_pmd.execute_cmd('clear port stats all') + self.virtio_user1_pmd.execute_cmd('show port stats all') + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 502' in out and 'RX-bytes: 279232' in out, 'expect: virtio-user1 RX-packets is 502 and RX-bytes is 279232') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + + def test_vm2vm_virtio_user_split_virtqueue_inorder_non_mergeable_path_multi_queues_check_chain_pkts_with_cbdma(self): + """ + Test Case 14: split virtqueue vm2vm inorder non-mergeable path multi-queues payload check with cbdma enabled + """ + self.cbdma_nic_dev_num = 4 + self.get_cbdma_ports_info_and_bind_to_dpdk() + large_4640_pkts_num = 0 + large_64_pkts_num = 448 + total_pkts_num = large_4640_pkts_num + large_64_pkts_num + self.queue_num = 2 + self.txd_num = 4096 + path_mode = 'server=1,packed_vq=0,mrg_rxbuf=0,in_order=1' + ringsize = 4096 + extern_params = '--rxq=2 --txq=2' + + self.logger.info('check pcap file info about virtio') + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" + + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) + self.send_27_4640byte_and_224_64byte_pkts() + self.vhost_user_pmd.execute_cmd('start') + # execute stop and port stop all to avoid testpmd tail_pkts issue. + self.vhost_user_pmd.execute_cmd('stop') + self.vhost_user_pmd.execute_cmd('port stop all') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_4640_num=large_4640_pkts_num) + + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_27_4640byte_and_224_64byte_pkts() + while True: + self.virtio_user1_pmd.execute_cmd('clear port stats all') + out = self.virtio_user1_pmd.execute_cmd('show port stats 0') + if 'RX-packets: 0' in out: + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_4640_num=large_4640_pkts_num) + break + + def test_vm2vm_virtio_user_split_virtqueue_vectorized_multi_queues_check_chain_pkts_with_cbdma(self): + """ + Test Case 15: split virtqueue vm2vm vectorized path multi-queues payload check with cbdma enabled + """ + self.cbdma_nic_dev_num = 4 + self.get_cbdma_ports_info_and_bind_to_dpdk() + large_4640_pkts_num = 0 + large_64_pkts_num = 448 + total_pkts_num = large_4640_pkts_num + large_64_pkts_num + self.queue_num = 2 + self.txd_num = 4096 + path_mode = 'server=1,packed_vq=0,mrg_rxbuf=0,in_order=0,vectorized=1' + ringsize = 4096 + extern_params = '--rxq=2 --txq=2' + + self.logger.info('check pcap file info about virtio') + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" + + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) + self.send_224_64byte_and_27_4640byte_pkts() + self.vhost_user_pmd.execute_cmd('start') + # execute stop and port stop all to avoid testpmd tail_pkts issue. + self.vhost_user_pmd.execute_cmd('stop') + self.vhost_user_pmd.execute_cmd('port stop all') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_4640_num=large_4640_pkts_num) + + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_224_64byte_and_27_4640byte_pkts() + self.virtio_user1_pmd.execute_cmd('clear port stats all') + self.virtio_user1_pmd.execute_cmd('show port stats all') + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_4640_num=large_4640_pkts_num) + + def test_vm2vm_virtio_user_split_virtqueue_inorder_mergeable_path_test_non_indirect_desc_with_cbdma(self): + """ + Test Case 16: split virtqueue vm2vm inorder mergeable path test non-indirect descriptor with cbdma enable + """ + self.cbdma_nic_dev_num = 4 + self.get_cbdma_ports_info_and_bind_to_dpdk() + large_8k_pkts_num = 2 + large_64_pkts_num = 502 + total_pkts_num = large_8k_pkts_num + large_64_pkts_num + self.queue_num = 2 + self.txd_num = 256 + path_mode = 'server=1,packed_vq=0,mrg_rxbuf=1,in_order=1' + ringsize = 256 + extern_params = '--rxq=2 --txq=2' - def test_vm2vm_virtio_user_packed_virtqueue_inorder_mergeable_path_with_cbdma(self): + self.logger.info('check pcap file info about virtio') + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" + + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) + self.send_251_64_and_32_8k_pkts() + self.vhost_user_pmd.execute_cmd('start') + # execute stop and port stop all to avoid testpmd tail_pkts issue. + self.vhost_user_pmd.execute_cmd('stop') + self.vhost_user_pmd.execute_cmd('port stop all') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 504' in out and 'RX-bytes: 48128' in out, 'expect: virtio-user1 RX-packets is 504 and RX-bytes is 48128') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_8k_num=large_8k_pkts_num) + + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa and virtio') + self.relanuch_vhost_iova_pa_and_virtio(path_mode, extern_params, ringsize) + self.send_251_64_and_32_8k_pkts() + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 504' in out and 'RX-bytes: 48128' in out, 'expect: virtio-user1 RX-packets is 504 and RX-bytes is 48128') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_8k_num=large_8k_pkts_num) + + def test_vm2vm_virtio_user_split_virtqueue_mergeable_path_test_indirect_desc_with_cbdma(self): """ - Test Case 14: packed virtqueue vm2vm inorder mergeable path multi-queues payload check with cbdma enabled + Test Case 17: split virtqueue vm2vm mergeable path test indirect descriptor with cbdma enable """ self.cbdma_nic_dev_num = 4 self.get_cbdma_ports_info_and_bind_to_dpdk() - large_8k_pkts_num = 502 - large_2k_pkts_num = 64 - total_pkts_num = large_8k_pkts_num + large_2k_pkts_num + large_8k_pkts_num = 10 + large_64_pkts_num = 502 + total_pkts_num = large_8k_pkts_num + large_64_pkts_num + self.queue_num = 2 + self.txd_num = 256 + path_mode = 'server=1,packed_vq=0,mrg_rxbuf=1,in_order=0' + ringsize = 256 + extern_params = '--rxq=2 --txq=2' + + self.logger.info('check pcap file info about virtio') + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" + + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) + self.send_251_64_and_32_8k_pkts() + self.vhost_user_pmd.execute_cmd('start') + # execute stop and port stop all to avoid testpmd tail_pkts issue. + self.vhost_user_pmd.execute_cmd('stop') + self.vhost_user_pmd.execute_cmd('port stop all') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 512' in out and 'RX-bytes: 112128' in out, 'expect: virtio-user1 RX-packets is 512 and RX-bytes is 112128') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_8k_num=large_8k_pkts_num) + + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa and virtio') + self.relanuch_vhost_iova_pa_and_virtio(path_mode, extern_params, ringsize) + self.send_251_64_and_32_8k_pkts() + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 512' in out and 'RX-bytes: 112128' in out, 'expect: virtio-user1 RX-packets is 512 and RX-bytes is 112128') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_8k_num=large_8k_pkts_num) + + def test_vm2vm_virtio_user_packed_virtqueue_non_mergeable_path_multi_queues_check_chain_pkts_with_cbdma(self): + """ + Test Case 18: packed virtqueue vm2vm non mergeable path multi-queues payload check with cbdma enabled + """ + self.cbdma_nic_dev_num = 4 + self.get_cbdma_ports_info_and_bind_to_dpdk() + pkts_64_num = 448 + pkts_4640_num = 0 + total_pkts_num = pkts_64_num + pkts_4640_num self.queue_num=2 - self.nopci=False + self.txd_num = 4096 path_mode = 'server=1,packed_vq=1,mrg_rxbuf=0,in_order=0' ringsize = 4096 extern_params = '--rxq=2 --txq=2' - # get dump pcap file of virtio - # the virtio0 will send 283 pkts, but the virtio only will received 252 pkts + self.logger.info('check pcap file info about virtio') - vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" - self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize, vdevs, no_pci=False, cbdma=True, pdump=False) - self.send_251_960byte_and_32_64byte_pkts() + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) + self.send_224_64byte_and_27_4640byte_pkts() + self.vhost_user_pmd.execute_cmd('start') # execute stop and port stop all to avoid testpmd tail_pkts issue. self.vhost_user_pmd.execute_cmd('stop') self.vhost_user_pmd.execute_cmd('port stop all') out = self.virtio_user1_pmd.execute_cmd('show port stats all') - self.verify('RX-packets: 566' in out and 'RX-bytes: 486016' in out, 'expect: virtio-user1 RX-packets is 566 and RX-bytes is 486016') - self.quit_all_testpmd() + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num, pkts_4640_num) - def test_vm2vm_virtio_user_packed_virtqueue_mergeable_path_with_cbdma(self): + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_224_64byte_and_27_4640byte_pkts() + self.virtio_user1_pmd.execute_cmd('clear port stats all') + self.virtio_user1_pmd.execute_cmd('show port stats all') + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num, pkts_4640_num) + + def test_vm2vm_virtio_user_packed_virtqueue_mergeable_path_multi_queues_check_chain_pkts_with_cbdma(self): """ - Test Case 15: packed virtqueue vm2vm mergeable path multi-queues payload check with cbdma enabled + Test Case 19: packed virtqueue vm2vm mergeable path multi-queues payload check with cbdma enabled """ self.cbdma_nic_dev_num = 4 self.get_cbdma_ports_info_and_bind_to_dpdk() @@ -831,23 +1034,220 @@ class TestVM2VMVirtioUser(TestCase): large_64_pkts_num = 448 total_pkts_num = large_4640_pkts_num + large_64_pkts_num self.queue_num=2 - self.nopci=False + self.txd_num = 4096 path_mode = 'server=1,packed_vq=1,mrg_rxbuf=1,in_order=0' ringsize = 4096 extern_params = '--rxq=2 --txq=2' - # get dump pcap file of virtio - # the virtio0 will send 283 pkts, but the virtio only will received 252 pkts + self.logger.info('check pcap file info about virtio') - vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" - self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize, vdevs, no_pci=False, cbdma=True, pdump=True) + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) self.send_27_4640byte_and_224_64byte_pkts() + self.vhost_user_pmd.execute_cmd('start') # execute stop and port stop all to avoid testpmd tail_pkts issue. self.vhost_user_pmd.execute_cmd('stop') self.vhost_user_pmd.execute_cmd('port stop all') - self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, large_4640_pkts_num, large_64_pkts_num) - self.logger.info('check pcap file info about vhost') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 502' in out and 'RX-bytes: 279232' in out, 'expect: virtio-user1 RX-packets is 502 and RX-bytes is 279232') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_27_4640byte_and_224_64byte_pkts() + self.virtio_user1_pmd.execute_cmd('clear port stats all') + self.virtio_user1_pmd.execute_cmd('show port stats all') + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 502' in out and 'RX-bytes: 279232' in out, 'expect: virtio-user1 RX-packets is 502 and RX-bytes is 279232') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + + def test_vm2vm_virtio_user_packed_virtqueue_inorder_mergeable_path_multi_queues_check_chain_pkts_with_cbdma(self): + """ + Test Case 20: packed virtqueue vm2vm inorder mergeable path multi-queues payload check with cbdma enabled + """ + self.cbdma_nic_dev_num = 4 + self.get_cbdma_ports_info_and_bind_to_dpdk() + large_4640_pkts_num = 54 + large_64_pkts_num = 448 + total_pkts_num = large_4640_pkts_num + large_64_pkts_num + self.queue_num=2 + self.txd_num = 4096 + path_mode = 'server=1,packed_vq=1,mrg_rxbuf=1,in_order=1' + ringsize = 4096 + extern_params = '--rxq=2 --txq=2' + + self.logger.info('check pcap file info about virtio') + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" + + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) + self.send_27_4640byte_and_224_64byte_pkts() + self.vhost_user_pmd.execute_cmd('start') + # execute stop and port stop all to avoid testpmd tail_pkts issue. + self.vhost_user_pmd.execute_cmd('stop') + self.vhost_user_pmd.execute_cmd('port stop all') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 502' in out and 'RX-bytes: 279232' in out, 'expect: virtio-user1 RX-packets is 502 and RX-bytes is 279232') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_27_4640byte_and_224_64byte_pkts() + self.virtio_user1_pmd.execute_cmd('clear port stats all') + self.virtio_user1_pmd.execute_cmd('show port stats all') + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 502' in out and 'RX-bytes: 279232' in out, 'expect: virtio-user1 RX-packets is 502 and RX-bytes is 279232') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + + def test_vm2vm_virtio_user_packed_virtqueue_inorder_non_mergeable_path_multi_queues_check_chain_pkts_with_cbdma(self): + """ + Test Case 21: packed virtqueue vm2vm inorder non-mergeable path multi-queues payload check with cbdma enabled + """ + self.cbdma_nic_dev_num = 4 + self.get_cbdma_ports_info_and_bind_to_dpdk() + large_4640_pkts_num = 0 + large_64_pkts_num = 448 + total_pkts_num = large_4640_pkts_num + large_64_pkts_num + self.queue_num=2 + self.txd_num = 4096 + path_mode = 'server=1,packed_vq=1,mrg_rxbuf=0,in_order=1' + ringsize = 4096 + extern_params = '--rxq=2 --txq=2' + + self.logger.info('check pcap file info about virtio') + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" + + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) + self.send_224_64byte_and_27_4640byte_pkts() + self.vhost_user_pmd.execute_cmd('start') + # execute stop and port stop all to avoid testpmd tail_pkts issue. + self.vhost_user_pmd.execute_cmd('stop') + self.vhost_user_pmd.execute_cmd('port stop all') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_224_64byte_and_27_4640byte_pkts() + self.virtio_user1_pmd.execute_cmd('clear port stats all') + self.virtio_user1_pmd.execute_cmd('show port stats all') + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + + def test_vm2vm_virtio_user_packed_virtqueue_vectorized_path_multi_queues_check_chain_pkts_with_cbdma(self): + """ + Test Case 22: packed virtqueue vm2vm vectorized path multi-queues payload check with cbdma enabled + """ + self.cbdma_nic_dev_num = 4 + self.get_cbdma_ports_info_and_bind_to_dpdk() + large_4640_pkts_num = 0 + large_64_pkts_num = 448 + total_pkts_num = large_4640_pkts_num + large_64_pkts_num + self.queue_num=2 + self.txd_num = 4096 + path_mode = 'server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1' + ringsize = 4096 + extern_params = '--rxq=2 --txq=2' + + self.logger.info('check pcap file info about virtio') + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" + + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) + self.send_224_64byte_and_27_4640byte_pkts() + self.vhost_user_pmd.execute_cmd('start') + # execute stop and port stop all to avoid testpmd tail_pkts issue. + self.vhost_user_pmd.execute_cmd('stop') + self.vhost_user_pmd.execute_cmd('port stop all') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_224_64byte_and_27_4640byte_pkts() + self.virtio_user1_pmd.execute_cmd('clear port stats all') + self.virtio_user1_pmd.execute_cmd('show port stats all') + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + + def test_vm2vm_virtio_user_packed_virtqueue_vectorized_path_ringsize_not_power_of_2_multi_queues_check_chain_pkts_with_cbdma(self): + """ + Test Case 23: packed virtqueue vm2vm vectorized path ringsize_not_power_of_2 multi-queues payload check with cbdma enabled + """ + self.cbdma_nic_dev_num = 4 + self.get_cbdma_ports_info_and_bind_to_dpdk() + large_4640_pkts_num = 0 + large_64_pkts_num = 448 + total_pkts_num = large_4640_pkts_num + large_64_pkts_num + self.queue_num=2 + self.txd_num = 4096 + path_mode = 'server=1,packed_vq=1,mrg_rxbuf=0,in_order=1,vectorized=1' + ringsize = 4097 + extern_params = '--rxq=2 --txq=2' + + self.logger.info('check pcap file info about virtio') + self.vdevs = f"--vdev 'eth_vhost0,iface=vhost-net0,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[0]};txq1@{self.cbdma_dev_infos[1]}]' " \ + f"--vdev 'eth_vhost1,iface=vhost-net1,queues=2,client=1,dmas=[txq0@{self.cbdma_dev_infos[2]};txq1@{self.cbdma_dev_infos[3]}]'" + + self.get_dump_file_of_virtio_user_cbdma(path_mode, extern_params, ringsize) + self.send_224_64byte_and_27_4640byte_pkts() + self.vhost_user_pmd.execute_cmd('start') + # execute stop and port stop all to avoid testpmd tail_pkts issue. + self.vhost_user_pmd.execute_cmd('stop') + self.vhost_user_pmd.execute_cmd('port stop all') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num= large_64_pkts_num, pkts_4640_num = large_4640_pkts_num) + if not self.check_2M_env: + self.logger.info('relanuch vhost testpmd iova pa') + self.relanuch_vhost_testpmd_iova_pa() + self.send_224_64byte_and_27_4640byte_pkts() + while True : + self.virtio_user1_pmd.execute_cmd('clear port stats all') + out = self.virtio_user1_pmd.execute_cmd('show port stats 0') + if 'RX-packets: 0' in out: + self.vhost_user_pmd.execute_cmd('start') + self.vhost_user_pmd.execute_cmd('stop') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 448' in out and 'RX-bytes: 28672' in out, 'expect: virtio-user1 RX-packets is 448 and RX-bytes is 28672') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_4640_num=large_4640_pkts_num) + break + + def test_vm2vm_virtio_user_packed_virtqueue_vectorized_path_test_indirect_desc(self): + """ + Test Case 24: packed virtqueue vm2vm vectorized-tx path multi-queues test indirect descriptor + """ + large_8k_pkts_num = 5 + large_64_pkts_num = 251 + total_pkts_num = large_8k_pkts_num + large_64_pkts_num + self.queue_num = 1 + self.txd_num = 256 + path_mode = 'packed_vq=1,mrg_rxbuf=1,in_order=1,vectorized=1' + ringsize = 256 + extern_params = '' + + self.logger.info('check pcap file info about virtio') + self.get_dump_file_of_virtio_user(path_mode, extern_params, ringsize) + # execute stop and port stop all to avoid testpmd tail_pkts issue. + self.vhost_user_pmd.execute_cmd('stop') + self.vhost_user_pmd.execute_cmd('port stop all') + out = self.virtio_user1_pmd.execute_cmd('show port stats all') + self.verify('RX-packets: 256' in out and 'RX-bytes: 56064' in out, 'expect: virtio-user1 RX-packets is 256 and RX-bytes is 56064') + self.check_packet_payload_valid_with_cbdma(self.dump_virtio_pcap, total_pkts_num, pkts_64_num=large_64_pkts_num, pkts_8k_num=large_8k_pkts_num) def close_all_session(self): if getattr(self, 'vhost_user', None): @@ -863,6 +1263,7 @@ class TestVM2VMVirtioUser(TestCase): """ Run after each test case. """ + self.quit_all_testpmd() self.bind_cbdma_device_to_kernel() self.dut.kill_all() time.sleep(2) -- 2.25.1