* [dts] [PATCH V3] add test suite interrupt_pmd
@ 2017-02-24 8:39 xu,gang
0 siblings, 0 replies; only message in thread
From: xu,gang @ 2017-02-24 8:39 UTC (permalink / raw)
To: dts; +Cc: xu,gang
Signed-off-by: xu,gang <gangx.xu@intel.com>
---
tests/TestSuite_interrupt_pmd.py | 274 +++++++++++++++++++++++++++++++++++++++
1 file changed, 274 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..92ce621
--- /dev/null
+++ b/tests/TestSuite_interrupt_pmd.py
@@ -0,0 +1,274 @@
+# 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, queuenum=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)
+ if queuenum == 1:
+ self.tester.scapy_append(
+ 'sendp([Ether(dst="%s")/IP()/UDP()/Raw(\'X\'*18)], iface="%s")' % (self.dmac, self.txItf))
+ elif queuenum == 2:
+ for i in range(16):
+ self.tester.scapy_append(
+ 'sendp([Ether(dst="%s")/IP(dst="127.0.0.%d")/UDP()/Raw(\'X\'*18)], iface="%s")' % (self.dmac, i, self.txItf))
+ else:
+ for i in range(256):
+ self.tester.scapy_append(
+ 'sendp([Ether(dst="%s")/IP(dst="127.0.0.%d")/UDP()/Raw(\'X\'*18)], iface="%s")' % (self.dmac, i, self.txItf))
+ self.tester.scapy_execute()
+
+ def test_diff_queue(self):
+ """
+ Verify interrupt pmd work fine with different queues
+ """
+ coremask = create_mask(self.cores)
+ if self.nic == "niantic":
+ self.max_queue = 16
+ elif "kawela" in self.nic:
+ self.max_queue = 16
+ elif self.nic == "powerville" or self.nic == "bartonhills":
+ self.max_queue = 8
+ elif self.nic == "springville":
+ self.max_queue = 4
+ elif self.nic == "fortville_eagle":
+ self.max_queue = 16
+ else:
+ self.max_queue = 2
+
+ for queue in range(1, self.max_queue):
+ #--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(self.max_queue)
+ out = self.dut.get_session_output(timeout=60)
+ self.dut.send_expect("^C", "# ")
+ for work_queue in range(0, self.max_queue):
+ self.verify_status(out, self.dut_ports[
+ 0], self.cores[0], work_queue)
+
+ 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):
+ # 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)
+ 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, queue):
+ """
+ Verify core status change
+ """
+ # make sure core normally waked up
+ wakeup_msg = "lcore %s is waked up from rx interrupt on port %s queue %s" % (
+ core, port, queue)
+ 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
^ permalink raw reply [flat|nested] only message in thread
only message in thread, other threads:[~2017-02-24 8:38 UTC | newest]
Thread overview: (only message) (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2017-02-24 8:39 [dts] [PATCH V3] add test suite interrupt_pmd xu,gang
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).