From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from dpdk.org (dpdk.org [92.243.14.124]) by inbox.dpdk.org (Postfix) with ESMTP id A6014A04B1; Fri, 28 Aug 2020 12:20:06 +0200 (CEST) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id 9B53E1C0CC; Fri, 28 Aug 2020 12:20:06 +0200 (CEST) Received: from mga14.intel.com (mga14.intel.com [192.55.52.115]) by dpdk.org (Postfix) with ESMTP id 99CBD1C08E for ; Fri, 28 Aug 2020 12:20:02 +0200 (CEST) IronPort-SDR: 0BZJLYzusjdz7/tNvADKEZ4RTXXBmbUUKBxJZA6VU12StqTHDQ7EO5GN4weN1oLFWqPvjOO6JN V/2/+jXHUsSw== X-IronPort-AV: E=McAfee;i="6000,8403,9726"; a="155901648" X-IronPort-AV: E=Sophos;i="5.76,363,1592895600"; d="scan'208";a="155901648" X-Amp-Result: SKIPPED(no attachment in message) X-Amp-File-Uploaded: False Received: from orsmga002.jf.intel.com ([10.7.209.21]) by fmsmga103.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 28 Aug 2020 03:20:01 -0700 IronPort-SDR: p9Zl/vF8u0iWWIKxYN6rYPgAc1CUnCU1n0ZX7xWwbqerDKv9dCK3SFUnShmi/8P+Va2Tnpf+oN KBR5aiIRy3tw== X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.76,363,1592895600"; d="scan'208";a="313560345" Received: from intel.sh.intel.com ([10.239.255.20]) by orsmga002.jf.intel.com with ESMTP; 28 Aug 2020 03:20:00 -0700 From: Chenxu Di To: dts@dpdk.org Cc: qi.fu@intel.com, Chenxu Di Date: Fri, 28 Aug 2020 09:50:36 +0000 Message-Id: <20200828095036.52226-2-chenxux.di@intel.com> X-Mailer: git-send-email 2.17.1 In-Reply-To: <20200828095036.52226-1-chenxux.di@intel.com> References: <20200828095036.52226-1-chenxux.di@intel.com> Subject: [dts] [PATCH v3 2/2] tests: add TestSuite_cvl_rss_configure.py 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: , Errors-To: dts-bounces@dpdk.org Sender: "dts" add new test suite for cvl rss configure Signed-off-by: Chenxu Di --- tests/TestSuite_cvl_rss_configure.py | 312 +++++++++++++++++++++++++++ 1 file changed, 312 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..ce81e2e --- /dev/null +++ b/tests/TestSuite_cvl_rss_configure.py @@ -0,0 +1,310 @@ +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) + +if not m: + GTP_TEID= "teid" +else: + GTP_TEID= "TEID" + +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} +} + +tv_mac_ipv4_pppod_pppoe = { + "name":"tv_mac_ipv4_pppod_pppoe", + "scapy_str":['Ether(dst="00:00:00:00:01:00")/PPPoE(sessionid=%d)/PPP(proto=%d)/IP()/("X"*480)' %(i, i+10) for i in range(0,100)], + "check_func_param": {"expect_port":0} +} + +pkt_str=[] +pkt = ['Ether(dst="00:00:00:00:01:00")/IP()/UDP(dport=2152)/GTP_U_Header(GTP_TEID=%d)/IP()/("X"*480)' %i for i in range(0,100)] +for i in pkt: + pkt_str.append(i.replace('GTP_TEID', GTP_TEID)) + +tv_mac_ipv4_gtpu_ipv4= { + "name":"tv_mac_ipv4_gtpu_ipv4", + "scapy_str":pkt_str, + "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 + ] + +tvs_mac_rss_other = [ + tv_mac_ipv4_pppod_pppoe, + tv_mac_ipv4_gtpu_ipv4 + ] + +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