From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from dpdk.org (dpdk.org [92.243.14.124]) by dpdk.space (Postfix) with ESMTP id 66AA0A0679 for ; Sun, 28 Apr 2019 04:46:07 +0200 (CEST) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id 5D1A01B4C7; Sun, 28 Apr 2019 04:46:07 +0200 (CEST) Received: from mga14.intel.com (mga14.intel.com [192.55.52.115]) by dpdk.org (Postfix) with ESMTP id 7C1144C93 for ; Sun, 28 Apr 2019 04:46:05 +0200 (CEST) X-Amp-Result: SKIPPED(no attachment in message) X-Amp-File-Uploaded: False Received: from orsmga001.jf.intel.com ([10.7.209.18]) by fmsmga103.fm.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384; 27 Apr 2019 19:46:04 -0700 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.60,403,1549958400"; d="scan'208";a="227345468" Received: from meijuan2.sh.intel.com ([10.67.119.112]) by orsmga001.jf.intel.com with ESMTP; 27 Apr 2019 19:46:03 -0700 From: zhaomeijuan To: dts@dpdk.org Cc: zhaomeijuan Date: Sun, 28 Apr 2019 10:47:12 +0000 Message-Id: <20190428104718.9143-1-meijuanx.zhao@intel.com> X-Mailer: git-send-email 2.17.1 Subject: [dts] [next][PATCH V1 1/7] tests/checksum_offload 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" *.remove old or unused module and code which replace it with pktgen API *.fix pep-8 issue *.quit task before start another *.enable pmd verbose function *.add enable rx cksum Signed-off-by: zhaomeijuan --- tests/TestSuite_checksum_offload.py | 58 +++++++++++++++++++++-------- 1 file changed, 43 insertions(+), 15 deletions(-) diff --git a/tests/TestSuite_checksum_offload.py b/tests/TestSuite_checksum_offload.py index 6541ba5..be66479 100644 --- a/tests/TestSuite_checksum_offload.py +++ b/tests/TestSuite_checksum_offload.py @@ -37,13 +37,18 @@ Test support of RX/TX Checksum Offload Features by Poll Mode Drivers. """ import string +import os import re -import rst +#import rst +from rst import RstReport import utils from test_case import TestCase from pmd_output import PmdOutput +# from packet import Packet from test_capabilities import DRIVER_TEST_LACK_CAPA +from pktgen import PacketGeneratorHelper + class TestChecksumOffload(TestCase): @@ -59,6 +64,15 @@ class TestChecksumOffload(TestCase): self.pmdout = PmdOutput(self.dut) self.portMask = utils.create_mask([self.dut_ports[0]]) self.ports_socket = self.dut.get_numa_id(self.dut_ports[0]) + # get dts output path + if self.logger.log_path.startswith(os.sep): + self.output_path = self.logger.log_path + else: + cur_path = os.path.dirname( + os.path.dirname(os.path.realpath(__file__))) + self.output_path = os.sep.join([cur_path, self.logger.log_path]) + # create an instance to set stream field setting + self.pktgen_helper = PacketGeneratorHelper() def set_up(self): """ @@ -181,10 +195,10 @@ class TestChecksumOffload(TestCase): self.tester.scapy_append('sendp([%s], iface="%s")' % (packets_sent[packet_type], tx_interface)) self.tester.scapy_execute() - p = self.tester.load_tcpdump_sniff_packets(inst) - nr_packets=len(p) - reslist = [p[i].pktgen.pkt.sprintf("%IP.chksum%;%TCP.chksum%;%UDP.chksum%;%SCTP.chksum%") for i in range(nr_packets)] - out = string.join(reslist, ",") + p = self.tester.load_tcpdump_sniff_packets(inst) + nr_packets=len(p) + reslist = [p[i].pktgen.pkt.sprintf("%IP.chksum%;%TCP.chksum%;%UDP.chksum%;%SCTP.chksum%") for i in range(nr_packets)] + out = string.join(reslist, ",") packets_received = out.split(',') self.verify(len(packets_sent) == len(packets_received), "Unexpected Packets Drop") @@ -260,7 +274,7 @@ class TestChecksumOffload(TestCase): result = dict() - self.checksum_enablehw(self.dut_ports[0]) + self.checksum_enablehw(self.dut_ports[0]) # get the packet checksum value result = self.get_chksum_values(pkts_ref) @@ -279,7 +293,7 @@ class TestChecksumOffload(TestCase): 'IPv6/UDP': 'Ether(dst="%s", src="52:00:00:00:00:00")/IPv6(src="::1")/UDP(chksum=0xf)/("X"*46)' % mac, 'IPv6/TCP': 'Ether(dst="%s", src="52:00:00:00:00:00")/IPv6(src="::1")/TCP(chksum=0xf)/("X"*46)' % mac} - if self.kdriver in DRIVER_TEST_LACK_CAPA['sctp_tx_offload']: + if self.kdriver in DRIVER_TEST_LACK_CAPA['sctp_tx_offload']: del pkts_good['IP/SCTP'] del pkts_bad['IP/SCTP'] del pkts_ref['IP/SCTP'] @@ -361,19 +375,33 @@ class TestChecksumOffload(TestCase): Pps = dict() Pct = dict() dmac = self.dut.get_mac_address(self.dut_ports[0]) + dmac1 = self.dut.get_mac_address(self.dut_ports[1]) result = [2, lcore, ptype, mode] for size in size_list: flow = flow_format % (dmac, size) - self.tester.scapy_append('wrpcap("test.pcap", [%s])' % flow) + pcap = os.sep.join([self.output_path, "test.pcap"]) + self.tester.scapy_append('wrpcap("%s", [%s])' % (pcap,flow)) self.tester.scapy_execute() + flow = flow_format % (dmac1, size) + pcap = os.sep.join([self.output_path, "test1.pcap"]) + self.tester.scapy_append('wrpcap("%s", [%s])' % (pcap,flow)) + self.tester.scapy_execute() + tgenInput = [] + pcap = os.sep.join([self.output_path, "test.pcap"]) tgenInput.append( - (self.tester.get_local_port(self.dut_ports[0]), self.tester.get_local_port(self.dut_ports[1]), "test.pcap")) + (self.tester.get_local_port(self.dut_ports[0]), self.tester.get_local_port(self.dut_ports[1]), pcap)) + pcap = os.sep.join([self.output_path, "test1.pcap"]) tgenInput.append( - (self.tester.get_local_port(self.dut_ports[1]), self.tester.get_local_port(self.dut_ports[0]), "test.pcap")) - Bps[str(size)], Pps[ - str(size)] = self.tester.traffic_generator_throughput(tgenInput) + (self.tester.get_local_port(self.dut_ports[1]), self.tester.get_local_port(self.dut_ports[0]), pcap)) + + # clear streams before add new streams + self.tester.pktgen.clear_streams() + # run packet generator + streams = self.pktgen_helper.prepare_stream_from_tginput(tgenInput, 100, + None, self.tester.pktgen) + Bps[str(size)], Pps[str(size)] = self.tester.pktgen.measure_throughput(stream_ids=streams) self.verify(Pps[str(size)] > 0, "No traffic detected") Pps[str(size)] /= 1E6 Pct[str(size)] = (Pps[str(size)] * 100) / \ @@ -390,6 +418,7 @@ class TestChecksumOffload(TestCase): """ # Verify that enough ports are available self.verify(len(self.dut_ports) >= 2, "Insufficient ports for testing") + self.dut.send_expect("quit", "#") # sizes = [64, 128, 256, 512, 1024] sizes = [64, 128] @@ -406,16 +435,15 @@ class TestChecksumOffload(TestCase): portMask = utils.create_mask([self.dut_ports[0], self.dut_ports[1]]) for mode in ["sw", "hw"]: self.logger.info("%s performance" % mode) - rst.write_text(mode + " Performance" + '\r\n') tblheader = ["Ports", "S/C/T", "Packet Type", "Mode"] for size in sizes: tblheader.append("%sB mpps" % str(size)) tblheader.append("%sB %% " % str(size)) self.result_table_create(tblheader) self.pmdout.start_testpmd( - lcore, "--portmask=%s" % self.portMask, socket=self.ports_socket) + lcore, "--portmask=%s" % self.portMask + " --enable-rx-cksum " + + "--port-topology=loop", socket=self.ports_socket) - self.dut.send_expect("set verbose 1", "testpmd> ") self.dut.send_expect("set fwd csum", "testpmd> ") if mode == "hw": self.checksum_enablehw(self.dut_ports[0]) -- 2.17.1