From patchwork Thu Aug 13 08:25:47 2020 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: "Yufen.Mo" X-Patchwork-Id: 75483 Return-Path: X-Original-To: patchwork@inbox.dpdk.org Delivered-To: patchwork@inbox.dpdk.org Received: from dpdk.org (dpdk.org [92.243.14.124]) by inbox.dpdk.org (Postfix) with ESMTP id EB35FA04B0; Thu, 13 Aug 2020 10:28:11 +0200 (CEST) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id D7AD81C0AD; Thu, 13 Aug 2020 10:28:11 +0200 (CEST) Received: from mga11.intel.com (mga11.intel.com [192.55.52.93]) by dpdk.org (Postfix) with ESMTP id AE4C61C020 for ; Thu, 13 Aug 2020 10:28:09 +0200 (CEST) IronPort-SDR: 0WJPMpa8BTHlG7uwaftCcbMm9Wpv864D8zcTmPb+0zeD+NB2BVCmOTOe1AE+OzbxglxuD+CL7t YX2GKZmYMzjQ== X-IronPort-AV: E=McAfee;i="6000,8403,9711"; a="151827473" X-IronPort-AV: E=Sophos;i="5.76,307,1592895600"; d="scan'208";a="151827473" X-Amp-Result: SKIPPED(no attachment in message) X-Amp-File-Uploaded: False Received: from fmsmga007.fm.intel.com ([10.253.24.52]) by fmsmga102.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 13 Aug 2020 01:28:09 -0700 IronPort-SDR: TRTP1b9Ft0C+7IoAcR2NRAYzu9QwxZJB6XLqQAXfh0qhYRzOoj02lmC9jdL2X8ONQTCSpbVZZX SArGsPNHN5DQ== X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.76,307,1592895600"; d="scan'208";a="276791705" Received: from dpdk-moyufen06.sh.intel.com ([10.67.116.208]) by fmsmga007.fm.intel.com with ESMTP; 13 Aug 2020 01:28:08 -0700 From: yufengmx To: dts@dpdk.org Cc: yufengmx Date: Thu, 13 Aug 2020 16:25:47 +0800 Message-Id: <20200813082547.2686-2-yufengx.mo@intel.com> X-Mailer: git-send-email 2.21.0 In-Reply-To: <20200813082547.2686-1-yufengx.mo@intel.com> References: <20200813082547.2686-1-yufengx.mo@intel.com> MIME-Version: 1.0 Subject: [dts] [PATCH V1 1/1] tests/dcf_lifecycle: enhance packet rx checking 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" filter broadcast packet in RX side then count the RX number. Signed-off-by: yufengmx --- tests/TestSuite_dcf_lifecycle.py | 23 +++++++++++++++++++---- 1 file changed, 19 insertions(+), 4 deletions(-) diff --git a/tests/TestSuite_dcf_lifecycle.py b/tests/TestSuite_dcf_lifecycle.py index 9be071c..6be7b24 100644 --- a/tests/TestSuite_dcf_lifecycle.py +++ b/tests/TestSuite_dcf_lifecycle.py @@ -426,14 +426,28 @@ class TestDcfLifeCycle(TestCase): cmd = 'clear port stats all' self.vf_pmd2_con([cmd, "testpmd> ", 15]) - def check_vf_pmd2_stats(self, traffic, portid=0, is_traffic_valid=True): + def parse_pmd2_verbose_pkt_count(self, portid, vf_id=0): + if not self.vf_pmd2_session: + return 0 + output = self.vf_pmd2_session.session.get_session_before(15) + pat = 'dst={dst}'.format(**self.get_mac_layer(portid, vf_id=vf_id).get('ether')) + result = re.findall(pat, output) + return len(result) if result else 0 + + def check_vf_pmd2_stats(self, traffic, verbose_parser, + portid=0, is_traffic_valid=True): pmd = PmdOutput(self.dut, session=self.vf_pmd2_session) info = pmd.get_pmd_stats(portid) or {} ori_pkt = info.get('RX-packets') or 0 traffic() + verbose_pkt = verbose_parser() info = pmd.get_pmd_stats(portid) or {} rx_pkt = info.get('RX-packets') or 0 check_pkt = rx_pkt - ori_pkt + if verbose_pkt != check_pkt: + msg = 'received packets contain un-expected packet' + self.logger.warning(msg) + check_pkt = verbose_pkt if is_traffic_valid: msg = f"port {portid} should receive packets, but no traffic happen" self.verify(check_pkt and check_pkt > 0, msg) @@ -451,12 +465,13 @@ class TestDcfLifeCycle(TestCase): def check_vf_pmd2_traffic(self, func_name, topo=None, flag=False): dut_port_id, vf_id = topo if topo else [0, 1] pkt = self.config_stream(dut_port_id, vf_id) - traffic = partial(self.send_packet_by_scapy, pkt, dut_port_id, 1) + traffic = partial(self.send_packet_by_scapy, pkt, dut_port_id, vf_id) + verbose_parser = partial(self.parse_pmd2_verbose_pkt_count, dut_port_id, vf_id) self.vf_pmd2_clear_port_stats() - self.check_vf_pmd2_stats(traffic) + self.check_vf_pmd2_stats(traffic, verbose_parser) status_change_func = getattr(self, func_name) status_change_func() - self.check_vf_pmd2_stats(traffic, is_traffic_valid=flag) + self.check_vf_pmd2_stats(traffic, verbose_parser, is_traffic_valid=flag) def run_test_pre(self, pmd_opitons): pri_pmd_option = pmd_opitons[0]