test suite reviews and discussions
 help / color / mirror / Atom feed
* [dts] [PATCH V1 0/1] tests/vhost_cbdma: set imix traffic
@ 2021-04-22  0:57 Yufen Mo
  2021-04-22  0:57 ` [dts] [PATCH V1 1/1] " Yufen Mo
       [not found] ` <DM5PR11MB1369226A0558C58254D5185C9D469@DM5PR11MB1369.namprd11.prod.outlook.com>
  0 siblings, 2 replies; 4+ messages in thread
From: Yufen Mo @ 2021-04-22  0:57 UTC (permalink / raw)
  To: dts, yinan.wang; +Cc: Yufen Mo


v1: 
 -  send continuous pkts with a group of pattern sizes [64,128,256,512,1024,1280,1518] 

Yufen Mo (1):
  tests/vhost_cbdma: set imix traffic

 tests/TestSuite_vhost_cbdma.py | 116 +++++++++++++++++++++++++++------
 1 file changed, 96 insertions(+), 20 deletions(-)

-- 
2.21.0


^ permalink raw reply	[flat|nested] 4+ messages in thread

* [dts] [PATCH V1 1/1] tests/vhost_cbdma: set imix traffic
  2021-04-22  0:57 [dts] [PATCH V1 0/1] tests/vhost_cbdma: set imix traffic Yufen Mo
