Re: [dts] [PATCH V1] tests/vdev_primary_secondary:add testsuite vdev primary secondary

["Wang, Yinan" <yinan.wang@intel.com>]

Acked-by: Wang, Yinan <yinan.wang@intel.com>

> -----Original Message-----
> From: Zhu, ShuaiX
> Sent: 2019年8月12日 17:05
> To: dts@dpdk.org
> Cc: Wang, Yinan <yinan.wang@intel.com>; Zhu, ShuaiX <shuaix.zhu@intel.com>
> Subject: [dts][PATCH V1] tests/vdev_primary_secondary:add testsuite vdev
> primary secondary
> 
> Add a new testsuite vdev_primary_secondary.
> 
> Signed-off-by: zhu,shuai <shuaix.zhu@intel.com>
> ---
>  tests/TestSuite_vdev_primary_secondary.py | 183 ++++++++++++++++++++++
>  1 file changed, 183 insertions(+)
>  create mode 100644 tests/TestSuite_vdev_primary_secondary.py
> 
> diff --git a/tests/TestSuite_vdev_primary_secondary.py
> b/tests/TestSuite_vdev_primary_secondary.py
> new file mode 100644
> index 0000000..6f8f235
> --- /dev/null
> +++ b/tests/TestSuite_vdev_primary_secondary.py
> @@ -0,0 +1,183 @@
> +# BSD LICENSE
> +# Copyright (c) <2019>, Intel Corporation # 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.
> +This test is a multi-process test which demonstrates how multiple
> +processes can work together to perform packet I/O and packet processing
> +in parallel, much as other example application work by using multiple
> +threads. In this example, each process reads packets from all network
> +ports being used - though from a different RX queue in each case. Those
> +packets are then forwarded by each process which sends them out by writing
> them directly to a suitable TX queue.
> +"""
> +
> +import time
> +import re
> +import utils
> +from test_case import TestCase
> +from virt_common import VM
> +
> +
> +class TestVdevPrimarySecondary(TestCase):
> +
> +    def set_up_all(self):
> +        """
> +        Run at the start of each test suite.
> +        """
> +        self.queues = 2
> +        self.mem_channels = self.dut.get_memory_channels()
> +        self.dut_ports = self.dut.get_ports(self.nic)
> +        self.verify(len(self.dut_ports) >= 1, "Insufficient ports for testing")
> +        self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])
> +        cores = self.dut.get_core_list("1S/12C/1T", socket=self.ports_socket)
> +        self.coremask = utils.create_mask(cores)
> +        self.verify(len(self.coremask) >= 6, "The machine has too few
> + cores.")
> +
> +    def set_up(self):
> +        """
> +        Run before each test case.
> +        """
> +        self.dut.send_expect("rm -rf ./vhost-net*", "#")
> +        self.dut.send_expect("killall -s INT testpmd", "#")
> +        self.dut.send_expect("killall -s INT qemu-system-x86_64", "#")
> +
> +
> +    def setup_vm_env(self):
> +        """
> +        Create testing environment
> +        """
> +        self.virtio_mac = "52:54:00:00:00:0"
> +        self.vm = VM(self.dut, 'vm0', 'vhost_sample')
> +        for i in range(self.queues):
> +            vm_params = {}
> +            vm_params['driver'] = 'vhost-user'
> +            vm_params['opt_path'] = './vhost-net%d' % i
> +            vm_params['opt_mac'] = "%s%d" % (self.virtio_mac, i+2)
> +            vm_params['opt_queue'] = self.queues
> +            vm_params['opt_server'] = 'server'
> +            vm_params['opt_settings'] = 'mrg_rxbuf=on,mq=on,vectors=%d' %
> (2*self.queues+2)
> +            self.vm.set_vm_device(**vm_params)
> +
> +        try:
> +            self.vm_dut = self.vm.start()
> +            if self.vm_dut is None:
> +                raise Exception("Set up VM ENV failed")
> +        except Exception as e:
> +            self.logger.error("ERROR: Failure for %s" % str(e))
> +
> +        return True
> +
> +
> +    def launch_testpmd(self):
> +        """
> +        launch testpmd
> +        """
> +        cmd = "./%s/app/testpmd -l 1-6 -n %d --socket-mem 2048,2048
> --legacy-mem --file-prefix=vhost" + \
> +              " --vdev 'net_vhost0,iface=vhost-net0,queues=%d,client=1'" +
> \
> +              " --vdev 'net_vhost1,iface=vhost-net1,queues=%d,client=1'" +
> \
> +              " -- -i --nb-cores=4 --rxq=%d --txq=%d --txd=1024 --rxd=1024"
> +        start_cmd = cmd % (self.target, self.mem_channels, self.queues,
> self.queues, self.queues, self.queues)
> +        self.dut.send_expect(start_cmd, "testpmd> ", 120)
> +        self.dut.send_expect("set fwd txonly", "testpmd> ", 120)
> +        self.dut.send_expect("start", "testpmd> ", 120)
> +
> +
> +    def launch_examples(self):
> +        example_cmd_auto =
> "./examples/multi_process/symmetric_mp/build/symmetric_mp -l 0 -n %d
> --proc-type=auto -- -p 3 --num-procs=%d --proc-id=0"
> +        example_cmd_secondary =
> "./examples/multi_process/symmetric_mp/build/symmetric_mp -l 1 -n %d
> --proc-type=secondary -- -p 3 --num-procs=%d --proc-id=1"
> +        final_cmd_first = example_cmd_auto % (self.mem_channels,
> self.queues)
> +        final_cmd_secondary = example_cmd_secondary %
> (self.mem_channels, self.queues)
> +        self.vhost_first.send_expect(final_cmd_first, " ", 120)
> +        self.vhost_secondary.send_expect(final_cmd_secondary, " ", 120)
> +
> +
> +    def prepare_symmetric_mp(self):
> +
> self.vm_dut.send_expect("cp ./examples/multi_process/symmetric_mp/main.c
> .", "#")
> +        self.vm_dut.send_expect(
> +                "sed -i '/.offloads =
> DEV_RX_OFFLOAD_CHECKSUM,/d' ./examples/multi_process/symmetric_mp/m
> ain.c", "#")
> +        out =
> self.vm_dut.build_dpdk_apps('./examples/multi_process/symmetric_mp')
> +        self.verify("Error" not in out, "compilation symmetric_mp
> + error")
> +
> +
> +    def restore_symmetric_mp_env(self):
> +
> self.vm_dut.send_expect("\cp ./main.c ./examples/multi_process/symmetric_m
> p/", "#", 15)
> +        out =
> self.vm_dut.build_dpdk_apps('./examples/multi_process/symmetric_mp')
> +        self.verify("Error" not in out, "compilation symmetric_mp
> + error")
> +
> +    def close_session(self):
> +        self.vm_dut.close_session(self.vhost_first)
> +        self.vm_dut.close_session(self.vhost_secondary)
> +
> +
> +    def test_Virtio_primary_and_secondary_process(self):
> +        # start testpmd
> +        self.launch_testpmd()
> +        self.setup_vm_env()
> +        # Modify code
> +        self.prepare_symmetric_mp()
> +        # create 2 new session
> +        self.vhost_first = self.vm_dut.new_session(suite="vhost_first")
> +        self.vhost_secondary =
> self.vm_dut.new_session(suite="vhsot_secondary")
> +        # start symmetric_mp
> +        self.launch_examples()
> +        time.sleep(3)
> +        vhost_first_out =  self.vhost_first.send_expect("^c", "#", 15)
> +        print vhost_first_out
> +        time.sleep(3)
> +        vhost_secondary_out = self.vhost_secondary.send_expect("^c", "#",
> 15)
> +        print vhost_secondary_out
> +        result_first = re.findall(r'Port \d: RX - (\w+)', vhost_first_out)
> +        result_secondary = re.findall(r'Port \d: RX - (\w+)',
> vhost_secondary_out)
> +        self.verify(len(result_first[0]) != 0 and len(result_first[1]) != 0 and
> len(result_secondary[0]) != 0 and len(result_secondary[1]) != 0, "RX no data")
> +        self.dut.send_expect("quit", "#", 15)
> +
> +    def tear_down(self):
> +        """
> +        Run after each test case.
> +        """
> +        self.restore_symmetric_mp_env()
> +        self.close_session()
> +        self.vm_dut.kill_all()
> +        self.dut.kill_all()
> +        self.vm.stop()
> +        self.dut.send_expect("killall -s INT testpmd", "#")
> +        self.dut.send_expect("killall -s INT qemu-system-x86_64", "#")
> +        time.sleep(2)
> +
> +
> +
> +    def tear_down_all(self):
> +        """
> +        Run after each test suite.
> +        """
> +        pass
> --
> 2.17.2