* [dts] [PATCH] test_plans: add floating_veb_test_plan.rst
@ 2016-12-06 7:36 peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] test_plans: add veb_switch_test_plan.rst peng,yuan
` (2 more replies)
0 siblings, 3 replies; 5+ messages in thread
From: peng,yuan @ 2016-12-06 7:36 UTC (permalink / raw)
To: dts; +Cc: Peng Yuan
From: Peng Yuan <yuan.peng@intel.com>
Signed-off-by: Peng Yuan <yuan.peng@intel.com>
diff --git a/test_plans/floating_veb_test_plan.rst b/test_plans/floating_veb_test_plan.rst
new file mode 100644
index 0000000..ad69570
--- /dev/null
+++ b/test_plans/floating_veb_test_plan.rst
@@ -0,0 +1,409 @@
+.. Copyright (c) <2016>, 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.
+
+=====================================
+VEB Switch and floating VEB Test Plan
+=====================================
+
+VEB Switching Introduction
+==========================
+
+IEEE EVB tutorial:
+http://www.ieee802.org/802_tutorials/2009-11
+/evb-tutorial-draft-20091116_v09.pdf
+
+Virtual Ethernet Bridge (VEB) - This is an IEEE EVB term. A VEB is a VLAN
+Bridge internal to Fortville that bridges the traffic of multiple VSIs over
+ an internal virtual network.
+
+Virtual Ethernet Port Aggregator (VEPA) - This is an IEEE EVB term. A VEPA
+multiplexes the traffic of one or more VSIs onto a single Fortville Ethernet
+port. The biggest difference between a VEB and a VEPA is that a VEB can
+switch packets internally between VSIs, whereas a VEPA cannot.
+
+Virtual Station Interface (VSI) - This is an IEEE EVB term that defines
+the properties of a virtual machine's (or a physical machine's) connection
+to the network. Each downstream v-port on a Fortville VEB or VEPA defines
+a VSI. A standards-based definition of VSI properties enables network
+management tools to perform virtual machine migration and associated network
+re-configuration in a vendor-neutral manner.
+
+My understanding of VEB is that it's an in-NIC switch(MAC/VLAN), and it can
+support VF->VF, PF->VF, VF->PF packet forwarding according to the NIC internal
+switch. It's similar as Niantic's SRIOV switch.
+
+Floating VEB Introduction
+=========================
+
+Floating VEB is based on VEB Switching. It will address 2 problems:
+
+Dependency on PF: When the physical port is link down, the functionality of
+the VEB/VEPA will not work normally. Even only data forwarding between the VF
+is required, one PF port will be wasted to create the related VEB.
+
+Ensure all the traffic from VF can only forwarding within the VFs connect
+to the floating VEB, cannot forward to the outside world.
+
+Prerequisites for VEB testing
+=============================
+
+1. Get the pci device id of DUT, for example::
+
+ ./dpdk-devbind.py --st
+ 0000:05:00.0 'Ethernet Controller X710 for 10GbE SFP+' if=ens785f0 drv=i40e
+ unused=
+
+2.1 Host PF in kernel driver. Create 2 VFs from 1 PF with kernel driver,
+ and set the VF MAC address at PF::
+
+ echo 2 > /sys/bus/pci/devices/0000\:05\:00.0/sriov_numvfs
+ ./dpdk-devbind.py --st
+
+ 0000:05:02.0 'XL710/X710 Virtual Function' unused=
+ 0000:05:02.1 'XL710/X710 Virtual Function' unused=
+
+ ip link set ens785f0 vf 0 mac 00:11:22:33:44:11
+ ip link set ens785f0 vf 1 mac 00:11:22:33:44:12
+
+2.2 Host PF in DPDK driver. Create 2VFs from 1 PF with dpdk driver::
+
+ ./dpdk-devbind.py -b igb_uio 05:00.0
+ echo 2 >/sys/bus/pci/devices/0000:05:00.0/max_vfs
+ ./dpdk-devbind.py --st
+ 0000:05:02.0 'XL710/X710 Virtual Function' unused=i40evf,igb_uio
+ 0000:05:02.1 'XL710/X710 Virtual Function' unused=i40evf,igb_uio
+
+3. Bind the VFs to dpdk driver::
+
+ ./tools/dpdk-devbind.py -b igb_uio 05:02.0 05:02.1
+
+4. Reserve huge pages memory(before using DPDK)::
+
+ echo 4096 > /sys/devices/system/node/node0/hugepages/hugepages-2048kB
+ /nr_hugepages
+ mkdir /mnt/huge
+ mount -t hugetlbfs nodev /mnt/huge
+
+
+Test Case1: Floating VEB inter VF-VF
+=======================================================
+
+Summary: 1 DPDK PF, then create 2VF, PF in the host running dpdk testpmd,
+and VF0 are running dpdk testpmd, VF0 send traffic, and set the packet's
+DEST MAC to VF1, check if VF1 can receive the packets. Check Inter VF-VF
+MAC switch when PF is link down as well as up.
+
+Launch PF testpmd::
+ ./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024
+ -w 05:00.0,enable_floating_veb=1 --file-prefix=test1 -- -i
+
+2. In the host, run testpmd with floating parameters and make the link down::
+
+ ./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024
+ -w 05:00.0,enable_floating_veb=1 --file-prefix=test1 -- -i
+ testpmd> port start all
+ testpmd> show port info all
+
+3. In VM1, run testpmd::
+
+ ./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024
+ -w 05:02.0 --file-prefix=test2 -- -i --crc-strip
+ testpmd>mac_addr add 0 vf1_mac_address
+ testpmd>set fwd rxonly
+ testpmd>start
+ testpmd>show port stats all
+
+ In VM2, run testpmd::
+
+ ./testpmd -c 0xf00 -n 4 --socket-mem 1024,1024 -w 05:02.1 --file-prefix=test3
+ -- -i --crc-strip --eth-peer=0,vf1_mac_address
+ testpmd>set fwd txonly
+ testpmd>start
+ testpmd>show port stats all
+
+4. check if VF1 can get all the packets. Check the packet content is no
+ corrupted. RX-packets=TX-packets, but there is a little RX-error.
+ RF receive no packets.
+
+5. Set "testpmd> port stop all" and "testpmd> start" in step2,
+ then run the step3-4 again. same result.
+
+
+Test Case2: Floating VEB PF can't get traffic from VF
+================================================================
+DPDK PF, then create 1VF, PF in the host running dpdk testpmd,
+send traffic from PF to VF0, VF0 can't receive any packets;
+send traffic from VF0 to PF, PF can't receive any packets either.
+
+
+1. In host, launch testpmd::
+
+ ./testpmd -c 0x3 -n 4 -w 82:00.0,enable_floating_veb=1 -- -i
+ testpmd> set fwd rxonly
+ testpmd> port start all
+ testpmd> start
+ testpmd> show port stats all
+
+3. In VM1, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,pf_mac_addr
+ testpmd>set fwd txonly
+ testpmd>start
+ testpmd>show port stats all
+
+4. Check if PF can not get any packets, so VF1->PF is not working.
+
+5. Set "testpmd> port stop all" in step2, then run the test case again.
+ Same result.
+
+
+
+Test Case2-2 Floating VEB VF can't receive traffic from outside world
+======================================================
+
+DPDK PF, then create 1VF, send traffic from tester to VF1,
+in floating mode, check VF1 can't receive traffic from tester.
+
+1. Start VM1 with VF1, see the prerequisite part.
+
+2. In host, launch testpmd::
+
+ ./testpmd -c 0x3 -n 4 -w 82:00.0,enable_floating_veb=1 -- -i
+ testpmd> set fwd mac
+ testpmd> port start all
+ testpmd> start
+ testpmd> show port stats all
+
+
+ In VM1, run testpmd:
+
+ ./testpmd -c 0x3 -n 4 -- -i
+ testpmd>show port info all //get VF_mac_address
+ testpmd>set fwd rxonly
+ testpmd>start
+ testpmd>show port stats all
+
+ In tester, run scapy
+
+ packet=Ether(dst="VF_mac_address")/IP()/UDP()/Raw('x'*20)
+ sendp(packet,iface="enp132s0f0")
+
+3. Check if VF1 can not get any packets, so tester->VF1 is not working.
+4. Set "testpmd> port stop all" in step2 in Host, then run the test case
+ again. same result.PF can't receive any packets.
+
+
+Test Case3: Floating VEB VF can not communicate with legacy VEB VF
+======================================================
+
+Summary: DPDK PF, then create 4VFs and 4VMs, VF1,VF3,VF4, floating VEB;
+VF2, lagecy VEB. Make PF link down(the cable can be pluged out),
+VFs in VMs are running dpdk testpmd.
+1. VF1 send traffic, and set the packet's DEST MAC to VF2,
+ check VF2 can not receive the packets.
+2. VF1 send traffic, and set the packet's DEST MAC to VF3,
+ check VF3 can receive the packets.
+3. VF4 send traffic, and set the packet's DEST MAC to VF3,
+ check VF3 can receive the packets.
+4. VF2 send traffic, and set the packet's DEST MAC to VF1,
+ check VF1 can not receive the packets.
+Check Inter-VM VF-VF MAC switch when PF is link down as well as up.
+
+Launch PF testpmd::
+ ./testpmd -c 0x3 -n 4
+ -w "82:00.0,enable_floating_veb=1,floating_veb_list=0;2-3" -- -i
+
+1. Start VM1 with VF1, VM2 with VF2, VM3 with VF3,
+ VM4 with VF4,see the prerequisite part.
+
+2. In the host, run testpmd with floating parameters and make the link down::
+
+ ./testpmd -c 0x3 -n 4
+ -w "82:00.0,enable_floating_veb=1,floating_veb_list=0;2-3" -- -i
+ //VF1 and VF3 in floating VEB, VF2 in legacy VEB
+
+ testpmd> port stop all
+ //this step should be executed after vf running testpmd.
+
+ testpmd> show port info all
+
+3. VF1 send traffic, and set the packet's DEST MAC to VF2,
+ check VF2 can not receive the packets.
+
+ In VM2, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i
+ testpmd>set fwd rxonly
+ testpmd>mac_addr add 0 vf2_mac_address //set the vf2_mac_address
+ testpmd>start
+ testpmd>show port stats all
+
+ In VM1, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,vf2_mac_address
+ testpmd>set fwd txonly
+ testpmd>start
+ testpmd>show port stats all
+
+ Check VF2 can not get any packets, so VF1->VF2 is not working.
+
+4. VF1 send traffic, and set the packet's DEST MAC to VF3,
+ check VF3 can receive the packets.
+
+ In VM3, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i
+ testpmd>set fwd rxonly
+ testpmd>show port info all //get the vf3_mac_address
+ testpmd>start
+ testpmd>show port stats all
+
+ In VM1, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,vf3_mac_address
+ testpmd>set fwd txonly
+ testpmd>start
+ testpmd>show port stats all
+
+ Check VF3 can get all the packets. Check the packet content is no corrupted.
+ so VF1->VF2 is working.
+
+5. VF2 send traffic, and set the packet's DEST MAC to VF1,
+ check VF1 can not receive the packets.
+
+ In VM1, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i
+ testpmd>set fwd rxonly
+ testpmd>show port info all //get the vf1_mac_address
+ testpmd>start
+ testpmd>show port stats all
+
+ In VM2, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,vf1_mac_address
+ testpmd>set fwd txonly
+ testpmd>start
+ testpmd>show port stats all
+
+ Check VF1 can not get any packets, so VF2->VF1 is not working.
+
+6. Set "testpmd> port start all" and "testpmd> start" in step2,
+ then run the step3-5 again. same result.
+
+
+Test Case4: PF can't get traffic from Floating VEB VF, but PF can get traffic
+================================================================
+from legacy VEB VF.
+================================================================
+DPDK PF, then create 2VFs, VF0 is in floating VEB, VF1 is in legacy VEB.
+1. Send traffic from VF0 to PF, then check PF will not see any traffic;
+2. Send traffic from VF1 to PF, then check PF will receive all the packets.
+3. send traffic from tester to VF0, check VF0 can't receive traffic from
+ tester.
+4. send traffic from tester to VF1, check VF1 can receive all the traffic
+ from tester.
+
+1. In host, launch testpmd::
+
+ ./testpmd -c 0x3 -n 4
+ -w 82:00.0,enable_floating_veb=1,floating_veb_list=0 -- -i
+ testpmd> set fwd rxonly
+ testpmd> port start all
+ testpmd> start
+ testpmd> show port stats all
+
+3. In VF1, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,pf_mac_addr
+ testpmd>set fwd txonly
+ testpmd>start
+ testpmd>show port stats all
+
+ Check PF can not get any packets, so VF1->PF is not working.
+
+4. In VF2, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,pf_mac_addr
+ testpmd>set fwd txonly
+ testpmd>start
+ testpmd>show port stats all
+
+ Check PF can get all the packets, so VF2->PF is working.
+
+5. Set "testpmd> port stop all" in step2 in Host,
+ then run the test case again. same result.
+
+6. In host, launch testpmd::
+
+ ./testpmd -c 0x3 -n 4
+ -w 82:00.0,enable_floating_veb=1,floating_veb_list=0 -- -i
+ testpmd> set fwd mac
+ testpmd> port start all
+ testpmd> start
+ testpmd> show port stats all
+
+
+7. In VF1, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i
+ testpmd>show port info all //get VF1_mac_address
+ testpmd>set fwd rxonly
+ testpmd>start
+ testpmd>show port stats all
+
+ In tester, run scapy
+
+ packet=Ether(dst="VF1_mac_address")/IP()/UDP()/Raw('x'*20)
+ sendp(packet,iface="enp132s0f0")
+
+ Check VF1 can not get any packets, so tester->VF1 is not working.
+
+8. In VF2, run testpmd::
+
+ ./testpmd -c 0x3 -n 4 -- -i
+ testpmd>show port info all //get VF2_mac_address
+ testpmd>set fwd rxonly
+ testpmd>start
+ testpmd>show port stats all
+
+ In tester, run scapy
+
+ packet=Ether(dst="VF2_mac_address")/IP()/UDP()/Raw('x'*20)
+ sendp(packet,iface="enp132s0f0")
+
+ Check VF1 can get all the packets, so tester->VF2 is working.
+
+5. Set "testpmd> port stop all" in step2 in Host, then run the test case again.
+ VF1 and VF2 cannot receive any packets. (because PF link down,
+ and PF can't receive any packets. so even if VF2 can't receive any packets.)
+
--
2.5.0
^ permalink raw reply [flat|nested] 5+ messages in thread
* [dts] [PATCH] test_plans: add veb_switch_test_plan.rst
2016-12-06 7:36 [dts] [PATCH] test_plans: add floating_veb_test_plan.rst peng,yuan
@ 2016-12-06 7:36 ` peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] tests: add TestSuite_floating_veb.py peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] tests: add TestSuite_veb_switch.py peng,yuan
2 siblings, 0 replies; 5+ messages in thread
From: peng,yuan @ 2016-12-06 7:36 UTC (permalink / raw)
To: dts; +Cc: Peng Yuan
From: Peng Yuan <yuan.peng@intel.com>
Signed-off-by: Peng Yuan <yuan.peng@intel.com>
diff --git a/test_plans/veb_switch_test_plan.rst b/test_plans/veb_switch_test_plan.rst
index 7cb3790..ca23df6 100644
--- a/test_plans/veb_switch_test_plan.rst
+++ b/test_plans/veb_switch_test_plan.rst
@@ -1,5 +1,5 @@
.. Copyright (c) <2016>, 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
@@ -37,232 +37,203 @@ VEB Switch and floating VEB Test Plan
VEB Switching Introduction
==========================
-IEEE EVB tutorial: http://www.ieee802.org/802_tutorials/2009-11/evb-tutorial-draft-20091116_v09.pdf
+IEEE EVB tutorial:
+http://www.ieee802.org/802_tutorials/2009-11
+/evb-tutorial-draft-20091116_v09.pdf
-Virtual Ethernet Bridge (VEB) - This is an IEEE EVB term. A VEB is a VLAN Bridge internal to Fortville that bridges the traffic of multiple VSIs over an internal virtual network.
+Virtual Ethernet Bridge (VEB) - This is an IEEE EVB term. A VEB is a VLAN
+Bridge internal to Fortville that bridges the traffic of multiple VSIs over
+ an internal virtual network.
-Virtual Ethernet Port Aggregator (VEPA) - This is an IEEE EVB term. A VEPA multiplexes the traffic of one or more VSIs onto a single Fortville Ethernet port. The biggest difference between a VEB and a VEPA is that a VEB can switch packets internally between VSIs, whereas a VEPA cannot.
+Virtual Ethernet Port Aggregator (VEPA) - This is an IEEE EVB term. A VEPA
+multiplexes the traffic of one or more VSIs onto a single Fortville Ethernet
+port. The biggest difference between a VEB and a VEPA is that a VEB can
+switch packets internally between VSIs, whereas a VEPA cannot.
-Virtual Station Interface (VSI) - This is an IEEE EVB term that defines the properties of a virtual machine's (or a physical machine's) connection to the network. Each downstream v-port on a Fortville VEB or VEPA defines a VSI. A standards-based definition of VSI properties enables network management tools to perform virtual machine migration and associated network re-configuration in a vendor-neutral manner.
+Virtual Station Interface (VSI) - This is an IEEE EVB term that defines
+the properties of a virtual machine's (or a physical machine's) connection
+to the network. Each downstream v-port on a Fortville VEB or VEPA defines
+a VSI. A standards-based definition of VSI properties enables network
+management tools to perform virtual machine migration and associated network
+re-configuration in a vendor-neutral manner.
-My understanding of VEB is that it's an in-NIC switch(MAC/VLAN), and it can support VF->VF, PF->VF, VF->PF packet forwarding according to the NIC internal switch. It's similar as Niantic's SRIOV switch.
-
-Floating VEB Introduction
-=========================
-
-Floating VEB is based on VEB Switching. It will address 2 problems:
-
-Dependency on PF: When the physical port is link down, the functionality of the VEB/VEPA will not work normally. Even only data forwarding between the VF is required, one PF port will be wasted to create the related VEB.
-
-Ensure all the traffic from VF can only forwarding within the VFs connect to the floating VEB, cannot forward out of the NIC port.
+My understanding of VEB is that it's an in-NIC switch(MAC/VLAN), and it can
+support VF->VF, PF->VF, VF->PF packet forwarding according to the NIC internal
+switch. It's similar as Niantic's SRIOV switch.
Prerequisites for VEB testing
=============================
1. Get the pci device id of DUT, for example::
- ./dpdk_nic_bind.py --st
-
- 0000:81:00.0 'Ethernet Controller X710 for 10GbE SFP+' if=ens259f0 drv=i40e unused=
+ ./dpdk-devbind.py --st
+ 0000:05:00.0 'Ethernet Controller X710 for 10GbE SFP+' if=ens785f0 drv=i40e
+ unused=
-2.1 Host PF in kernel driver. Create 2 VFs from 1 PF with kernel driver, and set the VF MAC address at PF0::
+2.1 Host PF in kernel driver. Create 2 VFs from 1 PF with kernel driver,
+ and set the VF MAC address at PF::
- echo 2 > /sys/bus/pci/devices/0000\:81\:00.0/sriov_numvfs
- ./dpdk_nic_bind.py --st
+ echo 2 > /sys/bus/pci/devices/0000\:05\:00.0/sriov_numvfs
+ ./dpdk-devbind.py --st
- 0000:81:02.0 'XL710/X710 Virtual Function' unused=
- 0000:81:02.1 'XL710/X710 Virtual Function' unused=
+ 0000:05:02.0 'XL710/X710 Virtual Function' unused=
+ 0000:05:02.1 'XL710/X710 Virtual Function' unused=
- ip link set ens259f0 vf 0 mac 00:11:22:33:44:11
- ip link set ens259f0 vf 1 mac 00:11:22:33:44:12
+ ip link set ens785f0 vf 0 mac 00:11:22:33:44:11
+ ip link set ens785f0 vf 1 mac 00:11:22:33:44:12
-2.2 Host PF in DPDK driver. Create 2VFs from 1 PF with dpdk driver.
+2.2 Host PF in DPDK driver. Create 2VFs from 1 PF with dpdk driver::
- ./dpdk_nic_bind.py -b igb_uio 81:00.0
- echo 2 >/sys/bus/pci/devices/0000:81:00.0/max_vfs
- ./dpdk_nic_bind.py --st
-
-3. Detach VFs from the host, bind them to pci-stub driver::
+ ./dpdk-devbind.py -b igb_uio 05:00.0
+ echo 2 >/sys/bus/pci/devices/0000:05:00.0/max_vfs
+ ./dpdk-devbind.py --st
+ 0000:05:02.0 'XL710/X710 Virtual Function' unused=i40evf,igb_uio
+ 0000:05:02.1 'XL710/X710 Virtual Function' unused=i40evf,igb_uio
- modprobe pci-stub
+3. Bind the VFs to dpdk driver::
- using `lspci -nn|grep -i ethernet` got VF device id, for example "8086 154c",
+ ./tools/dpdk-devbind.py -b igb_uio 05:02.0 05:02.1
- echo "8086 154c" > /sys/bus/pci/drivers/pci-stub/new_id
- echo 0000:81:02.0 > /sys/bus/pci/devices/0000:08:02.0/driver/unbind
- echo 0000:81:02.0 > /sys/bus/pci/drivers/pci-stub/bind
+4. Reserve huge pages memory(before using DPDK)::
- echo "8086 154c" > /sys/bus/pci/drivers/pci-stub/new_id
- echo 0000:81:02.1 > /sys/bus/pci/devices/0000:08:02.1/driver/unbind
- echo 0000:81:02.1 > /sys/bus/pci/drivers/pci-stub/bind
+ echo 4096 > /sys/devices/system/node/node0/hugepages/hugepages-2048kB
+ /nr_hugepages
+ mkdir /mnt/huge
+ mount -t hugetlbfs nodev /mnt/huge
-4. Lauch the VM with the VF PCI passthrough.
-
- taskset -c 18-19 qemu-system-x86_64 \
- -mem-path /mnt/huge -mem-prealloc \
- -enable-kvm -m 2048 -smp cores=2,sockets=1 -cpu host -name dpdk1-vm1 \
- -device pci-assign,host=81:02.0 \
- -drive file=/home/img/vm1.img \
- -netdev tap,id=ipvm1,ifname=tap3,script=/etc/qemu-ifup -device rtl8139,netdev=ipvm1,id=net0,mac=00:00:00:00:11:01 \
- -localtime -vnc :22 -daemonize
-
-Test Case1: VEB Switching Inter-VM VF-VF MAC switch
+Test Case1: VEB Switching Inter VF-VF MAC switch
===================================================
-Summary: Kernel PF, then create 2VFs and 2VMs, assign one VF to one VM, say VF1 in VM1, VF2 in VM2. VFs in VMs are running dpdk testpmd, send traffic to VF1, and set the packet's DEST MAC to VF2, check if VF2 can receive the packets. Check Inter-VM VF-VF MAC switch.
-
+Summary: Kernel PF, then create 2VFs. VFs running dpdk testpmd, send traffic
+to VF1, and set the packet's DEST MAC to VF2, check if VF2 can receive the
+packets. Check Inter VF-VF MAC switch.
+
Details::
-1. Start VM1 with VF1, VM2 with VF2, see the prerequisite part.
-2. In VM1, run testpmd::
+1. In VF1, run testpmd::
- ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,00:11:22:33:44:12
- testpmd>set mac fwd
- testpmd>set promisc off all
+ ./x86_64-native-linuxapp-gcc/app/testpmd -c 0x3 -n 4 --socket-mem 1024,1024
+ -w 05:02.0 --file-prefix=test1 -- -i --crc-strip --eth-peer=0,00:11:22:33:44:12
+ testpmd>set fwd mac
+ testpmd>set promisc all off
testpmd>start
- In VM2, run testpmd::
+ In VF2, run testpmd::
- ./testpmd -c 0x3 -n 4 -- -i
- testpmd>set mac fwd
- testpmd>set promisc off all
+ ./x86_64-native-linuxapp-gcc/app/testpmd -c 0xa -n 4 --socket-mem 1024,1024
+ -w 05:02.1 --file-prefix=test2 -- -i --crc-strip
+ testpmd>set fwd mac
+ testpmd>set promisc all off
testpmd>start
-3. Send 100 packets to VF1's MAC address, check if VF2 can get 100 packets. Check the packet content is not corrupted.
+2. Send 100 packets to VF1's MAC address, check if VF2 can get 100 packets.
+Check the packet content is no corrupted.
-Test Case2: VEB Switching Inter-VM VF-VF MAC/VLAN switch
+Test Case2: VEB Switching Inter VF-VF MAC/VLAN switch
========================================================
-Summary: Kernel PF, then create 2VFs and 2VMs, assign VF1 with VLAN=1 in VM1, VF2 with VLAN=2 in VM2. VFs in VMs are running dpdk testpmd, send traffic to VF1 with VLAN=1, then let it forwards to VF2, it should not work since they are not in the same VLAN; set VF2 with VLAN=1, then send traffic to VF1 with VLAN=1, and VF2 can receive the packets. Check inter-VM VF-VF MAC/VLAN switch.
+Summary: Kernel PF, then create 2VFs, assign VF1 with VLAN=1 in, VF2 with
+VLAN=2. VFs are running dpdk testpmd, send traffic to VF1 with VLAN=1,
+then let it forwards to VF2,it should not work since they are not in the
+same VLAN; set VF2 with VLAN=1, then send traffic to VF1 with VLAN=1,
+and VF2 can receive the packets. Check inter VF MAC/VLAN switch.
Details:
+1. Set the VLAN id of VF1 and VF2::
-1. Start VM1 with VF1, VM2 with VF2, see the prerequisite part.
+ ip link set ens785f0 vf 0 vlan 1
+ ip link set ens785f0 vf 1 vlan 2
-2. Set the VLAN id of VF1 and VF2::
+2. In VF1, run testpmd::
- ip link set ens259f0 vf 0 vlan 1
- ip link set ens259f0 vf 1 vlan 2
-
-3. In VM1, run testpmd::
-
- ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,00:11:22:33:44:12
- testpmd>set mac fwd
+ ./testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w 0000:05:02.0
+ --file-prefix=test1 -- -i --crc-strip --eth-peer=0,00:11:22:33:44:12
+ testpmd>set fwd mac
testpmd>set promisc all off
testpmd>start
- In VM2, run testpmd::
+ In VF2, run testpmd::
- ./testpmd -c 0x3 -n 4 -- -i
- testpmd>set mac fwd
+ ./testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w 0000:05:02.1
+ --file-prefix=test2 -- -i --crc-strip
+ testpmd>set fwd rxonly
testpmd>set promisc all off
testpmd>start
-4. Send 100 packets with VF1's MAC address and VLAN=1, check if VF2 can't get 100 packets since they are not in the same VLAN.
+4. Send 100 packets with VF1's MAC address and VLAN=1, check if VF2 can't
+ get 100 packets since they are not in the same VLAN.
5. Change the VLAN id of VF2::
- ip link set ens259f0 vf 1 vlan 1
+ ip link set ens785f0 vf 1 vlan 1
-6. Send 100 packets with VF1's MAC address and VLAN=1, check if VF2 can get 100 packets since they are in the same VLAN now. Check the packet content is not corrupted.
+6. Send 100 packets with VF1's MAC address and VLAN=1, check if VF2 can get
+ 100 packets since they are in the same VLAN now. Check the packet
+ content is not corrupted::
-Test Case3: VEB Switching Inter-VM PF-VF MAC switch
+ sendp([Ether(dst="00:11:22:33:44:11")/Dot1Q(vlan=1)/IP()
+ /Raw('x'*40)],iface="ens785f1")
+
+
+Test Case3: VEB Switching Inter PF-VF MAC switch
===================================================
-Summary: DPDK PF, then create 1VF, assign VF1 to VM1, PF in the host running dpdk traffic, send traffic from PF to VF1, ensure PF->VF1(let VF1 in promisc mode); send traffic from VF1 to PF, ensure VF1->PF can work.
+Summary: DPDK PF, then create 1VF, PF in the host running dpdk testpmd,
+send traffic from PF to VF1, ensure PF->VF1(let VF1 in promisc mode);
+send traffic from VF1 to PF,ensure VF1->PF can work.
Details:
-1. Start VM1 with VF1, see the prerequisite part.
+1. vf->pf
+ In host, launch testpmd::
-3. In host, launch testpmd::
-
- ./testpmd -c 0xc0000 -n 4 -- -i
- testpmd>set mac fwd
- testpmd>set promisc all on
+ ./testpmd -c 0x3 -n 4 -- -i
+ testpmd>set fwd rxonly
+ testpmd>set promisc all off
testpmd>start
In VM1, run testpmd::
- ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,pf_mac_addr (Note: this will let VF1 forwards packets to PF)
- testpmd>set mac fwd
- testpmd>set promisc all on
+ ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,pf_mac_addr
+ testpmd>set fwd txonly
+ testpmd>set promisc all off
testpmd>start
-
-4. Send 100 packets with VF1's MAC address, check if PF can get 100 packets, so VF1->PF is working. Check the packet content is not corrupted.
-
-5. Remove "--eth-peer" in VM1 testpmd commands, then send 100 packets with PF's MAC address, check if VF1 can get 100 packets, so PF->VF1 is working. Check the packet content is not corrupted.
-
-
-Test Case4: VEB Switching Inter-VM PF-VF/VF-VF MAC switch Performance
-=====================================================================
-
-Performance testing, repeat Testcase1(VF-VF) and Testcase3(PF-VF) to check the performance at different sizes(64B--1518B and jumbo frame--3000B) with 100% rate sending traffic.
-Test Case5: Floating VEB Inter-VM VF-VF
-=======================================
+2. pf->vf
+ In host, launch testpmd::
-Summary: DPDK PF, then create 2VFs and 2VMs, assign one VF to one VM, say VF1 in VM1, VF2 in VM2, and make PF link down(the cable can be pluged out). VFs in VMs are running dpdk testpmd, send traffic to VF1, and set the packet's DEST MAC to VF2, check if VF2 can receive the packets. Check Inter-VM VF-VF MAC switch when PF is link down as well as up.
-
-Details:
-
-1. Start VM1 with VF1, VM2 with VF2, see the prerequisite part.
-2. In the host, run testpmd with floating parameters and make the link down::
-
- ./testpmc -c 0xc0000 -n 4 --floating -- -i
- testpmd> port stop all
- testpmd> show port info all
-
-3. In VM1, run testpmd::
-
- ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,00:11:22:33:44:12
- testpmd>set mac fwd
- testpmd>set promisc off all
- testpmd>start
-
- In VM2, run testpmd::
+ ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,vf1_mac_addr
+ testpmd>set fwd txonly
+ testpmd>set promisc all off
+ testpmd>start
- ./testpmd -c 0x3 -n 4 -- -i
- testpmd>set mac fwd
- testpmd>set promisc off all
- testpmd>start
+ In VM1, run testpmd::
-
-4. Send 100 packets to VF1's MAC address, check if VF2 can get 100 packets. Check the packet content is not corrupted. Also check the PF's port stats, and there should be no packets RX/TX at PF port.
+ ./testpmd -c 0x3 -n 4 -- -i
+ testpmd>mac_addr add 0 vf1_mac_addr
+ testpmd>set fwd rxonly
+ testpmd>set promisc all off
+ testpmd>start
-5. In the host, run testpmd with floating parameters and keep the link up, then do step3 and step4, PF should have no RX/TX packets even when link is up::
+3. tester->vf
- ./testpmc -c 0xc0000 -n 4 --floating -- -i
- testpmd> port start all
- testpmd> show port info all
-
+4. Send 100 packets with PF's MAC address from VF, check if PF can get
+100 packets, so VF1->PF is working. Check the packet content is not corrupted.
-Test Case6: Floating VEB Inter-VM VF traffic can't be out of NIC
-================================================================
-
-DPDK PF, then create 1VF, assign VF1 to VM1, send traffic from VF1 to outside world, then check outside world will not see any traffic.
-
-Details:
-
-1. Start VM1 with VF1, see the prerequisite part.
-2. In the host, run testpmd with floating parameters.
-
- ./testpmc -c 0xc0000 -n 4 --floating -- -i
-
-3. In VM1, run testpmd, ::
-
- ./testpmd -c 0x3 -n 4 -- -i --eth-peer=0,pf_mac_addr
- testpmd>set fwd txonly
- testpmd>start
-
-
-4. At PF side, check the port stats to see if there is any RX/TX packets, and also check the traffic generator side(e.g: IXIA ports or another port connected to the DUT port) to ensure no packets.
+5. Send 100 packets with VF's MAC address from PF, check if VF1 can get
+100 packets, so PF->VF1 is working. Check the packet content is not corrupted.
+6. Send 100 packets with VF's MAC address from tester, check if VF1 can get
+100 packets, so tester->VF1 is working. Check the packet content is not
+corrupted.
+
-Test Case7: Floating VEB VF-VF Performance
-==========================================
+Test Case4: VEB Switching Inter-VM PF-VF/VF-VF MAC switch Performance
+=====================================================================
-Testing VF-VF performance at different sizes(64B--1518B and jumbo frame--3000B) with 100% rate sending traffic.
\ No newline at end of file
+Performance testing, repeat Testcase1(VF-VF) and Testcase3(PF-VF) to check
+the performance at different sizes(64B--1518B and jumbo frame--3000B)
+with 100% rate sending traffic
--
2.5.0
^ permalink raw reply [flat|nested] 5+ messages in thread
* [dts] [PATCH] tests: add TestSuite_floating_veb.py
2016-12-06 7:36 [dts] [PATCH] test_plans: add floating_veb_test_plan.rst peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] test_plans: add veb_switch_test_plan.rst peng,yuan
@ 2016-12-06 7:36 ` peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] tests: add TestSuite_veb_switch.py peng,yuan
2 siblings, 0 replies; 5+ messages in thread
From: peng,yuan @ 2016-12-06 7:36 UTC (permalink / raw)
To: dts; +Cc: Peng Yuan
From: Peng Yuan <yuan.peng@intel.com>
Signed-off-by: Peng Yuan <yuan.peng@intel.com>
diff --git a/tests/TestSuite_floating_veb.py b/tests/TestSuite_floating_veb.py
new file mode 100644
index 0000000..5b679b9
--- /dev/null
+++ b/tests/TestSuite_floating_veb.py
@@ -0,0 +1,689 @@
+# BSD LICENSE
+#
+# Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
+# All rights reserved.
+#
+# Redistribution and use in source and binary forms, with or without
+# modification, are permitted provided that the following conditions
+# are met:
+#
+# * Redistributions of source code must retain the above copyright
+# notice, this list of conditions and the following disclaimer.
+# * Redistributions in binary form must reproduce the above copyright
+# notice, this list of conditions and the following disclaimer in
+# the documentation and/or other materials provided with the
+# distribution.
+# * Neither the name of Intel Corporation nor the names of its
+# contributors may be used to endorse or promote products derived
+# from this software without specific prior written permission.
+#
+# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+"""
+DPDK Test suite.
+
+Test VEB Switch and floating VEB Features by Poll Mode Drivers.
+"""
+
+import re
+import time
+
+from virt_dut import VirtDut
+from project_dpdk import DPDKdut
+from dut import Dut
+from net_device import GetNicObj
+from net_device import RemoveNicObj
+from test_case import TestCase
+from pmd_output import PmdOutput
+from settings import HEADER_SIZE
+from packet import Packet
+from utils import RED
+
+
+class TestVEBSwitching(TestCase):
+
+ def VEB_get_stats(self, vf0_vf1, portid, rx_tx):
+ """
+ Get packets number from port statistic
+ """
+ if vf0_vf1 == "vf0":
+ stats = self.pmdout.get_pmd_stats(portid)
+ elif vf0_vf1 == "vf1":
+ stats = self.pmdout_session_secondary.get_pmd_stats(portid)
+ else:
+ return None
+
+ if rx_tx == "rx":
+ return [stats['RX-packets'], stats['RX-errors'], stats['RX-bytes']]
+ elif rx_tx == "tx":
+ return [stats['TX-packets'], stats['TX-errors'], stats['TX-bytes']]
+ else:
+ return None
+
+ def veb_get_pmd_stats(self, dev, portid, rx_tx):
+ stats = {}
+ rx_pkts_prefix = "RX-packets:"
+ rx_bytes_prefix = "RX-bytes:"
+ rx_error_prefix = "RX-errors:"
+ tx_pkts_prefix = "TX-packets:"
+ tx_error_prefix = "TX-errors:"
+ tx_bytes_prefix = "TX-bytes:"
+
+ if dev == "first":
+ out = self.dut.send_expect("show port stats %d" % portid, "testpmd> ")
+ elif dev == "second":
+ out = self.session_secondary.send_expect("show port stats %d" % portid, "testpmd> ")
+ elif dev == "third":
+ out = self.session_third.send_expect("show port stats %d" % portid, "testpmd> ")
+ else:
+ return None
+
+ stats["RX-packets"] = self.veb_get_pmd_value(rx_pkts_prefix, out)
+ stats["RX-bytes"] = self.veb_get_pmd_value(rx_bytes_prefix, out)
+ stats["RX-errors"] = self.veb_get_pmd_value(rx_error_prefix, out)
+ stats["TX-packets"] = self.veb_get_pmd_value(tx_pkts_prefix, out)
+ stats["TX-errors"] = self.veb_get_pmd_value(tx_error_prefix, out)
+ stats["TX-bytes"] = self.veb_get_pmd_value(tx_bytes_prefix, out)
+
+ if rx_tx == "rx":
+ return [stats['RX-packets'], stats['RX-errors'], stats['RX-bytes']]
+ elif rx_tx == "tx":
+ return [stats['TX-packets'], stats['TX-errors'], stats['TX-bytes']]
+ else:
+ return None
+
+
+ def veb_get_pmd_value(self, prefix, out):
+ pattern = re.compile(prefix + "(\s+)([0-9]+)")
+ m = pattern.search(out)
+ if m is None:
+ return None
+ else:
+ return int(m.group(2))
+
+ def send_packet(self, vf_mac, itf, tran_type=""):
+ """
+ Send 1 packet
+ """
+ self.tester.scapy_foreground()
+ self.tester.scapy_append('sys.path.append("./")')
+ self.dut.send_expect("start", "testpmd>")
+ mac = self.dut.get_mac_address(0)
+
+ if tran_type == "vlan":
+ packet = r'sendp([Ether(dst="%s", src=get_if_hwaddr("%s"))/Dot1Q(vlan=1)/IP(src="192.168.0.1", dst="192.168.0.2")], iface="%s")' % (vf_mac, itf, itf)
+ self.tester.scapy_append(packet)
+ self.tester.scapy_execute()
+ time.sleep(.5)
+ else:
+ packet = r'sendp([Ether(dst="%s", src=get_if_hwaddr("%s"))/IP(src="192.168.0.1", dst="192.168.0.2")], iface="%s")' % (vf_mac, itf, itf)
+ self.tester.scapy_append(packet)
+ self.tester.scapy_execute()
+ time.sleep(.5)
+
+ # Test cases.
+
+ def set_up_all(self):
+ """
+ Prerequisite steps for each test suite.
+ """
+ self.verify(self.nic in ["fortville_eagle", "fortville_spirit",
+ "fortville_spirit_single"],
+ "NIC Unsupported: " + str(self.nic))
+ self.dut_ports = self.dut.get_ports(self.nic)
+ self.verify(len(self.dut_ports) >= 1, "Insufficient ports")
+ self.session_secondary = self.dut.new_session()
+ self.session_third = self.dut.new_session()
+
+ self.setup_1pf_ddriver_1vf_env_flag = 0
+ self.setup_1pf_ddriver_2vf_env_flag = 0
+ self.setup_1pf_ddriver_4vf_env_flag = 0
+ self.vf0_mac = "00:11:22:33:44:11"
+ self.vf1_mac = "00:11:22:33:44:12"
+ self.vf2_mac = "00:11:22:33:44:13"
+ self.vf3_mac = "00:11:22:33:44:14"
+
+ self.used_dut_port = self.dut_ports[0]
+ localPort = self.tester.get_local_port(self.dut_ports[0])
+ self.tester_itf = self.tester.get_interface(localPort)
+ self.pf_interface = self.dut.ports_info[self.used_dut_port]['intf']
+ self.pf_mac_address = self.dut.get_mac_address(0)
+ self.pf_pci = self.dut.ports_info[self.used_dut_port]['pci']
+
+ def set_up(self):
+ """
+ This is to clear up environment before the case run.
+ """
+ self.dut.kill_all()
+
+ def setup_1pf_ddriver_4vf_env(self, driver='default'):
+
+ self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 4, driver='igb_uio')
+ self.sriov_vfs_port = self.dut.ports_info[self.used_dut_port]['vfs_port']
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+ try:
+
+ for port in self.sriov_vfs_port:
+ self.dut.send_expect("./tools/dpdk-devbind.py -b igb_uio %s" % (port.pci), "# ", 3)
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+ time.sleep(1)
+ for port_id in self.dut_ports:
+ if port_id == self.used_dut_port:
+ continue
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver()
+
+ self.setup_1pf_ddriver_4vf_env_flag = 1
+ except Exception as e:
+ self.destroy_1pf_ddriver_4vf_env()
+ raise Exception(e)
+
+ def destroy_1pf_ddriver_4vf_env(self):
+ self.session_third.send_expect("quit", "# ")
+ time.sleep(2)
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+ 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.setup_1pf_ddriver_4vf_env_flag = 0
+
+ def setup_1pf_ddriver_2vf_env(self, driver='default'):
+ self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 2, driver='igb_uio')
+ self.sriov_vfs_port = self.dut.ports_info[self.used_dut_port]['vfs_port']
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+ try:
+
+ for port in self.sriov_vfs_port:
+ self.dut.send_expect("./tools/dpdk-devbind.py -b igb_uio %s" % (port.pci), "# ", 3)
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+ time.sleep(1)
+ for port_id in self.dut_ports:
+ if port_id == self.used_dut_port:
+ continue
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver()
+
+ self.setup_1pf_ddriver_2vf_env_flag = 1
+ except Exception as e:
+ self.destroy_1pf_ddriver_2vf_env()
+ raise Exception(e)
+
+ def destroy_1pf_ddriver_2vf_env(self):
+ self.session_third.send_expect("quit", "# ")
+ time.sleep(2)
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+ 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.setup_1pf_ddriver_2vf_env_flag = 0
+
+ def setup_1pf_ddriver_1vf_env(self, driver='default'):
+ self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 1, driver='igb_uio')
+ self.sriov_vfs_port = self.dut.ports_info[self.used_dut_port]['vfs_port']
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+
+ try:
+
+ for port in self.sriov_vfs_port:
+ self.dut.send_expect("./tools/dpdk-devbind.py -b igb_uio %s" % (port.pci), "# ", 3)
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+ time.sleep(1)
+ for port_id in self.dut_ports:
+ if port_id == self.used_dut_port:
+ continue
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver()
+
+ self.setup_1pf_ddriver_1vf_env_flag = 1
+ except Exception as e:
+ self.destroy_1pf_ddriver_1vf_env()
+ raise Exception(e)
+
+ def destroy_1pf_ddriver_1vf_env(self):
+
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+ 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.setup_1pf_ddriver_1vf_env_flag = 0
+
+ def test_floating_VEB_inter_pf_vf(self):
+ """
+ DPDK PF, then create 1VF, PF in the host running dpdk testpmd, send traffic from PF to VF0, VF0 can't receive any packets; send traffic from VF0 to PF, PF can't rec eive any packets either.
+ """
+ # VF->PF
+ self.setup_1pf_ddriver_1vf_env(driver='')
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s,enable_floating_veb=1 --file-prefix=test1 -- -i" % self.pf_pci, "testpmd>", 120)
+ self.dut.send_expect("set fwd rxonly", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.pf_mac_address), "testpmd>", 120)
+ self.session_secondary.send_expect("set fwd txonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+
+ vf0_tx_stats = self.veb_get_pmd_stats("second", 0, "tx")
+ pf_rx_stats = self.veb_get_pmd_stats("first", 0, "rx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify(pf_rx_stats[0] == 0, "PF can receive packet from VF0, the floating VEB doesn't work")
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+
+ #PF->VF
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s,enable_floating_veb=1 --file-prefix=test1 -- -i --eth-peer=0,%s" % (self.pf_pci, self.vf0_mac), "testpmd>", 120)
+ self.dut.send_expect("set fwd txonly", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % (self.sriov_vfs_port[0].pci), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf0_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd rxonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.dut.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf0_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ pf_tx_stats = self.veb_get_pmd_stats("first", 0, "tx")
+ self.verify(pf_tx_stats[0] != 0, "no packet was sent by PF")
+ self.verify(vf0_rx_stats[0] == 0, "VF0 can receive packet from PF, the floating VEB doesn't work")
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+
+ #outside world ->VF
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s,enable_floating_veb=1 --file-prefix=test1 -- -i --eth-peer=0,%s" % (self.pf_pci, self.vf0_mac), "testpmd>", 120)
+ self.dut.send_expect("set fwd mac", "testpmd>")
+ self.dut.send_expect("set promisc all on", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % (self.sriov_vfs_port[0].pci), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf0_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd mac", "testpmd>")
+ self.session_secondary.send_expect("set promisc all on", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.send_packet(self.vf0_mac, self.tester_itf)
+ time.sleep(2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf0_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ self.verify(vf0_rx_stats[0] == 0, "VF0 can receive packet from outside world, the floating VEB doesn't work")
+
+ def test_floating_VEB_inter_vfs(self):
+ """
+ 1 DPDK PF, then create 2VF, PF in the host running dpdk testpmd, and VF0 are running dpdk testpmd, VF0 send traffic, and set the packet's DEST MAC to VF1, check if VF1 can receive the packets. Check Inter VF-VF MAC switch when PF is link down as well as up.
+ """
+ # PF link up, VF0->VF1
+ self.setup_1pf_ddriver_2vf_env(driver='')
+ # start PF
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s,enable_floating_veb=1 --file-prefix=test1 -- -i" % self.pf_pci, "testpmd>", 120)
+ self.dut.send_expect("port start all", "testpmd>")
+ time.sleep(2)
+ # start VF0
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % self.sriov_vfs_port[0].pci, "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf0_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd rxonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ # start VF1
+ self.session_third.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf00 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test3 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[1].pci, self.vf0_mac), "testpmd>", 120)
+ self.session_third.send_expect("set fwd txonly", "testpmd>")
+ self.session_third.send_expect("set promisc all off", "testpmd>")
+ self.session_third.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_third.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf0_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ vf1_tx_stats = self.veb_get_pmd_stats("third", 0, "tx")
+ self.verify(vf1_tx_stats[0] != 0, "no packet was sent by VF1")
+ self.verify(vf0_rx_stats[0] != 0, "no packet was received by VF0")
+ self.verify(vf1_tx_stats[0]*0.5 < vf0_rx_stats[0], "VF0 failed to receive most packets from VF1")
+
+ # PF link down, VF0 -> VF1
+ self.dut.send_expect("port stop all", "Port 0 Link Down", 10)
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_third.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_third.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+
+ vf1_tx_stats_pfstop = self.veb_get_pmd_stats("third", 0, "tx")
+ vf0_rx_stats_pfstop = self.veb_get_pmd_stats("second", 0, "rx")
+ vf1_tx_stats_pfstop[0] = vf1_tx_stats_pfstop[0] - vf1_tx_stats[0]
+ vf0_rx_stats_pfstop[0] = vf0_rx_stats_pfstop[0] - vf0_rx_stats[0]
+ self.verify(vf1_tx_stats_pfstop[0] != 0, "no packet was sent by VF1")
+ self.verify(vf0_rx_stats_pfstop[0] != 0, "no packet was received by VF0")
+ self.verify(vf1_tx_stats_pfstop[0]*0.5 < vf0_rx_stats_pfstop[0], "VF0 failed to receive most packets from VF1")
+
+ def test_floating_VEB_VF_and_legacy_VEB_VF(self):
+ """
+ DPDK PF, then create 4VF, VF0,VF2,VF3 are floating VEB; VF1 is lagecy VEB. Make PF link down(the cable can be pluged out), VFs are running dpdk testpmd.
+ 1. VF0 send traffic, and set the packet's DEST MAC to VF1, check VF1 can not receive the packets.
+ 2. VF1 send traffic, and set the packet's DEST MAC to VF0, check VF0 can not receive the packets.
+ 3. VF0 send traffic, and set the packet's DEST MAC to VF2, check VF2 can receive the packets.
+ 4. VF3 send traffic, and set the packet's DEST MAC to VF2, check VF2 can receive the packets.
+ """
+ self.setup_1pf_ddriver_4vf_env(driver='')
+ # start PF
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 \"-w %s,enable_floating_veb=1,floating_veb_list=0;2-3\" --file-prefix=test1 -- -i" % self.pf_pci, "testpmd>", 120)
+ self.dut.send_expect("port start all", "testpmd>")
+ time.sleep(2)
+ # VF1->VF0
+ # start VF0
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.vf1_mac), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf0_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd rxonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ # start VF1
+ self.session_third.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf00 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test3 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[1].pci, self.vf0_mac), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf1_mac, "testpmd>")
+ self.session_third.send_expect("set fwd txonly", "testpmd>")
+ self.session_third.send_expect("set promisc all off", "testpmd>")
+
+ # PF link down
+ self.dut.send_expect("port stop all", "Port 0 Link Down", 30)
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_third.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_third.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf0_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ vf1_tx_stats = self.veb_get_pmd_stats("third", 0, "tx")
+ self.verify(vf1_tx_stats[0] != 0, "no packet was sent by VF1")
+ self.verify(vf0_rx_stats[0] == 0, "floating_VEB VF can communicate with legacy_VEB VF")
+
+ # VF0->VF1
+ self.session_secondary.send_expect("set fwd txonly", "testpmd>")
+ self.session_third.send_expect("set fwd rxonly", "testpmd>")
+ self.session_third.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.session_third.send_expect("stop", "testpmd>", 2)
+ vf1_rx_stats = self.veb_get_pmd_stats("third", 0, "rx")
+ vf0_tx_stats = self.veb_get_pmd_stats("second", 0, "tx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify(vf1_rx_stats[0] == 0, "floating_VEB VF can communicate with legacy_VEB VF")
+
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.session_third.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # VF0->VF2
+ # start VF0
+ self.dut.send_expect("port start all", "testpmd>")
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.vf2_mac), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf0_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd txonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ # start VF2
+ self.session_third.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf00 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test3 -- -i --crc-strip" % self.sriov_vfs_port[2].pci, "testpmd>", 120)
+ self.session_third.send_expect("mac_addr add 0 %s" % self.vf2_mac, "testpmd>")
+ self.session_third.send_expect("set fwd rxonly", "testpmd>")
+ self.session_third.send_expect("set promisc all off", "testpmd>")
+
+ # PF link down
+ self.dut.send_expect("port stop all", "Port 0 Link Down", 30)
+ self.session_third.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.session_third.send_expect("stop", "testpmd>", 2)
+
+ vf2_rx_stats = self.veb_get_pmd_stats("third", 0, "rx")
+ vf0_tx_stats = self.veb_get_pmd_stats("second", 0, "tx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify(vf2_rx_stats[0] != 0, "floating_VEB VFs cannot communicate with each other")
+ self.verify(vf0_tx_stats[0] * 0.5 < vf2_rx_stats[0], "VF2 failed to receive packets from VF0")
+
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.session_third.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # VF3->VF2
+ # start VF3
+ self.dut.send_expect("port start all", "testpmd>")
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[3].pci, self.vf2_mac), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf0_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd txonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ # start VF2
+ self.session_third.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf00 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test3 -- -i --crc-strip" % self.sriov_vfs_port[2].pci, "testpmd>", 120)
+ self.session_third.send_expect("mac_addr add 0 %s" % self.vf2_mac, "testpmd>")
+ self.session_third.send_expect("set fwd rxonly", "testpmd>")
+ self.session_third.send_expect("set promisc all off", "testpmd>")
+
+ # PF link down
+ self.dut.send_expect("port stop all", "Port 0 Link Down", 30)
+ self.session_third.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.session_third.send_expect("stop", "testpmd>", 2)
+
+ vf2_rx_stats = self.veb_get_pmd_stats("third", 0, "rx")
+ vf3_tx_stats = self.veb_get_pmd_stats("second", 0, "tx")
+ self.verify(vf3_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify(vf2_rx_stats[0] != 0, "floating_VEB VFs cannot communicate with each other")
+ self.verify(vf3_tx_stats[0] * 0.5 < vf2_rx_stats[0], "VF2 failed to receive packets from VF3")
+
+ def test_floating_VEB_and_legacy_VEB_inter_pf_vf(self):
+ """
+ DPDK PF, then create 4VFs, VF0 and VF3 is in floating VEB, VF1 and VF2 are in legacy VEB.
+ 1. Send traffic from VF0 to PF, then check PF will not see any traffic;
+ 2. Send traffic from VF1 to PF, then check PF will receive all the packets.
+ 3. send traffic from tester to VF0, check VF0 can't receive traffic from tester.
+ 4. send traffic from tester to VF1, check VF1 can receive all the traffic from tester.
+ 5. send traffic from VF1 to VF2, check VF2 can receive all the traffic from VF1.
+ """
+ self.setup_1pf_ddriver_4vf_env(driver='')
+ # VF0->PF
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 \"-w %s,enable_floating_veb=1,floating_veb_list=0;3\" --file-prefix=test1 -- -i" % self.pf_pci, "testpmd>", 120)
+ self.dut.send_expect("set fwd rxonly", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.pf_mac_address), "testpmd>", 120)
+ self.session_secondary.send_expect("set fwd txonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+
+ vf0_tx_stats = self.veb_get_pmd_stats("second", 0, "tx")
+ pf_rx_stats = self.veb_get_pmd_stats("first", 0, "rx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify(pf_rx_stats[0] == 0, "PF can receive packet from VF0, the floating VEB doesn't work")
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # VF1->PF
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[1].pci, self.pf_mac_address), "testpmd>", 120)
+ self.session_secondary.send_expect("set fwd txonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+
+ vf1_tx_stats = self.veb_get_pmd_stats("second", 0, "tx")
+ pf_rx_stats = self.veb_get_pmd_stats("first", 0, "rx")
+ self.verify(vf1_tx_stats[0] != 0, "no packet was sent by VF1")
+ self.verify(pf_rx_stats[0] != 0, "PF can't receive packet from VF1, the VEB doesn't work")
+ self.verify(vf1_tx_stats[0] * 0.5 < pf_rx_stats[0], "PF failed to receive packets from VF1")
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # tester->VF0
+ self.dut.send_expect("set fwd mac", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % (self.sriov_vfs_port[0].pci), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf0_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd mac", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.send_packet(self.vf0_mac, self.tester_itf)
+ time.sleep(2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+
+ vf0_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ self.verify(vf0_rx_stats[0] == 0, "VF0 can receive packet from outside world, the floating VEB doesn't work")
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # tester->VF1
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % (self.sriov_vfs_port[1].pci), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf1_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd mac", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.send_packet(self.vf1_mac, self.tester_itf)
+ time.sleep(2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+
+ vf1_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ self.verify(vf1_rx_stats[0] == 1, "VF1 can't receive packet from outside world, the VEB doesn't work")
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # VF2->VF1
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % (self.sriov_vfs_port[1].pci), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf1_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd rxonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_third.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf00 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test3 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[2].pci, self.vf1_mac), "testpmd>", 120)
+ self.session_third.send_expect("set fwd txonly", "testpmd>")
+ self.session_third.send_expect("set promisc all off", "testpmd>")
+ self.session_third.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_third.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf1_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ vf2_tx_stats = self.veb_get_pmd_stats("third", 0, "tx")
+ self.verify(vf2_tx_stats[0] != 0, "no packet was sent by VF2")
+ self.verify(vf1_rx_stats[0] != 0, "VF1 can't receive packet from VF2, the VEB doesn't work")
+ self.verify(vf2_tx_stats[0] * 0.5 < vf1_rx_stats[0], "VF1 failed to receive packets from VF2")
+ self.session_third.send_expect("quit", "# ")
+ time.sleep(2)
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # PF link down, VF2->VF1
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % (self.sriov_vfs_port[1].pci), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf1_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd rxonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+
+ self.session_third.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf00 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test3 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[2].pci, self.vf1_mac), "testpmd>", 120)
+ self.session_third.send_expect("set fwd txonly", "testpmd>")
+ self.session_third.send_expect("set promisc all off", "testpmd>")
+
+ self.dut.send_expect("port stop all", "Port 0 Link Down", 10)
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_third.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_third.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf1_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ vf2_tx_stats = self.veb_get_pmd_stats("third", 0, "tx")
+ self.verify(vf2_tx_stats[0] != 0, "no packet was sent by VF2")
+ self.verify(vf1_rx_stats[0] != 0, "VF1 can't receive packet from VF2, the VEB doesn't work")
+ self.verify(vf2_tx_stats[0] * 0.5 < vf1_rx_stats[0], "VF1 failed to receive packets from VF2")
+
+ def tear_down(self):
+ """
+ Run after each test case.
+ """
+ if self.setup_1pf_ddriver_1vf_env_flag == 1:
+ self.destroy_1pf_ddriver_1vf_env()
+ if self.setup_1pf_ddriver_2vf_env_flag == 1:
+ self.destroy_1pf_ddriver_2vf_env()
+ if self.setup_1pf_ddriver_4vf_env_flag == 1:
+ self.destroy_1pf_ddriver_4vf_env()
+
+ self.dut.kill_all()
+
+ pass
+
+ def tear_down_all(self):
+ """
+ Run after each test suite.
+ """
+ self.dut.kill_all()
+ self.dut.close_session(self.session_secondary)
+ self.dut.close_session(self.session_third)
+ # Marvin recommended that all the dut ports should be bound to igb_uio.
+ for port_id in self.dut_ports:
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver(driver='igb_uio')
+
+ pass
--
2.5.0
^ permalink raw reply [flat|nested] 5+ messages in thread
* [dts] [PATCH] tests: add TestSuite_veb_switch.py
2016-12-06 7:36 [dts] [PATCH] test_plans: add floating_veb_test_plan.rst peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] test_plans: add veb_switch_test_plan.rst peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] tests: add TestSuite_floating_veb.py peng,yuan
@ 2016-12-06 7:36 ` peng,yuan
2016-12-07 2:18 ` Liu, Yong
2 siblings, 1 reply; 5+ messages in thread
From: peng,yuan @ 2016-12-06 7:36 UTC (permalink / raw)
To: dts; +Cc: Peng Yuan
From: Peng Yuan <yuan.peng@intel.com>
Signed-off-by: Peng Yuan <yuan.peng@intel.com>
diff --git a/tests/TestSuite_veb_switch.py b/tests/TestSuite_veb_switch.py
new file mode 100644
index 0000000..3492579
--- /dev/null
+++ b/tests/TestSuite_veb_switch.py
@@ -0,0 +1,523 @@
+# BSD LICENSE
+#
+# Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
+# All rights reserved.
+#
+# Redistribution and use in source and binary forms, with or without
+# modification, are permitted provided that the following conditions
+# are met:
+#
+# * Redistributions of source code must retain the above copyright
+# notice, this list of conditions and the following disclaimer.
+# * Redistributions in binary form must reproduce the above copyright
+# notice, this list of conditions and the following disclaimer in
+# the documentation and/or other materials provided with the
+# distribution.
+# * Neither the name of Intel Corporation nor the names of its
+# contributors may be used to endorse or promote products derived
+# from this software without specific prior written permission.
+#
+# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+"""
+DPDK Test suite.
+
+Test VEB Switch and floating VEB Features by Poll Mode Drivers.
+"""
+
+import re
+import time
+
+from virt_dut import VirtDut
+from project_dpdk import DPDKdut
+from dut import Dut
+from net_device import GetNicObj
+from net_device import RemoveNicObj
+from test_case import TestCase
+from pmd_output import PmdOutput
+from settings import HEADER_SIZE
+from packet import Packet
+from utils import RED
+
+
+class TestVEBSwitching(TestCase):
+
+ def VEB_get_stats(self, vf0_vf1, portid, rx_tx):
+ """
+ Get packets number from port statistic
+ """
+ if vf0_vf1 == "vf0":
+ stats = self.pmdout.get_pmd_stats(portid)
+ elif vf0_vf1 == "vf1":
+ stats = self.pmdout_session_secondary.get_pmd_stats(portid)
+ else:
+ return None
+
+ if rx_tx == "rx":
+ return [stats['RX-packets'], stats['RX-errors'], stats['RX-bytes']]
+ elif rx_tx == "tx":
+ return [stats['TX-packets'], stats['TX-errors'], stats['TX-bytes']]
+ else:
+ return None
+
+ def veb_get_pmd_stats(self, dev, portid, rx_tx):
+ stats = {}
+ rx_pkts_prefix = "RX-packets:"
+ rx_bytes_prefix = "RX-bytes:"
+ rx_error_prefix = "RX-errors:"
+ tx_pkts_prefix = "TX-packets:"
+ tx_error_prefix = "TX-errors:"
+ tx_bytes_prefix = "TX-bytes:"
+
+ if dev == "first":
+ out = self.dut.send_expect("show port stats %d" % portid, "testpmd> ")
+ elif dev == "second":
+ out = self.session_secondary.send_expect("show port stats %d" % portid, "testpmd> ")
+ elif dev == "third":
+ out = self.session_third.send_expect("show port stats %d" % portid, "testpmd> ")
+ else:
+ return None
+
+ stats["RX-packets"] = self.veb_get_pmd_value(rx_pkts_prefix, out)
+ stats["RX-bytes"] = self.veb_get_pmd_value(rx_bytes_prefix, out)
+ stats["RX-errors"] = self.veb_get_pmd_value(rx_error_prefix, out)
+ stats["TX-packets"] = self.veb_get_pmd_value(tx_pkts_prefix, out)
+ stats["TX-errors"] = self.veb_get_pmd_value(tx_error_prefix, out)
+ stats["TX-bytes"] = self.veb_get_pmd_value(tx_bytes_prefix, out)
+
+ if rx_tx == "rx":
+ return [stats['RX-packets'], stats['RX-errors'], stats['RX-bytes']]
+ elif rx_tx == "tx":
+ return [stats['TX-packets'], stats['TX-errors'], stats['TX-bytes']]
+ else:
+ return None
+
+
+ def veb_get_pmd_value(self, prefix, out):
+ pattern = re.compile(prefix + "(\s+)([0-9]+)")
+ m = pattern.search(out)
+ if m is None:
+ return None
+ else:
+ return int(m.group(2))
+
+ def send_packet(self, vf_mac, itf, tran_type=""):
+ """
+ Send 1 packet
+ """
+ self.tester.scapy_foreground()
+ self.tester.scapy_append('sys.path.append("./")')
+ self.dut.send_expect("start", "testpmd>")
+ mac = self.dut.get_mac_address(0)
+
+ if tran_type == "vlan":
+ packet = r'sendp([Ether(dst="%s", src=get_if_hwaddr("%s"))/Dot1Q(vlan=1)/IP(src="192.168.0.1", dst="192.168.0.2")], iface="%s")' % (vf_mac, itf, itf)
+ self.tester.scapy_append(packet)
+ self.tester.scapy_execute()
+ time.sleep(.5)
+ else:
+ packet = r'sendp([Ether(dst="%s", src=get_if_hwaddr("%s"))/IP(src="192.168.0.1", dst="192.168.0.2")], iface="%s")' % (vf_mac, itf, itf)
+ self.tester.scapy_append(packet)
+ self.tester.scapy_execute()
+ time.sleep(.5)
+
+ # Test cases.
+
+ def set_up_all(self):
+ """
+ Prerequisite steps for each test suite.
+ """
+ self.verify(self.nic in ["fortville_eagle", "fortville_spirit",
+ "fortville_spirit_single"],
+ "NIC Unsupported: " + str(self.nic))
+ self.dut_ports = self.dut.get_ports(self.nic)
+ self.verify(len(self.dut_ports) >= 1, "Insufficient ports")
+ self.session_secondary = self.dut.new_session()
+ self.session_third = self.dut.new_session()
+
+ self.setup_1pf_kdriver_2vf_env_flag = 0
+ self.setup_1pf_ddriver_1vf_env_flag = 0
+ self.setup_1pf_ddriver_2vf_env_flag = 0
+ self.vf0_mac = "00:11:22:33:44:11"
+ self.vf1_mac = "00:11:22:33:44:12"
+ self.vf2_mac = "00:11:22:33:44:13"
+ self.vf3_mac = "00:11:22:33:44:14"
+
+ self.used_dut_port = self.dut_ports[0]
+ localPort = self.tester.get_local_port(self.dut_ports[0])
+ self.tester_itf = self.tester.get_interface(localPort)
+ self.pf_interface = self.dut.ports_info[self.used_dut_port]['intf']
+ self.pf_mac_address = self.dut.get_mac_address(0)
+ self.pf_pci = self.dut.ports_info[self.used_dut_port]['pci']
+
+ def set_up(self):
+ """
+ This is to clear up environment before the case run.
+ """
+ self.dut.kill_all()
+
+ def setup_1pf_ddriver_2vf_env(self, driver='default'):
+ self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 2, driver='igb_uio')
+ self.sriov_vfs_port = self.dut.ports_info[self.used_dut_port]['vfs_port']
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+ try:
+
+ for port in self.sriov_vfs_port:
+ self.dut.send_expect("./tools/dpdk-devbind.py -b igb_uio %s" % (port.pci), "# ", 3)
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+ time.sleep(1)
+ for port_id in self.dut_ports:
+ if port_id == self.used_dut_port:
+ continue
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver()
+
+ self.setup_1pf_ddriver_2vf_env_flag = 1
+ except Exception as e:
+ self.destroy_1pf_ddriver_2vf_env()
+ raise Exception(e)
+
+ def destroy_1pf_ddriver_2vf_env(self):
+ self.session_third.send_expect("quit", "# ")
+ time.sleep(2)
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+ 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.setup_1pf_ddriver_2vf_env_flag = 0
+
+ def setup_1pf_ddriver_1vf_env(self, driver='default'):
+ self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 1, driver='igb_uio')
+ self.sriov_vfs_port = self.dut.ports_info[self.used_dut_port]['vfs_port']
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+
+ try:
+
+ for port in self.sriov_vfs_port:
+ self.dut.send_expect("./tools/dpdk-devbind.py -b igb_uio %s" % (port.pci), "# ", 3)
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+ time.sleep(1)
+ for port_id in self.dut_ports:
+ if port_id == self.used_dut_port:
+ continue
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver()
+
+ self.setup_1pf_ddriver_1vf_env_flag = 1
+ except Exception as e:
+ self.destroy_1pf_ddriver_1vf_env()
+ raise Exception(e)
+
+ def destroy_1pf_ddriver_1vf_env(self):
+
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+ 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.setup_1pf_ddriver_1vf_env_flag = 0
+
+ def setup_1pf_kdriver_2vf_env(self, driver='default'):
+ for port_id in self.dut_ports:
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver()
+ self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 2, driver=driver)
+ self.sriov_vfs_port = self.dut.ports_info[self.used_dut_port]['vfs_port']
+ self.dut.send_expect("ip link set %s vf 0 mac %s" % (self.pf_interface, self.vf0_mac), "# ", 3)
+ self.dut.send_expect("ip link set %s vf 1 mac %s" % (self.pf_interface, self.vf1_mac), "# ", 3)
+
+ try:
+
+ for port in self.sriov_vfs_port:
+ self.dut.send_expect("./tools/dpdk-devbind.py -b igb_uio %s" % (port.pci), "# ", 3)
+ self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
+ time.sleep(1)
+ self.setup_1pf_kdriver_2vf_env_flag = 1
+ except Exception as e:
+ self.destroy_1pf_kdriver_2vf_env()
+ raise Exception(e)
+
+ def destroy_1pf_kdriver_2vf_env(self):
+
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+ 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.setup_1pf_kdriver_2vf_env_flag = 0
+
+ def test_VEB_switching_inter_vfs(self):
+ """
+ Kernel PF, then create 2VFs. VFs running dpdk testpmd, send traffic to VF1, and set the packet's DEST MAC to VF2, check if VF2 can receive the packets. Check Inter VF-VF MAC switch.
+ """
+ self.setup_1pf_kdriver_2vf_env(driver='')
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test1 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.vf1_mac), "testpmd>", 120)
+ self.dut.send_expect("set fwd txonly", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % self.sriov_vfs_port[1].pci, "testpmd>", 120)
+ self.session_secondary.send_expect("set fwd rxonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>", 5)
+ self.dut.send_expect("start", "testpmd>", 5)
+ time.sleep(2)
+
+ self.dut.send_expect("stop", "testpmd>", 5)
+ self.session_secondary.send_expect("stop", "testpmd>", 5)
+
+ vf0_tx_stats = self.veb_get_pmd_stats("first", 0, "tx")
+ vf1_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify(vf0_tx_stats[0] * 0.5 < vf1_rx_stats[0], "VF1 failed to receive packets from VF0")
+
+ def test_VEB_switching_inter_vfs_mac_fwd(self):
+ """
+ Kernel PF, then create 2VFs. VFs running dpdk testpmd, send traffic to VF1, and set the packet's DEST MAC to VF2, check if VF2 can receive the packets. Check Inter VF-VF MAC switch.
+ """
+ self.setup_1pf_kdriver_2vf_env(driver='')
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test1 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.vf1_mac), "testpmd>", 120)
+ self.dut.send_expect("set fwd mac", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % self.sriov_vfs_port[1].pci, "testpmd>", 120)
+ self.session_secondary.send_expect("set fwd rxonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.send_packet(self.vf0_mac, self.tester_itf)
+
+ self.dut.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf0_tx_stats = self.veb_get_pmd_stats("first", 0, "tx")
+ vf1_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify(vf0_tx_stats == vf1_rx_stats, "VF1 failed to receive packets from VF0")
+
+ def test_VEB_switching_inter_vfs_vlan(self):
+ """
+ Kernel PF, then create 2VFs, assign VF1 with VLAN=1 in, VF2 with VLAN=2. VFs are running dpdk testpmd, send traffic to VF1 with VLAN=1, then let it forwards to VF2, it should not work since they are not in the same VLAN; set VF2 with VLAN=1, then send traffic to VF1 with VLAN=1, and VF2 can receive the packets. Check inter VF MAC/VLAN switch.
+ """
+ self.setup_1pf_kdriver_2vf_env(driver='')
+ # the two vfs belongs to different vlans
+ self.dut.send_expect("ip link set %s vf 0 vlan 1" % self.pf_interface, "# ", 1)
+ self.dut.send_expect("ip link set %s vf 1 vlan 2" % self.pf_interface, "# ", 1)
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test1 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.vf1_mac), "testpmd>", 120)
+ self.dut.send_expect("set fwd mac", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % self.sriov_vfs_port[1].pci, "testpmd>", 120)
+ self.session_secondary.send_expect("set fwd mac", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.send_packet(self.vf0_mac, self.tester_itf, "vlan")
+
+ self.dut.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf0_tx_stats = self.veb_get_pmd_stats("first", 0, "tx")
+ vf1_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify((vf0_tx_stats[0] == 1) and (vf1_rx_stats[0] == 0), "VF1 received packets from VF0, the vlan filter doen't work")
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # the two vfs belongs to the same vlan
+ self.dut.send_expect("ip link set %s vf 1 vlan 1" % self.pf_interface, "# ", 1)
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test1 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.vf1_mac), "testpmd>", 120)
+ self.dut.send_expect("set fwd mac", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % self.sriov_vfs_port[1].pci, "testpmd>", 120)
+ self.session_secondary.send_expect("set fwd mac", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.send_packet(self.vf0_mac, self.tester_itf, "vlan")
+
+ self.dut.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf0_tx_stats = self.veb_get_pmd_stats("first", 0, "tx")
+ vf1_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify((vf0_tx_stats[0] == 1) and (vf1_rx_stats[0] == 1), "VF1 didn't receive packets from VF0, the vlan filter doen't work")
+
+ def test_VEB_switching_inter_vfs_and_pf(self):
+ """
+ DPDK PF, then create 1VF, PF in the host running dpdk testpmd, VFs running dpdk testpmd, VF1 send traffic to VF2, check if VF2 can receive the packets. send traffic from PF to VF1, ensure PF->VF1; send traffic from VF1 to PF, ensure VF1->PF can work.
+ """
+ # VF->PF
+ self.setup_1pf_ddriver_2vf_env(driver='')
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test1 -- -i" % self.pf_pci, "testpmd>", 120)
+ self.dut.send_expect("set fwd rxonly", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.pf_mac_address), "testpmd>", 120)
+ self.session_secondary.send_expect("set fwd txonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+
+ vf0_tx_stats = self.veb_get_pmd_stats("second", 0, "tx")
+ pf_rx_stats = self.veb_get_pmd_stats("first", 0, "rx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify(pf_rx_stats[0] != 0, "no packet was received by PF")
+ self.verify(vf0_tx_stats[0]*0.5 < pf_rx_stats[0], "PF failed to receive most packets from VF0")
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+
+ #PF->VF
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test1 -- -i --eth-peer=0,%s" % (self.pf_pci, self.vf0_mac), "testpmd>", 120)
+ self.dut.send_expect("set fwd txonly", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % (self.sriov_vfs_port[0].pci), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf0_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd rxonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.dut.send_expect("stop", "testpmd>", 2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+
+ vf0_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ pf_tx_stats = self.veb_get_pmd_stats("first", 0, "tx")
+ self.verify(pf_tx_stats[0] != 0, "no packet was sent by PF")
+ self.verify(vf0_rx_stats[0] != 0, "no packet was received by VF0")
+ self.verify(vf0_rx_stats[0] > pf_tx_stats[0]*0.5, "VF0 failed to receive most packets from PF")
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # tester->VF
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test1 -- -i" % self.pf_pci, "testpmd>", 120)
+ self.dut.send_expect("set fwd mac", "testpmd>")
+ self.dut.send_expect("set promisc all off", "testpmd>")
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip" % (self.sriov_vfs_port[0].pci), "testpmd>", 120)
+ self.session_secondary.send_expect("mac_addr add 0 %s" % self.vf0_mac, "testpmd>")
+ self.session_secondary.send_expect("set fwd rxonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.send_packet(self.vf0_mac, self.tester_itf)
+ time.sleep(2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+ vf0_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ pf_tx_stats = self.veb_get_pmd_stats("first", 0, "tx")
+ self.verify(pf_tx_stats[0] == 0, "PF received unexpected packet")
+ self.verify(vf0_rx_stats[0] == 1, "no packet was received by VF0")
+
+ self.dut.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+ self.send_packet(self.pf_mac_address, self.tester_itf)
+ time.sleep(2)
+ self.session_secondary.send_expect("stop", "testpmd>", 2)
+ self.dut.send_expect("stop", "testpmd>", 2)
+ vf0_rx_stats = self.veb_get_pmd_stats("second", 0, "rx")
+ pf_tx_stats = self.veb_get_pmd_stats("first", 0, "tx")
+ pf_rx_stats = self.veb_get_pmd_stats("first", 0, "rx")
+ self.verify(pf_tx_stats[0] == 1, "no packet was sent by VF0")
+ self.verify(pf_rx_stats[0] == 1, "no packet was received by VF0")
+ self.verify(vf0_rx_stats[0] == 1, "no packet was received by VF0")
+ self.session_secondary.send_expect("quit", "# ")
+ time.sleep(2)
+ self.dut.send_expect("quit", "# ")
+ time.sleep(2)
+
+ # VF1->VF2
+ self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test1 -- -i" % self.pf_pci, "testpmd>", 120)
+
+ self.session_secondary.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf0 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test2 -- -i --crc-strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.vf1_mac), "testpmd>", 120)
+ self.session_secondary.send_expect("set fwd txonly", "testpmd>")
+ self.session_secondary.send_expect("set promisc all off", "testpmd>")
+ time.sleep(2)
+
+ self.session_third.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c 0xf00 -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test3 -- -i --crc-strip" % self.sriov_vfs_port[1].pci, "testpmd>", 120)
+ self.session_third.send_expect("mac_addr add 0 %s" % self.vf1_mac, "testpmd>")
+ self.session_third.send_expect("set fwd rxonly", "testpmd>")
+ self.session_third.send_expect("set promisc all off", "testpmd>")
+ self.session_third.send_expect("start", "testpmd>")
+ self.session_secondary.send_expect("start", "testpmd>")
+ time.sleep(2)
+
+ self.session_secondary.send_expect("stop", "testpmd>", 5)
+ self.session_third.send_expect("stop", "testpmd>", 5)
+
+ vf0_tx_stats = self.veb_get_pmd_stats("second", 0, "tx")
+ vf1_rx_stats = self.veb_get_pmd_stats("third", 0, "rx")
+ self.verify(vf0_tx_stats[0] != 0, "no packet was sent by VF0")
+ self.verify(vf0_tx_stats[0] * 0.5 < vf1_rx_stats[0], "VF1 failed to receive packets from VF0")
+
+
+ def tear_down(self):
+ """
+ Run after each test case.
+ """
+ if self.setup_1pf_kdriver_2vf_env_flag == 1:
+ self.destroy_1pf_kdriver_2vf_env()
+ if self.setup_1pf_ddriver_1vf_env_flag == 1:
+ self.destroy_1pf_ddriver_1vf_env()
+ if self.setup_1pf_ddriver_2vf_env_flag == 1:
+ self.destroy_1pf_ddriver_2vf_env()
+
+ self.dut.kill_all()
+
+ pass
+
+ def tear_down_all(self):
+ """
+ Run after each test suite.
+ """
+ self.dut.kill_all()
+ self.dut.close_session(self.session_secondary)
+ self.dut.close_session(self.session_third)
+ # Marvin recommended that all the dut ports should be bound to igb_uio.
+ for port_id in self.dut_ports:
+ port = self.dut.ports_info[port_id]['port']
+ port.bind_driver(driver='igb_uio')
+
+ pass
--
2.5.0
^ permalink raw reply [flat|nested] 5+ messages in thread
* Re: [dts] [PATCH] tests: add TestSuite_veb_switch.py
2016-12-06 7:36 ` [dts] [PATCH] tests: add TestSuite_veb_switch.py peng,yuan
@ 2016-12-07 2:18 ` Liu, Yong
0 siblings, 0 replies; 5+ messages in thread
From: Liu, Yong @ 2016-12-07 2:18 UTC (permalink / raw)
To: Peng, Yuan, dts; +Cc: Peng, Yuan
Yuan, some comments below.
> -----Original Message-----
> From: dts [mailto:dts-bounces@dpdk.org] On Behalf Of peng,yuan
> Sent: Tuesday, December 06, 2016 3:36 PM
> To: dts@dpdk.org
> Cc: Peng, Yuan
> Subject: [dts] [PATCH] tests: add TestSuite_veb_switch.py
>
> From: Peng Yuan <yuan.peng@intel.com>
>
> Signed-off-by: Peng Yuan <yuan.peng@intel.com>
>
> diff --git a/tests/TestSuite_veb_switch.py b/tests/TestSuite_veb_switch.py
> new file mode 100644
> index 0000000..3492579
> --- /dev/null
> +++ b/tests/TestSuite_veb_switch.py
> @@ -0,0 +1,523 @@
> +# BSD LICENSE
> +#
> +# Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
> +# All rights reserved.
> +#
> +# Redistribution and use in source and binary forms, with or without
> +# modification, are permitted provided that the following conditions
> +# are met:
> +#
> +# * Redistributions of source code must retain the above copyright
> +# notice, this list of conditions and the following disclaimer.
> +# * Redistributions in binary form must reproduce the above copyright
> +# notice, this list of conditions and the following disclaimer in
> +# the documentation and/or other materials provided with the
> +# distribution.
> +# * Neither the name of Intel Corporation nor the names of its
> +# contributors may be used to endorse or promote products derived
> +# from this software without specific prior written permission.
> +#
> +# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
> +# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
> +# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
> +# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
> +# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
> +# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
> +# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
> +# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
> +# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
> +# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
> +# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
> +
> +"""
> +DPDK Test suite.
> +
> +Test VEB Switch and floating VEB Features by Poll Mode Drivers.
> +"""
> +
> +import re
> +import time
> +
> +from virt_dut import VirtDut
> +from project_dpdk import DPDKdut
> +from dut import Dut
> +from net_device import GetNicObj
> +from net_device import RemoveNicObj
There's no need to import those two functions.
> +from test_case import TestCase
> +from pmd_output import PmdOutput
> +from settings import HEADER_SIZE
> +from packet import Packet
> +from utils import RED
> +
> +
> +
> + def send_packet(self, vf_mac, itf, tran_type=""):
> + """
> + Send 1 packet
> + """
> + self.tester.scapy_foreground()
> + self.tester.scapy_append('sys.path.append("./")')
> + self.dut.send_expect("start", "testpmd>")
> + mac = self.dut.get_mac_address(0)
> +
> + if tran_type == "vlan":
> + packet = r'sendp([Ether(dst="%s",
> src=get_if_hwaddr("%s"))/Dot1Q(vlan=1)/IP(src="192.168.0.1",
> dst="192.168.0.2")], iface="%s")' % (vf_mac, itf, itf)
> + self.tester.scapy_append(packet)
> + self.tester.scapy_execute()
> + time.sleep(.5)
> + else:
> + packet = r'sendp([Ether(dst="%s",
> src=get_if_hwaddr("%s"))/IP(src="192.168.0.1", dst="192.168.0.2")],
> iface="%s")' % (vf_mac, itf, itf)
> + self.tester.scapy_append(packet)
> + self.tester.scapy_execute()
> + time.sleep(.5)
> +
Recommend to use packet module function replace of scapy command. It will be helpful in later efficiency improvement.
> + def set_up(self):
> + """
> + This is to clear up environment before the case run.
> + """
> + self.dut.kill_all()
> +
> + def setup_1pf_ddriver_2vf_env(self, driver='default'):
> + self.dut.generate_sriov_vfs_by_port(self.used_dut_port, 2,
> driver='igb_uio')
> + self.sriov_vfs_port =
> self.dut.ports_info[self.used_dut_port]['vfs_port']
> + self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
Remove useless code here, it only waste the time and can't help on anything.
> + try:
> +
> + for port in self.sriov_vfs_port:
> + self.dut.send_expect("./tools/dpdk-devbind.py -b
> igb_uio %s" % (port.pci), "# ", 3)
Use self.drivername replace of igb_uio, igb_uio may not be the driver required to test. There're other choices like vfio-pci.
> + self.dut.send_expect("./tools/dpdk-devbind.py -s", "# ", 3)
Remove useless code here, it only waste the time and can't help on anything.
> + time.sleep(1)
> + for port_id in self.dut_ports:
> + if port_id == self.used_dut_port:
> + continue
> + port = self.dut.ports_info[port_id]['port']
> + port.bind_driver()
> +
Why need to bind other PF device to default kernel driver?
If only want to use some devices, you can use whitelist parameter.
> + self.setup_1pf_ddriver_2vf_env_flag = 1
> + except Exception as e:
> + self.destroy_1pf_ddriver_2vf_env()
> + raise Exception(e)
> +
> + def destroy_1pf_ddriver_2vf_env(self):
> + self.session_third.send_expect("quit", "# ")
> + time.sleep(2)
> + self.session_secondary.send_expect("quit", "# ")
> + time.sleep(2)
> + self.dut.send_expect("quit", "# ")
> + time.sleep(2)
> + 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.setup_1pf_ddriver_2vf_env_flag = 0
> +
> + def setup_1pf_ddriver_1vf_env(self, driver='default'):
Most part of this function look like function setup_1pf_kdriver_2vf_env, please combine these functions and just use parameter to distinguish the difference.
> +
> + def test_VEB_switching_inter_vfs(self):
> + """
> + Kernel PF, then create 2VFs. VFs running dpdk testpmd, send
> traffic to VF1, and set the packet's DEST MAC to VF2, check if VF2 can
> receive the packets. Check Inter VF-VF MAC switch.
> + """
> + self.setup_1pf_kdriver_2vf_env(driver='')
> + self.dut.send_expect("./x86_64-native-linuxapp-gcc/app/testpmd -c
> 0xf -n 4 --socket-mem 1024,1024 -w %s --file-prefix=test1 -- -i --crc-
> strip --eth-peer=0,%s" % (self.sriov_vfs_port[0].pci, self.vf1_mac),
> "testpmd>", 120)
Please not hard code DPDK target, in test suite you can use self.target.
> +
> + def tear_down_all(self):
> + """
> + Run after each test suite.
> + """
> + self.dut.kill_all()
> + self.dut.close_session(self.session_secondary)
> + self.dut.close_session(self.session_third)
> + # Marvin recommended that all the dut ports should be bound to
> igb_uio.
> + for port_id in self.dut_ports:
> + port = self.dut.ports_info[port_id]['port']
> + port.bind_driver(driver='igb_uio')
> +
Only need to used port back.
> + pass
> --
> 2.5.0
^ permalink raw reply [flat|nested] 5+ messages in thread
end of thread, other threads:[~2016-12-07 2:18 UTC | newest]
Thread overview: 5+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2016-12-06 7:36 [dts] [PATCH] test_plans: add floating_veb_test_plan.rst peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] test_plans: add veb_switch_test_plan.rst peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] tests: add TestSuite_floating_veb.py peng,yuan
2016-12-06 7:36 ` [dts] [PATCH] tests: add TestSuite_veb_switch.py peng,yuan
2016-12-07 2:18 ` Liu, Yong
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).