@ 2021-04-22  0:57 ` Yufen Mo
  2021-05-26  6:04   ` Tu, Lijuan
       [not found] ` <DM5PR11MB1369226A0558C58254D5185C9D469@DM5PR11MB1369.namprd11.prod.outlook.com>
  1 sibling, 1 reply; 4+ messages in thread
From: Yufen Mo @ 2021-04-22  0:57 UTC (permalink / raw)
  To: dts, yinan.wang; +Cc: Yufen Mo


send continuous pkts with a group of pattern sizes [64,128,256,512,1024,1280,1518]

Signed-off-by: Yufen Mo <yufengx.mo@intel.com>
---
 tests/TestSuite_vhost_cbdma.py | 116 +++++++++++++++++++++++++++------
 1 file changed, 96 insertions(+), 20 deletions(-)

diff --git a/tests/TestSuite_vhost_cbdma.py b/tests/TestSuite_vhost_cbdma.py
index 1b4de8b6..6bd5919b 100644
--- a/tests/TestSuite_vhost_cbdma.py
+++ b/tests/TestSuite_vhost_cbdma.py
@@ -43,6 +43,7 @@ Here is an example:
    --vdev 'net_vhost0,iface=/tmp/s0,queues=1,dmas=[txq0@80:04.0],dmathr=1024'
 """
 import rst, json
+import os
 import re
 import time
 from test_case import TestCase
@@ -98,13 +99,17 @@ class TestVirTioVhostCbdma(TestCase):
         self.test_parameters = self.get_suite_cfg()['test_parameters']
         # traffic duraion in second
         self.test_duration = self.get_suite_cfg()['test_duration']
-        # initilize throughput attribution
+        # traffic packet length mode
+        # 'fixed' or 'imix', default is 'fixed'
+        suite_cfg = self.get_suite_cfg()
+        self.pkt_length_mode = (suite_cfg or {}).get('pkt_length_mode') or 'fixed'
+        # initialize throughput attribution
         # {'TestCase':{ 'Mode': {'$framesize':{"$nb_desc": 'throughput'}}}
         self.throughput = {}
         # Accepted tolerance in Mpps
         self.gap = self.get_suite_cfg()['accepted_tolerance']
         self.test_result = {}
-        self.nb_desc = self.test_parameters[64][0]
+        self.nb_desc = self.test_parameters.get(list(self.test_parameters.keys())[0])[0]
         self.dut.send_expect("killall -I %s" % self.testpmd_name, '#', 20)
         self.dut.send_expect("rm -rf %s/vhost-net*" % self.base_dir, "#")
         self.dut.send_expect("rm -rf /tmp/s0", "#")
@@ -507,10 +512,58 @@ class TestVirTioVhostCbdma(TestCase):
             check_dict[size] = round(speed * linerate[size], 2)
         return check_dict
 
+    def send_imix_and_verify(self, mode, multiple_queue=True, queue_list=[]):
+        """
+        Send imix packet with packet generator and verify
+        """
+        frame_sizes = [
+            64, 128, 256, 512, 1024, 1280, 1518, ]
+        tgenInput = []
+        for frame_size in frame_sizes:
+            payload_size = frame_size - self.headers_size
+            port = self.tester.get_local_port(self.dut_ports[0])
+            fields_config = {'ip': {'src': {'action': 'random'}, }, }
+            if not multiple_queue:
+                fields_config = None
+            pkt = Packet()
+            pkt.assign_layers(['ether', 'ipv4', 'raw'])
+            pkt.config_layers([('ether', {'dst': '%s' % self.virtio_mac}), ('ipv4', {'src': '1.1.1.1'}),
+                               ('raw', {'payload': ['01'] * int('%d' % payload_size)})])
+            pkt.save_pcapfile(self.tester, "%s/multiqueuerandomip_%s.pcap" % (self.out_path, frame_size))
+            tgenInput.append((port, port, "%s/multiqueuerandomip_%s.pcap" % (self.out_path, frame_size)))
+
+        self.tester.pktgen.clear_streams()
+        streams = self.pktgen_helper.prepare_stream_from_tginput(tgenInput, 100, fields_config, self.tester.pktgen)
+        trans_options = {'delay': 5, 'duration': self.test_duration}
+        bps, pps = self.tester.pktgen.measure_throughput(stream_ids=streams, options=trans_options)
+        Mpps = pps / 1000000.0
+        Mbps = bps / 1000000.0
+        self.verify(Mbps > 0,
+                    f"{self.running_case} can not receive packets of frame size {frame_sizes}")
+        bps_linerate = self.wirespeed(self.nic, 64, 1) * 8 * (64 + 20)
+        throughput = Mbps * 100 / float(bps_linerate)
+        self.throughput[mode] = {
+            'imix': {
+                self.nb_desc: [Mbps, Mpps],
+                }
+        }
+        results_row = ['imix']
+        results_row.append(mode)
+        results_row.append(Mpps)
+        results_row.append(throughput)
+        self.result_table_add(results_row)
+        if queue_list:
+            # check RX/TX can work normally in each queues
+            self.check_packets_of_each_queue(queue_list=queue_list)
+
     def send_and_verify(self, mode, multiple_queue=True, queue_list=[]):
         """
         Send packet with packet generator and verify
         """
+        if self.pkt_length_mode == 'imix':
+            self.send_imix_and_verify(mode, multiple_queue, queue_list)
+            return
+
         self.throughput[mode] = dict()
         for frame_size in self.frame_sizes:
             self.throughput[mode][frame_size] = dict()
@@ -551,8 +604,12 @@ class TestVirTioVhostCbdma(TestCase):
             for mode in mode_list:
                 for frame_size in self.test_parameters.keys():
                     for nb_desc in self.test_parameters[frame_size]:
-                        self.expected_throughput[mode][frame_size][nb_desc] = round(
-                            self.throughput[mode][frame_size][nb_desc], 3)
+                        if frame_size == 'imix':
+                            self.expected_throughput[mode][frame_size][nb_desc] = round(
+                                self.throughput[mode][frame_size][nb_desc][1], 3)
+                        else:
+                            self.expected_throughput[mode][frame_size][nb_desc] = round(
+                                self.throughput[mode][frame_size][nb_desc], 3)
 
     def handle_results(self, mode_list):
         """
@@ -573,23 +630,42 @@ class TestVirTioVhostCbdma(TestCase):
         for mode in mode_list:
             self.test_result[mode] = dict()
             for frame_size in self.test_parameters.keys():
-                wirespeed = self.wirespeed(self.nic, frame_size, self.number_of_ports)
                 ret_datas = {}
-                for nb_desc in self.test_parameters[frame_size]:
-                    ret_data = {}
-                    ret_data[header[0]] = frame_size
-                    ret_data[header[1]] = mode
-                    ret_data[header[2]] = "{:.3f} Mpps".format(
-                        self.throughput[mode][frame_size][nb_desc])
-                    ret_data[header[3]] = "{:.3f}%".format(
-                        self.throughput[mode][frame_size][nb_desc] * 100 / wirespeed)
-                    ret_data[header[4]] = nb_desc
-                    ret_data[header[5]] = "{:.3f} Mpps".format(
-                        self.expected_throughput[mode][frame_size][nb_desc])
-                    ret_data[header[6]] = "{:.3f} Mpps".format(
-                        self.throughput[mode][frame_size][nb_desc] -
-                        self.expected_throughput[mode][frame_size][nb_desc])
-                    ret_datas[nb_desc] = deepcopy(ret_data)
+                if frame_size == 'imix':
+                    bps_linerate = self.wirespeed(self.nic, 64, 1) * 8 * (64 + 20)
+                    ret_datas = {}
+                    for nb_desc in self.test_parameters[frame_size]:
+                        ret_data = {}
+                        ret_data[header[0]] = frame_size
+                        ret_data[header[1]] = mode
+                        ret_data[header[2]] = "{:.3f} Mpps".format(
+                            self.throughput[mode][frame_size][nb_desc][1])
+                        ret_data[header[3]] = "{:.3f}%".format(
+                            self.throughput[mode][frame_size][nb_desc][0] * 100 / bps_linerate)
+                        ret_data[header[4]] = nb_desc
+                        ret_data[header[5]] = "{:.3f} Mpps".format(
+                            self.expected_throughput[mode][frame_size][nb_desc])
+                        ret_data[header[6]] = "{:.3f} Mpps".format(
+                            self.throughput[mode][frame_size][nb_desc][1] -
+                            self.expected_throughput[mode][frame_size][nb_desc])
+                        ret_datas[nb_desc] = deepcopy(ret_data)
+                else:
+                    wirespeed = self.wirespeed(self.nic, frame_size, self.number_of_ports)
+                    for nb_desc in self.test_parameters[frame_size]:
+                        ret_data = {}
+                        ret_data[header[0]] = frame_size
+                        ret_data[header[1]] = mode
+                        ret_data[header[2]] = "{:.3f} Mpps".format(
+                            self.throughput[mode][frame_size][nb_desc])
+                        ret_data[header[3]] = "{:.3f}%".format(
+                            self.throughput[mode][frame_size][nb_desc] * 100 / wirespeed)
+                        ret_data[header[4]] = nb_desc
+                        ret_data[header[5]] = "{:.3f} Mpps".format(
+                            self.expected_throughput[mode][frame_size][nb_desc])
+                        ret_data[header[6]] = "{:.3f} Mpps".format(
+                            self.throughput[mode][frame_size][nb_desc] -
+                            self.expected_throughput[mode][frame_size][nb_desc])
+                        ret_datas[nb_desc] = deepcopy(ret_data)
                 self.test_result[mode][frame_size] = deepcopy(ret_datas)
         # Create test results table
         self.result_table_create(header)
-- 
2.21.0


^ permalink raw reply	[flat|nested] 4+ messages in thread

* Re: [dts] [PATCH V1 0/1] tests/vhost_cbdma: set imix traffic
       [not found] ` <DM5PR11MB1369226A0558C58254D5185C9D469@DM5PR11MB1369.namprd11.prod.outlook.com>
