[dts] [DTS][PATCH V2 1/2] scatter: add scatter test suite

[Jingguo Fu <jingguox.fu@intel.com>]

Signed-off-by: Jingguo Fu <jingguox.fu@intel.com>
---
 tests/TestSuite_scatter.py | 132 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 132 insertions(+)
 create mode 100644 tests/TestSuite_scatter.py

diff --git a/tests/TestSuite_scatter.py b/tests/TestSuite_scatter.py
new file mode 100644
index 0000000..2ce5965
--- /dev/null
+++ b/tests/TestSuite_scatter.py
@@ -0,0 +1,132 @@
+# BSD LICENSE
+#
+# Copyright(c) 2010-2014 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.
+Test Scattered Packets.
+"""
+import dts
+from test_case import TestCase
+from pmd_output import PmdOutput
+
+EHTERNET_HEADER = 18
+IP_HEADER = 20
+DEFAULT_MBUF_SIZE = 2048
+JUMBO_FRAME_MTU = 9000
+STANDARD_MTU = 1500
+#
+#
+# Test class.
+#
+class TestScatter(TestCase):
+    #
+    #
+    #
+    # Test cases.
+    #
+    def set_up_all(self):
+        """
+        Run at the start of each test suite.
+        Scatter Prerequistites
+        """
+        dutPorts = self.dut.get_ports(self.nic)
+        # Verify that enough ports are available
+        self.verify(len(dutPorts) >= 2, "Insufficient ports")
+        self.pmdout = PmdOutput(self.dut)
+
+    def scatter_pktgen_send_packet(self, sPortid, rPortid, pktsize, num=1):
+        """
+        Functional test for scatter packets.
+        """
+        sport = self.tester.get_local_port(sPortid)
+        sintf = self.tester.get_interface(sport)
+        smac = self.dut.get_mac_address(sPortid)
+        rport = self.tester.get_local_port(rPortid)
+        rintf = self.tester.get_interface(rport)
+        self.tester.send_expect("ifconfig %s mtu %s" % (sintf, JUMBO_FRAME_MTU), "#")
+        self.tester.send_expect("ifconfig %s mtu %s" % (rintf, JUMBO_FRAME_MTU), "#")
+
+        self.tester.scapy_background()
+        self.tester.scapy_append(
+            'p = sniff(filter="ip",iface="%s", count=%d)' % (rintf, num))
+        self.tester.scapy_append('RESULT = str(p)')
+
+        pktlen = pktsize - EHTERNET_HEADER
+        padding = pktlen - IP_HEADER
+
+        self.tester.scapy_foreground()
+        self.tester.scapy_append(
+            'sendp([Ether(dst="%s")/IP(len=%s)/Raw(load="\x50"*%s)], iface="%s")' % (smac, pktlen, padding, sintf))
+        self.tester.scapy_execute()
+        res = self.tester.scapy_get_result()
+        self.tester.send_expect("ifconfig %s mtu %s" % (sintf, STANDARD_MTU), "#")
+        self.tester.send_expect("ifconfig %s mtu %s" % (rintf, STANDARD_MTU), "#")
+        return res
+
+    def set_up(self):
+        """
+        Run before each test case.
+        """
+        pass
+
+    def test_scatter_mbuf(self):
+        """
+        Scatter 2048 mbuf
+        """
+        dutPorts = self.dut.get_ports(self.nic)
+        portMask = dts.create_mask(dutPorts[:2])
+
+        # set the mbuf size to 1024
+        out = self.pmdout.start_testpmd(
+            "Default", "--mbcache=200 --mbuf-size=%s --portmask=%s --max-pkt-len=%s" % (DEFAULT_MBUF_SIZE,portMask, JUMBO_FRAME_MTU))
+        self.verify("Error" not in out, "launch error 1")
+        self.dut.send_expect("set fwd mac", "testpmd> ", 120)
+        self.dut.send_expect("start", "testpmd> ")
+
+        for offset in [-1, 0, 1, 4, 5]:
+            ret = self.scatter_pktgen_send_packet(
+                dutPorts[0], dutPorts[1], DEFAULT_MBUF_SIZE + offset)
+            self.verify("load='P" in ret, "packet receive error")
+
+        self.dut.send_expect("stop", "testpmd> ")
+        self.dut.send_expect("quit", "# ", 30)
+
+    def tear_down(self):
+        """
+        Run after each test case.
+        """
+        pass
+
+    def tear_down_all(self):
+        """
+        Run after each test suite.
+        """
+        pass
-- 
2.1.0