[dts] [PATCH V2] add test suite interrupt_pmd

[xu,gang]

Signed-off-by: xu,gang <gangx.xu at intel.com>
---
 tests/TestSuite_interrupt_pmd.py | 257 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 257 insertions(+)
 create mode 100644 tests/TestSuite_interrupt_pmd.py

diff --git a/tests/TestSuite_interrupt_pmd.py b/tests/TestSuite_interrupt_pmd.py
new file mode 100644
index 0000000..6cb3fb6
--- /dev/null
+++ b/tests/TestSuite_interrupt_pmd.py
@@ -0,0 +1,257 @@
+# BSD LICENSE
+#
+# Copyright(c) 2010-2017 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.
+
+"""
+DPDK Test suite.
+
+Rx interrupt pmd test suite.
+"""
+
+import string
+import re
+import time
+import utils
+from test_case import TestCase
+from utils import create_mask
+from packet import Packet, sniff_packets, load_sniff_packets
+
+
+class TestIntrPmd(TestCase):
+
+    VIFO_MODES = ['legacy', 'msi', 'msix']
+    IGBUIO_MODES = ['legacy', 'msix']
+
+    def set_up_all(self):
+        """
+        Run before each test suite.
+        """
+        self.dut_ports = self.dut.get_ports(self.nic)
+        self.verify(len(self.dut_ports) >= 2, "Insufficient ports")
+        self.cores = self.dut.get_core_list("1S/4C/1T")
+        self.portmask = utils.create_mask(self.dut_ports)
+        self.coremask = create_mask(self.cores)
+
+        self.path = "./examples/l3fwd-power/build/l3fwd-power"
+        self.build_app()
+
+    def build_app(self):
+        """
+        build sample app
+        """
+        out = self.dut.send_expect("make -C examples/l3fwd-power", "# ")
+        self.verify("Error" not in out, "compilation error 1")
+        self.verify("No such file" not in out, "compilation error 2")
+
+    def set_up(self):
+        """
+        Run before each test case.
+        """
+        pass
+
+    def scapy_send_packet(self, num=1):
+        """
+        Send a packet to port
+        """
+        self.dmac = self.dut.get_mac_address(self.dut_ports[0])
+        txport = self.tester.get_local_port(self.dut_ports[0])
+        self.txItf = self.tester.get_interface(txport)
+        pkt = Packet(pkt_type='UDP')
+        pkt.config_layer('ether', {'dst': self.dmac, })
+        pkt.send_pkt(tx_port=self.txItf, count=num)
+
+    def test_diff_queue(self):
+        """
+        Verify interrupt pmd work fine with different queues
+        """
+        coremask = create_mask(self.cores)
+        # At most 15 pair queues supported
+        queues = [2, 4, 8, 15]
+        for queue in queues:
+            #--config (port,queue,lcore)
+            config_cmd = "--config=\""
+            for idx in range(queue):
+                config_cmd += "(0,%d,%s)," % (idx, self.cores[0])
+            for idx in range(queue):
+                config_cmd += "(1,%d,%s)," % (idx, self.cores[1])
+            config_cmd += "\""
+            cmd = self.path + \
+                " -c %s -n %d -- -p %s -P " % (coremask,
+                                               self.dut.get_memory_channels(), self.portmask)
+            cmd += config_cmd
+            put = self.dut.send_expect(
+                cmd, "sleeps until interrupt triggers", 60)
+            self.scapy_send_packet()
+            out = self.dut.get_session_output(timeout=5)
+            print out
+            self.dut.send_expect("^C", "# ")
+            self.verify_status(out, self.dut_ports[0], self.cores[0])
+
+    def change_port_conf(self, lsc_enable=True, rxq_enable=True):
+        """
+        change interrupt enable
+        """
+        sed_cmd_fmt = "/intr_conf.*=.*{/,/\}\,$/c\    .intr_conf = {\\n\\t\\t.lsc = %d,\\n\\t\\t.rxq = %d,\\n\\t},"
+        lsc = 0
+        rxq = 0
+        if lsc_enable:
+            lsc = 1
+        if rxq_enable:
+            rxq = 1
+        sed_cmd_str = sed_cmd_fmt % (lsc, rxq)
+        self.dut.send_expect(
+            "sed -i '%s' examples/l3fwd-power/main.c" % sed_cmd_str, "# ")
+
+    def test_pf_lsc(self):
+        """
+        Verify diff interrupt enable
+        """
+        if self.drivername == "igb_uio":
+            for mode in self.IGBUIO_MODES:
+                param = "intr_mode=%s" % mode
+
+                self.dut.send_expect("rmmod igb_uio", "# ")
+                self.dut.send_expect(
+                    "insmod ./%s/kmod/igb_uio.ko %s" % (self.target, param), "# ")
+                self.dut.bind_interfaces_linux()
+
+                cmd = self.path + " -c %s -n %d -- -p %s -P " \
+                                  "--config=\"(0,0,%s),(1,0,%s)\"" \
+                                  % (self.coremask, self.dut.get_memory_channels(),
+                                     self.portmask, self.cores[0], self.cores[1])
+
+                # build l3fwd-power with only lsc interrupt enable
+                self.change_port_conf(lsc_enable=True, rxq_enable=False)
+                self.build_app()
+                self.verify_lsc_status(cmd, lsc=True)
+
+                # build l3fwd-power with lsc & rxq interrupt enable
+                self.change_port_conf(lsc_enable=True, rxq_enable=True)
+                self.build_app()
+                self.verify_lsc_status(cmd, lsc=False)
+        elif self.drivername == "vfio-pci":
+            # build l3fwd-power with lsc and rx interrupt enable
+            self.change_port_conf(lsc_enable=True, rxq_enable=True)
+            self.build_app()
+            # verify all vfio supported interrupt modes
+            for mode in self.VIFO_MODES:
+                cmd = self.path + " -c %s -n %d --vfio-intr=%s -- -p %s -P " \
+                                  "--config=\"(0,0,%s),(1,0,%s)\"" \
+                                  % (self.coremask, self.dut.get_memory_channels(), mode,
+                                     self.portmask, self.cores[0], self.cores[1])
+
+                if mode != "msix":
+                    self.verify_lsc_status(cmd, lsc=False)
+                else:
+                    self.verify_lsc_status(cmd, lsc=True)
+
+            # build l3fwd-power with only lsc interrupt enable
+            self.change_port_conf(lsc_enable=True, rxq_enable=False)
+            self.build_app()
+
+            # verify all vfio supported interrupt modes
+            for mode in self.VIFO_MODES:
+                cmd = self.path + " -c %s -n %d --vfio-intr=%s -- -p %s -P " \
+                                  "--config=\"(0,0,%s),(1,0,%s)\"" \
+                                  % (self.coremask, self.dut.get_memory_channels(), mode,
+                                     self.portmask, self.cores[0], self.cores[1])
+
+                self.verify_lsc_status(cmd, lsc=True)
+        elif self.drivername == "uio_pci_generic":
+            cmd = self.path + " -c %s -n %d -- -p %s -P " \
+                              "--config=\"(0,0,%s),(1,0,%s)\"" \
+                              % (self.coremask, self.dut.get_memory_channels(),
+                                 self.portmask, self.cores[0], self.cores[1])
+
+            # start l3fwd-power
+            # build l3fwd-power with only lsc interrupt enable
+            self.change_port_conf(lsc_enable=True, rxq_enable=False)
+            self.build_app()
+            self.verify_lsc_status(cmd, lsc=True)
+
+            # build l3fwd-power with lsc & rxq interrupt enable
+            self.change_port_conf(lsc_enable=True, rxq_enable=True)
+            self.build_app()
+            self.verify_lsc_status(cmd, lsc=False)
+
+    def verify_lsc_status(self, cmd, lsc=True):
+        """
+        Verify lsc interrupt status
+        """
+        # start l3fwd-power
+        out = self.dut.send_expect(cmd, "L3FWD_POWER", 60)
+        # wait for linke ready
+        time.sleep(10)
+
+        if lsc:
+            for idx in range(2):
+                txport = self.tester.get_local_port(self.dut_ports[idx])
+                txItf = self.tester.get_interface(txport)
+
+                self.tester.send_expect("ifconfig %s down" % txItf, "# ")
+                out = self.dut.get_session_output(timeout=10)
+                print out
+                self.verify("Port %d: Link Down" %
+                            idx in out, "LSC can't detected link down")
+                self.tester.send_expect("ifconfig %s up" % txItf, "# ")
+                out = self.dut.get_session_output(timeout=10)
+                self.verify("Port %d: Link Up" %
+                            idx in out, "LSC can't detected link up")
+        else:
+            self.verify("lsc won't enable" in out, "LSC should not enabled")
+
+        self.dut.kill_all()
+        time.sleep(2)
+
+    def verify_status(self, out, port, core):
+        """
+        Verify core status change
+        """
+        # make sure core normally waked up
+        wakeup_msg = "lcore %s is waked up from rx interrupt on port %s" % (
+            core, port)
+        self.verify(wakeup_msg in out, "Expected core not waked up")
+        # make sure core normally sleep
+        sleep_msg = "lcore %s sleeps until interrupt triggers" % core
+        self.verify(sleep_msg in out, "Expected core not sleep")
+
+    def tear_down(self):
+        """
+        Run after each test suite.
+        """
+        self.dut.kill_all()
+        time.sleep(2)
+        pass
+
+    def tear_down_all(self):
+        """
+        Run after each test suite.
+        """
+        pass
-- 
1.9.3