* [dts] [PATCH V1] tests/runtime_vf_queue_number:add testsuite for runtime vf queue number
@ 2019-04-22 3:25 Jianwei Mei
2019-04-22 9:55 ` Xiao, QimaiX
2019-04-23 18:28 ` Tu, Lijuan
0 siblings, 2 replies; 3+ messages in thread
From: Jianwei Mei @ 2019-04-22 3:25 UTC (permalink / raw)
To: dts; +Cc: Jianwei Mei
add testsuite for runtime vf queue number
Signed-off-by: Jianwei Mei <jianweix.mei@intel.com>
---
tests/TestSuite_runtime_vf_queue_number.py | 507 +++++++++++++++++++++
1 file changed, 507 insertions(+)
create mode 100644 tests/TestSuite_runtime_vf_queue_number.py
diff --git a/tests/TestSuite_runtime_vf_queue_number.py b/tests/TestSuite_runtime_vf_queue_number.py
new file mode 100644
index 0000000..3e03020
--- /dev/null
+++ b/tests/TestSuite_runtime_vf_queue_number.py
@@ -0,0 +1,507 @@
+# 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.
+
+'''
+
+import time
+import re
+from qemu_kvm import QEMUKvm
+from test_case import TestCase
+from pmd_output import PmdOutput
+
+VM_CORES_MASK = 'all'
+
+class TestRuntimeVfQn(TestCase):
+ supported_vf_driver = ['pci-stub', 'vfio-pci']
+ def set_up_all(self):
+ self.dut_ports = self.dut.get_ports(self.nic)
+ self.verify(len(self.dut_ports) >= 1, 'Insufficient ports')
+ self.src_intf = self.tester.get_interface(self.tester.get_local_port(0))
+ self.src_mac = self.tester.get_mac(self.tester.get_local_port(0))
+ self.dst_mac = self.dut.get_mac_address(0)
+ self.vm0 = None
+ self.pf_pci = self.dut.ports_info[self.dut_ports[0]]['pci']
+ self.host_testpmd = PmdOutput(self.dut)
+ self.used_dut_port = self.dut_ports[0]
+ self.vf_mac = "00:11:22:33:44:55"
+
+ def set_up(self):
+ self.dut.kill_all()
+
+ def setup_vm_env(self, driver='default'):
+ '''
+ setup qemu virtual environment,this is to set up 1pf and 2vfs environment, the pf can be bond to
+ kernel driver or dpdk driver.
+ '''
+ self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 2, driver=driver)
+ self.sriov_vfs_port_0 = self.dut.ports_info[self.used_dut_port]['vfs_port']
+
+ # set vf assign method and vf driver
+ self.vf_driver = self.get_suite_cfg()['vf_driver']
+ if self.vf_driver is None:
+ self.vf_driver = 'pci-stub'
+ self.verify(self.vf_driver in self.supported_vf_driver, "Unspported vf driver")
+ if self.vf_driver == 'pci-stub':
+ self.vf_assign_method = 'pci-assign'
+ else:
+ self.vf_assign_method = 'vfio-pci'
+ self.dut.send_expect('modprobe vfio-pci', '#')
+
+ try:
+ for port in self.sriov_vfs_port_0:
+ port.bind_driver(self.vf_driver)
+
+ time.sleep(1)
+ vf0_prop = {'opt_host': self.sriov_vfs_port_0[0].pci}
+ vf1_prop = {'opt_host': self.sriov_vfs_port_0[1].pci}
+
+ # set up VM0 ENV
+ self.vm0 = QEMUKvm(self.dut, 'vm0', 'vf_queue_number')
+ self.vm0.set_vm_device(driver=self.vf_assign_method, **vf0_prop)
+ self.vm_dut_0 = self.vm0.start()
+ if self.vm_dut_0 is None:
+ raise Exception('Set up VM0 ENV failed!')
+ except Exception as e:
+ print e
+ self.destroy_vm_env()
+ raise Exception(e)
+
+ def destroy_vm_env(self):
+ #destroy vm0
+ if getattr(self, 'vm0', None) and self.vm0:
+ self.vm0_dut_ports = None
+ self.vm0.stop()
+ self.vm0 = None
+
+ #destroy host testpmd
+ if getattr(self, 'host_testpmd', None):
+ self.host_testpmd.execute_cmd('quit', '# ')
+ self.host_testpmd = None
+
+ # reset used port's sriov
+ if getattr(self, 'used_dut_port', None):
+ self.dut.destroy_sriov_vfs_by_port(self.used_dut_port)
+ port = self.dut.ports_info[self.used_dut_port]['port']
+ port.bind_driver()
+ self.used_dut_port = None
+
+ # bind used ports with default driver
+ for port_id in self.dut_ports:
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver()
+
+ def preset_host_testpmd(self, core_mask, eal_param):
+ self.host_testpmd.start_testpmd(core_mask, param='', eal_param=eal_param)
+ time.sleep(2)
+
+ def send_packet(self, vf_mac, itf, integer):
+ """
+ Sends packets.
+ """
+ self.tester.scapy_foreground()
+ time.sleep(2)
+ for i in range(integer):
+ packet = r'sendp([Ether(dst="%s", src=get_if_hwaddr("%s"))/IP(src="10.0.0.1", dst="192.168.0.%d")], iface="%s")' % (
+ vf_mac, itf, i + 1, itf)
+ self.tester.scapy_append(packet)
+ self.tester.scapy_execute()
+ time.sleep(2)
+
+ def check_packet_queue(self, out):
+ """
+ get the queue which packet enter.
+ """
+ self.verify("Queue= 0" in out and "Queue= 1" in out and "Queue= 2" in out and "Queue= 3" in out
+ and "Queue= 4" in out and "Queue= 5" in out and "Queue= 6" in out and "Queue= 7" in out,
+ "there is some queues doesn't work")
+ lines = out.split("\r\n")
+ reta_line = {}
+ queue_flag = 0
+ packet_sumnum = 0
+ # collect the hash result and the queue id
+ for line in lines:
+ line = line.strip()
+ if queue_flag == 1:
+ result_scanner = r"RX-packets:\s?([0-9]+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ packet_num = m.group(1)
+ packet_sumnum = packet_sumnum + int(packet_num)
+ queue_flag = 0
+ elif line.strip().startswith("------- Forward"):
+ queue_flag = 1
+ elif line.strip().startswith("RX-packets"):
+ result_scanner = r"RX-packets:\s?([0-9]+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ packet_rec = m.group(1)
+
+ self.verify(packet_sumnum == int(packet_rec) == 254, "There are some packets lost.")
+
+ def stop_vm0(self):
+ if getattr(self, 'vm0', None) and self.vm0:
+ self.vm0_dut_ports = None
+ self.vm0.stop()
+ self.vm0 = None
+
+ def execute_testpmd_cmd(self, cmds):
+ if len(cmds) == 0:
+ return
+ for item in cmds:
+ if len(item) == 2:
+ self.vm0_testpmd.execute_cmd(item[0], int(item[1]))
+ else:
+ self.vm0_testpmd.execute_cmd(item[0])
+
+ def test_set_valid_vf_qn(self):
+ """
+ Test case 1: reserve valid vf queue number
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s,queue-num-per-vf=4 --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(1)
+ guest_cmds = [['stop'],
+ ['port stop all'],
+ ['port config all txq 4'],
+ ['port config all rxq 4'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds)
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 4 Tx queue number: 4" in outstring, "The RX/TX queue number error.")
+ time.sleep(10)
+ guest_cmds1 = [['stop'],
+ ['port stop all'],
+ ['port config all txq 5'],
+ ['port config all rxq 5'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds1)
+ outstring1 = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 5 Tx queue number: 5" in outstring1, "The RX/TX queue number error.")
+ time.sleep(2)
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_invalid_vf_qn(self):
+ """
+ Test case 2: reserve invalid VF queue number
+ :return:
+ """
+ eal_param = '-w %s,queue-num-per-vf=0 --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ testpmd_out = self.host_testpmd.start_testpmd(VM_CORES_MASK, param='', eal_param=eal_param)
+ self.verify("it must be power of 2 and equal or less than 16" in testpmd_out, "there is no 'Wrong VF queue number = 0' logs.")
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_valid_vf_qn_in_testpmd(self):
+ """
+ Test case 3: set valid VF queue number in testpmd command-line options
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param=' --rxq=3 --txq=3')
+ time.sleep(1)
+ self.vm0_testpmd.execute_cmd("set promisc all off", "testpmd> ")
+ self.vm0_testpmd.execute_cmd("set fwd mac", "testpmd> ")
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 3 Tx queue number: 3" in outstring, "The RX/TX queue number error.")
+
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac = self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+ self.send_packet(self.vf_mac, self.src_intf, 3)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("Queue= 0" in outstring1 or "Queue= 1" in outstring1 or "Queue= 2" in outstring1, "there is some queues doesn't work")
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_valid_min_vf_qn_in_testpmd(self):
+ """
+ Test case 3: set mininum valid VF queue number in testpmd command-line options
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param=' --rxq=1 --txq=1')
+ time.sleep(1)
+ self.vm0_testpmd.execute_cmd("set promisc all off", "testpmd> ")
+ self.vm0_testpmd.execute_cmd("set fwd mac", "testpmd> ")
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 1 Tx queue number: 1" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac = self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 3)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("RX-packets: 3" in outstring1 and "TX-packets: 3" in outstring1, "the count of packets is incorrect.")
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_valid_max_vf_qn_in_testpmd(self):
+ """
+ Test case 3: set maximum valid VF queue number in testpmd command-line options
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param=' --rxq=16 --txq=16')
+ time.sleep(10)
+ self.vm0_testpmd.execute_cmd("set promisc all off", "testpmd> ")
+ self.vm0_testpmd.execute_cmd("set fwd mac", "testpmd> ")
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 16 Tx queue number: 16" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac = self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 254)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ self.check_packet_queue(outstring1)
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_invalid_vf_qn_in_testpmd(self):
+ """
+ Test case 4: set invalid VF queue number in testpmd command-line options
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+
+ command_0 = "./%s/app/testpmd -c %s -n %d %s -- -i %s" \
+ % (self.dut.target, '0xf', self.dut.get_memory_channels(), gest_eal_param, ' --rxq=0 --txq=0')
+ outstring = self.vm0_testpmd.execute_cmd(command_0, expected='# ', timeout=120)
+ time.sleep(10)
+ self.verify("Either rx or tx queues should be non-zero" in outstring, "The output of testpmd start is different from expect when set invalid VF queue number 0.")
+ time.sleep(2)
+ command_17 = "./%s/app/testpmd -c %s -n %d %s -- -i %s" \
+ % (self.dut.target, '0xf', self.dut.get_memory_channels(), gest_eal_param, ' --rxq=17 --txq=17')
+ outstring1 = self.vm0_testpmd.execute_cmd(command_17, expected='# ', timeout=120)
+ time.sleep(10)
+ self.verify("rxq 17 invalid - must be >= 0 && <= 16" in outstring1,
+ "The output of testpmd start is different from expect when set invalid VF queue number 17.")
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_valid_vf_qn_with_testpmd_func_cmd(self):
+ """
+ Test case 5: set valid VF queue number with testpmd function command
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(10)
+ guest_cmds = [['set promisc all off'],
+ ['set fwd mac'],
+ ['stop'],
+ ['port stop all'],
+ ['port config all txq 3'],
+ ['port config all rxq 3'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds)
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 3 Tx queue number: 3" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac = self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 3)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("Queue= 0" in outstring1 or "Queue= 1" in outstring1 or "Queue= 2" in outstring1,
+ "there is some queues doesn't work")
+
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_min_vf_qn_with_testpmd_func_cmd(self):
+ """
+ Test case 5: set mininum valid VF queue number with testpmd function command
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(10)
+ guest_cmds = [['set promisc all off'],
+ ['set fwd mac'],
+ ['stop'],
+ ['port stop all'],
+ ['port config all txq 1'],
+ ['port config all rxq 1'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds)
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 1 Tx queue number: 1" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac = self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 3)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("RX-packets: 3" in outstring1 and "TX-packets: 3" in outstring1,
+ "the count of packets is incorrect.")
+
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_max_vf_qn_with_testpmd_func_cmd(self):
+ """
+ Test case 5: set maximum valid VF queue number with testpmd function command
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(10)
+ guest_cmds = [['set promisc all off'],
+ ['set fwd mac'],
+ ['stop'],
+ ['port stop all'],
+ ['port config all txq 16'],
+ ['port config all rxq 16'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds)
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 16 Tx queue number: 16" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac = self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 254)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ self.check_packet_queue(outstring1)
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_invalid_vf_qn_with_testpmd_func_cmd(self):
+ """
+ Test case 6: set invalid VF queue number with testpmd function command
+ :return:
+ """
+ # There is a bug of this test case, so the function hasn't been implemented.
+ pass
+
+ def test_reserve_vf_qn(self):
+ """
+ Test case 7: Reserve VF queue number when VF bind to kernel driver
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s,queue-num-per-vf=2 --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(1)
+ intf = self.vm_dut_0.ports_info[0]['intf']
+ if intf != 'N/A' and intf != '':
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ command = "./usertools/dpdk-devbind.py -b i40evf %s" % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd.execute_cmd(command, expected='# ', timeout=120)
+ output = self.vm0_testpmd.execute_cmd("ethtool -S %s" % intf, expected='# ', timeout=120)
+ self.verify("tx-0.packets: 0" in output and "tx-1.packets: 0" in output, "VF0 rxq and txq number is not 2.")
+ else:
+ time.sleep(120)
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ command = "./usertools/dpdk-devbind.py -b i40evf %s" % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd.execute_cmd(command, expected='# ', timeout=120)
+ nic_info = self.vm0_testpmd.execute_cmd("./usertools/dpdk-devbind.py -s | grep %s" % self.vm_dut_0.ports_info[0]['pci'], expected='# ', timeout=120)
+ time.sleep(2)
+ inf_str = nic_info.split("if=")[1]
+ inf = inf_str.split(" ")[0]
+ if "drv" not in inf and inf != "":
+ output = self.vm0_testpmd.execute_cmd("ethtool -S %s" % inf, expected='# ', timeout=120)
+ else:
+ output = ""
+ self.verify("tx-0.packets: 0" in output and "tx-1.packets: 0" in output, "VF0 rxq and txq number is not 2.")
+ self.dut.send_expect("quit", "# ")
+
+ def tear_down(self):
+ pass
+
+ def tear_down_all(self):
+ self.destroy_vm_env()
+ for port_id in self.dut_ports:
+ self.dut.destroy_sriov_vfs_by_port(port_id)
+
+ self.tester.send_expect("kill -9 $(ps aux | grep -i qemu | grep -v grep | awk {'print $2'})", '# ', 5)
--
2.17.2
^ permalink raw reply [flat|nested] 3+ messages in thread
* Re: [dts] [PATCH V1] tests/runtime_vf_queue_number:add testsuite for runtime vf queue number
2019-04-22 3:25 [dts] [PATCH V1] tests/runtime_vf_queue_number:add testsuite for runtime vf queue number Jianwei Mei
@ 2019-04-22 9:55 ` Xiao, QimaiX
2019-04-23 18:28 ` Tu, Lijuan
1 sibling, 0 replies; 3+ messages in thread
From: Xiao, QimaiX @ 2019-04-22 9:55 UTC (permalink / raw)
To: Mei, JianweiX, dts; +Cc: Mei, JianweiX
Tested-by: xiao, qimai <qimaix.xiao@intel.com>
-----Original Message-----
From: dts [mailto:dts-bounces@dpdk.org] On Behalf Of Jianwei Mei
Sent: Monday, April 22, 2019 11:25 AM
To: dts@dpdk.org
Cc: Mei, JianweiX <jianweix.mei@intel.com>
Subject: [dts] [PATCH V1] tests/runtime_vf_queue_number:add testsuite for runtime vf queue number
add testsuite for runtime vf queue number
Signed-off-by: Jianwei Mei <jianweix.mei@intel.com>
---
tests/TestSuite_runtime_vf_queue_number.py | 507 +++++++++++++++++++++
1 file changed, 507 insertions(+)
create mode 100644 tests/TestSuite_runtime_vf_queue_number.py
diff --git a/tests/TestSuite_runtime_vf_queue_number.py b/tests/TestSuite_runtime_vf_queue_number.py
new file mode 100644
index 0000000..3e03020
--- /dev/null
+++ b/tests/TestSuite_runtime_vf_queue_number.py
@@ -0,0 +1,507 @@
+# 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.
+
+'''
+
+import time
+import re
+from qemu_kvm import QEMUKvm
+from test_case import TestCase
+from pmd_output import PmdOutput
+
+VM_CORES_MASK = 'all'
+
+class TestRuntimeVfQn(TestCase):
+ supported_vf_driver = ['pci-stub', 'vfio-pci']
+ def set_up_all(self):
+ self.dut_ports = self.dut.get_ports(self.nic)
+ self.verify(len(self.dut_ports) >= 1, 'Insufficient ports')
+ self.src_intf = self.tester.get_interface(self.tester.get_local_port(0))
+ self.src_mac = self.tester.get_mac(self.tester.get_local_port(0))
+ self.dst_mac = self.dut.get_mac_address(0)
+ self.vm0 = None
+ self.pf_pci = self.dut.ports_info[self.dut_ports[0]]['pci']
+ self.host_testpmd = PmdOutput(self.dut)
+ self.used_dut_port = self.dut_ports[0]
+ self.vf_mac = "00:11:22:33:44:55"
+
+ def set_up(self):
+ self.dut.kill_all()
+
+ def setup_vm_env(self, driver='default'):
+ '''
+ setup qemu virtual environment,this is to set up 1pf and 2vfs environment, the pf can be bond to
+ kernel driver or dpdk driver.
+ '''
+ self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 2, driver=driver)
+ self.sriov_vfs_port_0 =
+ self.dut.ports_info[self.used_dut_port]['vfs_port']
+
+ # set vf assign method and vf driver
+ self.vf_driver = self.get_suite_cfg()['vf_driver']
+ if self.vf_driver is None:
+ self.vf_driver = 'pci-stub'
+ self.verify(self.vf_driver in self.supported_vf_driver, "Unspported vf driver")
+ if self.vf_driver == 'pci-stub':
+ self.vf_assign_method = 'pci-assign'
+ else:
+ self.vf_assign_method = 'vfio-pci'
+ self.dut.send_expect('modprobe vfio-pci', '#')
+
+ try:
+ for port in self.sriov_vfs_port_0:
+ port.bind_driver(self.vf_driver)
+
+ time.sleep(1)
+ vf0_prop = {'opt_host': self.sriov_vfs_port_0[0].pci}
+ vf1_prop = {'opt_host': self.sriov_vfs_port_0[1].pci}
+
+ # set up VM0 ENV
+ self.vm0 = QEMUKvm(self.dut, 'vm0', 'vf_queue_number')
+ self.vm0.set_vm_device(driver=self.vf_assign_method, **vf0_prop)
+ self.vm_dut_0 = self.vm0.start()
+ if self.vm_dut_0 is None:
+ raise Exception('Set up VM0 ENV failed!')
+ except Exception as e:
+ print e
+ self.destroy_vm_env()
+ raise Exception(e)
+
+ def destroy_vm_env(self):
+ #destroy vm0
+ if getattr(self, 'vm0', None) and self.vm0:
+ self.vm0_dut_ports = None
+ self.vm0.stop()
+ self.vm0 = None
+
+ #destroy host testpmd
+ if getattr(self, 'host_testpmd', None):
+ self.host_testpmd.execute_cmd('quit', '# ')
+ self.host_testpmd = None
+
+ # reset used port's sriov
+ if getattr(self, 'used_dut_port', None):
+ self.dut.destroy_sriov_vfs_by_port(self.used_dut_port)
+ port = self.dut.ports_info[self.used_dut_port]['port']
+ port.bind_driver()
+ self.used_dut_port = None
+
+ # bind used ports with default driver
+ for port_id in self.dut_ports:
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver()
+
+ def preset_host_testpmd(self, core_mask, eal_param):
+ self.host_testpmd.start_testpmd(core_mask, param='', eal_param=eal_param)
+ time.sleep(2)
+
+ def send_packet(self, vf_mac, itf, integer):
+ """
+ Sends packets.
+ """
+ self.tester.scapy_foreground()
+ time.sleep(2)
+ for i in range(integer):
+ packet = r'sendp([Ether(dst="%s", src=get_if_hwaddr("%s"))/IP(src="10.0.0.1", dst="192.168.0.%d")], iface="%s")' % (
+ vf_mac, itf, i + 1, itf)
+ self.tester.scapy_append(packet)
+ self.tester.scapy_execute()
+ time.sleep(2)
+
+ def check_packet_queue(self, out):
+ """
+ get the queue which packet enter.
+ """
+ self.verify("Queue= 0" in out and "Queue= 1" in out and "Queue= 2" in out and "Queue= 3" in out
+ and "Queue= 4" in out and "Queue= 5" in out and "Queue= 6" in out and "Queue= 7" in out,
+ "there is some queues doesn't work")
+ lines = out.split("\r\n")
+ reta_line = {}
+ queue_flag = 0
+ packet_sumnum = 0
+ # collect the hash result and the queue id
+ for line in lines:
+ line = line.strip()
+ if queue_flag == 1:
+ result_scanner = r"RX-packets:\s?([0-9]+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ packet_num = m.group(1)
+ packet_sumnum = packet_sumnum + int(packet_num)
+ queue_flag = 0
+ elif line.strip().startswith("------- Forward"):
+ queue_flag = 1
+ elif line.strip().startswith("RX-packets"):
+ result_scanner = r"RX-packets:\s?([0-9]+)"
+ scanner = re.compile(result_scanner, re.DOTALL)
+ m = scanner.search(line)
+ packet_rec = m.group(1)
+
+ self.verify(packet_sumnum == int(packet_rec) == 254, "There are
+ some packets lost.")
+
+ def stop_vm0(self):
+ if getattr(self, 'vm0', None) and self.vm0:
+ self.vm0_dut_ports = None
+ self.vm0.stop()
+ self.vm0 = None
+
+ def execute_testpmd_cmd(self, cmds):
+ if len(cmds) == 0:
+ return
+ for item in cmds:
+ if len(item) == 2:
+ self.vm0_testpmd.execute_cmd(item[0], int(item[1]))
+ else:
+ self.vm0_testpmd.execute_cmd(item[0])
+
+ def test_set_valid_vf_qn(self):
+ """
+ Test case 1: reserve valid vf queue number
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s,queue-num-per-vf=4 --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK,
+ eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(1)
+ guest_cmds = [['stop'],
+ ['port stop all'],
+ ['port config all txq 4'],
+ ['port config all rxq 4'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds)
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 4 Tx queue number: 4" in outstring, "The RX/TX queue number error.")
+ time.sleep(10)
+ guest_cmds1 = [['stop'],
+ ['port stop all'],
+ ['port config all txq 5'],
+ ['port config all rxq 5'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds1)
+ outstring1 = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 5 Tx queue number: 5" in outstring1, "The RX/TX queue number error.")
+ time.sleep(2)
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_invalid_vf_qn(self):
+ """
+ Test case 2: reserve invalid VF queue number
+ :return:
+ """
+ eal_param = '-w %s,queue-num-per-vf=0 --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ testpmd_out = self.host_testpmd.start_testpmd(VM_CORES_MASK, param='', eal_param=eal_param)
+ self.verify("it must be power of 2 and equal or less than 16" in testpmd_out, "there is no 'Wrong VF queue number = 0' logs.")
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_valid_vf_qn_in_testpmd(self):
+ """
+ Test case 3: set valid VF queue number in testpmd command-line options
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK,
+ eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param=' --rxq=3 --txq=3')
+ time.sleep(1)
+ self.vm0_testpmd.execute_cmd("set promisc all off", "testpmd> ")
+ self.vm0_testpmd.execute_cmd("set fwd mac", "testpmd> ")
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 3 Tx queue number: 3" in
+ outstring, "The RX/TX queue number error.")
+
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac = self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+ self.send_packet(self.vf_mac, self.src_intf, 3)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("Queue= 0" in outstring1 or "Queue= 1" in outstring1 or "Queue= 2" in outstring1, "there is some queues doesn't work")
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_valid_min_vf_qn_in_testpmd(self):
+ """
+ Test case 3: set mininum valid VF queue number in testpmd command-line options
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK,
+ eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param=' --rxq=1 --txq=1')
+ time.sleep(1)
+ self.vm0_testpmd.execute_cmd("set promisc all off", "testpmd> ")
+ self.vm0_testpmd.execute_cmd("set fwd mac", "testpmd> ")
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 1 Tx queue number: 1" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac =
+ self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 3)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("RX-packets: 3" in outstring1 and "TX-packets: 3" in outstring1, "the count of packets is incorrect.")
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_valid_max_vf_qn_in_testpmd(self):
+ """
+ Test case 3: set maximum valid VF queue number in testpmd command-line options
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK,
+ eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param=' --rxq=16 --txq=16')
+ time.sleep(10)
+ self.vm0_testpmd.execute_cmd("set promisc all off", "testpmd> ")
+ self.vm0_testpmd.execute_cmd("set fwd mac", "testpmd> ")
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 16 Tx queue number: 16" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac =
+ self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 254)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ self.check_packet_queue(outstring1)
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_invalid_vf_qn_in_testpmd(self):
+ """
+ Test case 4: set invalid VF queue number in testpmd command-line options
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK, eal_param=host_eal_param)
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+
+ command_0 = "./%s/app/testpmd -c %s -n %d %s -- -i %s" \
+ % (self.dut.target, '0xf', self.dut.get_memory_channels(), gest_eal_param, ' --rxq=0 --txq=0')
+ outstring = self.vm0_testpmd.execute_cmd(command_0, expected='# ', timeout=120)
+ time.sleep(10)
+ self.verify("Either rx or tx queues should be non-zero" in outstring, "The output of testpmd start is different from expect when set invalid VF queue number 0.")
+ time.sleep(2)
+ command_17 = "./%s/app/testpmd -c %s -n %d %s -- -i %s" \
+ % (self.dut.target, '0xf', self.dut.get_memory_channels(), gest_eal_param, ' --rxq=17 --txq=17')
+ outstring1 = self.vm0_testpmd.execute_cmd(command_17, expected='# ', timeout=120)
+ time.sleep(10)
+ self.verify("rxq 17 invalid - must be >= 0 && <= 16" in outstring1,
+ "The output of testpmd start is different from expect when set invalid VF queue number 17.")
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_valid_vf_qn_with_testpmd_func_cmd(self):
+ """
+ Test case 5: set valid VF queue number with testpmd function command
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK,
+ eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(10)
+ guest_cmds = [['set promisc all off'],
+ ['set fwd mac'],
+ ['stop'],
+ ['port stop all'],
+ ['port config all txq 3'],
+ ['port config all rxq 3'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds)
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 3 Tx queue number: 3" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac =
+ self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 3)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("Queue= 0" in outstring1 or "Queue= 1" in outstring1 or "Queue= 2" in outstring1,
+ "there is some queues doesn't work")
+
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_min_vf_qn_with_testpmd_func_cmd(self):
+ """
+ Test case 5: set mininum valid VF queue number with testpmd function command
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK,
+ eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(10)
+ guest_cmds = [['set promisc all off'],
+ ['set fwd mac'],
+ ['stop'],
+ ['port stop all'],
+ ['port config all txq 1'],
+ ['port config all rxq 1'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds)
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 1 Tx queue number: 1" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac =
+ self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 3)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("RX-packets: 3" in outstring1 and "TX-packets: 3" in outstring1,
+ "the count of packets is incorrect.")
+
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_max_vf_qn_with_testpmd_func_cmd(self):
+ """
+ Test case 5: set maximum valid VF queue number with testpmd function command
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK,
+ eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(10)
+ guest_cmds = [['set promisc all off'],
+ ['set fwd mac'],
+ ['stop'],
+ ['port stop all'],
+ ['port config all txq 16'],
+ ['port config all rxq 16'],
+ ['port start all']]
+ self.execute_testpmd_cmd(guest_cmds)
+ outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
+ time.sleep(2)
+ self.verify("port 0: RX queue number: 16 Tx queue number: 16" in outstring, "The RX/TX queue number error.")
+ self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
+ self.vf_mac =
+ self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
+
+ self.send_packet(self.vf_mac, self.src_intf, 254)
+ outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
+ self.check_packet_queue(outstring1)
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ self.dut.send_expect("quit", "# ")
+
+ def test_set_invalid_vf_qn_with_testpmd_func_cmd(self):
+ """
+ Test case 6: set invalid VF queue number with testpmd function command
+ :return:
+ """
+ # There is a bug of this test case, so the function hasn't been implemented.
+ pass
+
+ def test_reserve_vf_qn(self):
+ """
+ Test case 7: Reserve VF queue number when VF bind to kernel driver
+ :return:
+ """
+ self.stop_vm0()
+ self.setup_vm_env(driver='igb_uio')
+ host_eal_param = '-w %s,queue-num-per-vf=2 --file-prefix=test1 --socket-mem 1024,1024' % self.pf_pci
+ self.preset_host_testpmd(VM_CORES_MASK,
+ eal_param=host_eal_param)
+
+ gest_eal_param = '-w %s --file-prefix=test2' % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd = PmdOutput(self.vm_dut_0)
+ self.vm0_testpmd.start_testpmd(VM_CORES_MASK, eal_param=gest_eal_param, param='')
+ time.sleep(1)
+ intf = self.vm_dut_0.ports_info[0]['intf']
+ if intf != 'N/A' and intf != '':
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ command = "./usertools/dpdk-devbind.py -b i40evf %s" % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd.execute_cmd(command, expected='# ', timeout=120)
+ output = self.vm0_testpmd.execute_cmd("ethtool -S %s" % intf, expected='# ', timeout=120)
+ self.verify("tx-0.packets: 0" in output and "tx-1.packets: 0" in output, "VF0 rxq and txq number is not 2.")
+ else:
+ time.sleep(120)
+ self.vm0_testpmd.execute_cmd('quit', '# ')
+ command = "./usertools/dpdk-devbind.py -b i40evf %s" % self.vm_dut_0.ports_info[0]['pci']
+ self.vm0_testpmd.execute_cmd(command, expected='# ', timeout=120)
+ nic_info = self.vm0_testpmd.execute_cmd("./usertools/dpdk-devbind.py -s | grep %s" % self.vm_dut_0.ports_info[0]['pci'], expected='# ', timeout=120)
+ time.sleep(2)
+ inf_str = nic_info.split("if=")[1]
+ inf = inf_str.split(" ")[0]
+ if "drv" not in inf and inf != "":
+ output = self.vm0_testpmd.execute_cmd("ethtool -S %s" % inf, expected='# ', timeout=120)
+ else:
+ output = ""
+ self.verify("tx-0.packets: 0" in output and "tx-1.packets: 0" in output, "VF0 rxq and txq number is not 2.")
+ self.dut.send_expect("quit", "# ")
+
+ def tear_down(self):
+ pass
+
+ def tear_down_all(self):
+ self.destroy_vm_env()
+ for port_id in self.dut_ports:
+ self.dut.destroy_sriov_vfs_by_port(port_id)
+
+ self.tester.send_expect("kill -9 $(ps aux | grep -i qemu | grep
+ -v grep | awk {'print $2'})", '# ', 5)
--
2.17.2
^ permalink raw reply [flat|nested] 3+ messages in thread
* Re: [dts] [PATCH V1] tests/runtime_vf_queue_number:add testsuite for runtime vf queue number
2019-04-22 3:25 [dts] [PATCH V1] tests/runtime_vf_queue_number:add testsuite for runtime vf queue number Jianwei Mei
2019-04-22 9:55 ` Xiao, QimaiX
@ 2019-04-23 18:28 ` Tu, Lijuan
1 sibling, 0 replies; 3+ messages in thread
From: Tu, Lijuan @ 2019-04-23 18:28 UTC (permalink / raw)
To: Mei, JianweiX, dts; +Cc: Mei, JianweiX
No matter the VF queue number or reserved vf queue number should be random, not a fixed value.
> -----Original Message-----
> From: dts [mailto:dts-bounces@dpdk.org] On Behalf Of Jianwei Mei
> Sent: Sunday, April 21, 2019 8:25 PM
> To: dts@dpdk.org
> Cc: Mei, JianweiX <jianweix.mei@intel.com>
> Subject: [dts] [PATCH V1] tests/runtime_vf_queue_number:add testsuite for
> runtime vf queue number
>
> add testsuite for runtime vf queue number
>
> Signed-off-by: Jianwei Mei <jianweix.mei@intel.com>
> ---
> tests/TestSuite_runtime_vf_queue_number.py | 507
> +++++++++++++++++++++
> 1 file changed, 507 insertions(+)
> create mode 100644 tests/TestSuite_runtime_vf_queue_number.py
>
> diff --git a/tests/TestSuite_runtime_vf_queue_number.py
> b/tests/TestSuite_runtime_vf_queue_number.py
> new file mode 100644
> index 0000000..3e03020
> --- /dev/null
> +++ b/tests/TestSuite_runtime_vf_queue_number.py
> @@ -0,0 +1,507 @@
> +# BSD LICENSE
> +#
> +# Copyright(c) 2010-2019 Intel Corporation. All rights reserved.
[Lijuan] 2010-2019 -> 2019
> +# 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.
> +
> +'''
> +
> +import time
> +import re
> +from qemu_kvm import QEMUKvm
> +from test_case import TestCase
> +from pmd_output import PmdOutput
> +
> +VM_CORES_MASK = 'all'
> +
> +class TestRuntimeVfQn(TestCase):
> + supported_vf_driver = ['pci-stub', 'vfio-pci']
> + def set_up_all(self):
> + self.dut_ports = self.dut.get_ports(self.nic)
> + self.verify(len(self.dut_ports) >= 1, 'Insufficient ports')
> + self.src_intf = self.tester.get_interface(self.tester.get_local_port(0))
> + self.src_mac = self.tester.get_mac(self.tester.get_local_port(0))
> + self.dst_mac = self.dut.get_mac_address(0)
> + self.vm0 = None
> + self.pf_pci = self.dut.ports_info[self.dut_ports[0]]['pci']
> + self.host_testpmd = PmdOutput(self.dut)
> + self.used_dut_port = self.dut_ports[0]
> + self.vf_mac = "00:11:22:33:44:55"
> +
> + def set_up(self):
> + self.dut.kill_all()
> +
> + def setup_vm_env(self, driver='default'):
> + '''
> + setup qemu virtual environment,this is to set up 1pf and 2vfs
> environment, the pf can be bond to
> + kernel driver or dpdk driver.
> + '''
> + self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 2,
> driver=driver)
> + self.sriov_vfs_port_0 =
> + self.dut.ports_info[self.used_dut_port]['vfs_port']
> +
> + # set vf assign method and vf driver
> + self.vf_driver = self.get_suite_cfg()['vf_driver']
> + if self.vf_driver is None:
> + self.vf_driver = 'pci-stub'
> + self.verify(self.vf_driver in self.supported_vf_driver, "Unspported vf
> driver")
> + if self.vf_driver == 'pci-stub':
> + self.vf_assign_method = 'pci-assign'
> + else:
> + self.vf_assign_method = 'vfio-pci'
> + self.dut.send_expect('modprobe vfio-pci', '#')
> +
> + try:
> + for port in self.sriov_vfs_port_0:
> + port.bind_driver(self.vf_driver)
> +
> + time.sleep(1)
> + vf0_prop = {'opt_host': self.sriov_vfs_port_0[0].pci}
> + vf1_prop = {'opt_host': self.sriov_vfs_port_0[1].pci}
> +
> + # set up VM0 ENV
> + self.vm0 = QEMUKvm(self.dut, 'vm0', 'vf_queue_number')
> + self.vm0.set_vm_device(driver=self.vf_assign_method, **vf0_prop)
> + self.vm_dut_0 = self.vm0.start()
> + if self.vm_dut_0 is None:
> + raise Exception('Set up VM0 ENV failed!')
> + except Exception as e:
> + print e
> + self.destroy_vm_env()
> + raise Exception(e)
> +
> + def destroy_vm_env(self):
> + #destroy vm0
> + if getattr(self, 'vm0', None) and self.vm0:
> + self.vm0_dut_ports = None
> + self.vm0.stop()
> + self.vm0 = None
> +
> + #destroy host testpmd
> + if getattr(self, 'host_testpmd', None):
> + self.host_testpmd.execute_cmd('quit', '# ')
> + self.host_testpmd = None
> +
> + # reset used port's sriov
> + if getattr(self, 'used_dut_port', None):
> + self.dut.destroy_sriov_vfs_by_port(self.used_dut_port)
> + port = self.dut.ports_info[self.used_dut_port]['port']
> + port.bind_driver()
> + self.used_dut_port = None
> +
> + # bind used ports with default driver
> + for port_id in self.dut_ports:
> + port = self.dut.ports_info[port_id]['port']
> + port.bind_driver()
> +
> + def preset_host_testpmd(self, core_mask, eal_param):
> + self.host_testpmd.start_testpmd(core_mask, param='',
> eal_param=eal_param)
> + time.sleep(2)
> +
> + def send_packet(self, vf_mac, itf, integer):
> + """
> + Sends packets.
> + """
> + self.tester.scapy_foreground()
> + time.sleep(2)
> + for i in range(integer):
> + packet = r'sendp([Ether(dst="%s",
> src=get_if_hwaddr("%s"))/IP(src="10.0.0.1", dst="192.168.0.%d")],
> iface="%s")' % (
> + vf_mac, itf, i + 1, itf)
> + self.tester.scapy_append(packet)
> + self.tester.scapy_execute()
> + time.sleep(2)
> +
> + def check_packet_queue(self, out):
> + """
> + get the queue which packet enter.
> + """
> + self.verify("Queue= 0" in out and "Queue= 1" in out and "Queue= 2" in
> out and "Queue= 3" in out
> + and "Queue= 4" in out and "Queue= 5" in out and "Queue= 6"
> in out and "Queue= 7" in out,
> + "there is some queues doesn't work")
> + lines = out.split("\r\n")
> + reta_line = {}
> + queue_flag = 0
> + packet_sumnum = 0
> + # collect the hash result and the queue id
> + for line in lines:
> + line = line.strip()
> + if queue_flag == 1:
> + result_scanner = r"RX-packets:\s?([0-9]+)"
> + scanner = re.compile(result_scanner, re.DOTALL)
> + m = scanner.search(line)
> + packet_num = m.group(1)
> + packet_sumnum = packet_sumnum + int(packet_num)
> + queue_flag = 0
> + elif line.strip().startswith("------- Forward"):
> + queue_flag = 1
> + elif line.strip().startswith("RX-packets"):
> + result_scanner = r"RX-packets:\s?([0-9]+)"
> + scanner = re.compile(result_scanner, re.DOTALL)
> + m = scanner.search(line)
> + packet_rec = m.group(1)
> +
> + self.verify(packet_sumnum == int(packet_rec) == 254, "There are
> + some packets lost.")
> +
> + def stop_vm0(self):
> + if getattr(self, 'vm0', None) and self.vm0:
> + self.vm0_dut_ports = None
> + self.vm0.stop()
> + self.vm0 = None
> +
> + def execute_testpmd_cmd(self, cmds):
> + if len(cmds) == 0:
> + return
> + for item in cmds:
> + if len(item) == 2:
> + self.vm0_testpmd.execute_cmd(item[0], int(item[1]))
> + else:
> + self.vm0_testpmd.execute_cmd(item[0])
> +
> + def test_set_valid_vf_qn(self):
> + """
> + Test case 1: reserve valid vf queue number
> + :return:
> + """
> + self.stop_vm0()
[Lijuan] move to tear_down()
> + self.setup_vm_env(driver='igb_uio')
> + host_eal_param = '-w %s,queue-num-per-vf=4 --file-prefix=test1 --
> socket-mem 1024,1024' % self.pf_pci
> + self.preset_host_testpmd(VM_CORES_MASK,
> + eal_param=host_eal_param)
> +
> + gest_eal_param = '-w %s --file-prefix=test2' %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd = PmdOutput(self.vm_dut_0)
> + self.vm0_testpmd.start_testpmd(VM_CORES_MASK,
> eal_param=gest_eal_param, param='')
> + time.sleep(1)
> + guest_cmds = [['stop'],
> + ['port stop all'],
> + ['port config all txq 4'],
> + ['port config all rxq 4'],
> + ['port start all']]
> + self.execute_testpmd_cmd(guest_cmds)
> + outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("port 0: RX queue number: 4 Tx queue number: 4" in
> outstring, "The RX/TX queue number error.")
> + time.sleep(10)
> + guest_cmds1 = [['stop'],
> + ['port stop all'],
> + ['port config all txq 5'],
> + ['port config all rxq 5'],
> + ['port start all']]
> + self.execute_testpmd_cmd(guest_cmds1)
> + outstring1 = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("port 0: RX queue number: 5 Tx queue number: 5" in
> outstring1, "The RX/TX queue number error.")
> + time.sleep(2)
> + self.vm0_testpmd.execute_cmd('quit', '# ')
> + self.dut.send_expect("quit", "# ")
> +
> + def test_set_invalid_vf_qn(self):
> + """
> + Test case 2: reserve invalid VF queue number
> + :return:
> + """
> + eal_param = '-w %s,queue-num-per-vf=0 --file-prefix=test1 --socket-
> mem 1024,1024' % self.pf_pci
> + testpmd_out = self.host_testpmd.start_testpmd(VM_CORES_MASK,
> param='', eal_param=eal_param)
> + self.verify("it must be power of 2 and equal or less than 16" in
> testpmd_out, "there is no 'Wrong VF queue number = 0' logs.")
> + self.dut.send_expect("quit", "# ")
> +
> + def test_set_valid_vf_qn_in_testpmd(self):
> + """
> + Test case 3: set valid VF queue number in testpmd command-line
> options
> + :return:
> + """
> + self.stop_vm0()
> + self.setup_vm_env(driver='igb_uio')
> + host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' %
> self.pf_pci
> + self.preset_host_testpmd(VM_CORES_MASK,
> + eal_param=host_eal_param)
> +
> + gest_eal_param = '-w %s --file-prefix=test2' %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd = PmdOutput(self.vm_dut_0)
> + self.vm0_testpmd.start_testpmd(VM_CORES_MASK,
> eal_param=gest_eal_param, param=' --rxq=3 --txq=3')
> + time.sleep(1)
> + self.vm0_testpmd.execute_cmd("set promisc all off", "testpmd> ")
> + self.vm0_testpmd.execute_cmd("set fwd mac", "testpmd> ")
> + outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("port 0: RX queue number: 3 Tx queue number: 3" in
> + outstring, "The RX/TX queue number error.")
> +
> + self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
> + self.vf_mac = self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
> + self.send_packet(self.vf_mac, self.src_intf, 3)
> + outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("Queue= 0" in outstring1 or "Queue= 1" in outstring1 or
> "Queue= 2" in outstring1, "there is some queues doesn't work")
> + self.vm0_testpmd.execute_cmd('quit', '# ')
> + self.dut.send_expect("quit", "# ")
> +
> + def test_set_valid_min_vf_qn_in_testpmd(self):
> + """
> + Test case 3: set mininum valid VF queue number in testpmd command-
> line options
> + :return:
> + """
> + self.stop_vm0()
> + self.setup_vm_env(driver='igb_uio')
> + host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' %
> self.pf_pci
> + self.preset_host_testpmd(VM_CORES_MASK,
> + eal_param=host_eal_param)
> +
> + gest_eal_param = '-w %s --file-prefix=test2' %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd = PmdOutput(self.vm_dut_0)
> + self.vm0_testpmd.start_testpmd(VM_CORES_MASK,
> eal_param=gest_eal_param, param=' --rxq=1 --txq=1')
> + time.sleep(1)
> + self.vm0_testpmd.execute_cmd("set promisc all off", "testpmd> ")
> + self.vm0_testpmd.execute_cmd("set fwd mac", "testpmd> ")
> + outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("port 0: RX queue number: 1 Tx queue number: 1" in
> outstring, "The RX/TX queue number error.")
> + self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
> + self.vf_mac =
> + self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
> +
> + self.send_packet(self.vf_mac, self.src_intf, 3)
> + outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("RX-packets: 3" in outstring1 and "TX-packets: 3" in
> outstring1, "the count of packets is incorrect.")
> + self.vm0_testpmd.execute_cmd('quit', '# ')
> + self.dut.send_expect("quit", "# ")
> +
> + def test_set_valid_max_vf_qn_in_testpmd(self):
> + """
> + Test case 3: set maximum valid VF queue number in testpmd
> command-line options
> + :return:
> + """
> + self.stop_vm0()
> + self.setup_vm_env(driver='igb_uio')
> + host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' %
> self.pf_pci
> + self.preset_host_testpmd(VM_CORES_MASK,
> + eal_param=host_eal_param)
> +
> + gest_eal_param = '-w %s --file-prefix=test2' %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd = PmdOutput(self.vm_dut_0)
> + self.vm0_testpmd.start_testpmd(VM_CORES_MASK,
> eal_param=gest_eal_param, param=' --rxq=16 --txq=16')
> + time.sleep(10)
> + self.vm0_testpmd.execute_cmd("set promisc all off", "testpmd> ")
> + self.vm0_testpmd.execute_cmd("set fwd mac", "testpmd> ")
> + outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("port 0: RX queue number: 16 Tx queue number: 16" in
> outstring, "The RX/TX queue number error.")
> + self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
> + self.vf_mac =
> + self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
> +
> + self.send_packet(self.vf_mac, self.src_intf, 254)
> + outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
> + self.check_packet_queue(outstring1)
> + self.vm0_testpmd.execute_cmd('quit', '# ')
> + self.dut.send_expect("quit", "# ")
> +
> + def test_set_invalid_vf_qn_in_testpmd(self):
> + """
> + Test case 4: set invalid VF queue number in testpmd command-line
> options
> + :return:
> + """
> + self.stop_vm0()
> + self.setup_vm_env(driver='igb_uio')
> + host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' %
> self.pf_pci
> + self.preset_host_testpmd(VM_CORES_MASK,
> eal_param=host_eal_param)
> + gest_eal_param = '-w %s --file-prefix=test2' %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd = PmdOutput(self.vm_dut_0)
> +
> + command_0 = "./%s/app/testpmd -c %s -n %d %s -- -i %s" \
> + % (self.dut.target, '0xf', self.dut.get_memory_channels(),
> gest_eal_param, ' --rxq=0 --txq=0')
> + outstring = self.vm0_testpmd.execute_cmd(command_0, expected='# ',
> timeout=120)
> + time.sleep(10)
> + self.verify("Either rx or tx queues should be non-zero" in outstring,
> "The output of testpmd start is different from expect when set invalid VF
> queue number 0.")
> + time.sleep(2)
> + command_17 = "./%s/app/testpmd -c %s -n %d %s -- -i %s" \
> + % (self.dut.target, '0xf', self.dut.get_memory_channels(),
> gest_eal_param, ' --rxq=17 --txq=17')
> + outstring1 = self.vm0_testpmd.execute_cmd(command_17,
> expected='# ', timeout=120)
> + time.sleep(10)
> + self.verify("rxq 17 invalid - must be >= 0 && <= 16" in outstring1,
> + "The output of testpmd start is different from expect when set
> invalid VF queue number 17.")
> + self.dut.send_expect("quit", "# ")
> +
> + def test_set_valid_vf_qn_with_testpmd_func_cmd(self):
> + """
> + Test case 5: set valid VF queue number with testpmd function
> command
> + :return:
> + """
> + self.stop_vm0()
> + self.setup_vm_env(driver='igb_uio')
> + host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' %
> self.pf_pci
> + self.preset_host_testpmd(VM_CORES_MASK,
> + eal_param=host_eal_param)
> +
> + gest_eal_param = '-w %s --file-prefix=test2' %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd = PmdOutput(self.vm_dut_0)
> + self.vm0_testpmd.start_testpmd(VM_CORES_MASK,
> eal_param=gest_eal_param, param='')
> + time.sleep(10)
> + guest_cmds = [['set promisc all off'],
> + ['set fwd mac'],
> + ['stop'],
> + ['port stop all'],
> + ['port config all txq 3'],
> + ['port config all rxq 3'],
> + ['port start all']]
> + self.execute_testpmd_cmd(guest_cmds)
> + outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("port 0: RX queue number: 3 Tx queue number: 3" in
> outstring, "The RX/TX queue number error.")
> + self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
> + self.vf_mac =
> + self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
> +
> + self.send_packet(self.vf_mac, self.src_intf, 3)
> + outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("Queue= 0" in outstring1 or "Queue= 1" in outstring1 or
> "Queue= 2" in outstring1,
> + "there is some queues doesn't work")
> +
> + self.vm0_testpmd.execute_cmd('quit', '# ')
> + self.dut.send_expect("quit", "# ")
> +
> + def test_set_min_vf_qn_with_testpmd_func_cmd(self):
> + """
> + Test case 5: set mininum valid VF queue number with testpmd
> function command
> + :return:
> + """
> + self.stop_vm0()
> + self.setup_vm_env(driver='igb_uio')
> + host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' %
> self.pf_pci
> + self.preset_host_testpmd(VM_CORES_MASK,
> + eal_param=host_eal_param)
> +
> + gest_eal_param = '-w %s --file-prefix=test2' %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd = PmdOutput(self.vm_dut_0)
> + self.vm0_testpmd.start_testpmd(VM_CORES_MASK,
> eal_param=gest_eal_param, param='')
> + time.sleep(10)
> + guest_cmds = [['set promisc all off'],
> + ['set fwd mac'],
> + ['stop'],
> + ['port stop all'],
> + ['port config all txq 1'],
> + ['port config all rxq 1'],
> + ['port start all']]
> + self.execute_testpmd_cmd(guest_cmds)
> + outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("port 0: RX queue number: 1 Tx queue number: 1" in
> outstring, "The RX/TX queue number error.")
> + self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
> + self.vf_mac =
> + self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
> +
> + self.send_packet(self.vf_mac, self.src_intf, 3)
> + outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("RX-packets: 3" in outstring1 and "TX-packets: 3" in
> outstring1,
> + "the count of packets is incorrect.")
> +
> + self.vm0_testpmd.execute_cmd('quit', '# ')
> + self.dut.send_expect("quit", "# ")
> +
> + def test_set_max_vf_qn_with_testpmd_func_cmd(self):
> + """
> + Test case 5: set maximum valid VF queue number with testpmd
> function command
> + :return:
> + """
> + self.stop_vm0()
> + self.setup_vm_env(driver='igb_uio')
> + host_eal_param = '-w %s --file-prefix=test1 --socket-mem 1024,1024' %
> self.pf_pci
> + self.preset_host_testpmd(VM_CORES_MASK,
> + eal_param=host_eal_param)
> +
> + gest_eal_param = '-w %s --file-prefix=test2' %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd = PmdOutput(self.vm_dut_0)
> + self.vm0_testpmd.start_testpmd(VM_CORES_MASK,
> eal_param=gest_eal_param, param='')
> + time.sleep(10)
> + guest_cmds = [['set promisc all off'],
> + ['set fwd mac'],
> + ['stop'],
> + ['port stop all'],
> + ['port config all txq 16'],
> + ['port config all rxq 16'],
> + ['port start all']]
> + self.execute_testpmd_cmd(guest_cmds)
> + outstring = self.vm0_testpmd.execute_cmd("start", "testpmd> ", 120)
> + time.sleep(2)
> + self.verify("port 0: RX queue number: 16 Tx queue number: 16" in
> outstring, "The RX/TX queue number error.")
> + self.vm0_dut_ports = self.vm_dut_0.get_ports('any')
> + self.vf_mac =
> + self.vm0_testpmd.get_port_mac(self.vm0_dut_ports[0])
> +
> + self.send_packet(self.vf_mac, self.src_intf, 254)
> + outstring1 = self.vm0_testpmd.execute_cmd("stop", "testpmd> ", 120)
> + self.check_packet_queue(outstring1)
> + self.vm0_testpmd.execute_cmd('quit', '# ')
> + self.dut.send_expect("quit", "# ")
> +
> + def test_set_invalid_vf_qn_with_testpmd_func_cmd(self):
> + """
> + Test case 6: set invalid VF queue number with testpmd function
> command
> + :return:
> + """
> + # There is a bug of this test case, so the function hasn't been
> implemented.
> + pass
> +
> + def test_reserve_vf_qn(self):
> + """
> + Test case 7: Reserve VF queue number when VF bind to kernel driver
> + :return:
> + """
> + self.stop_vm0()
> + self.setup_vm_env(driver='igb_uio')
> + host_eal_param = '-w %s,queue-num-per-vf=2 --file-prefix=test1 --
> socket-mem 1024,1024' % self.pf_pci
> + self.preset_host_testpmd(VM_CORES_MASK,
> + eal_param=host_eal_param)
> +
> + gest_eal_param = '-w %s --file-prefix=test2' %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd = PmdOutput(self.vm_dut_0)
> + self.vm0_testpmd.start_testpmd(VM_CORES_MASK,
> eal_param=gest_eal_param, param='')
> + time.sleep(1)
> + intf = self.vm_dut_0.ports_info[0]['intf']
> + if intf != 'N/A' and intf != '':
> + self.vm0_testpmd.execute_cmd('quit', '# ')
> + command = "./usertools/dpdk-devbind.py -b i40evf %s" %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd.execute_cmd(command, expected='# ',
> timeout=120)
> + output = self.vm0_testpmd.execute_cmd("ethtool -S %s" % intf,
> expected='# ', timeout=120)
> + self.verify("tx-0.packets: 0" in output and "tx-1.packets: 0" in output,
> "VF0 rxq and txq number is not 2.")
> + else:
> + time.sleep(120)
> + self.vm0_testpmd.execute_cmd('quit', '# ')
> + command = "./usertools/dpdk-devbind.py -b i40evf %s" %
> self.vm_dut_0.ports_info[0]['pci']
> + self.vm0_testpmd.execute_cmd(command, expected='# ',
> timeout=120)
> + nic_info = self.vm0_testpmd.execute_cmd("./usertools/dpdk-
> devbind.py -s | grep %s" % self.vm_dut_0.ports_info[0]['pci'], expected='# ',
> timeout=120)
> + time.sleep(2)
> + inf_str = nic_info.split("if=")[1]
> + inf = inf_str.split(" ")[0]
> + if "drv" not in inf and inf != "":
> + output = self.vm0_testpmd.execute_cmd("ethtool -S %s" % inf,
> expected='# ', timeout=120)
> + else:
> + output = ""
> + self.verify("tx-0.packets: 0" in output and "tx-1.packets: 0" in output,
> "VF0 rxq and txq number is not 2.")
> + self.dut.send_expect("quit", "# ")
> +
> + def tear_down(self):
> + pass
> +
> + def tear_down_all(self):
> + self.destroy_vm_env()
> + for port_id in self.dut_ports:
> + self.dut.destroy_sriov_vfs_by_port(port_id)
> +
> + self.tester.send_expect("kill -9 $(ps aux | grep -i qemu | grep
> + -v grep | awk {'print $2'})", '# ', 5)
> --
> 2.17.2
^ permalink raw reply [flat|nested] 3+ messages in thread
end of thread, other threads:[~2019-04-23 18:28 UTC | newest]
Thread overview: 3+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2019-04-22 3:25 [dts] [PATCH V1] tests/runtime_vf_queue_number:add testsuite for runtime vf queue number Jianwei Mei
2019-04-22 9:55 ` Xiao, QimaiX
2019-04-23 18:28 ` 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).