ip: reassembly - add a way to disable for forus

[vpp.git] / test / test_ip_mcast.py

diff --git a/test/test_ip_mcast.py b/test/test_ip_mcast.py
index d0ca1f6..50ac01b 100644 (file)
--- a/test/test_ip_mcast.py
+++ b/test/test_ip_mcast.py
@@ -2,16 +2,17 @@
 
 import unittest
 
+from framework import tag_fixme_vpp_workers
 from framework import VppTestCase, VppTestRunner
 from vpp_ip import DpoProto
 from vpp_ip_route import VppIpMRoute, VppMRoutePath, VppMFibSignal, \
-    VppIpTable, FibPathProto
+    VppIpTable, FibPathProto, FibPathType
 from vpp_gre_interface import VppGreInterface
 from vpp_papi import VppEnum
 
 from scapy.packet import Raw
 from scapy.layers.l2 import Ether, GRE
-from scapy.layers.inet import IP, UDP, getmacbyip
+from scapy.layers.inet import IP, UDP, getmacbyip, ICMP
 from scapy.layers.inet6 import IPv6, getmacbyip6
 
 #
@@ -47,6 +48,7 @@ class TestMFIB(VppTestCase):
         self.assertNotIn("Failed", error)
 
 
+@tag_fixme_vpp_workers
 class TestIPMcast(VppTestCase):
     """ IP Multicast Test Case """
 
@@ -209,6 +211,9 @@ class TestIPMcast(VppTestCase):
 
         self.pg0.assert_nothing_captured(
             remark="IP multicast packets forwarded on default route")
+        count = self.statistics.get_err_counter(
+            "/err/ip4-input/Multicast RPF check failed")
+        self.assertEqual(count, len(tx))
 
         #
         # A (*,G).
@@ -508,6 +513,9 @@ class TestIPMcast(VppTestCase):
         self.vapi.cli("clear trace")
         tx = self.create_stream_ip6(self.pg1, "2002::1", "ff01:2::255")
         self.send_and_assert_no_replies(self.pg1, tx, "RPF miss")
+        count = self.statistics.get_err_counter(
+            "/err/ip6-input/Multicast RPF check failed")
+        self.assertEqual(count, 2 * len(tx))
 
         #
         # a stream that matches the route for (*, ff01::/16)
@@ -844,6 +852,43 @@ class TestIPMcast(VppTestCase):
         self.verify_capture_ip4(self.pg1, tx)
         self.verify_capture_ip4(self.pg2, tx)
 
+        #
+        # An (S,G). for for-us
+        #
+        route_0_0_0_0_224_0_0_5 = VppIpMRoute(
+            self,
+            "0.0.0.0",
+            "224.0.0.5", 32,
+            MRouteEntryFlags.MFIB_API_ENTRY_FLAG_NONE,
+            [VppMRoutePath(self.pg8.sw_if_index,
+                           MRouteItfFlags.MFIB_API_ITF_FLAG_ACCEPT),
+             VppMRoutePath(0xffffffff,
+                           MRouteItfFlags.MFIB_API_ITF_FLAG_FORWARD,
+                           type=FibPathType.FIB_PATH_TYPE_LOCAL)],
+            table_id=10)
+        route_0_0_0_0_224_0_0_5.add_vpp_config()
+
+        #
+        # a stream that matches the route for (0.0.0.0, 224.0.0.5)
+        #  small packets
+        #
+        self.vapi.cli("clear trace")
+        self.pg8.resolve_arp()
+
+        #
+        # send a ping to mcast address from peer on pg8
+        #  expect a response
+        #
+        icmp_id = 0xb
+        icmp_seq = 5
+        icmp_load = b'\x0a' * 18
+        tx = (Ether(dst=getmacbyip("224.0.0.5"), src=self.pg8.remote_mac) /
+              IP(src=self.pg8.remote_ip4, dst="224.0.0.5") /
+              ICMP(id=icmp_id, seq=icmp_seq) /
+              Raw(load=icmp_load)) * 2
+
+        self.send_and_expect(self.pg8, tx, self.pg8)
+
     def test_ip_mcast_gre(self):
         """ IP Multicast Replication over GRE"""