From: "Fu, Qi" <qi.fu@intel.com>
To: "Di, ChenxuX" <chenxux.di@intel.com>, "dts@dpdk.org" <dts@dpdk.org>
Subject: Re: [dts] [PATCH v4 2/2] tests: add TestSuite_cvl_rss_configure.py
Date: Tue, 1 Sep 2020 03:19:56 +0000 [thread overview]
Message-ID: <MWHPR11MB13924716B6468498B9BBB5BFEA2E0@MWHPR11MB1392.namprd11.prod.outlook.com> (raw)
In-Reply-To: <20200901023522.49731-2-chenxux.di@intel.com>
Acked-by: Fu, Qi <qi.fu@intel.com>
Best regards,
Fu, Qi
> -----Original Message-----
> From: Di, ChenxuX <chenxux.di@intel.com>
> Sent: Tuesday, September 1, 2020 10:35 AM
> To: dts@dpdk.org
> Cc: Fu, Qi <qi.fu@intel.com>; Di, ChenxuX <chenxux.di@intel.com>
> Subject: [dts][PATCH v4 2/2] tests: add TestSuite_cvl_rss_configure.py
>
> add new test suite for cvl rss configure
>
> Signed-off-by: Chenxu Di <chenxux.di@intel.com>
> ---
> tests/TestSuite_cvl_rss_configure.py | 283 +++++++++++++++++++++++++++
> 1 file changed, 283 insertions(+)
> create mode 100644 tests/TestSuite_cvl_rss_configure.py
>
> diff --git a/tests/TestSuite_cvl_rss_configure.py
> b/tests/TestSuite_cvl_rss_configure.py
> new file mode 100644
> index 0000000..c8ca6d5
> --- /dev/null
> +++ b/tests/TestSuite_cvl_rss_configure.py
> @@ -0,0 +1,283 @@
> +import json
> +import time
> +import re
> +import packet
> +import os
> +from scapy.contrib.gtp import *
> +from test_case import TestCase
> +from pmd_output import PmdOutput
> +from utils import BLUE, RED
> +from collections import OrderedDict
> +from packet import IncreaseIP, IncreaseIPv6 import rte_flow_common as
> +rfc
> +
> +out = os.popen("pip list|grep scapy ")
> +version_result =out.read()
> +p=re.compile('scapy\s+2\.3\.\d+')
> +m=p.search(version_result)
> +
> +tv_mac_ip_ipv4 = {
> + "name":"tv_mac_ip_ipv4",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IP(src="192.168.0.%d",
> dst="192.168.0.%d")/("X"*480)' %(i, i+10) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ip_ipv6 = {
> + "name":"tv_mac_ip_ipv6",
> + "scapy_str": ['Ether(dst="00:00:00:00:01:00")/IPv6(src="2001::%d",
> dst="2001::%d")/("X"*480)' %(i, i+10) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv4_udp_l3_random = {
> + "name":"tv_mac_ipv4_udp_l3_random",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IP(src="192.168.0.%d",
> dst="192.168.0.%d")/UDP()/("X"*480)' %(i,i+10) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv4_udp_l4_random = {
> + "name":"tv_mac_ipv4_udp_l4_random",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IP()/UDP(sport=%d,
> dport=%d)/("X"*480)' %(i+50,i+55) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv6_udp_l3_random = {
> + "name":"tv_mac_ipv6_udp_l3_random",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IPv6(src="2001::%d",
> dst="2001::%d")/UDP()/("X"*480)' %(i,i+10) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv6_udp_l4_random = {
> + "name":"tv_mac_ipv6_udp_l4_random",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IPv6()/UDP(sport=%d,
> dport=%d)/("X"*480)' %(i+50,i+55) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv4_tcp_l3_random = {
> + "name":"tv_mac_ipv4_tcp_l3_random",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IP(src="192.168.0.%d",
> dst="192.168.0.%d")/TCP()/("X"*480)' %(i,i+10) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv4_tcp_l4_random = {
> + "name":"tv_mac_ipv4_tcp_l4_random",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IP()/TCP(sport=%d,
> dport=%d)/("X"*480)' %(i+50,i+55) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv6_tcp_l3_random = {
> + "name":"tv_mac_ipv6_tcp_l3_random",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IPv6(src="2001::%d",
> dst="2001::%d")/TCP()/("X"*480)' %(i,i+10) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv6_tcp_l4_random = {
> + "name":"tv_mac_ipv6_tcp_l4_random",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IPv6()/TCP(sport=%d,
> dport=%d)/("X"*480)' %(i+50,i+55) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv4_sctp = {
> + "name":"tv_mac_ipv4_sctp",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IP(src="192.168.0.%d",
> dst="192.168.0.%d")/SCTP()/("X"*480)' %(i,i+10) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tv_mac_ipv6_sctp = {
> + "name":"tv_mac_ipv6_sctp",
> + "scapy_str":['Ether(dst="00:00:00:00:01:00")/IPv6(src="2001::%d",
> dst="2001::%d")/SCTP()/("X"*480)' %(i,i+10) for i in range(0,100)],
> + "check_func_param": {"expect_port":0} }
> +
> +tvs_mac_rss_ip = [
> + tv_mac_ip_ipv4,
> + tv_mac_ip_ipv6
> + ]
> +
> +tvs_mac_rss_l3 = [
> + tv_mac_ip_ipv4,
> + tv_mac_ip_ipv6,
> + tv_mac_ipv4_udp_l3_random,
> + tv_mac_ipv6_udp_l3_random,
> + tv_mac_ipv4_tcp_l3_random,
> + tv_mac_ipv6_tcp_l3_random,
> + tv_mac_ipv4_sctp,
> + tv_mac_ipv6_sctp
> + ]
> +
> +tvs_mac_rss_l4 = [
> + tv_mac_ipv4_udp_l4_random,
> + tv_mac_ipv6_udp_l4_random,
> + tv_mac_ipv4_tcp_l4_random,
> + tv_mac_ipv6_tcp_l4_random
> + ]
> +
> +tvs_mac_rss_udp = [
> + tv_mac_ipv4_udp_l3_random,
> + tv_mac_ipv4_udp_l4_random,
> + tv_mac_ipv6_udp_l3_random,
> + tv_mac_ipv6_udp_l4_random
> + ]
> +
> +tvs_mac_rss_udp_l4 = [
> + tv_mac_ipv4_udp_l4_random,
> + tv_mac_ipv6_udp_l4_random
> + ]
> +
> +tvs_mac_rss_tcp = [
> + tv_mac_ipv4_tcp_l3_random,
> + tv_mac_ipv4_tcp_l4_random,
> + tv_mac_ipv6_tcp_l3_random,
> + tv_mac_ipv6_tcp_l4_random
> + ]
> +
> +tvs_mac_rss_tcp_l4 = [
> + tv_mac_ipv4_tcp_l4_random,
> + tv_mac_ipv6_tcp_l4_random
> + ]
> +
> +tvs_mac_rss_sctp = [
> + tv_mac_ipv4_sctp,
> + tv_mac_ipv6_sctp
> + ]
> +
> +tvs_mac_rss_all = [
> + tv_mac_ip_ipv4,
> + tv_mac_ip_ipv6,
> + tv_mac_ipv4_udp_l3_random,
> + tv_mac_ipv4_udp_l4_random,
> + tv_mac_ipv6_udp_l3_random,
> + tv_mac_ipv6_udp_l4_random,
> + tv_mac_ipv4_tcp_l3_random,
> + tv_mac_ipv4_tcp_l4_random,
> + tv_mac_ipv6_tcp_l3_random,
> + tv_mac_ipv6_tcp_l4_random,
> + tv_mac_ipv4_sctp,
> + tv_mac_ipv6_sctp
> + ]
> +
> +test_results = OrderedDict()
> +
> +class RSSConfigureTest(TestCase):
> +
> + def set_up_all(self):
> + """
> + Run at the start of each test suite.
> + Generic filter Prerequistites
> + """
> + self.dut_ports = self.dut.get_ports(self.nic)
> + # Verify that enough ports are available
> + self.verify(len(self.dut_ports) >= 1, "Insufficient ports")
> + #self.cores = "1S/8C/1T"
> + self.pmdout = PmdOutput(self.dut)
> +
> + localPort = self.tester.get_local_port(self.dut_ports[0])
> + self.__tx_iface = self.tester.get_interface(localPort)
> + self.pf_interface = self.dut.ports_info[self.dut_ports[0]]['intf']
> + self.pf_mac = self.dut.get_mac_address(0)
> + self.pf_pci = self.dut.ports_info[self.dut_ports[0]]['pci']
> + self.verify(self.nic in
> + ["columbiaville_25g","columbiaville_100g"], "%s nic not support
> + ethertype filter" % self.nic)
> +
> + def set_up(self):
> + """
> + Run before each test case.
> + """
> + self.dut.kill_all()
> +
> + 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.kill_all()
> +
> + def create_testpmd_command(self, line_option):
> + """
> + Create testpmd command for non-pipeline mode
> + """
> + #Prepare testpmd EAL and parameters
> + all_eal_param = self.dut.create_eal_parameters(ports=[self.pf_pci])
> + print(all_eal_param) #print eal parameters
> + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target,
> all_eal_param, "--rxq=10 --txq=10" + line_option)
> + return command
> +
> + def _rss_validate_pattern(self, test_vectors, command, rss_type, is_rss):
> +
> + global test_results
> + out = self.dut.send_expect(command, "testpmd> ", 120)
> + self.logger.debug(out) #print the log
> + self.dut.send_expect("set fwd rxonly", "testpmd> ", 15)
> + self.dut.send_expect("set verbose 1", "testpmd> ", 15)
> + if rss_type != "":
> + self.dut.send_expect("port config all rss %s" % rss_type,
> + "testpmd> ", 15)
> +
> + test_results.clear()
> + self.count = 1
> + self.mac_count=100
> + for tv in test_vectors:
> + self.dut.send_expect("start", "testpmd> ", 15)
> + time.sleep(2)
> + tv["check_func_param"]["expect_port"] = self.dut_ports[0]
> + print("expect_port is", self.dut_ports[0])
> +
> + #send a packet
> + pkt = packet.Packet()
> + pkt.update_pkt(tv["scapy_str"])
> + pkt.send_pkt(self.tester, tx_port=self.__tx_iface,
> + count=self.count)
> +
> + out = self.dut.send_expect("stop", "testpmd> ",60)
> + print(out)
> + check_result = []
> + check_result = rfc.check_packets_of_each_queue(out)
> + self.verify(check_result[0] == is_rss, check_result[1])
> +
> + self.dut.send_expect("quit", "#")
> +
> + def test_command_line_option_rss_ip(self):
> + command = self.create_testpmd_command(line_option = " --rss-ip")
> + self._rss_validate_pattern(tvs_mac_rss_l3, command, rss_type = "", is_rss
> = True)
> + self._rss_validate_pattern(tvs_mac_rss_l4, command, rss_type =
> + "", is_rss = False)
> +
> + def test_command_line_option_rss_udp(self):
> + command = self.create_testpmd_command(line_option = " --rss-udp")
> + self._rss_validate_pattern(tvs_mac_rss_udp, command, rss_type = "",
> is_rss = True)
> + self._rss_validate_pattern(tvs_mac_rss_ip, command, rss_type = "", is_rss
> = False)
> + self._rss_validate_pattern(tvs_mac_rss_tcp, command, rss_type = "",
> is_rss = False)
> + self._rss_validate_pattern(tvs_mac_rss_sctp, command, rss_type
> + = "", is_rss = False)
> +
> + def test_command_line_option_rss_disable(self):
> + command = self.create_testpmd_command(line_option = " --disable-rss")
> + self._rss_validate_pattern(tvs_mac_rss_all, command, rss_type =
> + "", is_rss = False)
> +
> + def test_rss_configure_to_ip(self):
> + command = self.create_testpmd_command(line_option = "")
> + self._rss_validate_pattern(tvs_mac_rss_l3, command, rss_type = "", is_rss
> = True)
> + self._rss_validate_pattern(tvs_mac_rss_l4, command, rss_type =
> + "", is_rss = False)
> +
> + def test_rss_configure_to_udp(self):
> + command = self.create_testpmd_command(line_option = "")
> + self._rss_validate_pattern(tvs_mac_rss_udp, command, rss_type = "udp",
> is_rss = True)
> + self._rss_validate_pattern(tvs_mac_rss_tcp_l4, command,
> + rss_type = "udp", is_rss = False)
> +
> + def test_rss_configure_to_tcp(self):
> + command = self.create_testpmd_command(line_option = "")
> + self._rss_validate_pattern(tvs_mac_rss_tcp, command, rss_type = "tcp",
> is_rss = True)
> + self._rss_validate_pattern(tvs_mac_rss_udp_l4, command,
> + rss_type = "tcp", is_rss = False)
> +
> + def test_rss_configure_to_sctp(self):
> + command = self.create_testpmd_command(line_option = "")
> + self._rss_validate_pattern(tvs_mac_rss_sctp, command, rss_type = "sctp",
> is_rss = True)
> + self._rss_validate_pattern(tvs_mac_rss_udp_l4, command, rss_type =
> "sctp", is_rss = False)
> + self._rss_validate_pattern(tvs_mac_rss_tcp_l4, command,
> + rss_type = "sctp", is_rss = False)
> +
> + def test_rss_configure_to_all(self):
> + command = self.create_testpmd_command(line_option = "")
> + self._rss_validate_pattern(tvs_mac_rss_all, command, rss_type =
> + "all", is_rss = True)
> +
> + def test_rss_configure_to_default(self):
> + command = self.create_testpmd_command(line_option = "")
> + self._rss_validate_pattern(tvs_mac_rss_all, command, rss_type =
> + "default", is_rss = True)
> --
> 2.17.1
next prev parent reply other threads:[~2020-09-01 3:21 UTC|newest]
Thread overview: 5+ messages / expand[flat|nested] mbox.gz Atom feed top
2020-09-01 2:35 [dts] [PATCH v4 1/2] test_plans: add cvl_rss_configure_test_plan.rst Chenxu Di
2020-09-01 2:35 ` [dts] [PATCH v4 2/2] tests: add TestSuite_cvl_rss_configure.py Chenxu Di
2020-09-01 3:19 ` Fu, Qi [this message]
2020-09-01 3:21 ` [dts] [PATCH v4 1/2] test_plans: add cvl_rss_configure_test_plan.rst Fu, Qi
2020-09-02 3:34 ` Tu, Lijuan
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=MWHPR11MB13924716B6468498B9BBB5BFEA2E0@MWHPR11MB1392.namprd11.prod.outlook.com \
--to=qi.fu@intel.com \
--cc=chenxux.di@intel.com \
--cc=dts@dpdk.org \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
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).