* [dts] [PATCH v2] test suite: vf daemon DPDK PF+DPDK VF test suite @ 2017-03-01 5:56 Xueqin Lin 2017-03-01 13:35 ` Liu, Yong 0 siblings, 1 reply; 3+ messages in thread From: Xueqin Lin @ 2017-03-01 5:56 UTC (permalink / raw) To: dts; +Cc: Xueqin Lin --- tests/TestSuite_vf_daemon.py | 619 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 619 insertions(+) create mode 100644 tests/TestSuite_vf_daemon.py diff --git a/tests/TestSuite_vf_daemon.py b/tests/TestSuite_vf_daemon.py new file mode 100644 index 0000000..ef86735 --- /dev/null +++ b/tests/TestSuite_vf_daemon.py @@ -0,0 +1,619 @@ +# <COPYRIGHT_TAG> + +import time +import sys +import utils +from scapy.utils import rdpcap + +from qemu_kvm import QEMUKvm +from test_case import TestCase +from pmd_output import PmdOutput +from packet import Packet, sniff_packets, load_sniff_packets +from settings import get_nic_name +import random + +VM_CORES_MASK = 'all' +MAX_VLAN = 4095 + + +class Testvf_daemon(TestCase): + + def set_up_all(self): + + self.dut_ports = self.dut.get_ports(self.nic) + self.verify(len(self.dut_ports) >= 1, "Insufficient ports") + self.vm0 = None + self.vm1 = None + self.env_done = False + + + def set_up(self): + self.setup_vm_env() + + def bind_nic_driver(self, ports, driver=""): + + for port in ports: + netdev = self.dut.ports_info[port]['port'] + driver = netdev.get_nic_driver() + if driver != 'igb_uio': + netdev.bind_driver(driver='igb_uio') + + def setup_vm_env(self, driver='igb_uio'): + """ + Create testing environment with 2VFs generated from 1PF + """ + if self.env_done: + return + + self.bind_nic_driver(self.dut_ports[:1], driver="") + + self.used_dut_port = self.dut_ports[0] + tester_port = self.tester.get_local_port(self.used_dut_port) + self.tester_intf = self.tester.get_interface(tester_port) + + 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("rmmod %svf" %self.kdriver , "# ") + self.dut_testpmd = PmdOutput(self.dut) + time.sleep(1) + vf0_prop = {'opt_host': self.sriov_vfs_port[0].pci} + + # set up VM0 ENV + self.vm0 = QEMUKvm(self.dut, 'vm0', 'vf_daemon') + self.vm0.set_vm_device(driver='pci-assign', **vf0_prop) + try: + self.vm0_dut = self.vm0.start() + if self.vm0_dut is None: + raise Exception("Set up VM0 ENV failed!") + except Exception as e: + self.destroy_vm_env() + raise Exception(e) + + self.vm0_dut_ports = self.vm0_dut.get_ports('any') + self.vm0_testpmd = PmdOutput(self.vm0_dut) + + vf1_prop = {'opt_host': self.sriov_vfs_port[1].pci} + self.vm1 = QEMUKvm(self.dut, 'vm1', 'vf_daemon') + self.vm1.set_vm_device(driver='pci-assign', **vf1_prop) + try: + self.vm1_dut = self.vm1.start() + if self.vm1_dut is None: + raise Exception("Set up VM1 ENV failed!") + except Exception as e: + self.destroy_vm_env() + raise Exception(e) + self.vm1_dut_ports = self.vm1_dut.get_ports('any') + self.vm1_testpmd = PmdOutput(self.vm1_dut) + + self.env_done = True + + def destroy_vm_env(self): + + if getattr(self, 'vm0', None): + self.vm0_dut.kill_all() + self.vm0_testpmd = None + self.vm0_dut_ports = None + # destroy vm0 + self.vm0.stop() + self.vm0 = None + + if getattr(self, 'vm1', None): + self.vm1_dut.kill_all() + self.vm1_testpmd = None + self.vm1_dut_ports = None + # destroy vm1 + self.vm1.stop() + self.vm1 = None + + if getattr(self, 'used_dut_port', None): + self.dut.destroy_sriov_vfs_by_port(self.used_dut_port) + port = self.dut.ports_info[self.used_dut_port]['port'] + self.used_dut_port = None + + self.env_done = False + + + def packet_generate(self, dst_mac, vlan_id, pktsize): + + if vlan_id == 0: + pkt = Packet(pkt_type='UDP', pkt_len = pktsize) + else: + pkt = Packet(pkt_type='VLAN_UDP', pkt_len = pktsize) + pkt.config_layer('vlan', {'vlan': vlan_id}) + pkt.config_layer('ether', {'dst': dst_mac}) + return pkt + + def packet_dumpout(self,inst): + + pkts = load_sniff_packets(inst) + packetContentFile = "/tmp/packetContent.log" + pcap_file = "/tmp/sniff_%s.pcap"%self.tester_intf + fp = open(packetContentFile,'w') + backup_out = sys.stdout + sys.stdout = fp + pkts = rdpcap(pcap_file) + print pkts + fp.close() + sys.stdout = backup_out + fp = open(packetContentFile,'r') + out = fp.read() + fp.close() + return out + + + def send_and_pmdout(self, dst_mac, vlan_id = 0, pktsize = 64 , num = 1): + + pkt = self.packet_generate(dst_mac, vlan_id , pktsize) + inst = sniff_packets(self.tester_intf, timeout=5) + pkt.send_pkt(tx_port=self.tester_intf, count=num) + out = self.vm0_dut.get_session_output(timeout=2) + return out + + + def send_and_dumpout(self, dst_mac, vlan_id = 0, pktsize = 64, num = 1): + + pkt = self.packet_generate(dst_mac, vlan_id , pktsize) + inst = sniff_packets(self.tester_intf, timeout=5) + pkt.send_pkt(tx_port=self.tester_intf, count=num) + out = self.packet_dumpout(inst) + return out + + + def test_vlan_insert(self): + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + + self.vm0_testpmd.execute_cmd('set fwd mac') + self.vm0_testpmd.execute_cmd('set verbose 1') + self.vm0_testpmd.execute_cmd('start') + #Disable vlan insert which means insert vlan id as 0 + rx_vlan = 0 + self.dut_testpmd.execute_cmd('set vf vlan insert 0 0 %s' %rx_vlan) + time.sleep(1) + out = self.send_and_dumpout(self.vf0_mac) + self.verify("type=IPv4" in out, + "Failed to disable vlan insert packet!!!") + self.verify("vlan=%d" % rx_vlan not in out, + "Failed to disable vlan insert!!!") + + #Enable vlan insert which means insert vlan id as 1~4095 + random_vlan = random.randint(1, MAX_VLAN - 1) + rx_vlans = [1, random_vlan, MAX_VLAN] + for rx_vlan in rx_vlans: + self.dut_testpmd.execute_cmd('set vf vlan insert 0 0 %s'%rx_vlan) + time.sleep(1) + out = self.send_and_dumpout(self.vf0_mac) + self.verify("type=n_802_1Q" in out, "Failed to enable vlan insert packet!!!") + self.verify("vlan=%s" %rx_vlan in out, + "Failed to enable vlan insert packet!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + + + def test_multicast_mode(self): + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + + self.vm0_testpmd.execute_cmd('set fwd rxonly') + self.vm0_testpmd.execute_cmd('set verbose 1') + self.vm0_testpmd.execute_cmd('start') + self.dut_testpmd.execute_cmd('set vf promisc 0 0 off') + self.dut_testpmd.execute_cmd('set vf allmulti 0 0 off') + multi_mac = 'F3:00:33:22:11:00' + out = self.send_and_pmdout(multi_mac) + self.verify("received" not in out, "Failed to disable vf multicast mode!!!") + + out = self.send_and_pmdout(self.vf0_mac) + self.verify("received" in out, "Failed to disable vf multicast mode!!!") + self.verify("dst=%s" %self.vf0_mac in out, + "Failed to disable vf multicast mode!!!") + + self.dut_testpmd.execute_cmd('set vf allmulti 0 0 on') + out = self.send_and_pmdout(multi_mac) + self.verify("received" in out, "Failed to enable vf multicast mode!!!") + self.verify("dst=%s" %multi_mac in out, + "Failed to enable vf multicast mode!!!") + + out = self.send_and_pmdout(self.vf0_mac) + self.verify("received" in out, "Failed to enable vf multicast mode!!!") + self.verify("dst=%s" %self.vf0_mac in out, + "Failed to enable vf multicast mode!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + + + def test_promisc_mode(self): + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + + self.vm0_testpmd.execute_cmd('set fwd rxonly') + self.vm0_testpmd.execute_cmd('set verbose 1') + self.vm0_testpmd.execute_cmd('start') + self.dut_testpmd.execute_cmd('set vf promisc 0 0 off') + + wrong_mac = '9E:AC:72:49:43:11' + out = self.send_and_pmdout(wrong_mac) + self.verify("received" not in out, "Failed to disable vf promisc mode!!!") + + out = self.send_and_pmdout(self.vf0_mac) + self.verify("received" in out, "Failed to disable vf promisc mode!!!") + self.verify("dst=%s" %self.vf0_mac in out, + "Failed to disable vf promisc mode!!!") + + self.dut_testpmd.execute_cmd('set vf promisc 0 0 on') + out = self.send_and_pmdout(wrong_mac) + self.verify("received" in out, "Failed to enable vf promisc mode!!!") + self.verify("dst=%s" %wrong_mac in out, + "Failed to enable vf promisc mode!!!") + + out = self.send_and_pmdout(self.vf0_mac) + self.verify("received" in out, "Failed to enable vf promisc mode!!!") + self.verify("dst=%s" %self.vf0_mac in out, + "Failed to enable vf promisc mode!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + + + def test_broadcast_mode(self): + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + + self.vm0_testpmd.execute_cmd('set fwd rxonly') + self.vm0_testpmd.execute_cmd('set verbose 1') + self.vm0_testpmd.execute_cmd('start') + self.dut_testpmd.execute_cmd('set vf broadcast 0 0 off') + + dst_mac = 'FF:FF:FF:FF:FF:FF' + out = self.send_and_pmdout(dst_mac) + self.verify("received" not in out, "Failed to disable vf broadcast mode!!!") + + self.dut_testpmd.execute_cmd('set vf broadcast 0 0 on') + out = self.send_and_pmdout(dst_mac) + self.verify("received" in out, "Failed to enable vf broadcast mode!!!") + self.verify("dst=%s" %dst_mac in out, + "Failed to enable vf broadcast mode!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + + + def test_vf_mtu(self): + self.dut.send_expect("ifconfig %s mtu 9000" %self.tester_intf, "#") + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + + self.vm0_testpmd.execute_cmd('set fwd mac') + self.vm0_testpmd.execute_cmd('set verbose 1') + self.vm0_testpmd.execute_cmd('start') + pktsize = random.randint(1500, 9000) + out = self.send_and_dumpout(self.vf0_mac, 0, pktsize) + self.vm0_testpmd.execute_cmd('stop') + self.verify("src=%s" %(self.vf0_mac.lower()) not in out, + "Failed to receive and forward this length packet!!!") + + self.vm0_testpmd.execute_cmd('port stop all') + self.vm0_testpmd.execute_cmd('port config mtu 0 %s' %(pktsize+100)) + self.vm0_testpmd.execute_cmd('port start all') + self.vm0_testpmd.execute_cmd('start') + out = self.send_and_dumpout(self.vf0_mac, 0, pktsize) + self.vm0_testpmd.execute_cmd('stop') + self.verify("src=%s" %(self.vf0_mac.lower()) in out, + "Failed to receive and forward this length packet!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + self.dut.send_expect("ifconfig %s mtu 1500" %self.tester_intf, "#") + + + def test_vlan_tag(self): + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + + random_vlan = random.randint(1, MAX_VLAN - 1) + rx_vlans = [1, random_vlan, MAX_VLAN] + self.vm0_testpmd.execute_cmd('set fwd mac') + self.vm0_testpmd.execute_cmd('set verbose 1') + self.vm0_testpmd.execute_cmd('start') + for rx_vlan in rx_vlans: + self.vm0_testpmd.execute_cmd('rx_vlan add %s 0' %rx_vlan) + self.dut_testpmd.execute_cmd('set vf vlan tag 0 0 off') + time.sleep(1) + out = self.send_and_dumpout(self.vf0_mac, rx_vlan) + self.verify("src=%s" %(self.vf0_mac.lower()) not in out, + "Failed to disable vlan tag!!!") + + self.dut_testpmd.execute_cmd('set vf vlan tag 0 0 on') + time.sleep(1) + out = self.send_and_dumpout(self.vf0_mac, rx_vlan) + self.verify("src=%s" %(self.vf0_mac.lower()) in out, + "Failed to enable vlan tag!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + + + def test_tx_loopback(self): + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + self.vm1_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip --eth-peer=0,%s' %self.vf0_mac) + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + self.vm1_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --eth-peer=0,%s' %self.vf0_mac) + + self.vm0_testpmd.execute_cmd('set fwd rxonly') + self.vm0_testpmd.execute_cmd('set verbose 1') + self.vm0_testpmd.execute_cmd('start') + self.dut_testpmd.execute_cmd('set tx loopback 0 off') + + inst = sniff_packets(self.tester_intf, timeout=5) + + self.vm1_testpmd.execute_cmd('set burst 5') + self.vm1_testpmd.execute_cmd('start tx_first') + + dumpout = self.packet_dumpout(inst) + out = self.vm0_testpmd.execute_cmd('stop') + self.verify("dst=%s" %(self.vf0_mac.lower()) in dumpout, + "Failed to disable tx loopback!!!") + self.verify("RX-packets: 0" in out, "Failed to disable tx loopback!!!") + + self.vm0_testpmd.execute_cmd('start') + self.dut_testpmd.execute_cmd('set tx loopback 0 on') + + inst = sniff_packets(self.tester_intf, timeout=5) + + self.vm1_testpmd.execute_cmd('stop') + self.vm1_testpmd.execute_cmd('start tx_first') + + dumpout = self.packet_dumpout(inst) + out = self.vm0_testpmd.execute_cmd('stop') + self.verify("dst=%s" %(self.vf0_mac.lower()) not in dumpout, + "Failed to enable tx loopback!!!") + self.verify("RX-packets: 5" in out, "Failed to enable tx loopback!!!") + + self.vm0_testpmd.quit() + self.vm1_testpmd.quit() + self.dut_testpmd.quit() + + + + def test_all_queues_drop(self): + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + self.vm1_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + + self.vm0_testpmd.execute_cmd('set fwd rxonly') + self.vm0_testpmd.execute_cmd('set verbose 1') + self.vm0_testpmd.execute_cmd('start') + self.dut_testpmd.execute_cmd('set all queues drop 0 off') + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + self.vf1_mac = self.vm1_testpmd.get_port_mac(0) + out = self.send_and_pmdout(self.vf1_mac, 0, 64, 200) + out = self.vm1_testpmd.execute_cmd('show port stats 0') + self.verify("RX-packets: 127" in out, "Failed to let vf1 full of queues!!!") + out = self.send_and_pmdout(self.vf0_mac, 0, 64, 20) + out = self.vm0_testpmd.execute_cmd('show port stats 0') + self.verify("RX-packets: 0" in out, "Failed to disable all queues drop!!!") + self.dut_testpmd.execute_cmd('set all queues drop 0 on') + out = self.vm0_testpmd.execute_cmd('show port stats 0') + self.verify("RX-packets: 20" in out, "Failed to enable all queues drop!!!") + out = self.send_and_pmdout(self.vf0_mac, 0, 64, 20) + out = self.vm0_testpmd.execute_cmd('show port stats 0') + self.verify("RX-packets: 40" in out, "Failed to enable all queues drop!!!") + + self.vm0_testpmd.quit() + self.vm1_testpmd.quit() + self.dut_testpmd.quit() + + + def test_mac_antispoof(self): + fake_mac = '00:11:22:33:44:55' + self.vm0_dut.send_expect("sed -i -e '/uint64_t ol_flags = 0;/a " +\ + "\struct ether_addr fake_mac = {.addr_bytes = {0x00, 0x11, 0x22, 0x33, 0x44, 0x55},};'" +\ + " app/test-pmd/macswap.c", "# ", 30) + self.vm0_dut.send_expect("sed -i -e '/ether_addr_copy(&addr, ð_hdr->s_addr);/d' " +\ + " app/test-pmd/macswap.c", "# ", 30) + self.vm0_dut.send_expect("sed -i -e '/ether_addr_copy(ð_hdr->s_addr, ð_hdr->d_addr);/a " +\ + "\ether_addr_copy(&fake_mac, ð_hdr->s_addr);' app/test-pmd/macswap.c", "# ", 30) + self.vm0_dut.build_install_dpdk(self.target) + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + + self.vm0_testpmd.execute_cmd('set fwd macswap') + self.dut_testpmd.execute_cmd('set vf mac antispoof 0 0 off') + self.vm0_testpmd.execute_cmd('start') + dumpout = self.send_and_dumpout(self.vf0_mac) + out = self.vm0_testpmd.execute_cmd('stop') + self.verify("src=%s" %fake_mac in dumpout, "Failed to disable vf mac anspoof!!!") + self.verify("RX-packets: 1" in out, "Failed to receive packet!!!") + self.verify("TX-packets: 1" in out, "Failed to disable mac antispoof!!!") + + self.dut_testpmd.execute_cmd('set vf mac antispoof 0 0 on') + out = self.vm0_testpmd.execute_cmd('start') + dumpout = self.send_and_dumpout(self.vf0_mac) + out = self.vm0_testpmd.execute_cmd('stop') + self.verify("src=%s" %fake_mac not in dumpout, "Failed to enable vf mac anspoof!!!") + self.verify("RX-packets: 1" in out, "Failed to receive packet!!!") + self.verify("TX-packets: 0" in out, "Failed to enable mac antispoof!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + self.vm0_dut.send_expect("sed -i '/struct ether_addr fake_mac = {.addr_bytes = " +\ + "{0x00, 0x11, 0x22, 0x33, 0x44, 0x55},};/d' app/test-pmd/macswap.c", "# ", 30) + self.vm0_dut.send_expect("sed -i '/ether_addr_copy(&fake_mac, ð_hdr->s_addr);/d' " +\ + "app/test-pmd/macswap.c", "# ", 30) + self.vm0_dut.send_expect("sed -i '/ether_addr_copy(ð_hdr->s_addr, ð_hdr->d_addr);/a " +\ + "\ether_addr_copy(&addr, ð_hdr->s_addr);' app/test-pmd/macswap.c", "# ", 30) + self.vm0_dut.build_install_dpdk(self.target) + + + def test_vf_mac_set(self): + expect_mac = 'A2:22:33:44:55:66' + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + self.dut_testpmd.execute_cmd('set vf mac addr 0 0 %s' %expect_mac) + if self.kdriver == "i40e": + out = self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + out = self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + self.verify("%s" %expect_mac in out, "Failed to set vf mac!!!") + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + + self.vm0_testpmd.execute_cmd('set fwd mac') + self.vm0_testpmd.execute_cmd('start') + out = self.send_and_dumpout(self.vf0_mac) + self.verify("src=%s" %(expect_mac.lower()) in out, + "Failed to receive packet on setted vf mac!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + + + def test_vlan_antispoof(self): + + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + vf0_mac_lower = self.vf0_mac.lower() + random_vlan = random.randint(1, MAX_VLAN) + match_vlan = random_vlan + unmatch_vlan = (random_vlan + 2) % 4096 + self.vm0_testpmd.execute_cmd('set fwd mac') + self.vm0_testpmd.execute_cmd('start') + self.dut_testpmd.execute_cmd('rx_vlan add %d port 0 vf 1' %match_vlan) + if self.kdriver == "i40e": + self.dut_testpmd.execute_cmd('set vf vlan stripq 0 0 off') + else: + self.dut_testpmd.execute_cmd('vlan set filter off 0') + self.dut_testpmd.execute_cmd('vlan set strip off 0') + self.vm0_testpmd.execute_cmd('vlan set strip off 0') + + self.dut_testpmd.execute_cmd('set vf vlan antispoof 0 0 off') + time.sleep(1) + out = self.send_and_dumpout(self.vf0_mac,match_vlan) + self.verify("src=%s" %vf0_mac_lower in out, + "Failed to disable vlan antispoof with match vlan!!!") + out = self.send_and_dumpout(self.vf0_mac,unmatch_vlan) + self.verify("src=%s" %vf0_mac_lower in out, + "Failed to disable vlan antispoof with unmatch vlan!!!") + out = self.send_and_dumpout(self.vf0_mac) + self.verify("src=%s" %vf0_mac_lower in out, + "Failed to disable vlan antispoof with no vlan!!!") + + if self.kdriver == "ixgbe": + self.dut_testpmd.execute_cmd('set vf mac antispoof 0 0 on') + self.dut_testpmd.execute_cmd('set vf vlan antispoof 0 0 on') + time.sleep(1) + + out = self.send_and_dumpout(self.vf0_mac,match_vlan) + self.verify("src=%s" %vf0_mac_lower in out, + "Failed to enable vlan antispoof with match vlan!!!") + + out = self.send_and_dumpout(self.vf0_mac,unmatch_vlan) + self.verify("src=%s" %vf0_mac_lower not in out, + "Failed to enable vlan antispoof with unmatch vlan!!!") + + out = self.send_and_dumpout(self.vf0_mac) + self.verify("src=%s" %vf0_mac_lower not in out, + "Failed to enable vlan antispoof with no vlan!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + + + def test_vlan_strip(self): + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") + if self.kdriver == "i40e": + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, + '--port-topology=chained --crc-strip') + else: + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') + + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) + + random_vlan = random.randint(1, MAX_VLAN - 1) + rx_vlans = [1, random_vlan, MAX_VLAN] + self.vm0_testpmd.execute_cmd('set fwd mac') + self.vm0_testpmd.execute_cmd('set verbose 1') + self.vm0_testpmd.execute_cmd('start') + for rx_vlan in rx_vlans: + self.vm0_testpmd.execute_cmd('rx_vlan add %s 0' %rx_vlan) + self.dut_testpmd.execute_cmd('set vf vlan stripq 0 0 off') + time.sleep(1) + out = self.send_and_dumpout(self.vf0_mac,rx_vlan) + self.verify("type=n_802_1Q" in out, "Failed to disable strip vlan!!!") + + self.dut_testpmd.execute_cmd('set vf vlan stripq 0 0 on') + time.sleep(1) + out = self.send_and_dumpout(self.vf0_mac,rx_vlan) + self.verify("type=IPv4" in out, "Failed to disable strip vlan!!!") + + self.vm0_testpmd.quit() + self.dut_testpmd.quit() + + + def tear_down(self): + self.vm0_dut.kill_all() + self.vm1_dut.kill_all() + pass + + + def tear_down_all(self): + self.destroy_vm_env() + pass -- 2.5.5 ^ permalink raw reply [flat|nested] 3+ messages in thread
* Re: [dts] [PATCH v2] test suite: vf daemon DPDK PF+DPDK VF test suite 2017-03-01 5:56 [dts] [PATCH v2] test suite: vf daemon DPDK PF+DPDK VF test suite Xueqin Lin @ 2017-03-01 13:35 ` Liu, Yong 2017-03-03 6:44 ` Lin, Xueqin 0 siblings, 1 reply; 3+ messages in thread From: Liu, Yong @ 2017-03-01 13:35 UTC (permalink / raw) To: Xueqin Lin, dts Xueqin, Some comments below. Thanks, Marvin On 03/01/2017 01:56 PM, Xueqin Lin wrote: > --- > tests/TestSuite_vf_daemon.py | 619 +++++++++++++++++++++++++++++++++++++++++++ > 1 file changed, 619 insertions(+) > create mode 100644 tests/TestSuite_vf_daemon.py > > diff --git a/tests/TestSuite_vf_daemon.py b/tests/TestSuite_vf_daemon.py > new file mode 100644 > index 0000000..ef86735 > --- /dev/null > +++ b/tests/TestSuite_vf_daemon.py > @@ -0,0 +1,619 @@ > +# <COPYRIGHT_TAG> > + > +import time > +import sys > +import utils > +from scapy.utils import rdpcap > + > +from qemu_kvm import QEMUKvm > +from test_case import TestCase > +from pmd_output import PmdOutput > +from packet import Packet, sniff_packets, load_sniff_packets > +from settings import get_nic_name > +import random > + > +VM_CORES_MASK = 'all' > +MAX_VLAN = 4095 > + > + > +class Testvf_daemon(TestCase): > + > + def set_up_all(self): > + > + self.dut_ports = self.dut.get_ports(self.nic) > + self.verify(len(self.dut_ports) >= 1, "Insufficient ports") > + self.vm0 = None > + self.vm1 = None > + self.env_done = False > + > + > + def set_up(self): > + self.setup_vm_env() > + > + def bind_nic_driver(self, ports, driver=""): > + > + for port in ports: > + netdev = self.dut.ports_info[port]['port'] > + driver = netdev.get_nic_driver() > + if driver != 'igb_uio': > + netdev.bind_driver(driver='igb_uio') > + > + def setup_vm_env(self, driver='igb_uio'): > + """ > + Create testing environment with 2VFs generated from 1PF > + """ > + if self.env_done: > + return > + > + self.bind_nic_driver(self.dut_ports[:1], driver="") > + > + self.used_dut_port = self.dut_ports[0] > + tester_port = self.tester.get_local_port(self.used_dut_port) > + self.tester_intf = self.tester.get_interface(tester_port) > + > + 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("rmmod %svf" %self.kdriver , "# ") > + self.dut_testpmd = PmdOutput(self.dut) > + time.sleep(1) > + vf0_prop = {'opt_host': self.sriov_vfs_port[0].pci} > + > + # set up VM0 ENV > + self.vm0 = QEMUKvm(self.dut, 'vm0', 'vf_daemon') > + self.vm0.set_vm_device(driver='pci-assign', **vf0_prop) > + try: > + self.vm0_dut = self.vm0.start() > + if self.vm0_dut is None: > + raise Exception("Set up VM0 ENV failed!") > + except Exception as e: > + self.destroy_vm_env() > + raise Exception(e) > + > + self.vm0_dut_ports = self.vm0_dut.get_ports('any') > + self.vm0_testpmd = PmdOutput(self.vm0_dut) > + > + vf1_prop = {'opt_host': self.sriov_vfs_port[1].pci} > + self.vm1 = QEMUKvm(self.dut, 'vm1', 'vf_daemon') > + self.vm1.set_vm_device(driver='pci-assign', **vf1_prop) > + try: > + self.vm1_dut = self.vm1.start() > + if self.vm1_dut is None: > + raise Exception("Set up VM1 ENV failed!") > + except Exception as e: > + self.destroy_vm_env() > + raise Exception(e) > + self.vm1_dut_ports = self.vm1_dut.get_ports('any') > + self.vm1_testpmd = PmdOutput(self.vm1_dut) > + > + self.env_done = True > + > + def destroy_vm_env(self): > + > + if getattr(self, 'vm0', None): > + self.vm0_dut.kill_all() > + self.vm0_testpmd = None > + self.vm0_dut_ports = None > + # destroy vm0 > + self.vm0.stop() > + self.vm0 = None > + > + if getattr(self, 'vm1', None): > + self.vm1_dut.kill_all() > + self.vm1_testpmd = None > + self.vm1_dut_ports = None > + # destroy vm1 > + self.vm1.stop() > + self.vm1 = None > + > + if getattr(self, 'used_dut_port', None): > + self.dut.destroy_sriov_vfs_by_port(self.used_dut_port) > + port = self.dut.ports_info[self.used_dut_port]['port'] > + self.used_dut_port = None > + > + self.env_done = False > + > + > + def packet_generate(self, dst_mac, vlan_id, pktsize): > + > + if vlan_id == 0: > + pkt = Packet(pkt_type='UDP', pkt_len = pktsize) > + else: > + pkt = Packet(pkt_type='VLAN_UDP', pkt_len = pktsize) > + pkt.config_layer('vlan', {'vlan': vlan_id}) > + pkt.config_layer('ether', {'dst': dst_mac}) > + return pkt > + > + def packet_dumpout(self,inst): > + > + pkts = load_sniff_packets(inst) > + packetContentFile = "/tmp/packetContent.log" > + pcap_file = "/tmp/sniff_%s.pcap"%self.tester_intf > + fp = open(packetContentFile,'w') Please check pep8 code style. > + backup_out = sys.stdout > + sys.stdout = fp > + pkts = rdpcap(pcap_file) > + print pkts > + fp.close() > + sys.stdout = backup_out > + fp = open(packetContentFile,'r') > + out = fp.read() > + fp.close() > + return out > + > + Not sure why use this function for check packet content. We already have add some functions in packet module for stripping vlan id or other elements. > + def send_and_pmdout(self, dst_mac, vlan_id = 0, pktsize = 64 , num = 1): > + > + pkt = self.packet_generate(dst_mac, vlan_id , pktsize) > + inst = sniff_packets(self.tester_intf, timeout=5) > + pkt.send_pkt(tx_port=self.tester_intf, count=num) > + out = self.vm0_dut.get_session_output(timeout=2) > + return out > + > + > + def send_and_dumpout(self, dst_mac, vlan_id = 0, pktsize = 64, num = 1): > + > + pkt = self.packet_generate(dst_mac, vlan_id , pktsize) > + inst = sniff_packets(self.tester_intf, timeout=5) > + pkt.send_pkt(tx_port=self.tester_intf, count=num) > + out = self.packet_dumpout(inst) > + return out > + > + > + def test_vlan_insert(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + As I remember only i40e vf device required for crc-strip enable flag, recommend to let pmd_output module handle this. That's the reason why we add this module. > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + #Disable vlan insert which means insert vlan id as 0 > + rx_vlan = 0 > + self.dut_testpmd.execute_cmd('set vf vlan insert 0 0 %s' %rx_vlan) > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("type=IPv4" in out, > + "Failed to disable vlan insert packet!!!") > + self.verify("vlan=%d" % rx_vlan not in out, > + "Failed to disable vlan insert!!!") > + > + #Enable vlan insert which means insert vlan id as 1~4095 > + random_vlan = random.randint(1, MAX_VLAN - 1) > + rx_vlans = [1, random_vlan, MAX_VLAN] > + for rx_vlan in rx_vlans: > + self.dut_testpmd.execute_cmd('set vf vlan insert 0 0 %s'%rx_vlan) > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("type=n_802_1Q" in out, "Failed to enable vlan insert packet!!!") > + self.verify("vlan=%s" %rx_vlan in out, > + "Failed to enable vlan insert packet!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_multicast_mode(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set vf promisc 0 0 off') > + self.dut_testpmd.execute_cmd('set vf allmulti 0 0 off') > + multi_mac = 'F3:00:33:22:11:00' > + out = self.send_and_pmdout(multi_mac) > + self.verify("received" not in out, "Failed to disable vf multicast mode!!!") > + > + out = self.send_and_pmdout(self.vf0_mac) > + self.verify("received" in out, "Failed to disable vf multicast mode!!!") > + self.verify("dst=%s" %self.vf0_mac in out, > + "Failed to disable vf multicast mode!!!") > + > + self.dut_testpmd.execute_cmd('set vf allmulti 0 0 on') > + out = self.send_and_pmdout(multi_mac) > + self.verify("received" in out, "Failed to enable vf multicast mode!!!") > + self.verify("dst=%s" %multi_mac in out, > + "Failed to enable vf multicast mode!!!") > + > + out = self.send_and_pmdout(self.vf0_mac) > + self.verify("received" in out, "Failed to enable vf multicast mode!!!") > + self.verify("dst=%s" %self.vf0_mac in out, > + "Failed to enable vf multicast mode!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_promisc_mode(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set vf promisc 0 0 off') > + > + wrong_mac = '9E:AC:72:49:43:11' > + out = self.send_and_pmdout(wrong_mac) > + self.verify("received" not in out, "Failed to disable vf promisc mode!!!") > + > + out = self.send_and_pmdout(self.vf0_mac) > + self.verify("received" in out, "Failed to disable vf promisc mode!!!") > + self.verify("dst=%s" %self.vf0_mac in out, > + "Failed to disable vf promisc mode!!!") > + > + self.dut_testpmd.execute_cmd('set vf promisc 0 0 on') > + out = self.send_and_pmdout(wrong_mac) > + self.verify("received" in out, "Failed to enable vf promisc mode!!!") > + self.verify("dst=%s" %wrong_mac in out, > + "Failed to enable vf promisc mode!!!") > + > + out = self.send_and_pmdout(self.vf0_mac) > + self.verify("received" in out, "Failed to enable vf promisc mode!!!") > + self.verify("dst=%s" %self.vf0_mac in out, > + "Failed to enable vf promisc mode!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_broadcast_mode(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set vf broadcast 0 0 off') > + > + dst_mac = 'FF:FF:FF:FF:FF:FF' > + out = self.send_and_pmdout(dst_mac) > + self.verify("received" not in out, "Failed to disable vf broadcast mode!!!") > + > + self.dut_testpmd.execute_cmd('set vf broadcast 0 0 on') > + out = self.send_and_pmdout(dst_mac) > + self.verify("received" in out, "Failed to enable vf broadcast mode!!!") > + self.verify("dst=%s" %dst_mac in out, > + "Failed to enable vf broadcast mode!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_vf_mtu(self): > + self.dut.send_expect("ifconfig %s mtu 9000" %self.tester_intf, "#") > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + pktsize = random.randint(1500, 9000) > + out = self.send_and_dumpout(self.vf0_mac, 0, pktsize) > + self.vm0_testpmd.execute_cmd('stop') > + self.verify("src=%s" %(self.vf0_mac.lower()) not in out, > + "Failed to receive and forward this length packet!!!") > + > + self.vm0_testpmd.execute_cmd('port stop all') > + self.vm0_testpmd.execute_cmd('port config mtu 0 %s' %(pktsize+100)) > + self.vm0_testpmd.execute_cmd('port start all') > + self.vm0_testpmd.execute_cmd('start') > + out = self.send_and_dumpout(self.vf0_mac, 0, pktsize) > + self.vm0_testpmd.execute_cmd('stop') > + self.verify("src=%s" %(self.vf0_mac.lower()) in out, > + "Failed to receive and forward this length packet!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + self.dut.send_expect("ifconfig %s mtu 1500" %self.tester_intf, "#") > + > + > + def test_vlan_tag(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + random_vlan = random.randint(1, MAX_VLAN - 1) > + rx_vlans = [1, random_vlan, MAX_VLAN] > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + for rx_vlan in rx_vlans: > + self.vm0_testpmd.execute_cmd('rx_vlan add %s 0' %rx_vlan) > + self.dut_testpmd.execute_cmd('set vf vlan tag 0 0 off') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac, rx_vlan) > + self.verify("src=%s" %(self.vf0_mac.lower()) not in out, > + "Failed to disable vlan tag!!!") > + > + self.dut_testpmd.execute_cmd('set vf vlan tag 0 0 on') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac, rx_vlan) > + self.verify("src=%s" %(self.vf0_mac.lower()) in out, > + "Failed to enable vlan tag!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_tx_loopback(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + self.vm1_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip --eth-peer=0,%s' %self.vf0_mac) > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + self.vm1_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --eth-peer=0,%s' %self.vf0_mac) > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set tx loopback 0 off') > + > + inst = sniff_packets(self.tester_intf, timeout=5) > + > + self.vm1_testpmd.execute_cmd('set burst 5') > + self.vm1_testpmd.execute_cmd('start tx_first') > + > + dumpout = self.packet_dumpout(inst) > + out = self.vm0_testpmd.execute_cmd('stop') > + self.verify("dst=%s" %(self.vf0_mac.lower()) in dumpout, > + "Failed to disable tx loopback!!!") > + self.verify("RX-packets: 0" in out, "Failed to disable tx loopback!!!") > + > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set tx loopback 0 on') > + > + inst = sniff_packets(self.tester_intf, timeout=5) > + > + self.vm1_testpmd.execute_cmd('stop') > + self.vm1_testpmd.execute_cmd('start tx_first') > + > + dumpout = self.packet_dumpout(inst) > + out = self.vm0_testpmd.execute_cmd('stop') > + self.verify("dst=%s" %(self.vf0_mac.lower()) not in dumpout, > + "Failed to enable tx loopback!!!") > + self.verify("RX-packets: 5" in out, "Failed to enable tx loopback!!!") > + > + self.vm0_testpmd.quit() > + self.vm1_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + > + def test_all_queues_drop(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + self.vm1_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set all queues drop 0 off') > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + self.vf1_mac = self.vm1_testpmd.get_port_mac(0) > + out = self.send_and_pmdout(self.vf1_mac, 0, 64, 200) > + out = self.vm1_testpmd.execute_cmd('show port stats 0') > + self.verify("RX-packets: 127" in out, "Failed to let vf1 full of queues!!!") > + out = self.send_and_pmdout(self.vf0_mac, 0, 64, 20) > + out = self.vm0_testpmd.execute_cmd('show port stats 0') > + self.verify("RX-packets: 0" in out, "Failed to disable all queues drop!!!") > + self.dut_testpmd.execute_cmd('set all queues drop 0 on') > + out = self.vm0_testpmd.execute_cmd('show port stats 0') > + self.verify("RX-packets: 20" in out, "Failed to enable all queues drop!!!") > + out = self.send_and_pmdout(self.vf0_mac, 0, 64, 20) > + out = self.vm0_testpmd.execute_cmd('show port stats 0') > + self.verify("RX-packets: 40" in out, "Failed to enable all queues drop!!!") > + > + self.vm0_testpmd.quit() > + self.vm1_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_mac_antispoof(self): > + fake_mac = '00:11:22:33:44:55' > + self.vm0_dut.send_expect("sed -i -e '/uint64_t ol_flags = 0;/a " +\ > + "\struct ether_addr fake_mac = {.addr_bytes = {0x00, 0x11, 0x22, 0x33, 0x44, 0x55},};'" +\ > + " app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.send_expect("sed -i -e '/ether_addr_copy(&addr, ð_hdr->s_addr);/d' " +\ > + " app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.send_expect("sed -i -e '/ether_addr_copy(ð_hdr->s_addr, ð_hdr->d_addr);/a " +\ > + "\ether_addr_copy(&fake_mac, ð_hdr->s_addr);' app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.build_install_dpdk(self.target) > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd macswap') > + self.dut_testpmd.execute_cmd('set vf mac antispoof 0 0 off') > + self.vm0_testpmd.execute_cmd('start') > + dumpout = self.send_and_dumpout(self.vf0_mac) > + out = self.vm0_testpmd.execute_cmd('stop') > + self.verify("src=%s" %fake_mac in dumpout, "Failed to disable vf mac anspoof!!!") > + self.verify("RX-packets: 1" in out, "Failed to receive packet!!!") > + self.verify("TX-packets: 1" in out, "Failed to disable mac antispoof!!!") > + > + self.dut_testpmd.execute_cmd('set vf mac antispoof 0 0 on') > + out = self.vm0_testpmd.execute_cmd('start') > + dumpout = self.send_and_dumpout(self.vf0_mac) > + out = self.vm0_testpmd.execute_cmd('stop') > + self.verify("src=%s" %fake_mac not in dumpout, "Failed to enable vf mac anspoof!!!") > + self.verify("RX-packets: 1" in out, "Failed to receive packet!!!") > + self.verify("TX-packets: 0" in out, "Failed to enable mac antispoof!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + self.vm0_dut.send_expect("sed -i '/struct ether_addr fake_mac = {.addr_bytes = " +\ > + "{0x00, 0x11, 0x22, 0x33, 0x44, 0x55},};/d' app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.send_expect("sed -i '/ether_addr_copy(&fake_mac, ð_hdr->s_addr);/d' " +\ > + "app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.send_expect("sed -i '/ether_addr_copy(ð_hdr->s_addr, ð_hdr->d_addr);/a " +\ > + "\ether_addr_copy(&addr, ð_hdr->s_addr);' app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.build_install_dpdk(self.target) > + > + > + def test_vf_mac_set(self): > + expect_mac = 'A2:22:33:44:55:66' > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + self.dut_testpmd.execute_cmd('set vf mac addr 0 0 %s' %expect_mac) > + if self.kdriver == "i40e": > + out = self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + out = self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + self.verify("%s" %expect_mac in out, "Failed to set vf mac!!!") > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('start') > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("src=%s" %(expect_mac.lower()) in out, > + "Failed to receive packet on setted vf mac!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_vlan_antispoof(self): > + > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + vf0_mac_lower = self.vf0_mac.lower() > + random_vlan = random.randint(1, MAX_VLAN) > + match_vlan = random_vlan > + unmatch_vlan = (random_vlan + 2) % 4096 > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('rx_vlan add %d port 0 vf 1' %match_vlan) > + if self.kdriver == "i40e": > + self.dut_testpmd.execute_cmd('set vf vlan stripq 0 0 off') > + else: > + self.dut_testpmd.execute_cmd('vlan set filter off 0') > + self.dut_testpmd.execute_cmd('vlan set strip off 0') > + self.vm0_testpmd.execute_cmd('vlan set strip off 0') > + > + self.dut_testpmd.execute_cmd('set vf vlan antispoof 0 0 off') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac,match_vlan) > + self.verify("src=%s" %vf0_mac_lower in out, > + "Failed to disable vlan antispoof with match vlan!!!") > + out = self.send_and_dumpout(self.vf0_mac,unmatch_vlan) > + self.verify("src=%s" %vf0_mac_lower in out, > + "Failed to disable vlan antispoof with unmatch vlan!!!") > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("src=%s" %vf0_mac_lower in out, > + "Failed to disable vlan antispoof with no vlan!!!") > + > + if self.kdriver == "ixgbe": > + self.dut_testpmd.execute_cmd('set vf mac antispoof 0 0 on') > + self.dut_testpmd.execute_cmd('set vf vlan antispoof 0 0 on') > + time.sleep(1) > + > + out = self.send_and_dumpout(self.vf0_mac,match_vlan) > + self.verify("src=%s" %vf0_mac_lower in out, > + "Failed to enable vlan antispoof with match vlan!!!") > + > + out = self.send_and_dumpout(self.vf0_mac,unmatch_vlan) > + self.verify("src=%s" %vf0_mac_lower not in out, > + "Failed to enable vlan antispoof with unmatch vlan!!!") > + > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("src=%s" %vf0_mac_lower not in out, > + "Failed to enable vlan antispoof with no vlan!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_vlan_strip(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + random_vlan = random.randint(1, MAX_VLAN - 1) > + rx_vlans = [1, random_vlan, MAX_VLAN] > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + for rx_vlan in rx_vlans: > + self.vm0_testpmd.execute_cmd('rx_vlan add %s 0' %rx_vlan) > + self.dut_testpmd.execute_cmd('set vf vlan stripq 0 0 off') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac,rx_vlan) > + self.verify("type=n_802_1Q" in out, "Failed to disable strip vlan!!!") > + > + self.dut_testpmd.execute_cmd('set vf vlan stripq 0 0 on') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac,rx_vlan) > + self.verify("type=IPv4" in out, "Failed to disable strip vlan!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def tear_down(self): > + self.vm0_dut.kill_all() > + self.vm1_dut.kill_all() > + pass > + > + > + def tear_down_all(self): > + self.destroy_vm_env() > + pass ^ permalink raw reply [flat|nested] 3+ messages in thread
* Re: [dts] [PATCH v2] test suite: vf daemon DPDK PF+DPDK VF test suite 2017-03-01 13:35 ` Liu, Yong @ 2017-03-03 6:44 ` Lin, Xueqin 0 siblings, 0 replies; 3+ messages in thread From: Lin, Xueqin @ 2017-03-03 6:44 UTC (permalink / raw) To: Liu, Yong, dts Hi marvin, Reply as below, thanks for review. Best regards, Xueqin -----Original Message----- From: Liu, Yong Sent: Wednesday, March 1, 2017 9:35 PM To: Lin, Xueqin <xueqin.lin@intel.com>; dts@dpdk.org Subject: Re: [dts] [PATCH v2] test suite: vf daemon DPDK PF+DPDK VF test suite Xueqin, Some comments below. Thanks, Marvin On 03/01/2017 01:56 PM, Xueqin Lin wrote: > --- > tests/TestSuite_vf_daemon.py | 619 +++++++++++++++++++++++++++++++++++++++++++ > 1 file changed, 619 insertions(+) > create mode 100644 tests/TestSuite_vf_daemon.py > > diff --git a/tests/TestSuite_vf_daemon.py > b/tests/TestSuite_vf_daemon.py new file mode 100644 index > 0000000..ef86735 > --- /dev/null > +++ b/tests/TestSuite_vf_daemon.py > @@ -0,0 +1,619 @@ > +# <COPYRIGHT_TAG> > + > +import time > +import sys > +import utils > +from scapy.utils import rdpcap > + > +from qemu_kvm import QEMUKvm > +from test_case import TestCase > +from pmd_output import PmdOutput > +from packet import Packet, sniff_packets, load_sniff_packets from > +settings import get_nic_name import random > + > +VM_CORES_MASK = 'all' > +MAX_VLAN = 4095 > + > + > +class Testvf_daemon(TestCase): > + > + def set_up_all(self): > + > + self.dut_ports = self.dut.get_ports(self.nic) > + self.verify(len(self.dut_ports) >= 1, "Insufficient ports") > + self.vm0 = None > + self.vm1 = None > + self.env_done = False > + > + > + def set_up(self): > + self.setup_vm_env() > + > + def bind_nic_driver(self, ports, driver=""): > + > + for port in ports: > + netdev = self.dut.ports_info[port]['port'] > + driver = netdev.get_nic_driver() > + if driver != 'igb_uio': > + netdev.bind_driver(driver='igb_uio') > + > + def setup_vm_env(self, driver='igb_uio'): > + """ > + Create testing environment with 2VFs generated from 1PF > + """ > + if self.env_done: > + return > + > + self.bind_nic_driver(self.dut_ports[:1], driver="") > + > + self.used_dut_port = self.dut_ports[0] > + tester_port = self.tester.get_local_port(self.used_dut_port) > + self.tester_intf = self.tester.get_interface(tester_port) > + > + 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("rmmod %svf" %self.kdriver , "# ") > + self.dut_testpmd = PmdOutput(self.dut) > + time.sleep(1) > + vf0_prop = {'opt_host': self.sriov_vfs_port[0].pci} > + > + # set up VM0 ENV > + self.vm0 = QEMUKvm(self.dut, 'vm0', 'vf_daemon') > + self.vm0.set_vm_device(driver='pci-assign', **vf0_prop) > + try: > + self.vm0_dut = self.vm0.start() > + if self.vm0_dut is None: > + raise Exception("Set up VM0 ENV failed!") > + except Exception as e: > + self.destroy_vm_env() > + raise Exception(e) > + > + self.vm0_dut_ports = self.vm0_dut.get_ports('any') > + self.vm0_testpmd = PmdOutput(self.vm0_dut) > + > + vf1_prop = {'opt_host': self.sriov_vfs_port[1].pci} > + self.vm1 = QEMUKvm(self.dut, 'vm1', 'vf_daemon') > + self.vm1.set_vm_device(driver='pci-assign', **vf1_prop) > + try: > + self.vm1_dut = self.vm1.start() > + if self.vm1_dut is None: > + raise Exception("Set up VM1 ENV failed!") > + except Exception as e: > + self.destroy_vm_env() > + raise Exception(e) > + self.vm1_dut_ports = self.vm1_dut.get_ports('any') > + self.vm1_testpmd = PmdOutput(self.vm1_dut) > + > + self.env_done = True > + > + def destroy_vm_env(self): > + > + if getattr(self, 'vm0', None): > + self.vm0_dut.kill_all() > + self.vm0_testpmd = None > + self.vm0_dut_ports = None > + # destroy vm0 > + self.vm0.stop() > + self.vm0 = None > + > + if getattr(self, 'vm1', None): > + self.vm1_dut.kill_all() > + self.vm1_testpmd = None > + self.vm1_dut_ports = None > + # destroy vm1 > + self.vm1.stop() > + self.vm1 = None > + > + if getattr(self, 'used_dut_port', None): > + self.dut.destroy_sriov_vfs_by_port(self.used_dut_port) > + port = self.dut.ports_info[self.used_dut_port]['port'] > + self.used_dut_port = None > + > + self.env_done = False > + > + > + def packet_generate(self, dst_mac, vlan_id, pktsize): > + > + if vlan_id == 0: > + pkt = Packet(pkt_type='UDP', pkt_len = pktsize) > + else: > + pkt = Packet(pkt_type='VLAN_UDP', pkt_len = pktsize) > + pkt.config_layer('vlan', {'vlan': vlan_id}) > + pkt.config_layer('ether', {'dst': dst_mac}) > + return pkt > + > + def packet_dumpout(self,inst): > + > + pkts = load_sniff_packets(inst) > + packetContentFile = "/tmp/packetContent.log" > + pcap_file = "/tmp/sniff_%s.pcap"%self.tester_intf > + fp = open(packetContentFile,'w') Please check pep8 code style. > + backup_out = sys.stdout > + sys.stdout = fp > + pkts = rdpcap(pcap_file) > + print pkts > + fp.close() > + sys.stdout = backup_out > + fp = open(packetContentFile,'r') > + out = fp.read() > + fp.close() > + return out > + > + Not sure why use this function for check packet content. We already have add some functions in packet module for stripping vlan id or other elements. >>I can change to use strip vlan id and other elements. > + def send_and_pmdout(self, dst_mac, vlan_id = 0, pktsize = 64 , num = 1): > + > + pkt = self.packet_generate(dst_mac, vlan_id , pktsize) > + inst = sniff_packets(self.tester_intf, timeout=5) > + pkt.send_pkt(tx_port=self.tester_intf, count=num) > + out = self.vm0_dut.get_session_output(timeout=2) > + return out > + > + > + def send_and_dumpout(self, dst_mac, vlan_id = 0, pktsize = 64, num = 1): > + > + pkt = self.packet_generate(dst_mac, vlan_id , pktsize) > + inst = sniff_packets(self.tester_intf, timeout=5) > + pkt.send_pkt(tx_port=self.tester_intf, count=num) > + out = self.packet_dumpout(inst) > + return out > + > + > + def test_vlan_insert(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained') > + As I remember only i40e vf device required for crc-strip enable flag, recommend to let pmd_output module handle this. That's the reason why we add this module. >>Without "crc-strip" can't start testpmd for i40e driver. Have checked with developer about it, which is a bug introduced in commit "1bbcc5d2". Set conf->rxmode.hw_strip_crc just a workaround first. They will need to figure out to how to deal the change "1bbcc5d2" in the future. Which is a workaround may change in the future, I don't think we add it in the pmd_output in the framework, once change, it also results in some case failed. > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + #Disable vlan insert which means insert vlan id as 0 > + rx_vlan = 0 > + self.dut_testpmd.execute_cmd('set vf vlan insert 0 0 %s' %rx_vlan) > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("type=IPv4" in out, > + "Failed to disable vlan insert packet!!!") > + self.verify("vlan=%d" % rx_vlan not in out, > + "Failed to disable vlan insert!!!") > + > + #Enable vlan insert which means insert vlan id as 1~4095 > + random_vlan = random.randint(1, MAX_VLAN - 1) > + rx_vlans = [1, random_vlan, MAX_VLAN] > + for rx_vlan in rx_vlans: > + self.dut_testpmd.execute_cmd('set vf vlan insert 0 0 %s'%rx_vlan) > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("type=n_802_1Q" in out, "Failed to enable vlan insert packet!!!") > + self.verify("vlan=%s" %rx_vlan in out, > + "Failed to enable vlan insert packet!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_multicast_mode(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set vf promisc 0 0 off') > + self.dut_testpmd.execute_cmd('set vf allmulti 0 0 off') > + multi_mac = 'F3:00:33:22:11:00' > + out = self.send_and_pmdout(multi_mac) > + self.verify("received" not in out, "Failed to disable vf > + multicast mode!!!") > + > + out = self.send_and_pmdout(self.vf0_mac) > + self.verify("received" in out, "Failed to disable vf multicast mode!!!") > + self.verify("dst=%s" %self.vf0_mac in out, > + "Failed to disable vf multicast mode!!!") > + > + self.dut_testpmd.execute_cmd('set vf allmulti 0 0 on') > + out = self.send_and_pmdout(multi_mac) > + self.verify("received" in out, "Failed to enable vf multicast mode!!!") > + self.verify("dst=%s" %multi_mac in out, > + "Failed to enable vf multicast mode!!!") > + > + out = self.send_and_pmdout(self.vf0_mac) > + self.verify("received" in out, "Failed to enable vf multicast mode!!!") > + self.verify("dst=%s" %self.vf0_mac in out, > + "Failed to enable vf multicast mode!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_promisc_mode(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set vf promisc 0 0 off') > + > + wrong_mac = '9E:AC:72:49:43:11' > + out = self.send_and_pmdout(wrong_mac) > + self.verify("received" not in out, "Failed to disable vf > + promisc mode!!!") > + > + out = self.send_and_pmdout(self.vf0_mac) > + self.verify("received" in out, "Failed to disable vf promisc mode!!!") > + self.verify("dst=%s" %self.vf0_mac in out, > + "Failed to disable vf promisc mode!!!") > + > + self.dut_testpmd.execute_cmd('set vf promisc 0 0 on') > + out = self.send_and_pmdout(wrong_mac) > + self.verify("received" in out, "Failed to enable vf promisc mode!!!") > + self.verify("dst=%s" %wrong_mac in out, > + "Failed to enable vf promisc mode!!!") > + > + out = self.send_and_pmdout(self.vf0_mac) > + self.verify("received" in out, "Failed to enable vf promisc mode!!!") > + self.verify("dst=%s" %self.vf0_mac in out, > + "Failed to enable vf promisc mode!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_broadcast_mode(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set vf broadcast 0 0 off') > + > + dst_mac = 'FF:FF:FF:FF:FF:FF' > + out = self.send_and_pmdout(dst_mac) > + self.verify("received" not in out, "Failed to disable vf > + broadcast mode!!!") > + > + self.dut_testpmd.execute_cmd('set vf broadcast 0 0 on') > + out = self.send_and_pmdout(dst_mac) > + self.verify("received" in out, "Failed to enable vf broadcast mode!!!") > + self.verify("dst=%s" %dst_mac in out, > + "Failed to enable vf broadcast mode!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_vf_mtu(self): > + self.dut.send_expect("ifconfig %s mtu 9000" %self.tester_intf, "#") > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + pktsize = random.randint(1500, 9000) > + out = self.send_and_dumpout(self.vf0_mac, 0, pktsize) > + self.vm0_testpmd.execute_cmd('stop') > + self.verify("src=%s" %(self.vf0_mac.lower()) not in out, > + "Failed to receive and forward this length packet!!!") > + > + self.vm0_testpmd.execute_cmd('port stop all') > + self.vm0_testpmd.execute_cmd('port config mtu 0 %s' %(pktsize+100)) > + self.vm0_testpmd.execute_cmd('port start all') > + self.vm0_testpmd.execute_cmd('start') > + out = self.send_and_dumpout(self.vf0_mac, 0, pktsize) > + self.vm0_testpmd.execute_cmd('stop') > + self.verify("src=%s" %(self.vf0_mac.lower()) in out, > + "Failed to receive and forward this length packet!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + self.dut.send_expect("ifconfig %s mtu 1500" > + %self.tester_intf, "#") > + > + > + def test_vlan_tag(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + random_vlan = random.randint(1, MAX_VLAN - 1) > + rx_vlans = [1, random_vlan, MAX_VLAN] > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + for rx_vlan in rx_vlans: > + self.vm0_testpmd.execute_cmd('rx_vlan add %s 0' %rx_vlan) > + self.dut_testpmd.execute_cmd('set vf vlan tag 0 0 off') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac, rx_vlan) > + self.verify("src=%s" %(self.vf0_mac.lower()) not in out, > + "Failed to disable vlan tag!!!") > + > + self.dut_testpmd.execute_cmd('set vf vlan tag 0 0 on') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac, rx_vlan) > + self.verify("src=%s" %(self.vf0_mac.lower()) in out, > + "Failed to enable vlan tag!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_tx_loopback(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + self.vm1_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip --eth-peer=0,%s' %self.vf0_mac) > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + self.vm1_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --eth-peer=0,%s' > + %self.vf0_mac) > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set tx loopback 0 off') > + > + inst = sniff_packets(self.tester_intf, timeout=5) > + > + self.vm1_testpmd.execute_cmd('set burst 5') > + self.vm1_testpmd.execute_cmd('start tx_first') > + > + dumpout = self.packet_dumpout(inst) > + out = self.vm0_testpmd.execute_cmd('stop') > + self.verify("dst=%s" %(self.vf0_mac.lower()) in dumpout, > + "Failed to disable tx loopback!!!") > + self.verify("RX-packets: 0" in out, "Failed to disable tx > + loopback!!!") > + > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set tx loopback 0 on') > + > + inst = sniff_packets(self.tester_intf, timeout=5) > + > + self.vm1_testpmd.execute_cmd('stop') > + self.vm1_testpmd.execute_cmd('start tx_first') > + > + dumpout = self.packet_dumpout(inst) > + out = self.vm0_testpmd.execute_cmd('stop') > + self.verify("dst=%s" %(self.vf0_mac.lower()) not in dumpout, > + "Failed to enable tx loopback!!!") > + self.verify("RX-packets: 5" in out, "Failed to enable tx > + loopback!!!") > + > + self.vm0_testpmd.quit() > + self.vm1_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + > + def test_all_queues_drop(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + self.vm1_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained') > + > + self.vm0_testpmd.execute_cmd('set fwd rxonly') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('set all queues drop 0 off') > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + self.vf1_mac = self.vm1_testpmd.get_port_mac(0) > + out = self.send_and_pmdout(self.vf1_mac, 0, 64, 200) > + out = self.vm1_testpmd.execute_cmd('show port stats 0') > + self.verify("RX-packets: 127" in out, "Failed to let vf1 full of queues!!!") > + out = self.send_and_pmdout(self.vf0_mac, 0, 64, 20) > + out = self.vm0_testpmd.execute_cmd('show port stats 0') > + self.verify("RX-packets: 0" in out, "Failed to disable all queues drop!!!") > + self.dut_testpmd.execute_cmd('set all queues drop 0 on') > + out = self.vm0_testpmd.execute_cmd('show port stats 0') > + self.verify("RX-packets: 20" in out, "Failed to enable all queues drop!!!") > + out = self.send_and_pmdout(self.vf0_mac, 0, 64, 20) > + out = self.vm0_testpmd.execute_cmd('show port stats 0') > + self.verify("RX-packets: 40" in out, "Failed to enable all > + queues drop!!!") > + > + self.vm0_testpmd.quit() > + self.vm1_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_mac_antispoof(self): > + fake_mac = '00:11:22:33:44:55' > + self.vm0_dut.send_expect("sed -i -e '/uint64_t ol_flags = 0;/a " +\ > + "\struct ether_addr fake_mac = {.addr_bytes = {0x00, 0x11, 0x22, 0x33, 0x44, 0x55},};'" +\ > + " app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.send_expect("sed -i -e '/ether_addr_copy(&addr, ð_hdr->s_addr);/d' " +\ > + " app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.send_expect("sed -i -e '/ether_addr_copy(ð_hdr->s_addr, ð_hdr->d_addr);/a " +\ > + "\ether_addr_copy(&fake_mac, ð_hdr->s_addr);' app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.build_install_dpdk(self.target) > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd macswap') > + self.dut_testpmd.execute_cmd('set vf mac antispoof 0 0 off') > + self.vm0_testpmd.execute_cmd('start') > + dumpout = self.send_and_dumpout(self.vf0_mac) > + out = self.vm0_testpmd.execute_cmd('stop') > + self.verify("src=%s" %fake_mac in dumpout, "Failed to disable vf mac anspoof!!!") > + self.verify("RX-packets: 1" in out, "Failed to receive packet!!!") > + self.verify("TX-packets: 1" in out, "Failed to disable mac > + antispoof!!!") > + > + self.dut_testpmd.execute_cmd('set vf mac antispoof 0 0 on') > + out = self.vm0_testpmd.execute_cmd('start') > + dumpout = self.send_and_dumpout(self.vf0_mac) > + out = self.vm0_testpmd.execute_cmd('stop') > + self.verify("src=%s" %fake_mac not in dumpout, "Failed to enable vf mac anspoof!!!") > + self.verify("RX-packets: 1" in out, "Failed to receive packet!!!") > + self.verify("TX-packets: 0" in out, "Failed to enable mac > + antispoof!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + self.vm0_dut.send_expect("sed -i '/struct ether_addr fake_mac = {.addr_bytes = " +\ > + "{0x00, 0x11, 0x22, 0x33, 0x44, 0x55},};/d' app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.send_expect("sed -i '/ether_addr_copy(&fake_mac, ð_hdr->s_addr);/d' " +\ > + "app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.send_expect("sed -i '/ether_addr_copy(ð_hdr->s_addr, ð_hdr->d_addr);/a " +\ > + "\ether_addr_copy(&addr, ð_hdr->s_addr);' app/test-pmd/macswap.c", "# ", 30) > + self.vm0_dut.build_install_dpdk(self.target) > + > + > + def test_vf_mac_set(self): > + expect_mac = 'A2:22:33:44:55:66' > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + self.dut_testpmd.execute_cmd('set vf mac addr 0 0 %s' %expect_mac) > + if self.kdriver == "i40e": > + out = self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + out = self.vm0_testpmd.start_testpmd(VM_CORES_MASK, '--port-topology=chained') > + self.verify("%s" %expect_mac in out, "Failed to set vf mac!!!") > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('start') > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("src=%s" %(expect_mac.lower()) in out, > + "Failed to receive packet on setted vf mac!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_vlan_antispoof(self): > + > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + vf0_mac_lower = self.vf0_mac.lower() > + random_vlan = random.randint(1, MAX_VLAN) > + match_vlan = random_vlan > + unmatch_vlan = (random_vlan + 2) % 4096 > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('start') > + self.dut_testpmd.execute_cmd('rx_vlan add %d port 0 vf 1' %match_vlan) > + if self.kdriver == "i40e": > + self.dut_testpmd.execute_cmd('set vf vlan stripq 0 0 off') > + else: > + self.dut_testpmd.execute_cmd('vlan set filter off 0') > + self.dut_testpmd.execute_cmd('vlan set strip off 0') > + self.vm0_testpmd.execute_cmd('vlan set strip off 0') > + > + self.dut_testpmd.execute_cmd('set vf vlan antispoof 0 0 off') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac,match_vlan) > + self.verify("src=%s" %vf0_mac_lower in out, > + "Failed to disable vlan antispoof with match vlan!!!") > + out = self.send_and_dumpout(self.vf0_mac,unmatch_vlan) > + self.verify("src=%s" %vf0_mac_lower in out, > + "Failed to disable vlan antispoof with unmatch vlan!!!") > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("src=%s" %vf0_mac_lower in out, > + "Failed to disable vlan antispoof with no vlan!!!") > + > + if self.kdriver == "ixgbe": > + self.dut_testpmd.execute_cmd('set vf mac antispoof 0 0 on') > + self.dut_testpmd.execute_cmd('set vf vlan antispoof 0 0 on') > + time.sleep(1) > + > + out = self.send_and_dumpout(self.vf0_mac,match_vlan) > + self.verify("src=%s" %vf0_mac_lower in out, > + "Failed to enable vlan antispoof with match vlan!!!") > + > + out = self.send_and_dumpout(self.vf0_mac,unmatch_vlan) > + self.verify("src=%s" %vf0_mac_lower not in out, > + "Failed to enable vlan antispoof with unmatch vlan!!!") > + > + out = self.send_and_dumpout(self.vf0_mac) > + self.verify("src=%s" %vf0_mac_lower not in out, > + "Failed to enable vlan antispoof with no vlan!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def test_vlan_strip(self): > + self.dut_testpmd.start_testpmd("Default", "--port-topology=chained") > + if self.kdriver == "i40e": > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained --crc-strip') > + else: > + self.vm0_testpmd.start_testpmd(VM_CORES_MASK, > + '--port-topology=chained') > + > + self.vf0_mac = self.vm0_testpmd.get_port_mac(0) > + > + random_vlan = random.randint(1, MAX_VLAN - 1) > + rx_vlans = [1, random_vlan, MAX_VLAN] > + self.vm0_testpmd.execute_cmd('set fwd mac') > + self.vm0_testpmd.execute_cmd('set verbose 1') > + self.vm0_testpmd.execute_cmd('start') > + for rx_vlan in rx_vlans: > + self.vm0_testpmd.execute_cmd('rx_vlan add %s 0' %rx_vlan) > + self.dut_testpmd.execute_cmd('set vf vlan stripq 0 0 off') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac,rx_vlan) > + self.verify("type=n_802_1Q" in out, "Failed to disable > + strip vlan!!!") > + > + self.dut_testpmd.execute_cmd('set vf vlan stripq 0 0 on') > + time.sleep(1) > + out = self.send_and_dumpout(self.vf0_mac,rx_vlan) > + self.verify("type=IPv4" in out, "Failed to disable strip > + vlan!!!") > + > + self.vm0_testpmd.quit() > + self.dut_testpmd.quit() > + > + > + def tear_down(self): > + self.vm0_dut.kill_all() > + self.vm1_dut.kill_all() > + pass > + > + > + def tear_down_all(self): > + self.destroy_vm_env() > + pass ^ permalink raw reply [flat|nested] 3+ messages in thread
end of thread, other threads:[~2017-03-03 6:45 UTC | newest] Thread overview: 3+ messages (download: mbox.gz / follow: Atom feed) -- links below jump to the message on this page -- 2017-03-01 5:56 [dts] [PATCH v2] test suite: vf daemon DPDK PF+DPDK VF test suite Xueqin Lin 2017-03-01 13:35 ` Liu, Yong 2017-03-03 6:44 ` Lin, Xueqin
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).