5 from framework import VppTestCase, VppTestRunner
6 from vpp_ip import DpoProto
7 from vpp_ip_route import VppIpMRoute, VppMRoutePath, VppMFibSignal, \
8 MRouteItfFlags, MRouteEntryFlags, VppIpTable
10 from scapy.packet import Raw
11 from scapy.layers.l2 import Ether
12 from scapy.layers.inet import IP, UDP, getmacbyip
13 from scapy.layers.inet6 import IPv6, getmacbyip6
16 # The number of packets sent is set to 91 so that when we replicate more than 3
17 # times, which we do for some entries, we will generate more than 256 packets
18 # to the next node in the VLIB graph. Thus we are testing the code's
19 # correctness handling this over-flow.
20 # It's also an odd number so we hit any single loops.
25 class TestMFIB(VppTestCase):
26 """ MFIB Test Case """
30 super(TestMFIB, cls).setUpClass()
33 def tearDownClass(cls):
34 super(TestMFIB, cls).tearDownClass()
37 super(TestMFIB, self).setUp()
40 """ MFIB Unit Tests """
41 error = self.vapi.cli("test mfib")
44 self.logger.critical(error)
45 self.assertNotIn("Failed", error)
48 class TestIPMcast(VppTestCase):
49 """ IP Multicast Test Case """
53 super(TestIPMcast, cls).setUpClass()
56 def tearDownClass(cls):
57 super(TestIPMcast, cls).tearDownClass()
60 super(TestIPMcast, self).setUp()
62 # create 8 pg interfaces
63 self.create_pg_interfaces(range(9))
66 for i in self.pg_interfaces[:8]:
74 tbl4 = VppIpTable(self, 10)
76 self.pg8.set_table_ip4(10)
79 tbl6 = VppIpTable(self, 10, is_ip6=1)
81 self.pg8.set_table_ip6(10)
85 for i in self.pg_interfaces:
90 self.pg8.set_table_ip4(0)
91 self.pg8.set_table_ip6(0)
92 super(TestIPMcast, self).tearDown()
94 def create_stream_ip4(self, src_if, src_ip, dst_ip, payload_size=0):
96 # default to small packet sizes
97 p = (Ether(dst=src_if.local_mac, src=src_if.remote_mac) /
98 IP(src=src_ip, dst=dst_ip) /
99 UDP(sport=1234, dport=1234))
101 payload_size = 64 - len(p)
102 p = p / Raw('\xa5' * payload_size)
104 for i in range(0, N_PKTS_IN_STREAM):
108 def create_stream_ip6(self, src_if, src_ip, dst_ip):
110 for i in range(0, N_PKTS_IN_STREAM):
111 info = self.create_packet_info(src_if, src_if)
112 payload = self.info_to_payload(info)
113 p = (Ether(dst=src_if.local_mac, src=src_if.remote_mac) /
114 IPv6(src=src_ip, dst=dst_ip) /
115 UDP(sport=1234, dport=1234) /
121 def verify_filter(self, capture, sent):
122 if not len(capture) == len(sent):
123 # filter out any IPv6 RAs from the capture
125 if (p.haslayer(IPv6)):
129 def verify_capture_ip4(self, rx_if, sent, dst_mac=None):
130 rxd = rx_if.get_capture(len(sent))
133 capture = self.verify_filter(rxd, sent)
135 self.assertEqual(len(capture), len(sent))
137 for i in range(len(capture)):
142 self.assertEqual(eth.type, 0x800)
148 dst_mac = getmacbyip(rx_ip.dst)
150 # check the MAC address on the RX'd packet is correctly formed
151 self.assertEqual(eth.dst, dst_mac)
153 self.assertEqual(rx_ip.src, tx_ip.src)
154 self.assertEqual(rx_ip.dst, tx_ip.dst)
155 # IP processing post pop has decremented the TTL
156 self.assertEqual(rx_ip.ttl + 1, tx_ip.ttl)
161 def verify_capture_ip6(self, rx_if, sent):
162 capture = rx_if.get_capture(len(sent))
164 self.assertEqual(len(capture), len(sent))
166 for i in range(len(capture)):
171 self.assertEqual(eth.type, 0x86DD)
176 # check the MAC address on the RX'd packet is correctly formed
177 self.assertEqual(eth.dst, getmacbyip6(rx_ip.dst))
179 self.assertEqual(rx_ip.src, tx_ip.src)
180 self.assertEqual(rx_ip.dst, tx_ip.dst)
181 # IP processing post pop has decremented the TTL
182 self.assertEqual(rx_ip.hlim + 1, tx_ip.hlim)
184 def test_ip_mcast(self):
185 """ IP Multicast Replication """
188 # a stream that matches the default route. gets dropped.
190 self.vapi.cli("clear trace")
191 tx = self.create_stream_ip4(self.pg0, "1.1.1.1", "232.1.1.1")
192 self.pg0.add_stream(tx)
194 self.pg_enable_capture(self.pg_interfaces)
197 self.pg0.assert_nothing_captured(
198 remark="IP multicast packets forwarded on default route")
202 # one accepting interface, pg0, 7 forwarding interfaces
203 # many forwarding interfaces test the case where the replicate DPO
204 # needs to use extra cache lines for the buckets.
206 route_232_1_1_1 = VppIpMRoute(
210 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
211 [VppMRoutePath(self.pg0.sw_if_index,
212 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT),
213 VppMRoutePath(self.pg1.sw_if_index,
214 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
215 VppMRoutePath(self.pg2.sw_if_index,
216 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
217 VppMRoutePath(self.pg3.sw_if_index,
218 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
219 VppMRoutePath(self.pg4.sw_if_index,
220 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
221 VppMRoutePath(self.pg5.sw_if_index,
222 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
223 VppMRoutePath(self.pg6.sw_if_index,
224 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
225 VppMRoutePath(self.pg7.sw_if_index,
226 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD)])
227 route_232_1_1_1.add_vpp_config()
231 # one accepting interface, pg0, 2 forwarding interfaces
233 route_1_1_1_1_232_1_1_1 = VppIpMRoute(
236 "232.1.1.1", 27, # any grp-len is ok when src is set
237 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
238 [VppMRoutePath(self.pg0.sw_if_index,
239 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT),
240 VppMRoutePath(self.pg1.sw_if_index,
241 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
242 VppMRoutePath(self.pg2.sw_if_index,
243 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD)])
244 route_1_1_1_1_232_1_1_1.add_vpp_config()
248 # one accepting interface, pg0, 2 forwarding interfaces
249 # that use unicast next-hops
251 route_1_1_1_1_232_1_1_2 = VppIpMRoute(
255 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
256 [VppMRoutePath(self.pg0.sw_if_index,
257 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT),
258 VppMRoutePath(self.pg1.sw_if_index,
259 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
260 nh=self.pg1.remote_ip4),
261 VppMRoutePath(self.pg2.sw_if_index,
262 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
263 nh=self.pg2.remote_ip4)])
264 route_1_1_1_1_232_1_1_2.add_vpp_config()
268 # one accepting interface, pg0, 1 forwarding interfaces
270 route_232 = VppIpMRoute(
274 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
275 [VppMRoutePath(self.pg0.sw_if_index,
276 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT),
277 VppMRoutePath(self.pg1.sw_if_index,
278 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD)])
279 route_232.add_vpp_config()
282 # a stream that matches the route for (1.1.1.1,232.1.1.1)
285 self.vapi.cli("clear trace")
286 tx = self.create_stream_ip4(self.pg0, "1.1.1.1", "232.1.1.1")
287 self.pg0.add_stream(tx)
289 self.pg_enable_capture(self.pg_interfaces)
292 self.assertEqual(route_1_1_1_1_232_1_1_1.get_stats()['packets'],
295 # We expect replications on Pg1->7
296 self.verify_capture_ip4(self.pg1, tx)
297 self.verify_capture_ip4(self.pg2, tx)
299 # no replications on Pg0
300 self.pg0.assert_nothing_captured(
301 remark="IP multicast packets forwarded on PG0")
302 self.pg3.assert_nothing_captured(
303 remark="IP multicast packets forwarded on PG3")
306 # a stream that matches the route for (1.1.1.1,232.1.1.1)
309 self.vapi.cli("clear trace")
310 tx = self.create_stream_ip4(self.pg0, "1.1.1.1", "232.1.1.1",
312 self.pg0.add_stream(tx)
314 self.pg_enable_capture(self.pg_interfaces)
317 # We expect replications on Pg1->7
318 self.verify_capture_ip4(self.pg1, tx)
319 self.verify_capture_ip4(self.pg2, tx)
321 self.assertEqual(route_1_1_1_1_232_1_1_1.get_stats()['packets'],
324 # no replications on Pg0
325 self.pg0.assert_nothing_captured(
326 remark="IP multicast packets forwarded on PG0")
327 self.pg3.assert_nothing_captured(
328 remark="IP multicast packets forwarded on PG3")
331 # a stream to the unicast next-hops
333 self.vapi.cli("clear trace")
334 tx = self.create_stream_ip4(self.pg0, "1.1.1.1", "232.1.1.2")
335 self.pg0.add_stream(tx)
337 self.pg_enable_capture(self.pg_interfaces)
340 # We expect replications on Pg1->7
341 self.verify_capture_ip4(self.pg1, tx, dst_mac=self.pg1.remote_mac)
342 self.verify_capture_ip4(self.pg2, tx, dst_mac=self.pg2.remote_mac)
344 # no replications on Pg0 nor pg3
345 self.pg0.assert_nothing_captured(
346 remark="IP multicast packets forwarded on PG0")
347 self.pg3.assert_nothing_captured(
348 remark="IP multicast packets forwarded on PG3")
351 # a stream that matches the route for (*,232.0.0.0/8)
352 # Send packets with the 9th bit set so we test the correct clearing
353 # of that bit in the mac rewrite
355 self.vapi.cli("clear trace")
356 tx = self.create_stream_ip4(self.pg0, "1.1.1.1", "232.255.255.255")
357 self.pg0.add_stream(tx)
359 self.pg_enable_capture(self.pg_interfaces)
362 # We expect replications on Pg1 only
363 self.verify_capture_ip4(self.pg1, tx)
364 self.assertEqual(route_232.get_stats()['packets'], len(tx))
366 # no replications on Pg0, Pg2 not Pg3
367 self.pg0.assert_nothing_captured(
368 remark="IP multicast packets forwarded on PG0")
369 self.pg2.assert_nothing_captured(
370 remark="IP multicast packets forwarded on PG2")
371 self.pg3.assert_nothing_captured(
372 remark="IP multicast packets forwarded on PG3")
375 # a stream that matches the route for (*,232.1.1.1)
377 self.vapi.cli("clear trace")
378 tx = self.create_stream_ip4(self.pg0, "1.1.1.2", "232.1.1.1")
379 self.pg0.add_stream(tx)
381 self.pg_enable_capture(self.pg_interfaces)
384 # We expect replications on Pg1->7
385 self.verify_capture_ip4(self.pg1, tx)
386 self.verify_capture_ip4(self.pg2, tx)
387 self.verify_capture_ip4(self.pg3, tx)
388 self.verify_capture_ip4(self.pg4, tx)
389 self.verify_capture_ip4(self.pg5, tx)
390 self.verify_capture_ip4(self.pg6, tx)
391 self.verify_capture_ip4(self.pg7, tx)
393 # no replications on Pg0
394 self.pg0.assert_nothing_captured(
395 remark="IP multicast packets forwarded on PG0")
397 def test_ip6_mcast(self):
398 """ IPv6 Multicast Replication """
401 # a stream that matches the default route. gets dropped.
403 self.vapi.cli("clear trace")
404 tx = self.create_stream_ip6(self.pg0, "2001::1", "ff01::1")
405 self.pg0.add_stream(tx)
407 self.pg_enable_capture(self.pg_interfaces)
410 self.pg0.assert_nothing_captured(
411 remark="IPv6 multicast packets forwarded on default route")
415 # one accepting interface, pg0, 3 forwarding interfaces
417 route_ff01_1 = VppIpMRoute(
421 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
422 [VppMRoutePath(self.pg0.sw_if_index,
423 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT,
424 proto=DpoProto.DPO_PROTO_IP6),
425 VppMRoutePath(self.pg1.sw_if_index,
426 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
427 proto=DpoProto.DPO_PROTO_IP6),
428 VppMRoutePath(self.pg2.sw_if_index,
429 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
430 proto=DpoProto.DPO_PROTO_IP6),
431 VppMRoutePath(self.pg3.sw_if_index,
432 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
433 proto=DpoProto.DPO_PROTO_IP6)],
435 route_ff01_1.add_vpp_config()
439 # one accepting interface, pg0, 2 forwarding interfaces
441 route_2001_ff01_1 = VppIpMRoute(
444 "ff01::1", 0, # any grp-len is ok when src is set
445 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
446 [VppMRoutePath(self.pg0.sw_if_index,
447 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT,
448 proto=DpoProto.DPO_PROTO_IP6),
449 VppMRoutePath(self.pg1.sw_if_index,
450 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
451 proto=DpoProto.DPO_PROTO_IP6),
452 VppMRoutePath(self.pg2.sw_if_index,
453 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
454 proto=DpoProto.DPO_PROTO_IP6)],
456 route_2001_ff01_1.add_vpp_config()
460 # one accepting interface, pg0, 1 forwarding interface
462 route_ff01 = VppIpMRoute(
466 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
467 [VppMRoutePath(self.pg0.sw_if_index,
468 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT,
469 proto=DpoProto.DPO_PROTO_IP6),
470 VppMRoutePath(self.pg1.sw_if_index,
471 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
472 proto=DpoProto.DPO_PROTO_IP6)],
474 route_ff01.add_vpp_config()
477 # a stream that matches the route for (*, ff01::/16)
478 # sent on the non-accepting interface
480 self.vapi.cli("clear trace")
481 tx = self.create_stream_ip6(self.pg1, "2002::1", "ff01:2::255")
482 self.send_and_assert_no_replies(self.pg1, tx, "RPF miss")
485 # a stream that matches the route for (*, ff01::/16)
486 # sent on the accepting interface
488 self.vapi.cli("clear trace")
489 tx = self.create_stream_ip6(self.pg0, "2002::1", "ff01:2::255")
490 self.pg0.add_stream(tx)
492 self.pg_enable_capture(self.pg_interfaces)
495 # We expect replications on Pg1
496 self.verify_capture_ip6(self.pg1, tx)
498 # no replications on Pg0, Pg3
499 self.pg0.assert_nothing_captured(
500 remark="IP multicast packets forwarded on PG0")
501 self.pg2.assert_nothing_captured(
502 remark="IP multicast packets forwarded on PG2")
503 self.pg3.assert_nothing_captured(
504 remark="IP multicast packets forwarded on PG3")
507 # Bounce the interface and it should still work
509 self.pg1.admin_down()
510 self.pg0.add_stream(tx)
511 self.pg_enable_capture(self.pg_interfaces)
513 self.pg1.assert_nothing_captured(
514 remark="IP multicast packets forwarded on down PG1")
517 self.pg0.add_stream(tx)
518 self.pg_enable_capture(self.pg_interfaces)
520 self.verify_capture_ip6(self.pg1, tx)
523 # a stream that matches the route for (*,ff01::1)
525 self.vapi.cli("clear trace")
526 tx = self.create_stream_ip6(self.pg0, "2002::2", "ff01::1")
527 self.pg0.add_stream(tx)
529 self.pg_enable_capture(self.pg_interfaces)
532 # We expect replications on Pg1, 2, 3.
533 self.verify_capture_ip6(self.pg1, tx)
534 self.verify_capture_ip6(self.pg2, tx)
535 self.verify_capture_ip6(self.pg3, tx)
537 # no replications on Pg0
538 self.pg0.assert_nothing_captured(
539 remark="IPv6 multicast packets forwarded on PG0")
542 # a stream that matches the route for (2001::1, ff00::1)
544 self.vapi.cli("clear trace")
545 tx = self.create_stream_ip6(self.pg0, "2001::1", "ff01::1")
546 self.pg0.add_stream(tx)
548 self.pg_enable_capture(self.pg_interfaces)
551 # We expect replications on Pg1, 2,
552 self.verify_capture_ip6(self.pg1, tx)
553 self.verify_capture_ip6(self.pg2, tx)
555 # no replications on Pg0, Pg3
556 self.pg0.assert_nothing_captured(
557 remark="IP multicast packets forwarded on PG0")
558 self.pg3.assert_nothing_captured(
559 remark="IP multicast packets forwarded on PG3")
561 def _mcast_connected_send_stream(self, dst_ip):
562 self.vapi.cli("clear trace")
563 tx = self.create_stream_ip4(self.pg0,
566 self.pg0.add_stream(tx)
568 self.pg_enable_capture(self.pg_interfaces)
571 # We expect replications on Pg1.
572 self.verify_capture_ip4(self.pg1, tx)
576 def test_ip_mcast_connected(self):
577 """ IP Multicast Connected Source check """
581 # one accepting interface, pg0, 1 forwarding interfaces
583 route_232_1_1_1 = VppIpMRoute(
587 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
588 [VppMRoutePath(self.pg0.sw_if_index,
589 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT),
590 VppMRoutePath(self.pg1.sw_if_index,
591 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD)])
593 route_232_1_1_1.add_vpp_config()
594 route_232_1_1_1.update_entry_flags(
595 MRouteEntryFlags.MFIB_ENTRY_FLAG_CONNECTED)
598 # Now the (*,G) is present, send from connected source
600 tx = self._mcast_connected_send_stream("232.1.1.1")
603 # Constrct a representation of the signal we expect on pg0
605 signal_232_1_1_1_itf_0 = VppMFibSignal(self,
607 self.pg0.sw_if_index,
611 # read the only expected signal
613 signals = self.vapi.mfib_signal_dump()
615 self.assertEqual(1, len(signals))
617 signal_232_1_1_1_itf_0.compare(signals[0])
620 # reading the signal allows for the generation of another
621 # so send more packets and expect the next signal
623 tx = self._mcast_connected_send_stream("232.1.1.1")
625 signals = self.vapi.mfib_signal_dump()
626 self.assertEqual(1, len(signals))
627 signal_232_1_1_1_itf_0.compare(signals[0])
630 # A Second entry with connected check
631 # one accepting interface, pg0, 1 forwarding interfaces
633 route_232_1_1_2 = VppIpMRoute(
637 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
638 [VppMRoutePath(self.pg0.sw_if_index,
639 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT),
640 VppMRoutePath(self.pg1.sw_if_index,
641 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD)])
643 route_232_1_1_2.add_vpp_config()
644 route_232_1_1_2.update_entry_flags(
645 MRouteEntryFlags.MFIB_ENTRY_FLAG_CONNECTED)
648 # Send traffic to both entries. One read should net us two signals
650 signal_232_1_1_2_itf_0 = VppMFibSignal(self,
652 self.pg0.sw_if_index,
654 tx = self._mcast_connected_send_stream("232.1.1.1")
655 tx2 = self._mcast_connected_send_stream("232.1.1.2")
658 # read the only expected signal
660 signals = self.vapi.mfib_signal_dump()
662 self.assertEqual(2, len(signals))
664 signal_232_1_1_1_itf_0.compare(signals[1])
665 signal_232_1_1_2_itf_0.compare(signals[0])
667 route_232_1_1_1.update_entry_flags(
668 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE)
669 route_232_1_1_2.update_entry_flags(
670 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE)
672 def test_ip_mcast_signal(self):
673 """ IP Multicast Signal """
677 # one accepting interface, pg0, 1 forwarding interfaces
679 route_232_1_1_1 = VppIpMRoute(
683 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
684 [VppMRoutePath(self.pg0.sw_if_index,
685 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT),
686 VppMRoutePath(self.pg1.sw_if_index,
687 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD)])
689 route_232_1_1_1.add_vpp_config()
690 route_232_1_1_1.update_entry_flags(
691 MRouteEntryFlags.MFIB_ENTRY_FLAG_SIGNAL)
694 # Now the (*,G) is present, send from connected source
696 tx = self._mcast_connected_send_stream("232.1.1.1")
699 # Constrct a representation of the signal we expect on pg0
701 signal_232_1_1_1_itf_0 = VppMFibSignal(self,
703 self.pg0.sw_if_index,
707 # read the only expected signal
709 signals = self.vapi.mfib_signal_dump()
711 self.assertEqual(1, len(signals))
713 signal_232_1_1_1_itf_0.compare(signals[0])
716 # reading the signal allows for the generation of another
717 # so send more packets and expect the next signal
719 tx = self._mcast_connected_send_stream("232.1.1.1")
721 signals = self.vapi.mfib_signal_dump()
722 self.assertEqual(1, len(signals))
723 signal_232_1_1_1_itf_0.compare(signals[0])
726 # Set the negate-signal on the accepting interval - the signals
729 route_232_1_1_1.update_path_flags(
730 self.pg0.sw_if_index,
731 (MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT |
732 MRouteItfFlags.MFIB_ITF_FLAG_NEGATE_SIGNAL))
734 self.vapi.cli("clear trace")
735 tx = self._mcast_connected_send_stream("232.1.1.1")
737 signals = self.vapi.mfib_signal_dump()
738 self.assertEqual(0, len(signals))
741 # Clear the SIGNAL flag on the entry and the signals should
742 # come back since the interface is still NEGATE-SIGNAL
744 route_232_1_1_1.update_entry_flags(
745 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE)
747 tx = self._mcast_connected_send_stream("232.1.1.1")
749 signals = self.vapi.mfib_signal_dump()
750 self.assertEqual(1, len(signals))
751 signal_232_1_1_1_itf_0.compare(signals[0])
754 # Lastly remove the NEGATE-SIGNAL from the interface and the
755 # signals should stop
757 route_232_1_1_1.update_path_flags(self.pg0.sw_if_index,
758 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT)
760 tx = self._mcast_connected_send_stream("232.1.1.1")
761 signals = self.vapi.mfib_signal_dump()
762 self.assertEqual(0, len(signals))
764 def test_ip_mcast_vrf(self):
765 """ IP Multicast Replication in non-default table"""
769 # one accepting interface, pg0, 2 forwarding interfaces
771 route_1_1_1_1_232_1_1_1 = VppIpMRoute(
775 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
776 [VppMRoutePath(self.pg8.sw_if_index,
777 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT),
778 VppMRoutePath(self.pg1.sw_if_index,
779 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
780 VppMRoutePath(self.pg2.sw_if_index,
781 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD)],
783 route_1_1_1_1_232_1_1_1.add_vpp_config()
786 # a stream that matches the route for (1.1.1.1,232.1.1.1)
789 self.vapi.cli("clear trace")
790 tx = self.create_stream_ip4(self.pg8, "1.1.1.1", "232.1.1.1")
791 self.pg8.add_stream(tx)
793 self.pg_enable_capture(self.pg_interfaces)
796 # We expect replications on Pg1 & 2
797 self.verify_capture_ip4(self.pg1, tx)
798 self.verify_capture_ip4(self.pg2, tx)
800 def test_ip6_mcast_vrf(self):
801 """ IPv6 Multicast Replication in non-default table"""
805 # one accepting interface, pg0, 2 forwarding interfaces
807 route_2001_ff01_1 = VppIpMRoute(
811 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
812 [VppMRoutePath(self.pg8.sw_if_index,
813 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT,
814 proto=DpoProto.DPO_PROTO_IP6),
815 VppMRoutePath(self.pg1.sw_if_index,
816 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
817 proto=DpoProto.DPO_PROTO_IP6),
818 VppMRoutePath(self.pg2.sw_if_index,
819 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD,
820 proto=DpoProto.DPO_PROTO_IP6)],
823 route_2001_ff01_1.add_vpp_config()
826 # a stream that matches the route for (2001::1, ff00::1)
828 self.vapi.cli("clear trace")
829 tx = self.create_stream_ip6(self.pg8, "2001::1", "ff01::1")
830 self.pg8.add_stream(tx)
832 self.pg_enable_capture(self.pg_interfaces)
835 # We expect replications on Pg1, 2,
836 self.verify_capture_ip6(self.pg1, tx)
837 self.verify_capture_ip6(self.pg2, tx)
839 def test_bidir(self):
840 """ IP Multicast Bi-directional """
843 # A (*,G). The set of accepting interfaces matching the forwarding
845 route_232_1_1_1 = VppIpMRoute(
849 MRouteEntryFlags.MFIB_ENTRY_FLAG_NONE,
850 [VppMRoutePath(self.pg0.sw_if_index,
851 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT |
852 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
853 VppMRoutePath(self.pg1.sw_if_index,
854 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT |
855 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
856 VppMRoutePath(self.pg2.sw_if_index,
857 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT |
858 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD),
859 VppMRoutePath(self.pg3.sw_if_index,
860 MRouteItfFlags.MFIB_ITF_FLAG_ACCEPT |
861 MRouteItfFlags.MFIB_ITF_FLAG_FORWARD)])
862 route_232_1_1_1.add_vpp_config()
864 tx = self.create_stream_ip4(self.pg0, "1.1.1.1", "232.1.1.1")
865 self.pg0.add_stream(tx)
867 self.pg_enable_capture(self.pg_interfaces)
870 # We expect replications on Pg1, 2, 3, but not on pg0
871 self.verify_capture_ip4(self.pg1, tx)
872 self.verify_capture_ip4(self.pg2, tx)
873 self.verify_capture_ip4(self.pg3, tx)
874 self.pg0.assert_nothing_captured(
875 remark="IP multicast packets forwarded on PG0")
878 if __name__ == '__main__':
879 unittest.main(testRunner=VppTestRunner)