Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/125518/?format=api
{ "id": 125518, "url": "http://patches.dpdk.org/api/patches/125518/?format=api", "web_url": "http://patches.dpdk.org/project/dts/patch/20230327061218.3203632-4-weix.ling@intel.com/", "project": { "id": 3, "url": "http://patches.dpdk.org/api/projects/3/?format=api", "name": "DTS", "link_name": "dts", "list_id": "dts.dpdk.org", "list_email": "dts@dpdk.org", "web_url": "", "scm_url": "git://dpdk.org/tools/dts", "webscm_url": "http://git.dpdk.org/tools/dts/", "list_archive_url": "https://inbox.dpdk.org/dts", "list_archive_url_format": "https://inbox.dpdk.org/dts/{}", "commit_url_format": "" }, "msgid": "<20230327061218.3203632-4-weix.ling@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20230327061218.3203632-4-weix.ling@intel.com", "date": "2023-03-27T06:12:18", "name": "[V3,3/3] tests/dsa: add dsa testsuite", "commit_ref": null, "pull_url": null, "state": "accepted", "archived": false, "hash": "756864d126e8dc9fa148b18ddded83f161b15d36", "submitter": { "id": 1828, "url": "http://patches.dpdk.org/api/people/1828/?format=api", "name": "Ling, WeiX", "email": "weix.ling@intel.com" }, "delegate": null, "mbox": "http://patches.dpdk.org/project/dts/patch/20230327061218.3203632-4-weix.ling@intel.com/mbox/", "series": [ { "id": 27544, "url": "http://patches.dpdk.org/api/series/27544/?format=api", "web_url": "http://patches.dpdk.org/project/dts/list/?series=27544", "date": "2023-03-27T06:12:15", "name": "add new dsa test_plans and testsuite", "version": 3, "mbox": "http://patches.dpdk.org/series/27544/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/125518/comments/", "check": "warning", "checks": "http://patches.dpdk.org/api/patches/125518/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dts-bounces@dpdk.org>", "X-Original-To": "patchwork@inbox.dpdk.org", "Delivered-To": "patchwork@inbox.dpdk.org", "Received": [ "from mails.dpdk.org (mails.dpdk.org [217.70.189.124])\n\tby inbox.dpdk.org (Postfix) with ESMTP id BBD474284E;\n\tMon, 27 Mar 2023 08:15:17 +0200 (CEST)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id B7079427E9;\n\tMon, 27 Mar 2023 08:15:17 +0200 (CEST)", "from mga18.intel.com (mga18.intel.com [134.134.136.126])\n by mails.dpdk.org (Postfix) with ESMTP id 0A05840ED5\n for <dts@dpdk.org>; Mon, 27 Mar 2023 08:15:15 +0200 (CEST)", "from fmsmga002.fm.intel.com ([10.253.24.26])\n by orsmga106.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 26 Mar 2023 23:15:15 -0700", "from unknown (HELO localhost.localdomain) ([10.239.252.222])\n by fmsmga002-auth.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 26 Mar 2023 23:15:14 -0700" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/simple;\n d=intel.com; i=@intel.com; q=dns/txt; s=Intel;\n t=1679897716; x=1711433716;\n h=from:to:cc:subject:date:message-id:in-reply-to:\n references:mime-version:content-transfer-encoding;\n bh=tzYfciuUFBHqEFc2cEVowXWWO1CsTErDaSaRypweFR4=;\n b=IbhKEkZpzuoTDz2qAZS1IZ5d5cJ45vB3/igYKj3sMtKuLjpAivij68XF\n BBj96osEDW4SMCNLeqAXtnMSTg7tjvq0dHunA+UXnPksLtEryMZ7q+UN5\n bcTVFiC2ZMDPUJaMw3OcS4lWLGUM/gX+At/rHj6CX/gu5yl6dwMlkkcZh\n ktm99xnTH8TLAnaDovCuuaEm2+84hPO6Tv5yqM6ohZKcw2Bg0kCTOOdwG\n 2wFDZGXHCjHWAWnJxgrPmylcudZIXSHqXpG1CllWw8SxinVqnIUGypMUV\n ajmdwOIC8UtAcl3im9moTfx3yhQDdinZuapUxlvaQp/KxoFRu+/RDKimH A==;", "X-IronPort-AV": [ "E=McAfee;i=\"6600,9927,10661\"; a=\"324072394\"", "E=Sophos;i=\"5.98,293,1673942400\"; d=\"scan'208\";a=\"324072394\"", "E=McAfee;i=\"6600,9927,10661\"; a=\"794198257\"", "E=Sophos;i=\"5.98,293,1673942400\"; d=\"scan'208\";a=\"794198257\"" ], "X-ExtLoop1": "1", "From": "Wei Ling <weix.ling@intel.com>", "To": "dts@dpdk.org", "Cc": "Wei Ling <weix.ling@intel.com>", "Subject": "[dts][PATCH V3 3/3] tests/dsa: add dsa testsuite", "Date": "Mon, 27 Mar 2023 14:12:18 +0800", "Message-Id": "<20230327061218.3203632-4-weix.ling@intel.com>", "X-Mailer": "git-send-email 2.25.1", "In-Reply-To": "<20230327061218.3203632-1-weix.ling@intel.com>", "References": "<20230327061218.3203632-1-weix.ling@intel.com>", "MIME-Version": "1.0", "Content-Transfer-Encoding": "8bit", "X-BeenThere": "dts@dpdk.org", "X-Mailman-Version": "2.1.29", "Precedence": "list", "List-Id": "test suite reviews and discussions <dts.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dts>,\n <mailto:dts-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://mails.dpdk.org/archives/dts/>", "List-Post": "<mailto:dts@dpdk.org>", "List-Help": "<mailto:dts-request@dpdk.org?subject=help>", "List-Subscribe": "<https://mails.dpdk.org/listinfo/dts>,\n <mailto:dts-request@dpdk.org?subject=subscribe>", "Errors-To": "dts-bounces@dpdk.org" }, "content": "Add new dsa testsuite to test dpdk-dma application\nand example of how to use the DMAdev API to make a packet copy\napplication use DSA channel with DPDK driver and Kernel driver.\n\nSigned-off-by: Wei Ling <weix.ling@intel.com>\n---\n tests/TestSuite_dsa.py | 481 +++++++++++++++++++++++++++++++++++++++++\n 1 file changed, 481 insertions(+)\n create mode 100644 tests/TestSuite_dsa.py", "diff": "diff --git a/tests/TestSuite_dsa.py b/tests/TestSuite_dsa.py\nnew file mode 100644\nindex 00000000..c9572e06\n--- /dev/null\n+++ b/tests/TestSuite_dsa.py\n@@ -0,0 +1,481 @@\n+# SPDX-License-Identifier: BSD-3-Clause\n+# Copyright(c) 2023 Intel Corporation\n+#\n+\n+import re\n+import time\n+\n+from framework.packet import Packet\n+from framework.pktgen import TRANSMIT_CONT\n+from framework.test_case import TestCase\n+\n+from .virtio_common import dsa_common as DC\n+\n+\n+class TestDSA(TestCase):\n+ def set_up_all(self):\n+ \"\"\"\n+ Run at the start of each test suite.\n+ \"\"\"\n+ self.frame_sizes = [64, 256, 512, 1024, 1518]\n+ self.dut_ports = self.dut.get_ports()\n+ self.verify(len(self.dut_ports) >= 1, \"Insufficient ports for testing\")\n+ self.ports_socket = self.dut.get_numa_id(self.dut_ports[0])\n+ out = self.dut.build_dpdk_apps(\"./examples/dma\")\n+ self.verify(\"Error\" not in out, \"compilation dma error\")\n+ self.dma_path = self.dut.apps_name[\"dma\"]\n+ self.dma_name = self.dma_path.split(\"/\")[-1]\n+ self.core_num = 1\n+ self.DC = DC(self)\n+\n+ def set_up(self):\n+ \"\"\"\n+ Run before each test case.\n+ \"\"\"\n+ # Prepare the result table\n+ self.table_header = [\"Frame\"]\n+ self.table_header.append(\"Mpps\")\n+ self.table_header.append(\"Worker Threads\")\n+ self.table_header.append(\"Copy Mode\")\n+ self.table_header.append(\"Updating MAC\")\n+ self.table_header.append(\"Rx Queues\")\n+ self.table_header.append(\"% linerate\")\n+ self.result_table_create(self.table_header)\n+ self.dut.send_expect(\"killall -I %s\" % self.dma_name, \"#\", 20)\n+\n+ def get_core_list(self):\n+ \"\"\"\n+ get cores list depend on self.work_thread\n+ \"\"\"\n+ core_config = \"1S/%dC/1T\" % self.core_num\n+ core_list = self.dut.get_core_list(core_config, socket=self.ports_socket)\n+ return core_list\n+\n+ def launch_dma_app(self, eal_params):\n+ \"\"\"\n+ launch dma with different params\n+ \"\"\"\n+ port_info = 0\n+ for i in range(self.nic_port_num):\n+ port_info |= 1 << i\n+ updating_mac = (\n+ \"--mac-updating\" if self.updating_mac == \"enabled\" else \"--no-mac-updating\"\n+ )\n+ rx_queues = self.rx_queues / self.nic_port_num\n+ cmd = \"%s %s -- -p %s -q %d %s -c %s\" % (\n+ self.dma_path,\n+ eal_params,\n+ hex(port_info),\n+ rx_queues,\n+ updating_mac,\n+ self.copy_mode,\n+ )\n+ expected = self.dma_path.split(\"/\")[-1].strip()\n+ self.dut.send_expect(cmd, expected)\n+ time.sleep(3)\n+ out = self.dut.get_session_output(timeout=1)\n+ self.logger.info(\"out before: {}\".format(out))\n+ \"\"\"\n+ when start DSA app, default cores num is 2, it will only one thread\n+ when the cores num > 2, there will have 2 thread, and the max value of thread\n+ num is 2.\n+ \"\"\"\n+ self.work_thread = 2 if self.core_num > 2 else 1\n+ work_thread_info = \"Worker Threads = %d\" % self.work_thread\n+ copy_mode_info = \"Copy Mode = %s\" % self.copy_mode\n+ update_mac_info = \"Updating MAC = %s\" % self.updating_mac\n+ rx_queues_info = \"Rx Queues = %d\" % rx_queues\n+ self.verify(\n+ work_thread_info in out\n+ and copy_mode_info in out\n+ and update_mac_info in out\n+ and rx_queues_info in out,\n+ \"The output info not match setting for the cmd, please check\",\n+ )\n+\n+ def config_stream(self, frame_size):\n+ stream_ids = []\n+ for port in range(self.nic_port_num):\n+ tx_port = self.tester.get_local_port(self.dut_ports[port])\n+ rx_port = tx_port\n+ if self.nic_port_num > 1:\n+ if port % self.nic_port_num == 0:\n+ rx_port = self.tester.get_local_port(self.dut_ports[port + 1])\n+ else:\n+ rx_port = self.tester.get_local_port(self.dut_ports[port - 1])\n+ dst_mac = self.dut.get_mac_address(self.dut_ports[port])\n+ # pkt config\n+ pkt = Packet(pkt_type=\"UDP\", pkt_len=frame_size)\n+ # pkt.config_layer(\"ether\", {\"dst\": \"%s\" % dst_mac})\n+ pkt.config_layer(\"udp\", {\"src\": 1111, \"dst\": 1112})\n+ pkt.save_pcapfile(\n+ self.tester, \"%s/dsa_%d.pcap\" % (self.tester.tmp_file, port)\n+ )\n+ stream_option = {\n+ \"pcap\": \"%s/dsa_%d.pcap\" % (self.tester.tmp_file, port),\n+ \"fields_config\": {\n+ \"ether\": {\n+ \"dst\": {\n+ \"action\": \"random\",\n+ }\n+ },\n+ \"ip\": {\n+ \"src\": {\n+ \"action\": \"random\",\n+ \"start\": \"16.0.0.1\",\n+ \"step\": 1,\n+ \"end\": \"16.0.0.64\",\n+ }\n+ },\n+ },\n+ \"stream_config\": {\n+ \"rate\": 100,\n+ \"transmit_mode\": TRANSMIT_CONT,\n+ },\n+ }\n+ stream_id = self.tester.pktgen.add_stream(\n+ tx_port, tx_port, \"%s/dsa_%d.pcap\" % (self.tester.tmp_file, port)\n+ )\n+ self.tester.pktgen.config_stream(stream_id, stream_option)\n+ stream_ids.append(stream_id)\n+ return stream_ids\n+\n+ def send_and_verify(self, check_each_queue=True):\n+ \"\"\"\n+ Send packet with packet generator and verify\n+ \"\"\"\n+ for frame_size in self.frame_sizes:\n+ self.tester.pktgen.clear_streams()\n+ stream_ids = self.config_stream(frame_size)\n+ traffic_opt = {\"method\": \"throughput\", \"rate\": 100, \"duration\": 20}\n+ self.logger.info(\n+ \"start to send %d frame size packets from pktgen\" % frame_size\n+ )\n+ _, pps = self.tester.pktgen.measure(stream_ids, traffic_opt)\n+ self.verify(\n+ pps > 0,\n+ \"%s can not receive packets of frame size %d\"\n+ % (self.running_case, frame_size),\n+ )\n+ self.update_result_tables(frame_size, pps)\n+ if check_each_queue:\n+ self.check_enqueue_packets_of_each_channel()\n+\n+ def check_enqueue_packets_of_each_channel(self):\n+ \"\"\"\n+ Check stats of dma app, each dma channel can enqueue packets\n+ \"\"\"\n+ out = self.dut.get_session_output(timeout=2)\n+ index = out.rfind(\"Statistics for port 0\")\n+ out = out[index:]\n+ data_info = re.findall(\"Total completed ops:\\s*(\\d*)\", out)\n+ self.verify(\n+ (len(data_info) - 1) == self.rx_queues,\n+ \"There miss some queue, the run queue is \"\n+ \"%d, and expect queue num is %d\" % ((len(data_info) - 1), self.rx_queues),\n+ )\n+ for index in range(self.rx_queues):\n+ self.verify(\n+ data_info[index] != 0, \"the queue %d can not enqueues data\" % index\n+ )\n+\n+ def update_result_tables(self, frame_size, pps):\n+ Mpps = pps / 1000000.0\n+ linerate = (\n+ Mpps * 100 / float(self.wirespeed(self.nic, frame_size, self.nic_port_num))\n+ )\n+ self.work_thread = 2 if self.core_num > 2 else 1\n+ results_row = [frame_size]\n+ results_row.append(Mpps)\n+ results_row.append(self.work_thread)\n+ results_row.append(self.copy_mode)\n+ results_row.append(self.updating_mac)\n+ results_row.append(self.rx_queues / self.nic_port_num)\n+ results_row.append(linerate)\n+ self.result_table_add(results_row)\n+\n+ def test_perf_dsa_basic_test_using_dpdk_driver(self):\n+ \"\"\"\n+ Test Case 1: DMA basic test with differnet size packets using DSA dpdk driver\n+ \"\"\"\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ self.core_num = 2\n+ self.rx_queues = 1\n+ self.nic_port_num = 1\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"hw\"\n+ ports = dsas\n+ for i in range(self.nic_port_num):\n+ ports.append(self.dut.ports_info[i][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=%s\" % self.rx_queues}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports, port_options=port_options\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_multi_threads_using_dpdk_driver(self):\n+ \"\"\"\n+ Test Case 2: DMA test with multi-threads using DSA dpdk driver\n+ \"\"\"\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ self.core_num = 3\n+ self.rx_queues = 1\n+ self.nic_port_num = 1\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"hw\"\n+ ports = dsas\n+ for i in range(self.nic_port_num):\n+ ports.append(self.dut.ports_info[i][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=%s\" % self.rx_queues}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports, port_options=port_options\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_multi_nic_ports_using_dpdk_driver(self):\n+ \"\"\"\n+ Test Case 3: DMA test with multi nic ports using DSA dpdk driver\n+ \"\"\"\n+ self.verify(len(self.dut_ports) >= 2, \"Insufficient ports for testing\")\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ self.core_num = 5\n+ self.rx_queues = 2\n+ self.nic_port_num = 2\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"hw\"\n+ ports = dsas\n+ for i in range(self.nic_port_num):\n+ ports.append(self.dut.ports_info[i][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=%s\" % self.rx_queues}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports, port_options=port_options\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_multi_queues_using_dpdk_driver(self):\n+ \"\"\"\n+ Test Case 4: DMA test with multi-queues using DSA dpdk driver\n+ \"\"\"\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ self.core_num = 3\n+ self.nic_port_num = 1\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"hw\"\n+ queue_list = [2, 4, 8]\n+ ports = dsas\n+ for i in range(self.nic_port_num):\n+ ports.append(self.dut.ports_info[i][\"pci\"])\n+ for self.rx_queues in queue_list:\n+ port_options = {dsas[0]: \"max_queues=%s\" % self.rx_queues}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports, port_options=port_options\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.dut.send_expect(\"^c\", \"# \")\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_diff_update_mac_using_dpdk_driver(self):\n+ \"\"\"\n+ Test Case 5: DMA performance comparison between mac-updating and no-mac-updating using DSA dpdk driver\n+ \"\"\"\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ self.core_num = 2\n+ self.rx_queues = 2\n+ self.nic_port_num = 1\n+ self.updating_mac = \"disabled\"\n+ self.copy_mode = \"hw\"\n+ ports = dsas\n+ for i in range(self.nic_port_num):\n+ ports.append(self.dut.ports_info[i][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=%s\" % self.rx_queues}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports, port_options=port_options\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+\n+ self.dut.send_expect(\"^c\", \"# \")\n+ self.updating_mac = \"enabled\"\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_diff_copy_mode_using_dpdk_driver(self):\n+ \"\"\"\n+ Test Case 6: DMA performance comparison between SW copies and HW copies using DSA dpdk driver\n+ \"\"\"\n+ dsas = self.DC.bind_dsa_to_dpdk_driver(\n+ dsa_num=1, driver_name=\"vfio-pci\", socket=self.ports_socket\n+ )\n+ self.core_num = 3\n+ self.rx_queues = 4\n+ self.nic_port_num = 1\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"sw\"\n+ ports = dsas\n+ for i in range(self.nic_port_num):\n+ ports.append(self.dut.ports_info[i][\"pci\"])\n+ port_options = {dsas[0]: \"max_queues=%s\" % self.rx_queues}\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports, port_options=port_options\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=False)\n+\n+ self.dut.send_expect(\"^c\", \"# \")\n+ self.copy_mode = \"hw\"\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def test_perf_dsa_basic_test_using_kernel_driver(self):\n+ \"\"\"\n+ Test Case 7: DMA basic test with differnet size packets using DSA kernel driver\n+ \"\"\"\n+ self.DC.create_wq(wq_num=1, dsa_idxs=[0])\n+ self.core_num = 2\n+ self.rx_queues = 1\n+ self.nic_port_num = 1\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"hw\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_multi_thread_using_kernel_driver(self):\n+ \"\"\"\n+ Test Case 8: DMA test with multi-threads using DSA kernel driver\n+ \"\"\"\n+ self.DC.create_wq(wq_num=1, dsa_idxs=[0])\n+ self.core_num = 3\n+ self.rx_queues = 1\n+ self.nic_port_num = 1\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"hw\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_multi_nic_ports_using_kernle_driver(self):\n+ \"\"\"\n+ Test Case 9: DMA test with multi nic ports using DSA kernel driver\n+ \"\"\"\n+ self.verify(len(self.dut_ports) >= 2, \"Insufficient ports for testing\")\n+ self.DC.create_wq(wq_num=2, dsa_idxs=[0])\n+ self.core_num = 5\n+ self.rx_queues = 2\n+ self.nic_port_num = 2\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"hw\"\n+ ports = [self.dut.ports_info[0][\"pci\"], self.dut.ports_info[1][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_multi_queues_using_kernel_driver(self):\n+ \"\"\"\n+ Test Case 10: DMA test with multi-queues using DSA kernel driver\n+ \"\"\"\n+ self.DC.create_wq(wq_num=8, dsa_idxs=[0])\n+ self.core_num = 3\n+ self.nic_port_num = 1\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"hw\"\n+ queue_list = [2, 4, 8]\n+ for self.rx_queues in queue_list:\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.dut.send_expect(\"^c\", \"# \")\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_diff_update_mac_using_kernel_driver(self):\n+ \"\"\"\n+ Test Case 11: DMA performance comparison between mac-updating and no-mac-updating using DSA kernel driver\n+ \"\"\"\n+ self.DC.create_wq(wq_num=2, dsa_idxs=[0])\n+ self.core_num = 2\n+ self.rx_queues = 2\n+ self.nic_port_num = 1\n+ self.updating_mac = \"disabled\"\n+ self.copy_mode = \"hw\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+\n+ self.dut.send_expect(\"^c\", \"# \")\n+ self.updating_mac = \"enabled\"\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def test_perf_dsa_with_diff_copy_mode_using_kernel_driver(self):\n+ \"\"\"\n+ Test Case 12: DMA performance comparison between SW copies and HW copies using DSA kernel driver\n+ \"\"\"\n+ self.DC.create_wq(wq_num=4, dsa_idxs=[0])\n+ self.core_num = 3\n+ self.rx_queues = 4\n+ self.nic_port_num = 1\n+ self.updating_mac = \"enabled\"\n+ self.copy_mode = \"sw\"\n+ ports = [self.dut.ports_info[0][\"pci\"]]\n+ eal_params = self.dut.create_eal_parameters(\n+ cores=self.get_core_list(), ports=ports\n+ )\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=False)\n+\n+ self.dut.send_expect(\"^c\", \"# \")\n+ self.copy_mode = \"hw\"\n+ self.launch_dma_app(eal_params=eal_params)\n+ self.send_and_verify(check_each_queue=True)\n+ self.result_table_print()\n+\n+ def tear_down(self):\n+ \"\"\"\n+ Run after each test case.\n+ \"\"\"\n+ self.dut.send_expect(\"^c\", \"# \")\n+ self.dut.send_expect(\"killall -I %s\" % self.dma_name, \"#\", 20)\n+ self.dut.kill_all()\n+\n+ def tear_down_all(self):\n+ \"\"\"\n+ Run after each test suite.\n+ \"\"\"\n+ pass\n", "prefixes": [ "V3", "3/3" ] }