From: "Wang, Yinan" <yinan.wang@intel.com>
To: "Ma, LihongX" <lihongx.ma@intel.com>, "dts@dpdk.org" <dts@dpdk.org>
Subject: Re: [dts] [PATCH V1] tests: add test suite vm2vm virtio user
Date: Fri, 27 Dec 2019 08:29:45 +0000 [thread overview]
Message-ID: <E0CBA5A1980F1F408E1F28F9991B5B1D50F6A5C6@SHSMSX104.ccr.corp.intel.com> (raw)
In-Reply-To: <1577300825-8227-1-git-send-email-lihongx.ma@intel.com>
Acked-by: Wang, Yinan <yinan.wang@intel.com>
> -----Original Message-----
> From: Ma, LihongX <lihongx.ma@intel.com>
> Sent: 2019年12月26日 3:07
> To: dts@dpdk.org
> Cc: Wang, Yinan <yinan.wang@intel.com>; Ma, LihongX
> <lihongx.ma@intel.com>
> Subject: [dts][PATCH V1] tests: add test suite vm2vm virtio user
>
> Signed-off-by: lihong <lihongx.ma@intel.com>
> ---
> tests/TestSuite_vm2vm_virtio_user.py | 538
> +++++++++++++++++++++++++++++++++++
> 1 file changed, 538 insertions(+)
> create mode 100644 tests/TestSuite_vm2vm_virtio_user.py
>
> diff --git a/tests/TestSuite_vm2vm_virtio_user.py
> b/tests/TestSuite_vm2vm_virtio_user.py
> new file mode 100644
> index 0000000..17bee0e
> --- /dev/null
> +++ b/tests/TestSuite_vm2vm_virtio_user.py
> @@ -0,0 +1,538 @@
> +# 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.
> +
> +Test cases for vm2vm virtio-user
> +This suite include split virtqueue vm2vm in-order mergeable, in-order
> +non-mergeable, mergeable, non-mergeable, vector_rx path test and packed
> +virtqueue vm2vm in-order mergeable, in-order non-mergeable, mergeable,
> +non-mergeable path test """
> +import re
> +import time
> +import utils
> +from test_case import TestCase
> +from packet import Packet
> +from pmd_output import PmdOutput
> +
> +
> +class TestVM2VMVirtioUser(TestCase):
> + def set_up_all(self):
> + self.memory_channel = self.dut.get_memory_channels()
> + self.dump_virtio_pcap = "/tmp/pdump-virtio-rx.pcap"
> + self.dump_vhost_pcap = "/tmp/pdump-vhost-rx.pcap"
> + self.vhost_prefix = 'vhost'
> + self.virtio_prefix = 'virtio'
> + socket_num = len(set([int(core['socket']) for core in self.dut.cores]))
> + self.socket_mem = ','.join(['1024']*socket_num)
> + self.get_core_list()
> + self.rebuild_flag = False
> + self.config_value = 'CONFIG_RTE_LIBRTE_PMD_PCAP'
> + self.enable_pcap_lib_in_dpdk(self.dut)
> +
> + def set_up(self):
> + """
> + run before each test case.
> + """
> + self.dut.send_expect("rm -rf ./vhost-net*", "#")
> + self.dut.send_expect("rm -rf %s" % self.dump_virtio_pcap, "#")
> + self.dut.send_expect("rm -rf %s" % self.dump_vhost_pcap, "#")
> +
> + def get_core_list(self):
> + """
> + create core mask
> + """
> + self.core_config = "1S/6C/1T"
> + self.cores_list = self.dut.get_core_list(self.core_config)
> + self.verify(len(self.cores_list) >= 6, 'There no enough cores to run this
> suite')
> + self.core_list_vhost = self.cores_list[0:2]
> + self.core_list_virtio0 = self.cores_list[2:4]
> + self.core_list_virtio1 = self.cores_list[4:6]
> +
> + self.vhost_user = self.dut.new_session(suite="vhost-user")
> + self.virtio_user0 = self.dut.new_session(suite="virtio-user0")
> + self.virtio_user1 = self.dut.new_session(suite="virtio-user1")
> + self.pdump_session = self.dut.new_session(suite="pdump")
> + self.pmd_vhost = PmdOutput(self.dut, self.vhost_user)
> + self.pmd_virtio0 = PmdOutput(self.dut, self.virtio_user0)
> + self.pmd_virtio1 = PmdOutput(self.dut, self.virtio_user1)
> +
> + def enable_pcap_lib_in_dpdk(self, client_dut):
> + """
> + enable pcap lib in dpdk code and recompile
> + """
> + out = self.dut.send_command('cat config/common_base',
> timeout=3)
> + pcap = re.search('%s=(\S*)' % self.config_value, out)
> + self.verify(pcap is not None, 'The config:%s can not find in
> common_base' % self.config_value)
> + default_value = pcap.group(1)
> + if str.lower(default_value) != 'y':
> + client_dut.send_expect("sed -i 's/%s=n$/%s=y/'
> config/common_base" % (
> + self.config_value, self.config_value), '# ')
> + client_dut.build_install_dpdk(self.target)
> + self.rebuild_flag = True
> +
> + def disable_pcap_lib_in_dpdk(self, client_dut):
> + """
> + reset pcap lib in dpdk and recompile
> + """
> + if self.rebuild_flag is True:
> + client_dut.send_expect("sed -i 's/%s=y$/%s=n/'
> config/common_base" %
> + (self.config_value, self.config_value), "#")
> + client_dut.build_install_dpdk(self.target)
> +
> + def launch_vhost_testpmd(self, vdev_num, fixed_prefix=False,
> fwd_mode='io'):
> + eal_params =
> self.dut.create_eal_parameters(cores=self.core_list_vhost,
> + no_pci=True, prefix=self.vhost_prefix,
> fixed_prefix=fixed_prefix)
> + vdev_params = ''
> + for i in range(vdev_num):
> + vdev_params += "--vdev
> + 'net_vhost%d,iface=./vhost-net%d,queues=1' " % (i, i)
> +
> + self.command_line = self.dut.target + '/app/testpmd %s ' + \
> + '--socket-mem %s %s -- -i --nb-cores=1 --no-flush-rx'
> +
> + self.command_line = self.command_line % (
> + eal_params, self.socket_mem,
> vdev_params)
> + self.pmd_vhost.execute_cmd(self.command_line, timeout=30)
> + self.pmd_vhost.execute_cmd('set fwd %s' % fwd_mode)
> +
> + def start_virtio_testpmd_with_vhost_net1(self, path_mode,
> extern_params=''):
> + """
> + launch the testpmd as virtio with vhost_net1
> + """
> + eal_params =
> self.dut.create_eal_parameters(cores=self.core_list_virtio1,
> + no_pci=True, prefix=self.virtio_prefix, fixed_prefix=True)
> + vdev_params =
> '--vdev=net_virtio_user1,mac=00:01:02:03:04:05,path=./vhost-net1,queues=1,
> %s ' % path_mode
> + command_line = self.dut.target + "/app/testpmd %s " + \
> + "--socket-mem %s %s -- -i --nb-cores=1 --txd=256 --rxd=256 %s"
> + command_line = command_line % (eal_params, self.socket_mem,
> + vdev_params, extern_params)
> + self.pmd_virtio1.execute_cmd(command_line, timeout=30)
> + self.pmd_virtio1.execute_cmd('set fwd rxonly')
> + self.pmd_virtio1.execute_cmd('start')
> +
> + def start_virtio_testpmd_with_vhost_net0(self, path_mode,
> extern_params=''):
> + """
> + launch the testpmd as virtio with vhost_net0
> + and start to send 251 small packets with diff burst
> + """
> + eal_params =
> self.dut.create_eal_parameters(cores=self.core_list_virtio0,
> + no_pci=True, prefix='virtio0')
> + vdev_params =
> '--vdev=net_virtio_user0,mac=00:01:02:03:04:05,path=./vhost-net0,queues=1,
> %s ' % path_mode
> + command_line = self.dut.target + '/app/testpmd %s ' + \
> + '--socket-mem %s %s -- -i --nb-cores=1 --txd=256 --rxd=256 %s'
> + command_line = command_line % (eal_params, self.socket_mem,
> + vdev_params, extern_params)
> +
> + self.pmd_virtio0.execute_cmd(command_line, timeout=30)
> + self.pmd_virtio0.execute_cmd('set burst 1')
> + self.pmd_virtio0.execute_cmd('start tx_first 27')
> + self.pmd_virtio0.execute_cmd('stop')
> + self.pmd_virtio0.execute_cmd('set burst 32')
> + self.pmd_virtio0.execute_cmd('start tx_first 7')
> +
> + def resend_32_large_pkt_from_virtio0(self):
> + self.pmd_virtio0.execute_cmd('stop')
> + self.pmd_virtio0.execute_cmd('set burst 32')
> + self.pmd_virtio0.execute_cmd('set txpkts 2000')
> + self.pmd_virtio0.execute_cmd('start tx_first 1')
> +
> + def launch_pdump_to_capture_pkt(self, dump_port, file_prefix,
> filename):
> + """
> + launch pdump app with dump_port and file_prefix
> + the pdump app should start after testpmd started
> + if dump the vhost-testpmd, the vhost-testpmd should started before
> launch pdump
> + if dump the virtio-testpmd, the virtio-testpmd should started before
> launch pdump
> + """
> + eal_params = self.dut.create_eal_parameters(cores='Default',
> + prefix=file_prefix, fixed_prefix=True)
> + command_line = self.target + "/app/dpdk-pdump %s -v -- " + \
> + "--pdump '%s,queue=*,rx-dev=%s,mbuf-size=8000'"
> + self.pdump_session.send_expect(command_line % (eal_params,
> + dump_port, filename), 'Port')
> +
> + def get_dump_file_of_virtio_user(self, path_mode, extern_param=''):
> + """
> + get the dump file of virtio user
> + the virtio_user0 always send 251 small pkts + 32 large pkts(8k) to
> verify
> + how many pkts can received by virtio1
> + """
> + dump_port = 'device_id=net_virtio_user1'
> + self.launch_vhost_testpmd(vdev_num=2)
> + self.start_virtio_testpmd_with_vhost_net1(path_mode,
> extern_param)
> + self.launch_pdump_to_capture_pkt(dump_port, self.virtio_prefix,
> self.dump_virtio_pcap)
> + # the virtio0 will send 251 small pkts
> + self.start_virtio_testpmd_with_vhost_net0(path_mode,
> extern_param)
> + # then send 32 large pkts
> + self.pmd_virtio0.execute_cmd('stop')
> + self.pmd_virtio0.execute_cmd('set burst 32')
> + self.pmd_virtio0.execute_cmd('set txpkts 2000,2000,2000,2000')
> + self.pmd_virtio0.execute_cmd('start tx_first 1')
> + # packet will fwd after vhost testpmd start
> + self.pmd_vhost.execute_cmd('start')
> +
> + def get_dump_file_of_vhost_user(self, path_mode, extern_param=''):
> + """
> + get the dump file of vhost testpmd
> + the virtio0 will alway send 251 small pkts + some large pkts(depend
> on
> + diff path_mode send diff pkts num) to verify how many pkts can
> received by vhost
> + """
> + dump_port = 'port=0'
> + self.launch_vhost_testpmd(vdev_num=1, fixed_prefix=True,
> fwd_mode='rxonly')
> + self.pmd_vhost.execute_cmd('start')
> + self.launch_pdump_to_capture_pkt(dump_port, self.vhost_prefix,
> self.dump_vhost_pcap)
> + # the virtio0 send 251 small pkts
> + self.start_virtio_testpmd_with_vhost_net0(path_mode,
> extern_param)
> + # if the path_mode is mergeable, then send large pkt to verify
> + # and packed mergeable and split mergeable is diff about large pkt
> + # in packed mergeable, 1 large pkt will occupies 5 ring, so send 1
> large pkt to verify
> + # in split mergeable, 1 large pkt will occupied 1 ring, so send 5 large
> pkt to verify
> + mergeable = re.search('mrg_rxbuf\s*=\s*1', path_mode)
> + split = re.search('packed_vq\s*=\s*0', path_mode)
> + no_inorder = re.search('in_order\s*=\s*0', path_mode)
> + pkt_num = 1
> + if split and mergeable and no_inorder:
> + pkt_num = 5
> + if mergeable:
> + self.pmd_virtio0.execute_cmd('stop')
> + self.pmd_virtio0.execute_cmd('set burst %d' % pkt_num)
> + self.pmd_virtio0.execute_cmd('set txpkts
> 2000,2000,2000,2000')
> + self.pmd_virtio0.execute_cmd('start tx_first 1')
> +
> + def check_packet_payload_valid(self, filename, small_pkts_num,
> large_8k_pkts_num, large_2k_pkts_num):
> + """
> + check the payload is valid
> + """
> + # stop pdump
> + total_pkts_num = small_pkts_num + large_8k_pkts_num +
> large_2k_pkts_num
> + time.sleep(2)
> + self.pdump_session.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()
> + pkts = pkt.read_pcapfile(filename)
> + self.verify(pkts is not None and len(pkts) == total_pkts_num,
> + "The virtio/vhost do not capture all the packets"
> + "expect pkt num is: %d, actual pkt num is: %d" %
> (total_pkts_num, len(pkts)))
> + for i in range(len(pkts)):
> + if i < small_pkts_num:
> + pkt_len = 64
> + elif i >= small_pkts_num and i <
> small_pkts_num+large_8k_pkts_num:
> + pkt_len = 8000
> + else:
> + pkt_len = 2000
> + self.verify(len(pkts[i]) == pkt_len, 'the received pkts len is wrong,'
> + 'the received pkt len is: %d, expect pkt len is:
> + %d' % (len(pkts[i]), pkt_len))
> +
> + def check_vhost_and_virtio_pkts_content(self):
> + """
> + vhost received pkts in self.dump_vhost_pcap, virtio received pkts
> self.dump_virtio_pcap
> + check headers and payload of all pkts are same.
> + """
> + pk_rx_virtio = Packet()
> + pk_rx_vhost = Packet()
> + pk_rx_virtio.read_pcapfile(self.dump_virtio_pcap)
> + pk_rx_vhost.read_pcapfile(self.dump_vhost_pcap)
> + # check the headers and payload is same of vhost and virtio
> + for i in range(len(pk_rx_virtio)):
> + self.verify(pk_rx_virtio[i].haslayer('Raw'), 'The pkt index %d,
> virtio pkt has no layer Raw' % i)
> + self.verify(pk_rx_vhost[i].haslayer('Raw'), 'The pkt index %d,
> vhost pkt has no layer Raw' % i)
> + self.verify(pk_rx_virtio[i].haslayer('UDP'), 'The pkt index %d,
> virtio pkt has no layer UDP' % i)
> + self.verify(pk_rx_vhost[i].haslayer('UDP'), 'The pkt index %d,
> vhost pkt has no layer UDP' % i)
> + rx_virtio_load = pk_rx_virtio[i]['Raw'].load
> + rx_vhost_load = pk_rx_vhost[i]['Raw'].load
> + rx_virtio_head = pk_rx_virtio[i]['UDP'].remove_payload()
> + rx_vhost_head = pk_rx_vhost[i]['UDP'].remove_payload()
> + # check header is same
> + self.verify(pk_rx_virtio[i] == pk_rx_vhost[i], 'the head is different
> on index: %d' % i + \
> + 'virtio head: %s, vhost head: %s' %
> (pk_rx_virtio[i].show, pk_rx_vhost[i].show()))
> + # check payload is same
> + self.verify(len(rx_virtio_load) == len(rx_vhost_load),
> + 'the len is diff between virtio pcap and vhost pcap,'
> + 'virtio len:%d, vhost len: %d' % (len(rx_virtio_load),
> len(rx_vhost_load)))
> + diff_list = [s for s in range(len(rx_virtio_load)) if
> rx_virtio_load[s] != rx_vhost_load[s]]
> + self.verify(len(diff_list) == 0, 'there have some diff between the
> load of virtio and vhost pcap' + \
> + 'pkt index is: %d, the load index include %s' % (i,
> + diff_list))
> +
> + def quit_all_testpmd(self):
> + self.pmd_vhost.quit()
> + self.pmd_virtio0.quit()
> + self.pmd_virtio1.quit()
> + self.pdump_session.send_expect('^c', '# ', 60)
> +
> + def test_vm2vm_virtio_user_packed_virtqueue_mergeable_path(self):
> + """
> + packed virtqueue vm2vm 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
> + """
> + small_pkts_num = 251
> + large_8k_pkts_num = 1
> + large_2k_pkts_num = 32
> + path_mode = 'packed_vq=1,mrg_rxbuf=1,in_order=0'
> + # get dump pcap file of virtio
> + # the virtio0 will send 283 pkts, but the virtio only will received 252
> pkts
> + # then resend 32 large pkts, all will received
> + self.logger.info('check pcap file info about virtio')
> + self.get_dump_file_of_virtio_user(path_mode)
> + self.resend_32_large_pkt_from_virtio0()
> + self.check_packet_payload_valid(self.dump_virtio_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + # get dump pcap file of vhost
> + self.logger.info('check pcap file info about vhost')
> + self.get_dump_file_of_vhost_user(path_mode)
> + self.resend_32_large_pkt_from_virtio0()
> + self.check_packet_payload_valid(self.dump_vhost_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + self.logger.info('diff the pcap file of vhost and virtio')
> + self.check_vhost_and_virtio_pkts_content()
> +
> + 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
> + """
> + small_pkts_num = 251
> + large_8k_pkts_num = 1
> + large_2k_pkts_num = 0
> + path_mode = 'packed_vq=1,mrg_rxbuf=1,in_order=1'
> + # 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')
> + self.get_dump_file_of_virtio_user(path_mode)
> + self.check_packet_payload_valid(self.dump_virtio_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + # get dump pcap file of vhost
> + self.logger.info('check pcap file info about vhost')
> + self.get_dump_file_of_vhost_user(path_mode)
> + self.check_packet_payload_valid(self.dump_vhost_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + self.logger.info('diff the pcap file of vhost and virtio')
> + self.check_vhost_and_virtio_pkts_content()
> +
> + def
> test_vm2vm_virtio_user_packed_virtqueue_no_mergeable_path(self):
> + """
> + packed virtqueue vm2vm non-mergeable path test
> + about non-mergeable path, it can not received large pkts
> + """
> + small_pkts_num = 251
> + large_8k_pkts_num = 0
> + large_2k_pkts_num = 0
> + path_mode = 'packed_vq=1,mrg_rxbuf=0,in_order=0'
> + # get dump pcap file of virtio
> + # the virtio0 will send 283 pkts, but the virtio only will received 251
> pkts
> + # the no-mergeable path can not received large pkts
> + self.logger.info('check pcap file info about virtio')
> + self.get_dump_file_of_virtio_user(path_mode)
> + self.check_packet_payload_valid(self.dump_virtio_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + # get dump pcap file of vhost
> + self.logger.info('check pcap file info about vhost')
> + self.get_dump_file_of_vhost_user(path_mode)
> + self.check_packet_payload_valid(self.dump_vhost_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + self.logger.info('diff the pcap file of vhost and virtio')
> + self.check_vhost_and_virtio_pkts_content()
> +
> + def
> test_vm2vm_virtio_user_packed_virtqueue_inorder_no_mergeable_path(self):
> + """
> + packed virtqueue vm2vm inorder non-mergeable path test
> + about non-mergeable path, it can not received large pkts
> + """
> + small_pkts_num = 251
> + large_8k_pkts_num = 0
> + large_2k_pkts_num = 0
> + path_mode = 'packed_vq=1,mrg_rxbuf=0,in_order=1'
> + # get dump pcap file of virtio
> + # the virtio0 will send 283 pkts, but the virtio only will received 251
> pkts
> + # the no-mergeable path can not received large pkts
> + self.logger.info('check pcap file info about virtio')
> + self.get_dump_file_of_virtio_user(path_mode)
> + self.check_packet_payload_valid(self.dump_virtio_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + # get dump pcap file of vhost
> + self.logger.info('check pcap file info about vhost')
> + self.get_dump_file_of_vhost_user(path_mode)
> + self.check_packet_payload_valid(self.dump_vhost_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + self.logger.info('diff the pcap file of vhost and virtio')
> + self.check_vhost_and_virtio_pkts_content()
> +
> + def test_vm2vm_virtio_user_split_virtqueue_mergeable_path(self):
> + """
> + 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
> + """
> + small_pkts_num = 251
> + large_8k_pkts_num = 5
> + large_2k_pkts_num = 32
> + path_mode = 'packed_vq=0,mrg_rxbuf=1,in_order=0'
> + # get dump pcap file of virtio
> + # the virtio0 will send 283 pkts, but the virtio only will received 256
> pkts
> + # then virtio send 32 large pkts, the virtio will all received
> + self.logger.info('check pcap file info about virtio')
> + self.get_dump_file_of_virtio_user(path_mode)
> + self.resend_32_large_pkt_from_virtio0()
> + self.check_packet_payload_valid(self.dump_virtio_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + # get dump pcap file of vhost
> + self.logger.info('check pcap file info about vhost')
> + self.get_dump_file_of_vhost_user(path_mode)
> + self.resend_32_large_pkt_from_virtio0()
> + self.check_packet_payload_valid(self.dump_vhost_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + self.logger.info('diff the pcap file of vhost and virtio')
> + self.check_vhost_and_virtio_pkts_content()
> +
> + def
> test_vm2vm_virtio_user_split_virtqueue_inorder_mergeable_path(self):
> + """
> + 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
> + """
> + small_pkts_num = 251
> + large_8k_pkts_num = 1
> + large_2k_pkts_num = 0
> + path_mode = 'packed_vq=0,mrg_rxbuf=1,in_order=1'
> + # 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')
> + self.get_dump_file_of_virtio_user(path_mode)
> + self.check_packet_payload_valid(self.dump_virtio_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + # get dump pcap file of vhost
> + self.logger.info('check pcap file info about vhost')
> + self.get_dump_file_of_vhost_user(path_mode)
> + self.check_packet_payload_valid(self.dump_vhost_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + self.logger.info('diff the pcap file of vhost and virtio')
> + self.check_vhost_and_virtio_pkts_content()
> +
> + def test_vm2vm_virtio_user_split_virtqueue_no_mergeable_path(self):
> + """
> + split virtqueue vm2vm non-mergeable path test
> + about non-mergeable path, it can not received large pkts
> + """
> + small_pkts_num = 251
> + large_8k_pkts_num = 0
> + large_2k_pkts_num = 0
> + path_mode = 'packed_vq=0,mrg_rxbuf=0,in_order=0'
> + extern_params = '--enable-hw-vlan-strip'
> + # get dump pcap file of virtio
> + # the virtio0 will send 283 pkts, but the virtio only will received 251
> pkts
> + self.logger.info('check pcap file info about virtio')
> + self.get_dump_file_of_virtio_user(path_mode, extern_params)
> + self.check_packet_payload_valid(self.dump_virtio_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + # get dump pcap file of vhost
> + self.logger.info('check pcap file info about vhost')
> + self.get_dump_file_of_vhost_user(path_mode, extern_params)
> + self.check_packet_payload_valid(self.dump_vhost_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + self.logger.info('diff the pcap file of vhost and virtio')
> + self.check_vhost_and_virtio_pkts_content()
> +
> + def
> test_vm2vm_virtio_user_split_virtqueue_inorder_no_mergeable_path(self):
> + """
> + split virtqueue vm2vm inorder non-mergeable path test
> + about non-mergeable path, it can not received large pkts
> + """
> + small_pkts_num = 251
> + large_8k_pkts_num = 0
> + large_2k_pkts_num = 0
> + path_mode = 'packed_vq=0,mrg_rxbuf=0,in_order=1'
> + # get dump pcap file of virtio
> + # the virtio0 will send 283 pkts, but the virtio only will received 251
> pkts
> + self.logger.info('check pcap file info about virtio')
> + self.get_dump_file_of_virtio_user(path_mode)
> + self.check_packet_payload_valid(self.dump_virtio_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + # get dump pcap file of vhost
> + self.logger.info('check pcap file info about vhost')
> + self.get_dump_file_of_vhost_user(path_mode)
> + self.check_packet_payload_valid(self.dump_vhost_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + self.logger.info('diff the pcap file of vhost and virtio')
> + self.check_vhost_and_virtio_pkts_content()
> +
> + def test_vm2vm_virtio_user_split_virtqueue_vector_rx_path(self):
> + """
> + split virtqueue vm2vm vector_rx path test
> + about vector_rx path, it can not received large pkts
> + """
> + small_pkts_num = 251
> + large_8k_pkts_num = 0
> + large_2k_pkts_num = 0
> + path_mode = 'packed_vq=0,mrg_rxbuf=0,in_order=0'
> + # get dump pcap file of virtio
> + # the virtio0 will send 283 pkts, but the virtio only will received 251
> pkts
> + self.logger.info('check pcap file info about virtio')
> + self.get_dump_file_of_virtio_user(path_mode)
> + self.check_packet_payload_valid(self.dump_virtio_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + # get dump pcap file of vhost
> + self.logger.info('check pcap file info about vhost')
> + self.get_dump_file_of_vhost_user(path_mode)
> + self.check_packet_payload_valid(self.dump_vhost_pcap,
> + small_pkts_num, large_8k_pkts_num, large_2k_pkts_num)
> +
> + self.logger.info('diff the pcap file of vhost and virtio')
> + self.check_vhost_and_virtio_pkts_content()
> +
> + def close_all_session(self):
> + if getattr(self, 'vhost_user', None):
> + self.dut.close_session(self.vhost_user)
> + if getattr(self, 'virtio-user0', None):
> + self.dut.close_session(self.virtio-user0)
> + if getattr(self, 'virtio-user1', None):
> + self.dut.close_session(self.virtio-user1)
> + if getattr(self, 'pdump_session', None):
> + self.dut.close_session(self.pdump_session)
> +
> + def tear_down(self):
> + #
> + # Run after each test case.
> + #
> + self.dut.kill_all()
> + time.sleep(2)
> +
> + def tear_down_all(self):
> + """
> + Run after each test suite.
> + """
> + self.disable_pcap_lib_in_dpdk(self.dut)
> + self.close_all_session()
> --
> 2.7.4
next prev parent reply other threads:[~2019-12-27 8:29 UTC|newest]
Thread overview: 4+ messages / expand[flat|nested] mbox.gz Atom feed top
2019-12-25 19:07 lihong
2019-12-27 8:29 ` Wang, Yinan [this message]
2020-01-02 2:18 ` Tu, Lijuan
2020-01-02 2:18 ` Tu, Lijuan
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=E0CBA5A1980F1F408E1F28F9991B5B1D50F6A5C6@SHSMSX104.ccr.corp.intel.com \
--to=yinan.wang@intel.com \
--cc=dts@dpdk.org \
--cc=lihongx.ma@intel.com \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
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).