@ 2021-04-22  2:45   ` Wang, Yinan
  0 siblings, 0 replies; 4+ messages in thread
From: Wang, Yinan @ 2021-04-22  2:45 UTC (permalink / raw)
  To: Mo, YufengX, dts

Acked-by:  Yinan Wang <yinan.wang@intel.com>

> -----Original Message-----
> From: Mo, YufengX <yufengx.mo@intel.com>
> Sent: 2021?4?22? 9:10
> To: dts@dpdk.org; Wang, Yinan <yinan.wang@intel.com>
> Subject: RE: [dts][PATCH V1 0/1] tests/vhost_cbdma: set imix traffic
> 
> > -----Original Message-----
> > From: Mo, YufengX <yufengx.mo@intel.com>
> > Sent: Thursday, April 22, 2021 8:58 AM
> > To: dts@dpdk.org; Wang, Yinan <yinan.wang@intel.com>
> > Cc: Mo, YufengX <yufengx.mo@intel.com>
> > Subject: [dts][PATCH V1 0/1] tests/vhost_cbdma: set imix traffic
> 
> Tested-by: Yufen Mo<yufengx.mo@intel.com>

^ permalink raw reply	[flat|nested] 4+ messages in thread

* Re: [dts] [PATCH V1 1/1] tests/vhost_cbdma: set imix traffic
  2021-04-22  0:57 ` [dts] [PATCH V1 1/1] " Yufen Mo
@ 2021-05-26  6:04   ` Tu, Lijuan
  0 siblings, 0 replies; 4+ messages in thread
From: Tu, Lijuan @ 2021-05-26  6:04 UTC (permalink / raw)
  To: Mo, YufengX, dts, Wang, Yinan; +Cc: Mo, YufengX

> send continuous pkts with a group of pattern sizes
> [64,128,256,512,1024,1280,1518]
> 
> Signed-off-by: Yufen Mo <yufengx.mo@intel.com>

Applied, thanks

^ permalink raw reply	[flat|nested] 4+ messages in thread

end of thread, other threads:[~2021-05-26  6:04 UTC | newest]

Thread overview: 4+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2021-04-22  0:57 [dts] [PATCH V1 0/1] tests/vhost_cbdma: set imix traffic Yufen Mo
2021-04-22  0:57 ` [dts] [PATCH V1 1/1] " Yufen Mo
2021-05-26  6:04   ` Tu, Lijuan
     [not found] ` <DM5PR11MB1369226A0558C58254D5185C9D469@DM5PR11MB1369.namprd11.prod.outlook.com>
2021-04-22  2:45   ` [dts] [PATCH V1 0/1] " Wang, Yinan

test suite reviews and discussions

This inbox may be cloned and mirrored by anyone:

	git clone --mirror https://inbox.dpdk.org/dts/0 dts/git/0.git

	# If you have public-inbox 1.1+ installed, you may
	# initialize and index your mirror using the following commands:
	public-inbox-init -V2 dts dts/ https://inbox.dpdk.org/dts \
		dts@dpdk.org
	public-inbox-index dts

Example config snippet for mirrors.
Newsgroup available over NNTP:
	nntp://inbox.dpdk.org/inbox.dpdk.dts


AGPL code for this site: git clone https://public-inbox.org/public-inbox.git