test suite reviews and discussions
 help / color / Atom feed
* [dts] [PATCH V1]pvp_virtio_user_multi_queues: delete old suite which has been replaced by new suite
@ 2020-05-14  9:54 Xiao Qimai
  2020-05-14  9:54 ` [dts] [PATCH V1]vm2vm_virtio_pmd: delete unnecessary code Xiao Qimai
  2020-05-19  2:00 ` [dts] [PATCH V1]pvp_virtio_user_multi_queues: delete old suite which has been replaced by new suite Tu, Lijuan
  0 siblings, 2 replies; 4+ messages in thread
From: Xiao Qimai @ 2020-05-14  9:54 UTC (permalink / raw)
  To: dts; +Cc: Xiao Qimai

*. this suite has been replaced by pvp_virtio_user_multi_queues_port_restart

Signed-off-by: Xiao Qimai <qimaix.xiao@intel.com>
---
 tests/TestSuite_pvp_virtio_user_multi_queues.py | 310 ------------------------
 1 file changed, 310 deletions(-)
 delete mode 100644 tests/TestSuite_pvp_virtio_user_multi_queues.py

diff --git a/tests/TestSuite_pvp_virtio_user_multi_queues.py b/tests/TestSuite_pvp_virtio_user_multi_queues.py
deleted file mode 100644
index 4cde5b8..0000000
--- a/tests/TestSuite_pvp_virtio_user_multi_queues.py
+++ /dev/null
@@ -1,310 +0,0 @@
-# BSD LICENSE
-#
-# Copyright(c) 2010-2019 Intel Corporation. All rights reserved.
-# All rights reserved.
-#
-# Redistribution and use in source and binary forms, with or without
-# modification, are permitted provided that the following conditions
-# are met:
-#
-#   * Redistributions of source code must retain the above copyright
-#     notice, this list of conditions and the following disclaimer.
-#   * Redistributions in binary form must reproduce the above copyright
-#     notice, this list of conditions and the following disclaimer in
-#     the documentation and/or other materials provided with the
-#     distribution.
-#   * Neither the name of Intel Corporation nor the names of its
-#     contributors may be used to endorse or promote products derived
-#     from this software without specific prior written permission.
-#
-# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
-# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
-# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
-# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
-# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
-# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
-# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
-# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
-# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
-# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
-# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-
-"""
-DPDK Test suite.
-Test vhost/virtio-user loopback multi-queues on 8 tx/rx path.
-Includes Mergeable, Normal, Vector_RX, Inorder mergeable,
-Inorder no-mergeable, Virtio 1.1 mergeable, Virtio 1.1 no-mergeable Path,
-Virtio 1.1 inorder no-mergeable Path.
-"""
-
-import utils
-import time
-import re
-from settings import HEADER_SIZE
-from test_case import TestCase
-from pktgen import PacketGeneratorHelper
-
-
-class TestPVPVirtioMultiQueues(TestCase):
-
-    def set_up_all(self):
-        """
-        Run at the start of each test suite.
-        """
-        self.tester.extend_external_packet_generator(TestPVPVirtioMultiQueues, self)
-        self.frame_sizes = [64, 128, 256, 512, 1024, 1518]
-        self.core_config = "1S/6C/1T"
-        self.queue_number = 2
-        self.port_number = 2
-        self.dut_ports = self.dut.get_ports()
-        self.verify(len(self.dut_ports) >= 1, "Insufficient ports for testing")
-        self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])
-        self.cores_num = len([n for n in self.dut.cores if int(n['socket'])
-                          == self.ports_socket])
-        self.verify(self.cores_num >= 6,
-                    "There has not enought cores to test this case")
-        self.headers_size = HEADER_SIZE['eth'] + HEADER_SIZE['ip'] + \
-            HEADER_SIZE['udp']
-        self.core_list = self.dut.get_core_list(
-            self.core_config, socket=self.ports_socket)
-        self.core_list_user = self.core_list[0:3]
-        self.core_list_host = self.core_list[3:6]
-        self.dst_mac = self.dut.get_mac_address(self.dut_ports[0])
-
-        self.logger.info("you can config packet_size in file %s.cfg," % self.suite_name + \
-                        "in region 'suite' like packet_sizes=[64, 128, 256]")
-        # get the frame_sizes from cfg file
-        if 'packet_sizes' in self.get_suite_cfg():
-            self.frame_sizes = self.get_suite_cfg()['packet_sizes']
-
-        self.out_path = '/tmp'
-        out = self.tester.send_expect('ls -d %s' % self.out_path, '# ')
-        if 'No such file or directory' in out:
-            self.tester.send_expect('mkdir -p %s' % self.out_path, '# ')
-        # create an instance to set stream field setting
-        self.pktgen_helper = PacketGeneratorHelper()
-
-    def set_up(self):
-        """
-        Run before each test case.
-        """
-        # Prepare the result table
-        self.dut.send_expect("rm -rf ./vhost-net*", "#")
-        self.dut.send_expect("killall -s INT testpmd", "#")
-        self.table_header = ["Frame", "Mode", "Throughput(Mpps)", "% linerate"]
-        self.result_table_create(self.table_header)
-
-        self.vhost_user = self.dut.new_session(suite="vhost-user")
-        self.virtio_user = self.dut.new_session(suite="virtio-user")
-
-    @property
-    def check_2M_env(self):
-        out = self.dut.send_expect("cat /proc/meminfo |grep Hugepagesize|awk '{print($2)}'", "# ")
-        return True if out == '2048' else False
-
-    def start_vhost_testpmd(self):
-        """
-        start testpmd on vhost
-        """
-        eal_param = self.dut.create_eal_parameters(socket=self.ports_socket, cores=self.core_list_host, prefix='vhost',
-                                                   vdevs=['net_vhost0,iface=vhost-net,queues=2,client=0'])
-        command_line_client = "./%s/app/testpmd " % self.target + eal_param + ' -- -i --nb-cores=2 --rxq=2 --txq=2 --rss-ip'
-        self.vhost_user.send_expect(command_line_client, "testpmd> ", 120)
-        self.vhost_user.send_expect("set fwd mac", "testpmd> ", 120)
-        self.vhost_user.send_expect("start", "testpmd> ", 120)
-
-    def start_virtio_testpmd(self, args):
-        """
-        start testpmd on virtio
-        """
-        eal_param = self.dut.create_eal_parameters(socket=self.ports_socket, cores=self.core_list_user, prefix='virtio',
-                                                   no_pci=True, vdevs=[
-                'net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net,queues=2,%s' % args["version"]])
-        if self.check_2M_env:
-            eal_param += " --single-file-segments"
-        command_line_user = "./%s/app/testpmd " % self.target + eal_param + " -- -i %s --rss-ip --nb-cores=2 --rxq=2 --txq=2" % \
-                            args["path"]
-        self.virtio_user.send_expect(command_line_user, "testpmd> ", 120)
-        self.virtio_user.send_expect("set fwd mac", "testpmd> ", 120)
-        self.virtio_user.send_expect("start", "testpmd> ", 120)
-
-    def update_result_table(self, frame_size, case_info, Mpps, throughput):
-        results_row = [frame_size]
-        results_row.append(case_info)
-        results_row.append(Mpps)
-        results_row.append(throughput)
-        self.result_table_add(results_row)
-
-    def check_packets_of_each_queue(self, frame_size):
-        """
-        check each queue has receive packets
-        """
-        out = self.vhost_user.send_expect("stop", "testpmd> ", 60)
-        for port_index in range(0, self.port_number):
-            for queue_index in range(0, self.queue_number):
-                queue_info = re.findall("RX\s*Port=\s*%d/Queue=\s*%d" %
-                                (port_index, queue_index),  out)
-                queue = queue_info[0]
-                index = out.find(queue)
-                rx = re.search("RX-packets:\s*(\d*)", out[index:])
-                tx = re.search("TX-packets:\s*(\d*)", out[index:])
-                rx_packets = int(rx.group(1))
-                tx_packets = int(tx.group(1))
-                self.verify(rx_packets > 0 and tx_packets > 0,
-                      "The queue %d rx-packets or tx-packets is 0 about " %
-                      queue_index + \
-                      "frame_size:%d, rx-packets:%d, tx-packets:%d" %
-                      (frame_size, rx_packets, tx_packets))
-
-        self.vhost_user.send_expect("start", "testpmd> ", 60)
-
-    def set_fields(self):
-        """
-        set ip protocol field behavior
-        """
-        fields_config = {'ip':  {'dst': {'action': 'random'}, }, }
-        return fields_config
-
-    def send_and_verify(self, case_info):
-        """
-        start to send packets and calculate avg throughput
-        """
-        for frame_size in self.frame_sizes:
-            payload_size = frame_size - self.headers_size
-            tgen_input = []
-            port = self.tester.get_local_port(self.dut_ports[0])
-            self.tester.scapy_append('a=[Ether(dst="%s")/IP(src="0.240.74.101",proto=255)/UDP()/("X"*%d)]' % (self.dst_mac, payload_size))
-            self.tester.scapy_append('wrpcap("%s/multiqueue.pcap" , a)' % self.out_path)
-            self.tester.scapy_execute()
-
-            tgen_input.append((port, port, "%s/multiqueue.pcap" % self.out_path))
-
-            vm_config = self.set_fields()
-            self.tester.pktgen.clear_streams()
-            streams = self.pktgen_helper.prepare_stream_from_tginput(tgen_input, 100, vm_config, self.tester.pktgen)
-            # set traffic option
-            traffic_opt = {'delay': 5, 'duration': 20}
-            _, pps = self.tester.pktgen.measure_throughput(stream_ids=streams, options=traffic_opt)
-            Mpps = pps / 1000000.0
-            self.verify(Mpps > 0, "can not receive packets of frame size %d" % (frame_size))
-            throughput = Mpps * 100 / \
-                        float(self.wirespeed(self.nic, frame_size, 1))
-
-            self.update_result_table(frame_size, case_info, Mpps, throughput)
-            self.check_packets_of_each_queue(frame_size)
-        self.result_table_print()
-
-    def close_all_testpmd(self):
-        """
-        close all testpmd of vhost and virtio
-        """
-        self.vhost_user.send_expect("quit", "#", 60)
-        self.virtio_user.send_expect("quit", "#", 60)
-
-    def close_all_session(self):
-        """
-        close all session of vhost and vhost-user
-        """
-        self.dut.close_session(self.virtio_user)
-        self.dut.close_session(self.vhost_user)
-
-    def test_perf_pvp_viritouser_multi_queue_virtio11_mergeable(self):
-        """
-        performance for Vhost PVP virtio 1.1 Mergeable Path.
-        """
-        virtio_pmd_arg = {"version": "in_order=0,packed_vq=1,mrg_rxbuf=1",
-                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
-        self.start_vhost_testpmd()
-        self.start_virtio_testpmd(virtio_pmd_arg)
-        self.send_and_verify("virtio_1.1 mergeable on")
-        self.close_all_testpmd()
-
-    def test_perf_pvp_viritouser_multi_queue_virtio11_normal(self):
-        """
-        performance for Vhost PVP virtio1.1 Normal Path.
-        """
-        virtio_pmd_arg = {"version": "in_order=0,packed_vq=1,mrg_rxbuf=0",
-                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
-        self.start_vhost_testpmd()
-        self.start_virtio_testpmd(virtio_pmd_arg)
-        self.send_and_verify("virtio_1.1 mergeable off")
-        self.close_all_testpmd()
-
-    def test_perf_pvp_viritouser_multi_queue_virtio11_inorder(self):
-        """
-        performance for Vhost PVP virtio1.1 inorder Path.
-        """
-        virtio_pmd_arg = {"version": "in_order=1,packed_vq=1,mrg_rxbuf=0",
-                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
-        self.start_vhost_testpmd()
-        self.start_virtio_testpmd(virtio_pmd_arg)
-        self.send_and_verify("virtio_1.1 inorder")
-        self.close_all_testpmd()
-
-    def test_perf_pvp_viritouser_multi_queue_inorder_mergeable(self):
-        """
-        performance for Vhost PVP In_order mergeable Path.
-        """
-        virtio_pmd_arg = {"version": "packed_vq=0,in_order=1,mrg_rxbuf=1",
-                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
-        self.start_vhost_testpmd()
-        self.start_virtio_testpmd(virtio_pmd_arg)
-        self.send_and_verify("inoder mergeable on")
-        self.close_all_testpmd()
-
-    def test_perf_pvp_viritouser_multi_queue_inorder_no_mergeable(self):
-        """
-        performance for Vhost PVP In_order no_mergeable Path.
-        """
-        virtio_pmd_arg = {"version": "packed_vq=0,in_order=1,mrg_rxbuf=0",
-                        "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
-        self.start_vhost_testpmd()
-        self.start_virtio_testpmd(virtio_pmd_arg)
-        self.send_and_verify("inoder mergeable off")
-        self.close_all_testpmd()
-
-    def test_perf_pvp_viritouser_mulit_queue_mergeable(self):
-        """
-        performance for Vhost PVP Mergeable Path.
-        """
-        virtio_pmd_arg = {"version": "packed_vq=0,in_order=0,mrg_rxbuf=1",
-                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
-        self.start_vhost_testpmd()
-        self.start_virtio_testpmd(virtio_pmd_arg)
-        self.send_and_verify("virito mergeable")
-        self.close_all_testpmd()
-
-    def test_perf_pvp_viritouser_multi_queue_normal(self):
-        """
-        performance for Vhost PVP Normal Path.
-        """
-        virtio_pmd_arg = {"version": "packed_vq=0,in_order=0,mrg_rxbuf=0",
-                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
-        self.start_vhost_testpmd()
-        self.start_virtio_testpmd(virtio_pmd_arg)
-        self.send_and_verify("virtio normal")
-        self.close_all_testpmd()
-
-    def test_perf_pvp_viritouser_multi_queue_vector_rx(self):
-        """
-        performance for Vhost PVP Vector_RX Path
-        """
-        virtio_pmd_arg = {"version": "packed_vq=0,in_order=0,mrg_rxbuf=0",
-                            "path": "--tx-offloads=0x0"}
-        self.start_vhost_testpmd()
-        self.start_virtio_testpmd(virtio_pmd_arg)
-        self.send_and_verify("virito vector rx")
-        self.close_all_testpmd()
-
-    def tear_down(self):
-        """
-        Run after each test case.
-        """
-        self.dut.send_expect("killall -s INT testpmd", "#")
-        self.close_all_session()
-
-    def tear_down_all(self):
-        """
-        Run after each test suite.
-        """
-        pass
-- 
1.8.3.1


^ permalink raw reply	[flat|nested] 4+ messages in thread

* [dts] [PATCH V1]vm2vm_virtio_pmd: delete unnecessary code
  2020-05-14  9:54 [dts] [PATCH V1]pvp_virtio_user_multi_queues: delete old suite which has been replaced by new suite Xiao Qimai
@ 2020-05-14  9:54 ` Xiao Qimai
  2020-05-19  1:58   ` Tu, Lijuan
  2020-05-19  2:00 ` [dts] [PATCH V1]pvp_virtio_user_multi_queues: delete old suite which has been replaced by new suite Tu, Lijuan
  1 sibling, 1 reply; 4+ messages in thread
From: Xiao Qimai @ 2020-05-14  9:54 UTC (permalink / raw)
  To: dts; +Cc: Xiao Qimai

*. remove unnecessary code

Signed-off-by: Xiao Qimai <qimaix.xiao@intel.com>
---
 tests/TestSuite_vm2vm_virtio_pmd.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/tests/TestSuite_vm2vm_virtio_pmd.py b/tests/TestSuite_vm2vm_virtio_pmd.py
index d1fce80..d4ffdc7 100644
--- a/tests/TestSuite_vm2vm_virtio_pmd.py
+++ b/tests/TestSuite_vm2vm_virtio_pmd.py
@@ -1,4 +1,3 @@
-710703wyn
 # BSD LICENSE
 #
 # Copyright(c) <2019> Intel Corporation.
-- 
1.8.3.1


^ permalink raw reply	[flat|nested] 4+ messages in thread

* Re: [dts] [PATCH V1]vm2vm_virtio_pmd: delete unnecessary code
  2020-05-14  9:54 ` [dts] [PATCH V1]vm2vm_virtio_pmd: delete unnecessary code Xiao Qimai
@ 2020-05-19  1:58   ` Tu, Lijuan
  0 siblings, 0 replies; 4+ messages in thread
From: Tu, Lijuan @ 2020-05-19  1:58 UTC (permalink / raw)
  To: Xiao, QimaiX, dts; +Cc: Xiao, QimaiX

This was covered by Yinan' s patch, thanks

> -----Original Message-----
> From: dts [mailto:dts-bounces@dpdk.org] On Behalf Of Xiao Qimai
> Sent: Thursday, May 14, 2020 5:55 PM
> To: dts@dpdk.org
> Cc: Xiao, QimaiX <qimaix.xiao@intel.com>
> Subject: [dts] [PATCH V1]vm2vm_virtio_pmd: delete unnecessary code
> 
> *. remove unnecessary code
> 
> Signed-off-by: Xiao Qimai <qimaix.xiao@intel.com>
> ---
>  tests/TestSuite_vm2vm_virtio_pmd.py | 1 -
>  1 file changed, 1 deletion(-)
> 
> diff --git a/tests/TestSuite_vm2vm_virtio_pmd.py
> b/tests/TestSuite_vm2vm_virtio_pmd.py
> index d1fce80..d4ffdc7 100644
> --- a/tests/TestSuite_vm2vm_virtio_pmd.py
> +++ b/tests/TestSuite_vm2vm_virtio_pmd.py
> @@ -1,4 +1,3 @@
> -710703wyn
>  # BSD LICENSE
>  #
>  # Copyright(c) <2019> Intel Corporation.
> --
> 1.8.3.1


^ permalink raw reply	[flat|nested] 4+ messages in thread

* Re: [dts] [PATCH V1]pvp_virtio_user_multi_queues: delete old suite which has been replaced by new suite
  2020-05-14  9:54 [dts] [PATCH V1]pvp_virtio_user_multi_queues: delete old suite which has been replaced by new suite Xiao Qimai
  2020-05-14  9:54 ` [dts] [PATCH V1]vm2vm_virtio_pmd: delete unnecessary code Xiao Qimai
@ 2020-05-19  2:00 ` Tu, Lijuan
  1 sibling, 0 replies; 4+ messages in thread
From: Tu, Lijuan @ 2020-05-19  2:00 UTC (permalink / raw)
  To: Xiao, QimaiX, dts; +Cc: Xiao, QimaiX

Applied, thanks

> -----Original Message-----
> From: dts [mailto:dts-bounces@dpdk.org] On Behalf Of Xiao Qimai
> Sent: Thursday, May 14, 2020 5:55 PM
> To: dts@dpdk.org
> Cc: Xiao, QimaiX <qimaix.xiao@intel.com>
> Subject: [dts] [PATCH V1]pvp_virtio_user_multi_queues: delete old suite
> which has been replaced by new suite
> 
> *. this suite has been replaced by
> pvp_virtio_user_multi_queues_port_restart
> 
> Signed-off-by: Xiao Qimai <qimaix.xiao@intel.com>
> ---
>  tests/TestSuite_pvp_virtio_user_multi_queues.py | 310 ------------------------
>  1 file changed, 310 deletions(-)
>  delete mode 100644 tests/TestSuite_pvp_virtio_user_multi_queues.py
> 
> diff --git a/tests/TestSuite_pvp_virtio_user_multi_queues.py
> b/tests/TestSuite_pvp_virtio_user_multi_queues.py
> deleted file mode 100644
> index 4cde5b8..0000000
> --- a/tests/TestSuite_pvp_virtio_user_multi_queues.py
> +++ /dev/null
> @@ -1,310 +0,0 @@
> -# BSD LICENSE
> -#
> -# Copyright(c) 2010-2019 Intel Corporation. All rights reserved.
> -# All rights reserved.
> -#
> -# Redistribution and use in source and binary forms, with or without -#
> modification, are permitted provided that the following conditions -# are met:
> -#
> -#   * Redistributions of source code must retain the above copyright
> -#     notice, this list of conditions and the following disclaimer.
> -#   * Redistributions in binary form must reproduce the above copyright
> -#     notice, this list of conditions and the following disclaimer in
> -#     the documentation and/or other materials provided with the
> -#     distribution.
> -#   * Neither the name of Intel Corporation nor the names of its
> -#     contributors may be used to endorse or promote products derived
> -#     from this software without specific prior written permission.
> -#
> -# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
> CONTRIBUTORS -# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
> INCLUDING, BUT NOT -# LIMITED TO, THE IMPLIED WARRANTIES OF
> MERCHANTABILITY AND FITNESS FOR -# A PARTICULAR PURPOSE ARE
> DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT -# OWNER OR
> CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, -#
> SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
> -# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
> OF USE, -# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
> CAUSED AND ON ANY -# THEORY OF LIABILITY, WHETHER IN CONTRACT,
> STRICT LIABILITY, OR TORT -# (INCLUDING NEGLIGENCE OR OTHERWISE)
> ARISING IN ANY WAY OUT OF THE USE -# OF THIS SOFTWARE, EVEN IF
> ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
> -
> -"""
> -DPDK Test suite.
> -Test vhost/virtio-user loopback multi-queues on 8 tx/rx path.
> -Includes Mergeable, Normal, Vector_RX, Inorder mergeable, -Inorder no-
> mergeable, Virtio 1.1 mergeable, Virtio 1.1 no-mergeable Path, -Virtio 1.1
> inorder no-mergeable Path.
> -"""
> -
> -import utils
> -import time
> -import re
> -from settings import HEADER_SIZE
> -from test_case import TestCase
> -from pktgen import PacketGeneratorHelper
> -
> -
> -class TestPVPVirtioMultiQueues(TestCase):
> -
> -    def set_up_all(self):
> -        """
> -        Run at the start of each test suite.
> -        """
> -
> self.tester.extend_external_packet_generator(TestPVPVirtioMultiQueues,
> self)
> -        self.frame_sizes = [64, 128, 256, 512, 1024, 1518]
> -        self.core_config = "1S/6C/1T"
> -        self.queue_number = 2
> -        self.port_number = 2
> -        self.dut_ports = self.dut.get_ports()
> -        self.verify(len(self.dut_ports) >= 1, "Insufficient ports for testing")
> -        self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])
> -        self.cores_num = len([n for n in self.dut.cores if int(n['socket'])
> -                          == self.ports_socket])
> -        self.verify(self.cores_num >= 6,
> -                    "There has not enought cores to test this case")
> -        self.headers_size = HEADER_SIZE['eth'] + HEADER_SIZE['ip'] + \
> -            HEADER_SIZE['udp']
> -        self.core_list = self.dut.get_core_list(
> -            self.core_config, socket=self.ports_socket)
> -        self.core_list_user = self.core_list[0:3]
> -        self.core_list_host = self.core_list[3:6]
> -        self.dst_mac = self.dut.get_mac_address(self.dut_ports[0])
> -
> -        self.logger.info("you can config packet_size in file %s.cfg," %
> self.suite_name + \
> -                        "in region 'suite' like packet_sizes=[64, 128, 256]")
> -        # get the frame_sizes from cfg file
> -        if 'packet_sizes' in self.get_suite_cfg():
> -            self.frame_sizes = self.get_suite_cfg()['packet_sizes']
> -
> -        self.out_path = '/tmp'
> -        out = self.tester.send_expect('ls -d %s' % self.out_path, '# ')
> -        if 'No such file or directory' in out:
> -            self.tester.send_expect('mkdir -p %s' % self.out_path, '# ')
> -        # create an instance to set stream field setting
> -        self.pktgen_helper = PacketGeneratorHelper()
> -
> -    def set_up(self):
> -        """
> -        Run before each test case.
> -        """
> -        # Prepare the result table
> -        self.dut.send_expect("rm -rf ./vhost-net*", "#")
> -        self.dut.send_expect("killall -s INT testpmd", "#")
> -        self.table_header = ["Frame", "Mode", "Throughput(Mpps)", "%
> linerate"]
> -        self.result_table_create(self.table_header)
> -
> -        self.vhost_user = self.dut.new_session(suite="vhost-user")
> -        self.virtio_user = self.dut.new_session(suite="virtio-user")
> -
> -    @property
> -    def check_2M_env(self):
> -        out = self.dut.send_expect("cat /proc/meminfo |grep
> Hugepagesize|awk '{print($2)}'", "# ")
> -        return True if out == '2048' else False
> -
> -    def start_vhost_testpmd(self):
> -        """
> -        start testpmd on vhost
> -        """
> -        eal_param = self.dut.create_eal_parameters(socket=self.ports_socket,
> cores=self.core_list_host, prefix='vhost',
> -                                                   vdevs=['net_vhost0,iface=vhost-
> net,queues=2,client=0'])
> -        command_line_client = "./%s/app/testpmd " % self.target + eal_param
> + ' -- -i --nb-cores=2 --rxq=2 --txq=2 --rss-ip'
> -        self.vhost_user.send_expect(command_line_client, "testpmd> ", 120)
> -        self.vhost_user.send_expect("set fwd mac", "testpmd> ", 120)
> -        self.vhost_user.send_expect("start", "testpmd> ", 120)
> -
> -    def start_virtio_testpmd(self, args):
> -        """
> -        start testpmd on virtio
> -        """
> -        eal_param = self.dut.create_eal_parameters(socket=self.ports_socket,
> cores=self.core_list_user, prefix='virtio',
> -                                                   no_pci=True, vdevs=[
> -                'net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-
> net,queues=2,%s' % args["version"]])
> -        if self.check_2M_env:
> -            eal_param += " --single-file-segments"
> -        command_line_user = "./%s/app/testpmd " % self.target + eal_param +
> " -- -i %s --rss-ip --nb-cores=2 --rxq=2 --txq=2" % \
> -                            args["path"]
> -        self.virtio_user.send_expect(command_line_user, "testpmd> ", 120)
> -        self.virtio_user.send_expect("set fwd mac", "testpmd> ", 120)
> -        self.virtio_user.send_expect("start", "testpmd> ", 120)
> -
> -    def update_result_table(self, frame_size, case_info, Mpps, throughput):
> -        results_row = [frame_size]
> -        results_row.append(case_info)
> -        results_row.append(Mpps)
> -        results_row.append(throughput)
> -        self.result_table_add(results_row)
> -
> -    def check_packets_of_each_queue(self, frame_size):
> -        """
> -        check each queue has receive packets
> -        """
> -        out = self.vhost_user.send_expect("stop", "testpmd> ", 60)
> -        for port_index in range(0, self.port_number):
> -            for queue_index in range(0, self.queue_number):
> -                queue_info = re.findall("RX\s*Port=\s*%d/Queue=\s*%d" %
> -                                (port_index, queue_index),  out)
> -                queue = queue_info[0]
> -                index = out.find(queue)
> -                rx = re.search("RX-packets:\s*(\d*)", out[index:])
> -                tx = re.search("TX-packets:\s*(\d*)", out[index:])
> -                rx_packets = int(rx.group(1))
> -                tx_packets = int(tx.group(1))
> -                self.verify(rx_packets > 0 and tx_packets > 0,
> -                      "The queue %d rx-packets or tx-packets is 0 about " %
> -                      queue_index + \
> -                      "frame_size:%d, rx-packets:%d, tx-packets:%d" %
> -                      (frame_size, rx_packets, tx_packets))
> -
> -        self.vhost_user.send_expect("start", "testpmd> ", 60)
> -
> -    def set_fields(self):
> -        """
> -        set ip protocol field behavior
> -        """
> -        fields_config = {'ip':  {'dst': {'action': 'random'}, }, }
> -        return fields_config
> -
> -    def send_and_verify(self, case_info):
> -        """
> -        start to send packets and calculate avg throughput
> -        """
> -        for frame_size in self.frame_sizes:
> -            payload_size = frame_size - self.headers_size
> -            tgen_input = []
> -            port = self.tester.get_local_port(self.dut_ports[0])
> -
> self.tester.scapy_append('a=[Ether(dst="%s")/IP(src="0.240.74.101",proto=2
> 55)/UDP()/("X"*%d)]' % (self.dst_mac, payload_size))
> -            self.tester.scapy_append('wrpcap("%s/multiqueue.pcap" , a)' %
> self.out_path)
> -            self.tester.scapy_execute()
> -
> -            tgen_input.append((port, port, "%s/multiqueue.pcap" %
> self.out_path))
> -
> -            vm_config = self.set_fields()
> -            self.tester.pktgen.clear_streams()
> -            streams =
> self.pktgen_helper.prepare_stream_from_tginput(tgen_input, 100,
> vm_config, self.tester.pktgen)
> -            # set traffic option
> -            traffic_opt = {'delay': 5, 'duration': 20}
> -            _, pps = self.tester.pktgen.measure_throughput(stream_ids=streams,
> options=traffic_opt)
> -            Mpps = pps / 1000000.0
> -            self.verify(Mpps > 0, "can not receive packets of frame size %d" %
> (frame_size))
> -            throughput = Mpps * 100 / \
> -                        float(self.wirespeed(self.nic, frame_size, 1))
> -
> -            self.update_result_table(frame_size, case_info, Mpps, throughput)
> -            self.check_packets_of_each_queue(frame_size)
> -        self.result_table_print()
> -
> -    def close_all_testpmd(self):
> -        """
> -        close all testpmd of vhost and virtio
> -        """
> -        self.vhost_user.send_expect("quit", "#", 60)
> -        self.virtio_user.send_expect("quit", "#", 60)
> -
> -    def close_all_session(self):
> -        """
> -        close all session of vhost and vhost-user
> -        """
> -        self.dut.close_session(self.virtio_user)
> -        self.dut.close_session(self.vhost_user)
> -
> -    def test_perf_pvp_viritouser_multi_queue_virtio11_mergeable(self):
> -        """
> -        performance for Vhost PVP virtio 1.1 Mergeable Path.
> -        """
> -        virtio_pmd_arg = {"version": "in_order=0,packed_vq=1,mrg_rxbuf=1",
> -                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
> -        self.start_vhost_testpmd()
> -        self.start_virtio_testpmd(virtio_pmd_arg)
> -        self.send_and_verify("virtio_1.1 mergeable on")
> -        self.close_all_testpmd()
> -
> -    def test_perf_pvp_viritouser_multi_queue_virtio11_normal(self):
> -        """
> -        performance for Vhost PVP virtio1.1 Normal Path.
> -        """
> -        virtio_pmd_arg = {"version": "in_order=0,packed_vq=1,mrg_rxbuf=0",
> -                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
> -        self.start_vhost_testpmd()
> -        self.start_virtio_testpmd(virtio_pmd_arg)
> -        self.send_and_verify("virtio_1.1 mergeable off")
> -        self.close_all_testpmd()
> -
> -    def test_perf_pvp_viritouser_multi_queue_virtio11_inorder(self):
> -        """
> -        performance for Vhost PVP virtio1.1 inorder Path.
> -        """
> -        virtio_pmd_arg = {"version": "in_order=1,packed_vq=1,mrg_rxbuf=0",
> -                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
> -        self.start_vhost_testpmd()
> -        self.start_virtio_testpmd(virtio_pmd_arg)
> -        self.send_and_verify("virtio_1.1 inorder")
> -        self.close_all_testpmd()
> -
> -    def test_perf_pvp_viritouser_multi_queue_inorder_mergeable(self):
> -        """
> -        performance for Vhost PVP In_order mergeable Path.
> -        """
> -        virtio_pmd_arg = {"version": "packed_vq=0,in_order=1,mrg_rxbuf=1",
> -                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
> -        self.start_vhost_testpmd()
> -        self.start_virtio_testpmd(virtio_pmd_arg)
> -        self.send_and_verify("inoder mergeable on")
> -        self.close_all_testpmd()
> -
> -    def test_perf_pvp_viritouser_multi_queue_inorder_no_mergeable(self):
> -        """
> -        performance for Vhost PVP In_order no_mergeable Path.
> -        """
> -        virtio_pmd_arg = {"version": "packed_vq=0,in_order=1,mrg_rxbuf=0",
> -                        "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
> -        self.start_vhost_testpmd()
> -        self.start_virtio_testpmd(virtio_pmd_arg)
> -        self.send_and_verify("inoder mergeable off")
> -        self.close_all_testpmd()
> -
> -    def test_perf_pvp_viritouser_mulit_queue_mergeable(self):
> -        """
> -        performance for Vhost PVP Mergeable Path.
> -        """
> -        virtio_pmd_arg = {"version": "packed_vq=0,in_order=0,mrg_rxbuf=1",
> -                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
> -        self.start_vhost_testpmd()
> -        self.start_virtio_testpmd(virtio_pmd_arg)
> -        self.send_and_verify("virito mergeable")
> -        self.close_all_testpmd()
> -
> -    def test_perf_pvp_viritouser_multi_queue_normal(self):
> -        """
> -        performance for Vhost PVP Normal Path.
> -        """
> -        virtio_pmd_arg = {"version": "packed_vq=0,in_order=0,mrg_rxbuf=0",
> -                            "path": "--tx-offloads=0x0 --enable-hw-vlan-strip"}
> -        self.start_vhost_testpmd()
> -        self.start_virtio_testpmd(virtio_pmd_arg)
> -        self.send_and_verify("virtio normal")
> -        self.close_all_testpmd()
> -
> -    def test_perf_pvp_viritouser_multi_queue_vector_rx(self):
> -        """
> -        performance for Vhost PVP Vector_RX Path
> -        """
> -        virtio_pmd_arg = {"version": "packed_vq=0,in_order=0,mrg_rxbuf=0",
> -                            "path": "--tx-offloads=0x0"}
> -        self.start_vhost_testpmd()
> -        self.start_virtio_testpmd(virtio_pmd_arg)
> -        self.send_and_verify("virito vector rx")
> -        self.close_all_testpmd()
> -
> -    def tear_down(self):
> -        """
> -        Run after each test case.
> -        """
> -        self.dut.send_expect("killall -s INT testpmd", "#")
> -        self.close_all_session()
> -
> -    def tear_down_all(self):
> -        """
> -        Run after each test suite.
> -        """
> -        pass
> --
> 1.8.3.1


^ permalink raw reply	[flat|nested] 4+ messages in thread

end of thread, back to index

Thread overview: 4+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2020-05-14  9:54 [dts] [PATCH V1]pvp_virtio_user_multi_queues: delete old suite which has been replaced by new suite Xiao Qimai
2020-05-14  9:54 ` [dts] [PATCH V1]vm2vm_virtio_pmd: delete unnecessary code Xiao Qimai
2020-05-19  1:58   ` Tu, Lijuan
2020-05-19  2:00 ` [dts] [PATCH V1]pvp_virtio_user_multi_queues: delete old suite which has been replaced by new suite Tu, Lijuan

test suite reviews and discussions

Archives are clonable:
	git clone --mirror http://inbox.dpdk.org/dts/0 dts/git/0.git

	# If you have public-inbox 1.1+ installed, you may
	# initialize and index your mirror using the following commands:
	public-inbox-init -V2 dts dts/ http://inbox.dpdk.org/dts \
		dts@dpdk.org
	public-inbox-index dts


Newsgroup available over NNTP:
	nntp://inbox.dpdk.org/inbox.dpdk.dts


AGPL code for this site: git clone https://public-inbox.org/ public-inbox