* [dts] [PATCH V1] tests/vdev_primary_secondary:add testsuite vdev primary secondary
@ 2019-08-12 9:05 zhu,shuai
2019-08-13 6:40 ` Wang, Yinan
2019-08-21 9:34 ` Tu, Lijuan
0 siblings, 2 replies; 3+ messages in thread
From: zhu,shuai @ 2019-08-12 9:05 UTC (permalink / raw)
To: dts; +Cc: yinan.wang, zhu,shuai
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/main.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_mp/", "#", 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
^ permalink raw reply [flat|nested] 3+ messages in thread
* Re: [dts] [PATCH V1] tests/vdev_primary_secondary:add testsuite vdev primary secondary
2019-08-12 9:05 [dts] [PATCH V1] tests/vdev_primary_secondary:add testsuite vdev primary secondary zhu,shuai
@ 2019-08-13 6:40 ` Wang, Yinan
2019-08-21 9:34 ` Tu, Lijuan
1 sibling, 0 replies; 3+ messages in thread
From: Wang, Yinan @ 2019-08-13 6:40 UTC (permalink / raw)
To: Zhu, ShuaiX, dts
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
^ permalink raw reply [flat|nested] 3+ messages in thread
* Re: [dts] [PATCH V1] tests/vdev_primary_secondary:add testsuite vdev primary secondary
2019-08-12 9:05 [dts] [PATCH V1] tests/vdev_primary_secondary:add testsuite vdev primary secondary zhu,shuai
2019-08-13 6:40 ` Wang, Yinan
@ 2019-08-21 9:34 ` Tu, Lijuan
1 sibling, 0 replies; 3+ messages in thread
From: Tu, Lijuan @ 2019-08-21 9:34 UTC (permalink / raw)
To: Zhu, ShuaiX, dts; +Cc: Wang, Yinan, Zhu, ShuaiX
Applied, thanks
> -----Original Message-----
> From: dts [mailto:dts-bounces@dpdk.org] On Behalf Of zhu,shuai
> Sent: Monday, August 12, 2019 5:05 PM
> 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/
> main.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
> _mp/", "#", 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
^ permalink raw reply [flat|nested] 3+ messages in thread
end of thread, other threads:[~2019-08-21 9:34 UTC | newest]
Thread overview: 3+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2019-08-12 9:05 [dts] [PATCH V1] tests/vdev_primary_secondary:add testsuite vdev primary secondary zhu,shuai
2019-08-13 6:40 ` Wang, Yinan
2019-08-21 9:34 ` Tu, Lijuan
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).