[RFC PATCH v1 2/2] dts: merge DTS tests/TestSuite_pf_smoke.py to DPDK

["Juraj Linkeš" <juraj.linkes@pantheon.tech>]

---
 dts/tests/TestSuite_pf_smoke.py | 170 ++++++++++++++++++++++++++++++++
 1 file changed, 170 insertions(+)
 create mode 100644 dts/tests/TestSuite_pf_smoke.py

diff --git a/dts/tests/TestSuite_pf_smoke.py b/dts/tests/TestSuite_pf_smoke.py
new file mode 100644
index 0000000000..586ae8c685
--- /dev/null
+++ b/dts/tests/TestSuite_pf_smoke.py
@@ -0,0 +1,170 @@
+# BSD LICENSE
+#
+# Copyright(c)2021 Intel Corporation. All rights reserved.
+# All rights reserved.
+#
+# Redistribution and use in source and binary forms, with or without
+# modification, are permitted provided that the following conditions
+# are met:
+#
+#   * Redistributions of source code must retain the above copyright
+#     notice, this list of conditions and the following disclaimer.
+#   * Redistributions in binary form must reproduce the above copyright
+#     notice, this list of conditions and the following disclaimer in
+#     the documentation and/or other materials provided with the
+#     distribution.
+#   * Neither the name of Intel Corporation nor the names of its
+#     contributors may be used to endorse or promote products derived
+#     from this software without specific prior written permission.
+#
+# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+from framework.packet import Packet
+from framework.pmd_output import PmdOutput
+from framework.test_case import TestCase
+
+from .smoke_base import (
+    DEFAULT_MTU_VALUE,
+    JUMBO_FRAME_LENGTH,
+    JUMBO_FRAME_MTU,
+    LAUNCH_QUEUE,
+    SmokeTest,
+)
+
+
+class TestPfSmoke(TestCase):
+    def set_up_all(self):
+        """
+        Run at the start of each test suite.
+
+
+        Smoke Prerequisites
+        """
+
+        # Based on h/w type, choose how many ports to use
+        self.smoke_dut_ports = self.dut.get_ports(self.nic)
+
+        # Verify that enough ports are available
+        self.verify(len(self.smoke_dut_ports) >= 1, "Insufficient ports")
+        self.smoke_tester_port = self.tester.get_local_port(self.smoke_dut_ports[0])
+        self.smoke_tester_nic = self.tester.get_interface(self.smoke_tester_port)
+        self.smoke_tester_mac = self.tester.get_mac(self.smoke_dut_ports[0])
+        self.smoke_dut_mac = self.dut.get_mac_address(self.smoke_dut_ports[0])
+
+        # Verify that enough core
+        self.cores = self.dut.get_core_list("1S/4C/1T")
+        self.verify(self.cores is not None, "Insufficient cores for speed testing")
+
+        # init pkt
+        self.pkt = Packet()
+
+        # set default app parameter
+        self.pmd_out = PmdOutput(self.dut)
+        self.ports = [self.dut.ports_info[self.smoke_dut_ports[0]]["pci"]]
+        self.test_func = SmokeTest(self)
+        self.check_session = self.dut.new_session(suite="pf_smoke_test")
+
+    def set_up(self):
+        """
+        Run before each test case.
+        """
+        # set tester mtu and testpmd parameter
+        if self._suite_result.test_case == "test_pf_jumbo_frames":
+            self.tester.send_expect(
+                "ifconfig {} mtu {}".format(self.smoke_tester_nic, JUMBO_FRAME_MTU),
+                "# ",
+            )
+            self.param = (
+                "--max-pkt-len={} --tx-offloads=0x8000 --rxq={} --txq={}".format(
+                    JUMBO_FRAME_LENGTH, LAUNCH_QUEUE, LAUNCH_QUEUE
+                )
+            )
+        else:
+            self.param = "--rxq={} --txq={}".format(LAUNCH_QUEUE, LAUNCH_QUEUE)
+        # verify app launch state.
+        out = self.check_session.send_expect(
+            "ls -l /var/run/dpdk |awk '/^d/ {print $NF}'", "# ", 1
+        )
+        if out == "" or "No such file or directory" in out:
+            self.pf_launch_dpdk_app()
+
+    def pf_launch_dpdk_app(self):
+        self.pmd_out.start_testpmd(cores=self.cores, ports=self.ports, param=self.param)
+
+        # set default param
+        self.dut.send_expect("set promisc all off", "testpmd> ")
+        self.pmd_out.wait_link_status_up(self.smoke_dut_ports[0])
+
+    def test_pf_jumbo_frames(self):
+        """
+        This case aims to test transmitting jumbo frame packet on testpmd with
+        jumbo frame support.
+        """
+        self.dut.send_expect("set fwd mac", "testpmd> ")
+        self.dut.send_expect("set verbose 3", "testpmd> ")
+        self.dut.send_expect("start", "testpmd> ")
+        self.pmd_out.wait_link_status_up(self.smoke_dut_ports[0])
+        result = self.test_func.check_jumbo_frames()
+        self.verify(result, "enable disable jumbo frames failed")
+
+    def test_pf_rss(self):
+        """
+        Check default rss function.
+        """
+        self.dut.send_expect("set fwd rxonly", "testpmd> ")
+        self.dut.send_expect("set verbose 1", "testpmd> ")
+        self.dut.send_expect("start", "testpmd> ")
+        self.pmd_out.wait_link_status_up(self.smoke_dut_ports[0])
+        result = self.test_func.check_rss()
+        self.verify(result, "enable disable rss failed")
+
+    def test_pf_tx_rx_queue(self):
+        """
+        Check dpdk queue configure.
+        """
+        self.dut.send_expect("set verbose 1", "testpmd> ")
+        self.dut.send_expect("set fwd rxonly", "testpmd> ")
+        self.dut.send_expect("start", "testpmd> ")
+        self.pmd_out.wait_link_status_up(self.smoke_dut_ports[0])
+        result = self.test_func.check_tx_rx_queue()
+        self.verify(result, "check tx rx queue failed")
+
+    def tear_down(self):
+        self.pmd_out.execute_cmd("stop")
+
+        # set tester mtu to default value
+        if self._suite_result.test_case == "test_pf_jumbo_frames":
+            self.tester.send_expect(
+                "ifconfig {} mtu {}".format(self.smoke_tester_nic, DEFAULT_MTU_VALUE),
+                "# ",
+            )
+
+        # set dpdk queues to launch value
+        if self._suite_result.test_case == "test_pf_tx_rx_queue":
+            self.dut.send_expect("stop", "testpmd> ")
+            self.dut.send_expect("port stop all", "testpmd> ")
+            self.dut.send_expect(
+                "port config all rxq {}".format(LAUNCH_QUEUE), "testpmd> "
+            )
+            self.dut.send_expect(
+                "port config all txq {}".format(LAUNCH_QUEUE), "testpmd> "
+            )
+            self.dut.send_expect("port start all", "testpmd> ")
+        self.dut.send_expect("quit", "# ")
+        self.dut.kill_all()
+
+    def tear_down_all(self):
+        if self.check_session:
+            self.dut.close_session(self.check_session)
+            self.check_session = None
+        self.dut.kill_all()
-- 
2.20.1