From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mga02.intel.com (mga02.intel.com [134.134.136.20]) by dpdk.org (Postfix) with ESMTP id D32445320 for ; Thu, 22 Jun 2017 04:11:20 +0200 (CEST) Received: from fmsmga001.fm.intel.com ([10.253.24.23]) by orsmga101.jf.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384; 21 Jun 2017 19:11:19 -0700 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.39,371,1493708400"; d="scan'208";a="1163287652" Received: from unknown (HELO dpdk-fedora20.icx.intel.com) ([10.240.176.135]) by fmsmga001.fm.intel.com with ESMTP; 21 Jun 2017 19:11:18 -0700 From: "xu,huilong" To: dts@dpdk.org Cc: "xu,huilong" Date: Thu, 22 Jun 2017 10:12:40 +0800 Message-Id: <1498097560-14858-2-git-send-email-huilongx.xu@intel.com> X-Mailer: git-send-email 1.9.3 In-Reply-To: <1498097560-14858-1-git-send-email-huilongx.xu@intel.com> References: <1498097560-14858-1-git-send-email-huilongx.xu@intel.com> Subject: [dts] [PATCH V1 2/2] add qinq test suite X-BeenThere: dts@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: test suite reviews and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Thu, 22 Jun 2017 02:11:21 -0000 qinq test suite include four cases. Two PF case: qinq_pack_type and qinq_filter_PF_queues Two VF case: qinq_filter_with_diffierent_tpid and packet_filter_VF_queues qinq filte only support fortville nic with firemware 6.0.0 Signed-off-by: xu,huilong --- tests/TestSuite_qinq_filter.py | 353 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 353 insertions(+) create mode 100644 tests/TestSuite_qinq_filter.py diff --git a/tests/TestSuite_qinq_filter.py b/tests/TestSuite_qinq_filter.py new file mode 100644 index 0000000..9d03fe9 --- /dev/null +++ b/tests/TestSuite_qinq_filter.py @@ -0,0 +1,353 @@ +# BSD LICENSE +# +# Copyright(c) 2010-2017 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 the support of VLAN Offload Features by Poll Mode Drivers. + +""" + +from test_case import TestCase +from scapy.all import * +import utils +import time + +class TestQinqFilter(TestCase): + + def set_up_all(self): + """ + Run at the start of each test suite. + + """ + global dutRxPortId + global dutTxPortId + + self.verify(self.nic in ["fortville_eagle", "fortville_spirit", "fortville_spirit_single", "fortville_25G"], + "NIC %s not support this test" % self.nic) + print 'this case only support fortville with 6.0.0+ firemware and dpdk17.05+' + ports = self.dut.get_ports() + # Verify that enough ports are available + self.verify(len(ports) >= 1, "Insufficient ports") + + valports = [_ for _ in ports if self.tester.get_local_port(_) != -1] + dutRxPortId = valports[0] + dutTxPortId = valports[0] + + port = self.tester.get_local_port(dutRxPortId) + self.txItf = self.tester.get_interface(port) + self.smac = self.tester.get_mac(port) + # the package dect mac must is dut tx port id when the port promisc is off + self.dmac = self.dut.get_mac_address(dutRxPortId) + + self.portMask = utils.create_mask(valports[:1]) + + cores = self.dut.get_core_list('1S/2C/1T') + self.coreMask = utils.create_mask(cores) + + self.dut.send_expect("sed -i -e 's/CONFIG_RTE_LIBRTE_I40E_INC_VECTOR=.*$/" + + "CONFIG_RTE_LIBRTE_I40E_INC_VECTOR=n/' config/common_base", "# ", 30) + self.dut.build_install_dpdk(self.target) + + def vlan_send_packet(self, vlans): + """ + Send $num of packet to portid, vlans must a list. the member is (vlan id,vlan values). + eg: vlans = [(0x8100, 1),(0x8100, 4093)] + """ + + vlanString = 'sendp([Ether( dst="%s", src="%s")/' % (self.dmac, self.smac) + for vlan_config in vlans: + vlanString += "Dot1Q(id=%s,vlan=%s)/" % vlan_config + vlanString += 'IP(src="192.168.0.1", dst="192.168.0.2")/Raw("x" * 20)],iface="%s")' % self.txItf + + self.tester.scapy_append(vlanString) + self.tester.scapy_execute() + + def creat_pcap(self, vlans_list): + """ + creat pcap and changed out vlan tpid to 0x88a8 + """ + packets = [] + for vlan in vlans_list: + packets.append(Ether(dst=self.dmac, src=self.smac)/Dot1Q(id=0x8100,vlan=vlan[0])/Dot1Q(id=0x8100,vlan=vlan[1])/IP(src="192.168.0.1", dst="192.168.0.2")/Raw("x"*20)) + self.tester.send_expect('rm -rf tmp_qinq.pcap', "# ") + self.tester.send_expect('rm -rf dst_qinq.pcap', "# ") + wrpcap('tmp_qinq.pcap', packets) + + fr = open('tmp_qinq.pcap', 'rb') + packet_bin = [] + while 1: + s = fr.read(1) + if not s: + break + packet_bin.append(s) + match_bin = (['\x81', '\x00', '\x00', '\x01'], + ['\x81', '\x00', '\x00', '\x02'], + ['\x81', '\x00', '\x00', '\x03']) + for i in range(len(packet_bin) - len(match_bin[0])): + if packet_bin[i: i+ len(match_bin[0])] in match_bin: + packet_bin[i:i + len(match_bin[0]) - 1] = ['\x88','\xa8', '\x00'] + fw = open('/root/dst_qinq.pcap', 'wb') + for word in packet_bin: + fw.write(word) + fw.close() + + def config_vfs(self, port_id, vfs): + """ + if vfs is 0, call destroy_sriov_vfs_by_port in dut for destory vf. + if vfs > 0, call generate_sriov_vfs_by_port generate vf and bind igb_uio to vf + """ + if vfs: + self.dut.generate_sriov_vfs_by_port(port_id, vfs, 'igb_uio') + for port in self.dut.ports_info[port_id]['vfs_port']: + port.bind_driver('igb_uio') + else: + self.dut.destroy_sriov_vfs_by_port(port_id) + + + def set_up(self): + """ + Run before each test case. + """ + pass + + def test_qinq_pack_type(self): + """ + Enable receipt of dual VLAN packets + """ + + self.dut.send_expect(r'./%s/app/testpmd -c %s -n 4 -- -i \ + --portmask=%s --port-topology=loop \ + --rxq=4 --txq=4 --txqflags=0x0 --disable-rss' % (self.target, self.coreMask, self.portMask), + "testpmd> ") + self.dut.send_expect("vlan set qinq on %s" % dutRxPortId, "testpmd> ") + self.dut.send_expect("set fwd rxonly", "testpmd> ") + self.dut.send_expect("set verbose 1", "testpmd> ") + self.dut.send_expect("start", "testpmd> ", 120) + time.sleep(5) + + self.vlan_send_packet([(0x8100, 2), (0x8100, 3)]) + out = self.dut.get_session_output() + self.verify('QinQ VLAN' in out, "dual vlan not received:" + str(out)) + + self.dut.send_expect("quit", "#") + + def test_qinq_filter_PF_queues(self): + """ + qinq filter packet received by assign PF queues + """ + self.dut.send_expect(r'./%s/app/testpmd -c %s -n 4 -- -i \ + --portmask=%s --port-topology=loop \ + --rxq=4 --txq=4 --txqflags=0x0 --disable-rss' % (self.target, self.coreMask, self.portMask), + "testpmd> ") + self.dut.send_expect("vlan set qinq on %s" % dutRxPortId, "testpmd> ") + self.dut.send_expect("set fwd rxonly", "testpmd> ") + self.dut.send_expect("set verbose 1", "testpmd> ") + self.dut.send_expect("start", "testpmd> ", 120) + time.sleep(5) + + # out vlan 1, inner vlan 4093 packet will received by PF queue 1 + self.dut.send_expect(r'flow create 0 ingress pattern eth / vlan tci is 1 / vlan tci is 4093 / end actions pf / queue index 1 / end', "testpmd> ") + + # out vlan 2, inner vlan 4094 packet will received by PF queue 1 + self.dut.send_expect(r'flow create 0 ingress pattern eth / vlan tci is 2 / vlan tci is 4094 / end actions pf / queue index 2 / end', "testpmd> ") + + self.vlan_send_packet([(0x8100, 1), (0x8100, 4093)]) + out = self.dut.get_session_output() + self.verify('queue 1: received 1 packets' in out, "out vlan 1, inner vlan 4093 received not by queue 1 : %s" % out) + + self.vlan_send_packet([(0x8100, 2), (0x8100, 4094)]) + out = self.dut.get_session_output() + self.verify('queue 2: received 1 packets' in out, "out vlan 1, inner vlan 4093 received not by queue 2 : %s" % out) + + self.dut.send_expect("quit", "#") + + def test_qinq_packet_filter_VF_queues(self): + """ + qinq filter packet received by assign VF queues + """ + self.config_vfs(dutRxPortId, 2) + vf_list = self.dut.ports_info[dutRxPortId]['sriov_vfs_pci'] + self.verify(len(vf_list) == 2, 'config 2 vf failed: %s' % str(vf_list)) + vf0_session = self.dut.new_session('qinq_filter') + vf1_session = self.dut.new_session('qinq_filter') + + self.dut.send_expect(r'./%s/app/testpmd -c %s -n 4 \ + --socket-mem=1024,1024 --file-prefix=pf -w %s -- -i --port-topology=loop \ + --rxq=4 --txq=4 --txqflags=0x0 --disable-rss' + % (self.target, self.coreMask, self.dut.ports_info[dutRxPortId]['pci']), + "testpmd> ") + self.dut.send_expect("vlan set qinq on %s" % dutRxPortId, "testpmd> ") + self.dut.send_expect("set fwd rxonly", "testpmd> ") + self.dut.send_expect("set verbose 1", "testpmd> ") + self.dut.send_expect("start", "testpmd> ", 120) + + # out vlan 1, inner vlan 4093 packet will received by vf0 queue 2 + self.dut.send_expect(r'flow create 0 ingress pattern eth / vlan tci is 1 / vlan tci is 4093 / end actions vf id 0 / queue index 2 / end', "testpmd> ") + # out vlan 2, inner vlan 4094 packet will received by vf1 queue 3 + self.dut.send_expect(r'flow create 0 ingress pattern eth / vlan tci is 2 / vlan tci is 4094 / end actions vf id 1 / queue index 3 / end', "testpmd> ") + # out vlan 3, inner vlan 4094 packet will received by pf queue 1 + self.dut.send_expect(r'flow create 0 ingress pattern eth / vlan tci is 3 / vlan tci is 4094 / end actions pf / queue index 1 / end', "testpmd> ") + + vf0_session.send_expect(r'./%s/app/testpmd -c %s -n 4 \ + --socket-mem=1024,1024 --file-prefix=vf0 -w %s -- -i --port-topology=loop \ + --rxq=4 --txq=4 --txqflags=0x0 --disable-rss' + % (self.target, self.coreMask, vf_list[0]), + "testpmd> ") + + vf1_session.send_expect(r'./%s/app/testpmd -c %s -n 4 \ + --socket-mem=1024,1024 --file-prefix=vf1 -w %s -- -i --port-topology=loop \ + --rxq=4 --txq=4 --txqflags=0x0 --disable-rss' + % (self.target, self.coreMask, vf_list[1]), + "testpmd>") + for session_name in [vf0_session, vf1_session]: + session_name.send_expect("set fwd rxonly", "testpmd> ") + session_name.send_expect("set verbose 1", "testpmd> ") + session_name.send_expect("start", "testpmd> ", 120) + time.sleep(5) + for vlan_config in [[(0x8100, 1),(0x8100, 4093)], [(0x8100, 2),(0x8100, 4094)], [(0x8100, 3),(0x8100, 4094)]]: + self.vlan_send_packet(vlan_config) + + dut_out = self.dut.get_session_output() + vf0_out = vf0_session.get_session_before(30) + vf1_out = vf1_session.get_session_before(30) + + error_message = '' + if 'queue 1: received 1 packets' not in dut_out: + error_message += 'dut testpmd received packt queue error: %s' % dut_out + elif 'queue 2: received 1 packets' not in vf0_out: + error_message += ' vf0 testpmd received packt queue error: %s' % vf0_out + elif 'queue 3: received 1 packets' not in vf1_out: + error_message += ' vf1 testpmd received packt queue error: %s' % vf1_out + + for session_name in [vf0_session, vf1_session]: + session_name.send_expect("quit", "#") + self.dut.close_session(session_name) + self.dut.send_expect("quit", "#") + + self.config_vfs(dutRxPortId, 0) + vf_list = self.dut.ports_info[dutRxPortId]['sriov_vfs_pci'] + self.verify(len(vf_list) == 0, 'destroy vf failed: %s' % str(vf_list)) + + self.verify(not error_message, error_message) + + def test_qinq_filter_with_diffierent_tpid(self): + """ + qinq filter packet with diffferent tpid received by assign VF queues + """ + self.config_vfs(dutRxPortId, 2) + vf_list = self.dut.ports_info[dutRxPortId]['sriov_vfs_pci'] + self.verify(len(vf_list) == 2, 'config 2 vf failed: %s' % str(vf_list)) + vf0_session = self.dut.new_session('qinq_filter') + vf1_session = self.dut.new_session('qinq_filter') + + self.dut.send_expect(r'./%s/app/testpmd -c %s -n 4 \ + --socket-mem=1024,1024 --file-prefix=pf -w %s -- -i --port-topology=loop \ + --rxq=4 --txq=4 --txqflags=0x0 --disable-rss' + % (self.target, self.coreMask, self.dut.ports_info[dutRxPortId]['pci']), + "testpmd> ") + self.dut.send_expect("vlan set qinq on %s" % dutRxPortId, "testpmd> ") + self.dut.send_expect("set fwd rxonly", "testpmd> ") + self.dut.send_expect("set verbose 1", "testpmd> ") + self.dut.send_expect("start", "testpmd> ", 120) + time.sleep(5) + + # out vlan 1, inner vlan 4093 packet will received by vf0 queue 2 + self.dut.send_expect(r'flow create 0 ingress pattern eth / vlan tci is 1 / vlan tci is 4093 / end actions vf id 0 / queue index 2 / end', "testpmd> ") + # out vlan 2, inner vlan 4094 packet will received by vf1 queue 3 + self.dut.send_expect(r'flow create 0 ingress pattern eth / vlan tci is 2 / vlan tci is 4094 / end actions vf id 1 / queue index 3 / end', "testpmd> ") + # out vlan 3, inner vlan 4094 packet will received by pf queue 1 + self.dut.send_expect(r'flow create 0 ingress pattern eth / vlan tci is 3 / vlan tci is 4094 / end actions pf / queue index 1 / end', "testpmd> ") + + self.dut.send_expect('vlan set outer tpid 0x88a8 0', "testpmd") + + vf0_session.send_expect(r'./%s/app/testpmd -c %s -n 4 \ + --socket-mem=1024,1024 --file-prefix=vf0 -w %s -- -i --port-topology=loop \ + --rxq=4 --txq=4 --txqflags=0x0 --disable-rss' + % (self.target, self.coreMask, vf_list[0]), + "testpmd> ") + + vf1_session.send_expect(r'./%s/app/testpmd -c %s -n 4 \ + --socket-mem=1024,1024 --file-prefix=vf1 -w %s -- -i --port-topology=loop \ + --rxq=4 --txq=4 --txqflags=0x0 --disable-rss' + % (self.target, self.coreMask, vf_list[1]), + "testpmd>") + for session_name in [vf0_session, vf1_session]: + session_name.send_expect("set fwd rxonly", "testpmd> ") + session_name.send_expect("set verbose 1", "testpmd> ") + session_name.send_expect("start", "testpmd> ", 120) + time.sleep(5) + + self.creat_pcap([(1, 4093), (2, 4094), (3, 4094)]) + + self.tester.scapy_append('pcap = rdpcap("/root/dst_qinq.pcap")') + self.tester.scapy_append('sendp(pcap, iface="%s")' % self.txItf) + self.tester.scapy_execute() + time.sleep(5) + + dut_out = self.dut.get_session_output() + vf0_out = vf0_session.get_session_before(30) + vf1_out = vf1_session.get_session_before(30) + + error_message = '' + if 'queue 1: received 1 packets' not in dut_out: + error_message += 'dut testpmd received packt queue error: %s' % dut_out + elif 'queue 2: received 1 packets' not in vf0_out: + error_message += ' vf0 testpmd received packt queue error: %s' % vf0_out + elif 'queue 3: received 1 packets' not in vf1_out: + error_message += ' vf1 testpmd received packt queue error: %s' % vf1_out + + for session_name in [vf0_session, vf1_session]: + session_name.send_expect("quit", "#") + self.dut.close_session(session_name) + self.dut.send_expect("quit", "#") + + self.config_vfs(dutRxPortId, 0) + vf_list = self.dut.ports_info[dutRxPortId]['sriov_vfs_pci'] + self.verify(len(vf_list) == 0, 'destroy vf failed: %s' % str(vf_list)) + + self.verify(not error_message, error_message) + + + def tear_down(self): + """ + Run after each test case. + """ + self.dut.kill_all() + + def tear_down_all(self): + """ + Run after each test suite. + """ + self.dut.send_expect("sed -i -e 's/CONFIG_RTE_LIBRTE_I40E_INC_VECTOR=.*$/" + + "CONFIG_RTE_LIBRTE_I40E_INC_VECTOR=y/' config/common_base", "# ", 30) + self.dut.build_install_dpdk(self.target) -- 1.9.3