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 A5969A0519; Fri, 3 Jul 2020 08:03:59 +0200 (CEST) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id 8356E1D929; Fri, 3 Jul 2020 08:03:59 +0200 (CEST) Received: from mga14.intel.com (mga14.intel.com [192.55.52.115]) by dpdk.org (Postfix) with ESMTP id 82C301D9C0 for ; Fri, 3 Jul 2020 08:03:57 +0200 (CEST) IronPort-SDR: 4Kh/GCLIitaL91JA8R3EhSZXTV0FOlONOcCN8h9U4VyVwk3MHrSCoBrD+D/vW1YgikpL0eAUye ZYqURiDhpHXA== X-IronPort-AV: E=McAfee;i="6000,8403,9670"; a="146187913" X-IronPort-AV: E=Sophos;i="5.75,307,1589266800"; d="scan'208";a="146187913" 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; 02 Jul 2020 23:03:53 -0700 IronPort-SDR: madKcT/RZoVQ6RiAmNQa00/L0iPIz3lS8jlXPz0tGKQhNyFWCfUo6kHzVGsc8CAMlh5PhKyBX9 24yXkcaq61fQ== X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.75,307,1589266800"; d="scan'208";a="296117934" Received: from unknown (HELO cb-dts.sh.intel.com) ([10.240.183.58]) by orsmga002.jf.intel.com with ESMTP; 02 Jul 2020 23:03:51 -0700 From: ChenBo To: dts@dpdk.org Cc: ChenBo Date: Fri, 3 Jul 2020 13:53:08 +0800 Message-Id: <20200703055308.29197-1-box.c.chen@intel.com> X-Mailer: git-send-email 2.17.1 Subject: [dts] [PATCH V1] tests/iavf_fdir: Adaptation regression modification 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" 1.Use global variables instead of devil numbers. 2.Support for DUT and Tester is not the same ENV. 3.Fixed an issue with group packet exceptions. 4.Modify the environment cleanup process to increase code robustness. Signed-off-by: ChenBo --- tests/TestSuite_iavf_fdir.py | 58 +++++++++++++++++++----------------- tests/rte_flow_common.py | 24 ++++++++------- 2 files changed, 44 insertions(+), 38 deletions(-) diff --git a/tests/TestSuite_iavf_fdir.py b/tests/TestSuite_iavf_fdir.py index f1adc0f..f2004c6 100644 --- a/tests/TestSuite_iavf_fdir.py +++ b/tests/TestSuite_iavf_fdir.py @@ -37,6 +37,7 @@ from packet import Packet from pmd_output import PmdOutput from test_case import TestCase import rte_flow_common as rfc +from rte_flow_common import CVL_TXQ_RXQ_NUMBER from multiprocessing import Process from multiprocessing import Manager @@ -126,9 +127,9 @@ MAC_IPV6_PAY = { MAC_IPV6_PAY_protocol = { "match": [ 'Ether(dst="00:11:22:33:44:55")/IPv6(dst="CDCD:910A:2222:5498:8475:1111:3900:2020", src="2001::2", nh=44, tc=1, hlim=2)/("X"*480)', - 'Ether(dst="00:11:22:33:44:55")/IPv6(dst="CDCD:910A:2222:5498:8475:1111:3900:2020")/IPv6ExtHdrFragment(100)/("X"*480)', + 'Ether(dst="00:11:22:33:44:55")/IPv6(dst="CDCD:910A:2222:5498:8475:1111:3900:2020")/IPv6ExtHdrFragment()/("X"*480)', 'Ether(dst="00:11:22:33:44:55")/IPv6(dst="CDCD:910A:2222:5498:8475:1111:3900:2020", nh=44)/TCP(sport=22,dport=23)/("X"*480)', - 'Ether(dst="00:11:22:33:44:55")/IPv6(dst="CDCD:910A:2222:5498:8475:1111:3900:2020")/IPv6ExtHdrFragment(100)/TCP(sport=22,dport=23)/("X"*480)', + 'Ether(dst="00:11:22:33:44:55")/IPv6(dst="CDCD:910A:2222:5498:8475:1111:3900:2020")/IPv6ExtHdrFragment()/TCP(sport=22,dport=23)/("X"*480)', 'Ether(dst="00:11:22:33:44:55")/IPv6(dst="CDCD:910A:2222:5498:8475:1111:3900:2020", nh=6)/("X"*480)', 'Ether(dst="00:11:22:33:44:55")/IPv6(dst="CDCD:910A:2222:5498:8475:1111:3900:2020")/TCP(sport=22,dport=23)/("X"*480)'], "mismatch": [ @@ -1302,11 +1303,16 @@ class TestIAVFFdir(TestCase): self.src_file_dir = 'dep/' self.dut_file_dir = '/tmp/' + self.cvlq_num = CVL_TXQ_RXQ_NUMBER def set_up(self): """ Run before each test case. """ + self.re_load_ice_driver() + time.sleep(1) + self.setup_2pf_4vf_env() + time.sleep(1) self.launch_testpmd() def setup_2pf_4vf_env(self, driver='default'): @@ -1384,8 +1390,8 @@ class TestIAVFFdir(TestCase): self.dut.send_expect("rmmod ice", "# ", 40) ice_driver_file_location = self.suite_config["ice_driver_file_location"] self.dut.send_expect("insmod %s" % ice_driver_file_location, "# ") - self.dut.send_expect("ifconfig %s up" % self.tester_iface0, "# ", 15) - self.dut.send_expect("ifconfig %s up" % self.tester_iface1, "# ", 15) + self.dut.send_expect("ifconfig %s up" % self.dut_ports[0], "# ", 15) + self.dut.send_expect("ifconfig %s up" % self.dut_ports[1], "# ", 15) def config_testpmd(self): self.pmd_output.execute_cmd("set fwd rxonly") @@ -1401,7 +1407,7 @@ class TestIAVFFdir(TestCase): def launch_testpmd(self): self.pmd_output.start_testpmd(cores="1S/4C/1T", - param="--rxq=16 --txq=16", + param="--rxq={} --txq={}".format(self.cvlq_num, self.cvlq_num), eal_param="-w %s -w %s" % ( self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf0[1].pci), socket=self.ports_socket) @@ -1508,7 +1514,7 @@ class TestIAVFFdir(TestCase): self.verify(not p.search(out), "flow rule on port %s is existed" % port_id) def check_rule_number(self, port_id=0, num=0): - out = self.pmd_output.execute_cmd("flow list %s" % port_id) + out = self.dut.send_command("flow list %s" % port_id, timeout=30) result_scanner = r'\d*.*?\d*.*?\d*.*?=>*' scanner = re.compile(result_scanner, re.DOTALL) li = scanner.findall(out) @@ -1848,12 +1854,12 @@ class TestIAVFFdir(TestCase): m1 = p.search(out_pf1) eal_param = "-c 0xf -n 6 -w %s -w %s --file-prefix=pf0" % (self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf0[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16") + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={}".format(self.cvlq_num, self.cvlq_num)) self.dut.send_expect(command, "testpmd> ", 300) self.config_testpmd() eal_param = "-c 0xf0 -n 6 -w %s -w %s --file-prefix=pf1" % (self.sriov_vfs_pf1[0].pci,self.sriov_vfs_pf1[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16") + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={}".format(self.cvlq_num, self.cvlq_num)) self.session_secondary.send_expect(command, "testpmd> ", 300) #self.session_secondary.config_testpmd() self.session_secondary.send_expect("set fwd rxonly", "testpmd> ") @@ -2001,12 +2007,12 @@ class TestIAVFFdir(TestCase): m1 = p.search(out_pf1) eal_param = "-c 0xf -n 6 -w %s -w %s --file-prefix=pf0" % (self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf0[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16") + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={}".format(self.cvlq_num, self.cvlq_num)) self.dut.send_expect(command, "testpmd> ", 300) self.config_testpmd() eal_param = "-c 0xf0 -n 6 -w %s -w %s --file-prefix=pf1" % (self.sriov_vfs_pf1[0].pci,self.sriov_vfs_pf1[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16") + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={}".format(self.cvlq_num, self.cvlq_num)) self.session_secondary.send_expect(command, "testpmd> ", 300) #self.session_secondary.config_testpmd() self.session_secondary.send_expect("set fwd rxonly", "testpmd> ") @@ -2154,12 +2160,12 @@ class TestIAVFFdir(TestCase): m1 = p.search(out_pf1) eal_param = "-c 0xf -n 6 -w %s -w %s --file-prefix=pf0" % (self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf0[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16") + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={}".format(self.cvlq_num, self.cvlq_num)) self.dut.send_expect(command, "testpmd> ", 300) self.config_testpmd() eal_param = "-c 0xf0 -n 6 -w %s -w %s --file-prefix=pf1" % (self.sriov_vfs_pf1[0].pci,self.sriov_vfs_pf1[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16") + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={}".format(self.cvlq_num, self.cvlq_num)) self.session_secondary.send_expect(command, "testpmd> ", 300) #self.session_secondary.config_testpmd() self.session_secondary.send_expect("set fwd rxonly", "testpmd> ") @@ -2291,7 +2297,7 @@ class TestIAVFFdir(TestCase): self.dut.session.copy_file_to(self.src_file_dir + src_file, self.dut_file_dir) eal_param = "-c f -n 6 -w %s -w %s" % (self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf0[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16 --cmdline-file=%s" % self.dut_file_dir + src_file) + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={} --cmdline-file=%s".format(self.cvlq_num, self.cvlq_num) % self.dut_file_dir + src_file) self.dut.send_expect(command, "testpmd> ", 300) self.config_testpmd() @@ -2361,7 +2367,7 @@ class TestIAVFFdir(TestCase): self.dut.session.copy_file_to(self.src_file_dir + src_file, self.dut_file_dir) eal_param = "-c f -n 6 -w %s -w %s" % (self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf1[0].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16 --cmdline-file=%s" % self.dut_file_dir + src_file) + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={} --cmdline-file=%s".format(self.cvlq_num, self.cvlq_num) % self.dut_file_dir + src_file) self.dut.send_expect(command, "testpmd> ", 300) self.config_testpmd() @@ -2453,7 +2459,7 @@ class TestIAVFFdir(TestCase): self.verify(count == 513, "failed to create 1025 fdir rules on pf.") self.dut.session.copy_file_to(self.src_file_dir + src_file, self.dut_file_dir) # create 1025 rules on pf1 - fkr = open(self.dut_file_dir + src_file, "r+") + fkr = open(self.src_file_dir + src_file, "r+") kernel_rules = fkr.read() fkr.close() self.dut.send_expect(kernel_rules, "# ") @@ -2477,7 +2483,7 @@ class TestIAVFFdir(TestCase): # start testpmd with creating rules in commandline eal_param = "-c f -n 6 -w %s -w %s" % (self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf0[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16 --cmdline-file=%s" % self.dut_file_dir + src_file_vf) + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={} --cmdline-file=%s".format(self.cvlq_num, self.cvlq_num) % self.dut_file_dir + src_file_vf) fdw = open("15360_rules_vf_result.txt", "w") fdw.write(self.dut.send_expect(command, "testpmd> ", 360)) fdw.close() @@ -2545,7 +2551,7 @@ class TestIAVFFdir(TestCase): self.verify(count == 14848, "failed to create 14848 fdir rules on pf.") self.dut.session.copy_file_to(self.src_file_dir + src_file, self.dut_file_dir) # create 15360 rules on pf1 - fkr = open(self.dut_file_dir + src_file, "r+") + fkr = open(self.src_file_dir + src_file, "r+") kernel_rules = fkr.read() fkr.close() self.dut.send_expect(kernel_rules, "# ") @@ -2554,7 +2560,7 @@ class TestIAVFFdir(TestCase): self.dut.send_expect("ethtool -N %s flow-type tcp4 src-ip 192.168.100.0 dst-ip 192.168.100.2 src-port 32 dst-port 33 action 8" % self.pf1_intf, "Cannot insert RX class rule: No space left on device") # start testpmd with creating rules in commandline eal_param = "-c f -n 6 -w %s -w %s" % (self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf1[0].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16") + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={}".format(self.cvlq_num, self.cvlq_num)) self.dut.send_expect(command, "testpmd> ", 20) self.config_testpmd() @@ -2606,7 +2612,7 @@ class TestIAVFFdir(TestCase): self.destroy_env() self.setup_npf_nvf_env(pf_num=1,vf_num=16) self.dut.send_expect('ip link set %s vf 10 mac 00:11:22:33:44:55' % self.pf0_intf, '#') - command = "./%s/app/testpmd -c f -n 6 -- -i %s" % (self.dut.target, "--rxq=16 --txq=16") + command = "./%s/app/testpmd -c f -n 6 -- -i %s" % (self.dut.target, "--rxq=4 --txq=4") self.dut.send_expect(command, "testpmd> ", 360) self.config_testpmd() for port_id in range(11): @@ -2637,9 +2643,6 @@ class TestIAVFFdir(TestCase): self.create_fdir_rule(rule, check_stats=False) - self.destroy_env() - self.setup_2pf_4vf_env() - def test_stress_port_stop_start(self): """ Rules can take effect after port stop/start @@ -2681,7 +2684,7 @@ class TestIAVFFdir(TestCase): self.dut.session.copy_file_to(self.src_file_dir + src_file, self.dut_file_dir) eal_param = "-c f -n 6 -w %s -w %s" % (self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf0[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16 --cmdline-file=%s" % self.dut_file_dir + src_file) + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={} --cmdline-file=%s".format(self.cvlq_num, self.cvlq_num) % self.dut_file_dir + src_file) self.dut.send_expect(command, "testpmd> ", 900) self.config_testpmd() self.check_fdir_rule(port_id=0, stats=False) @@ -2716,7 +2719,7 @@ class TestIAVFFdir(TestCase): self.dut.session.copy_file_to(self.src_file_dir + src_file, self.dut_file_dir) eal_param = "-c f -n 6 -w %s -w %s" % (self.sriov_vfs_pf0[0].pci,self.sriov_vfs_pf0[1].pci) - command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq=16 --txq=16 --cmdline-file=%s" % self.dut_file_dir + src_file) + command = "./%s/app/testpmd %s -- -i %s" % (self.dut.target, eal_param, "--rxq={} --txq={} --cmdline-file=%s".format(self.cvlq_num, self.cvlq_num) % self.dut_file_dir + src_file) self.dut.send_expect(command, "testpmd> ", 900) self.config_testpmd() self.check_fdir_rule(port_id=0, stats=False) @@ -3101,7 +3104,7 @@ class TestIAVFFdir(TestCase): self.dut.send_expect("quit", "# ") self.pmd_output.start_testpmd(cores="1S/4C/1T", - param="--rxq=16 --txq=16 --enable-rx-cksum --port-topology=loop", + param="--rxq={} --txq={} --enable-rx-cksum --port-topology=loop".format(self.cvlq_num, self.cvlq_num), eal_param="-w %s" % self.sriov_vfs_pf0[0].pci, socket=self.ports_socket) vlan = 51 @@ -3197,7 +3200,7 @@ class TestIAVFFdir(TestCase): self.dut.send_expect("quit", "# ") self.pmd_output.start_testpmd(cores="1S/4C/1T", - param="--rxq=16 --txq=16 --enable-rx-cksum --port-topology=loop", + param="--rxq={} --txq={} --enable-rx-cksum --port-topology=loop".format(self.cvlq_num, self.cvlq_num), eal_param="-w %s" % self.sriov_vfs_pf0[0].pci, socket=self.ports_socket) vlan = 51 @@ -3286,7 +3289,7 @@ class TestIAVFFdir(TestCase): self.dut.send_expect("quit", "# ") self.pmd_output.start_testpmd(cores="1S/4C/1T", - param="--rxq=16 --txq=16 --enable-rx-cksum --port-topology=loop", + param="--rxq={} --txq={} --enable-rx-cksum --port-topology=loop".format(self.cvlq_num, self.cvlq_num), eal_param="-w %s" % self.sriov_vfs_pf0[0].pci, socket=self.ports_socket) vlan = 51 @@ -3353,6 +3356,7 @@ class TestIAVFFdir(TestCase): def tear_down(self): # destroy all flow rule on port 0 + self.destroy_env() self.dut.kill_all() if getattr(self, 'session_secondary', None): self.dut.close_session(self.session_secondary) diff --git a/tests/rte_flow_common.py b/tests/rte_flow_common.py index 0574e49..3d46e5e 100644 --- a/tests/rte_flow_common.py +++ b/tests/rte_flow_common.py @@ -34,6 +34,8 @@ import time import re from utils import GREEN, RED +CVL_TXQ_RXQ_NUMBER = 16 + # switch filter common functions def get_suite_config(test_case): """ @@ -400,7 +402,7 @@ def check_mark(out, pkt_num, check_param, stats=True): else: raise Exception("got wrong output, not match pattern %s" % p.pattern) if mark_id is not None: - mark_list = set(int(i, 16) for i in fdir_scanner.findall(out)) + mark_list = set(int(i, CVL_TXQ_RXQ_NUMBER) for i in fdir_scanner.findall(out)) verify(all([i == check_param["mark_id"] for i in mark_list]), "failed: some packet mark id of %s not match" % mark_list) else: @@ -424,11 +426,11 @@ def check_mark(out, pkt_num, check_param, stats=True): def verify_directed_by_rss(out, rxq=64, stats=True): p = re.compile('RSS\shash=(\w+)\s-\sRSS\squeue=(\w+)') pkt_info = p.findall(out) - pkt_queue = set([int(i[1], 16) for i in pkt_info]) + pkt_queue = set([int(i[1], CVL_TXQ_RXQ_NUMBER) for i in pkt_info]) if stats: - verify(all([int(i[0], 16) % rxq == int(i[1], 16) for i in pkt_info]), 'some pkt not directed by rss.') + verify(all([int(i[0], CVL_TXQ_RXQ_NUMBER) % rxq == int(i[1], CVL_TXQ_RXQ_NUMBER) for i in pkt_info]), 'some pkt not directed by rss.') else: - verify(not any([int(i[0], 16) % rxq == int(i[1], 16) for i in pkt_info]), 'some pkt directed by rss') + verify(not any([int(i[0], CVL_TXQ_RXQ_NUMBER) % rxq == int(i[1], CVL_TXQ_RXQ_NUMBER) for i in pkt_info]), 'some pkt directed by rss') return pkt_queue @@ -458,23 +460,23 @@ def check_iavf_fdir_queue(out, pkt_num, check_param, stats=True): verify(not any(q == queue for q in res_queue), "fail: queue id should not matched, expect queue %s, got %s" % (queue, res_queue)) print((GREEN("pass: queue id %s not matched" % res_queue))) elif isinstance(queue, list): - verify_iavf_fdir_directed_by_rss(out, rxq=16, stats=True) + verify_iavf_fdir_directed_by_rss(out, rxq=CVL_TXQ_RXQ_NUMBER, stats=True) print((GREEN("pass: queue id %s not matched" % res_queue))) else: raise Exception("wrong action value, expect queue_index or queue_group") else: raise Exception("got wrong output, not match pattern %s" % p.pattern) -def verify_iavf_fdir_directed_by_rss(out, rxq=16, stats=True): +def verify_iavf_fdir_directed_by_rss(out, rxq=CVL_TXQ_RXQ_NUMBER, stats=True): p = re.compile("RSS hash=(0x\w+) - RSS queue=(0x\w+)") pkt_info = p.findall(out) if stats: for i in pkt_info: - verify((int(i[0],16) % rxq == int(i[1],16)), "some packets are not directed by RSS") + verify((int(i[0],CVL_TXQ_RXQ_NUMBER) % rxq == int(i[1],CVL_TXQ_RXQ_NUMBER)), "some packets are not directed by RSS") print(GREEN("pass: queue id %s is redirected by RSS hash value %s" % (i[1], i[0]))) else: for i in pkt_info: - verify((int(i[0],16) % rxq != int(i[1],16)), "some packets are not directed by RSS") + verify((int(i[0],CVL_TXQ_RXQ_NUMBER) % rxq != int(i[1],CVL_TXQ_RXQ_NUMBER)), "some packets are not directed by RSS") def check_iavf_fdir_passthru(out, pkt_num, check_param, stats=True): # check the actual queue is distributed by RSS @@ -485,7 +487,7 @@ def check_iavf_fdir_passthru(out, pkt_num, check_param, stats=True): p = re.compile('RSS\shash=(\w+)\s-\sRSS\squeue=(\w+)') pkt_hash = p.findall(out) verify(pkt_num == len(pkt_hash), "fail: got wrong number of passthru packets, expect passthru packet number %s, got %s." % (pkt_num, len(pkt_hash))) - verify_iavf_fdir_directed_by_rss(out, rxq=16, stats=True) + verify_iavf_fdir_directed_by_rss(out, rxq=CVL_TXQ_RXQ_NUMBER, stats=True) def check_iavf_fdir_mark(out, pkt_num, check_param, stats=True): mark_scanner = "FDIR matched ID=(0x\w+)" @@ -499,7 +501,7 @@ def check_iavf_fdir_mark(out, pkt_num, check_param, stats=True): mark_list = [i for i in res] print("mark list is: ", mark_list) verify(len(res) == pkt_num, "get wrong number of packet with mark_id") - verify(all([int(i, 16) == check_param["mark_id"] for i in res]), + verify(all([int(i, CVL_TXQ_RXQ_NUMBER) == check_param["mark_id"] for i in res]), "failed: some packet mark id of %s not match" % mark_list) if check_param.get("queue") is not None: check_iavf_fdir_queue(out, pkt_num, check_param, stats) @@ -629,7 +631,7 @@ def check_iavf_packets_rss_queue(out, count, rss_match=True): packet_sumnum = packet_sumnum + int(packet_num) if rss_match: - if queue_flag == 16 and packet_sumnum == count: + if queue_flag == CVL_TXQ_RXQ_NUMBER and packet_sumnum == count: log_msg = "Packets has send to %s queues" % queue_flag return True, log_msg else: -- 2.17.1