* [dts] [PATCH] add ddp mpls test suite and profile file
@ 2017-04-13 0:21 Xueqin Lin
2017-04-20 8:06 ` Liu, Yong
0 siblings, 1 reply; 2+ messages in thread
From: Xueqin Lin @ 2017-04-13 0:21 UTC (permalink / raw)
To: dts; +Cc: Xueqin Lin
---
dep/mpls.pkgo | Bin 0 -> 1200 bytes
tests/TestSuite_ddp_mpls.py | 239 ++++++++++++++++++++++++++++++++++++++++++++
2 files changed, 239 insertions(+)
create mode 100644 dep/mpls.pkgo
create mode 100644 tests/TestSuite_ddp_mpls.py
diff --git a/dep/mpls.pkgo b/dep/mpls.pkgo
new file mode 100644
index 0000000000000000000000000000000000000000..0676cabea83e9e862bdfee8fa08ff687e0fcfd15
GIT binary patch
literal 1200
zcmah}&59F25U!p{!V(nXK~Ewrf)`mLn)q{(=q6c&i4NIpK!T7?(%B3<nGQ1@b#Ei;
zx~ty3dGfFaK_5c&F;?&eym*e)J*_hv4=Jer=IiRJuCA^g03bF1P}CUJB>;<zAXP#-
zIBfc2z<k=`l8u;T+ORYbTpv5vsCdFd+H##OvDt2v^~ZMIHH$Oh7gjPyz9Bvkl1EDc
zv$QkuB03Aj*z-B%0UP){`hOET^jQ>nV{gc$CjvSaNhVazgMj-{@u?>#v>_)v47jA@
zkWDenjP3b?jfz{61tS)YsM~quHX>TRy?*N^okx761BHAhLg@uN=rG(xceyvioYNDX
zG3V)HQJY<dZiry)?aad@m-=$q$f{bM#(3e`{aA&S24jQI4Zbk=(%>tD`vzYdJTQ1@
z@QuN@2Gw03)BsdJ{6M{mm-7oXJ>6oV`(X{Bg!UQ|0>pyD%aB8^MDh4tmRsaw@jM)%
zenKT+ky<Ga4yuc){lA}BZ}s1&+|un?*6}}Je9i5$-b>Xc;a4<Q19Hr&0NZ8;IiBDg
z)W0MX$O|gVUO~5e;-AAMC>MWXcG|xLcar6bqwxa7N6AFuZ$qz?@h3O5@%YkL3+;J;
zGJH<`krzPqw-U75K&txt`1dKyM9Z40r%KVbbHJa;kPW47ZR)cD_y0Aqz*j`2pv`Wt
zQdzH5A1ChVxXK@&;|hNprYzc}Vr~-XbR0VHWP~q8O!dauT~+?5I{!X?+p7HJVO#w#
mlxS|b_fK%Uz47;cv_03ZyJkZ3ymP&E*G>Hk&F;OHrtk+tO5&FQ
literal 0
HcmV?d00001
diff --git a/tests/TestSuite_ddp_mpls.py b/tests/TestSuite_ddp_mpls.py
new file mode 100644
index 0000000..2481c01
--- /dev/null
+++ b/tests/TestSuite_ddp_mpls.py
@@ -0,0 +1,239 @@
+# <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'
+PF_MAX_QUEUE = 64
+VF_MAX_QUEUE = 4
+
+class Testddp_mpls(TestCase):
+
+ def set_up_all(self):
+ self.verify(self.nic in ['fortville_25g'],
+ 'ddp mpls can not support %s nic' % self.nic)
+ self.dut_ports = self.dut.get_ports(self.nic)
+ self.verify(len(self.dut_ports) >= 1, "Insufficient ports")
+ self.vm0 = None
+ self.env_done = False
+ profile_file = r'dep/mpls.pkgo'
+ profile_dst = "/tmp/"
+ self.dut.session.copy_file_to(profile_file, profile_dst)
+
+
+ def set_up(self):
+ self.setup_vm_env()
+
+
+ def bind_nic_driver(self, ports, driver=""):
+ if driver == "igb_uio":
+ 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')
+ else:
+ for port in ports:
+ netdev = self.dut.ports_info[port]['port']
+ driver_now = netdev.get_nic_driver()
+ if driver == "":
+ driver = netdev.default_driver
+ if driver != driver_now:
+ netdev.bind_driver(driver=driver)
+
+
+ def setup_vm_env(self, driver='igb_uio'):
+ """
+ Create testing environment with VF generated from 1PF
+ """
+ if self.env_done == False:
+ self.bind_nic_driver(self.dut_ports[:1], driver="igb_uio")
+ 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, 1, driver=driver)
+ self.sriov_vfs_port = self.dut.ports_info[
+ self.used_dut_port]['vfs_port']
+ for port in self.sriov_vfs_port:
+ port.bind_driver('pci-stub')
+ time.sleep(1)
+ 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', 'ddp_mpls')
+ 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)
+ self.env_done = True
+
+ self.dut_testpmd.start_testpmd(
+ "Default","--port-topology=chained --txq=%s --rxq=%s"
+ % (PF_MAX_QUEUE, PF_MAX_QUEUE))
+ self.vm0_testpmd.start_testpmd(
+ VM_CORES_MASK,"--port-topology=chained --txq=%s --rxq=%s"
+ % (VF_MAX_QUEUE, VF_MAX_QUEUE))
+
+
+ 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, '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 load_profile(self):
+ """
+ Load profile to update FVL configuration tables, profile will be
+ stored in binary file and need to be passed to AQ to program FVL
+ during initialization stage.
+ """
+ self.dut_testpmd.execute_cmd('port stop all')
+ time.sleep(1)
+ out = self.dut_testpmd.execute_cmd('ddp get list 0')
+ self.verify("Profile number is: 0" in out,
+ "Failed to get ddp profile info list!!!")
+ self.dut_testpmd.execute_cmd('ddp add 0 /tmp/mpls.pkgo')
+ out = self.dut_testpmd.execute_cmd('ddp get list 0')
+ self.verify("Profile number is: 1" in out,
+ "Failed to load ddp profile!!!")
+ self.dut_testpmd.execute_cmd('port start all')
+ time.sleep(1)
+
+
+ def mpls_test(self, port='pf', pkt='udp'):
+ """
+ Send mpls packet to dut, reveive packet from configured queue.
+ Input: port type, packet type
+ """
+ pkts = []
+ if port == 'pf':
+ queue = random.randint(1, PF_MAX_QUEUE - 1)
+ self.dut_testpmd.execute_cmd('set fwd rxonly')
+ self.dut_testpmd.execute_cmd('set verbose 1')
+ self.dut_testpmd.execute_cmd('start')
+ else:
+ queue = random.randint(1, VF_MAX_QUEUE - 1)
+ self.vm0_testpmd.execute_cmd('set fwd rxonly')
+ self.vm0_testpmd.execute_cmd('set verbose 1')
+ self.vm0_testpmd.execute_cmd('start')
+ random_label = random.randint(0x0, 0xFFFFF)
+ label = hex(random_label)
+ wrong_label = hex((random_label + 2) % int(0xFFFFF))
+ self.dut_testpmd.execute_cmd('flow create 0 ingress pattern eth / ipv4\
+ / %s / mpls label is %s / end actions %s / queue index %d / end'
+ % (pkt, label, port, queue) )
+ for times in range(2):
+ if pkt == 'udp':
+ pkts = {'mpls/good chksum udp': 'Ether()/IP()/UDP(dport=6635)\
+ /MPLS(label=%s)/Ether()/IP()/TCP()'% label,
+ 'mpls/bad chksum udp': 'Ether()/IP()/UDP(chksum=0x1234,\
+ dport=6635)/MPLS(label=%s)/Ether()/IP()/TCP()'% label }
+ else:
+ pkts = {'mpls/good chksum gre': 'Ether()/IP(proto=47)/GRE(proto=0x8847)\
+ /MPLS(label=%s)/Ether()/IP()/UDP()'% label,
+ 'mpls/bad chksum gre': 'Ether()/IP(proto=47)/GRE(chksum=0x1234,\
+ proto=0x8847)/MPLS(label=%s)/Ether()/IP()/UDP()'% label }
+ for packet_type in pkts.keys():
+ self.tester.scapy_append('sendp([%s], iface="%s")'
+ % (pkts[packet_type], self.tester_intf))
+ self.tester.scapy_execute()
+ if port == 'pf':
+ out = self.dut.get_session_output(timeout=2)
+ else:
+ out = self.vm0_dut.get_session_output(timeout=2)
+
+ self.verify("port 0/queue %d" % queue in out,
+ "Failed to receive packet in this queue!!!")
+ self.verify("PKT_RX_L4_CKSUM_GOOD" in out,"Failed to check CKSUM!!!")
+ label = wrong_label
+ queue = 0
+
+
+ def test_load_ddp(self):
+ """
+ Load profile to update FVL configuration tables.
+ """
+ self.load_profile()
+
+
+ def test_mpls_udp_pf(self):
+ """
+ MPLS is supported by NVM with profile updated. Send mpls upd packet to PF,
+ check PF could receive packet using configured queue, checksum is good.
+ """
+ self.load_profile()
+ self.mpls_test(port='pf', pkt='udp')
+
+
+ def test_mpls_gre_pf(self):
+ """
+ MPLS is supported by NVM with profile updated. Send mpls gre packet to PF,
+ check PF could receive packet using configured queue, checksum is good.
+ """
+ self.load_profile()
+ self.mpls_test(port='pf', pkt='gre')
+
+
+ def test_mpls_udp_vf(self):
+ """
+ MPLS is supported by NVM with profile updated. Send mpls upd packet to VF,
+ check VF could receive packet using configured queue, checksum is good.
+ """
+ self.load_profile()
+ self.mpls_test(port='vf id 0', pkt='udp')
+
+
+ def test_mpls_gre_vf(self):
+ """
+ MPLS is supported by NVM with profile updated. Send mpls gre packet to VF,
+ check VF could receive packet using configured queue, checksum is good.
+ """
+ self.load_profile()
+ self.mpls_test(port='vf id 0', pkt='gre')
+
+
+ def tear_down(self):
+ if self.vm0_testpmd:
+ self.dut_testpmd.execute_cmd('write reg 0 0xb8190 1')
+ self.dut_testpmd.execute_cmd('write reg 0 0xb8190 2')
+ self.vm0_testpmd.quit()
+ self.dut_testpmd.quit()
+ self.vm0_dut.kill_all()
+ pass
+
+
+ def tear_down_all(self):
+ self.destroy_vm_env()
+ pass
--
2.5.5
^ permalink raw reply [flat|nested] 2+ messages in thread
* Re: [dts] [PATCH] add ddp mpls test suite and profile file
2017-04-13 0:21 [dts] [PATCH] add ddp mpls test suite and profile file Xueqin Lin
@ 2017-04-20 8:06 ` Liu, Yong
0 siblings, 0 replies; 2+ messages in thread
From: Liu, Yong @ 2017-04-20 8:06 UTC (permalink / raw)
To: Xueqin Lin, dts
Thanks, applied.
On 04/13/2017 08:21 AM, Xueqin Lin wrote:
> ---
> dep/mpls.pkgo | Bin 0 -> 1200 bytes
> tests/TestSuite_ddp_mpls.py | 239 ++++++++++++++++++++++++++++++++++++++++++++
> 2 files changed, 239 insertions(+)
> create mode 100644 dep/mpls.pkgo
> create mode 100644 tests/TestSuite_ddp_mpls.py
^ permalink raw reply [flat|nested] 2+ messages in thread
end of thread, other threads:[~2017-04-20 8:17 UTC | newest]
Thread overview: 2+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2017-04-13 0:21 [dts] [PATCH] add ddp mpls test suite and profile file Xueqin Lin
2017-04-20 8:06 ` 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).