3 * Copyright (C) 2008 Everton da Silva Marques
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * General Public License for more details.
15 * You should have received a copy of the GNU General Public License along
16 * with this program; see the file COPYING; if not, write to the Free Software
17 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
28 #include "lib_errors.h"
32 #include "pim_mroute.h"
36 #include "pim_iface.h"
37 #include "pim_macro.h"
40 #include "pim_register.h"
41 #include "pim_ifchannel.h"
42 #include "pim_zlookup.h"
45 #include "pim_vxlan.h"
47 static void mroute_read_on(struct pim_instance
*pim
);
49 static int pim_mroute_set(struct pim_instance
*pim
, int enable
)
53 socklen_t data_len
= sizeof(data
);
57 * We need to create the VRF table for the pim mroute_socket
59 if (pim
->vrf
->vrf_id
!= VRF_DEFAULT
) {
60 frr_with_privs(&pimd_privs
) {
62 data
= pim
->vrf
->data
.l
.table_id
;
63 err
= setsockopt(pim
->mroute_socket
, IPPROTO_IP
,
68 "%s %s: failure: setsockopt(fd=%d,IPPROTO_IP, MRT_TABLE=%d): errno=%d: %s",
69 __FILE__
, __func__
, pim
->mroute_socket
,
70 data
, errno
, safe_strerror(errno
));
77 frr_with_privs(&pimd_privs
) {
78 opt
= enable
? MRT_INIT
: MRT_DONE
;
80 * *BSD *cares* about what value we pass down
84 err
= setsockopt(pim
->mroute_socket
, IPPROTO_IP
,
85 opt
, &data
, data_len
);
88 "%s %s: failure: setsockopt(fd=%d,IPPROTO_IP,%s=%d): errno=%d: %s",
89 __FILE__
, __func__
, pim
->mroute_socket
,
90 enable
? "MRT_INIT" : "MRT_DONE", data
, errno
,
91 safe_strerror(errno
));
96 #if defined(HAVE_IP_PKTINFO)
98 /* Linux and Solaris IP_PKTINFO */
100 if (setsockopt(pim
->mroute_socket
, IPPROTO_IP
, IP_PKTINFO
,
103 "Could not set IP_PKTINFO on socket fd=%d: errno=%d: %s",
104 pim
->mroute_socket
, errno
,
105 safe_strerror(errno
));
110 setsockopt_so_recvbuf(pim
->mroute_socket
, 1024 * 1024 * 8);
112 flags
= fcntl(pim
->mroute_socket
, F_GETFL
, 0);
114 zlog_warn("Could not get flags on socket fd:%d %d %s",
115 pim
->mroute_socket
, errno
, safe_strerror(errno
));
116 close(pim
->mroute_socket
);
119 if (fcntl(pim
->mroute_socket
, F_SETFL
, flags
| O_NONBLOCK
)) {
120 zlog_warn("Could not set O_NONBLOCK on socket fd:%d %d %s",
121 pim
->mroute_socket
, errno
, safe_strerror(errno
));
122 close(pim
->mroute_socket
);
128 int upcalls
= IGMPMSG_WRVIFWHOLE
;
131 err
= setsockopt(pim
->mroute_socket
, IPPROTO_IP
, opt
, &upcalls
,
135 "Failure to register for VIFWHOLE and WRONGVIF upcalls %d %s",
136 errno
, safe_strerror(errno
));
141 "PIM-SM will not work properly on this platform, until the ability to receive the WRVIFWHOLE upcall");
148 static const char *const igmpmsgtype2str
[IGMPMSG_WRVIFWHOLE
+ 1] = {
149 "<unknown_upcall?>", "NOCACHE", "WRONGVIF", "WHOLEPKT", "WRVIFWHOLE"};
151 static int pim_mroute_msg_nocache(int fd
, struct interface
*ifp
,
152 const struct igmpmsg
*msg
)
154 struct pim_interface
*pim_ifp
= ifp
->info
;
155 struct pim_upstream
*up
;
159 rpg
= pim_ifp
? RP(pim_ifp
->pim
, msg
->im_dst
) : NULL
;
161 * If the incoming interface is unknown OR
162 * the Interface type is SSM we don't need to
165 if (!rpg
|| pim_rpf_addr_is_inaddr_none(rpg
)) {
166 if (PIM_DEBUG_MROUTE_DETAIL
)
168 "%s: Interface is not configured correctly to handle incoming packet: Could be !pim_ifp, !SM, !RP",
175 * If we've received a multicast packet that isn't connected to
178 if (!pim_if_connected_to_source(ifp
, msg
->im_src
)) {
179 if (PIM_DEBUG_MROUTE_DETAIL
)
181 "%s: Received incoming packet that doesn't originate on our seg",
186 memset(&sg
, 0, sizeof(struct prefix_sg
));
187 sg
.src
= msg
->im_src
;
188 sg
.grp
= msg
->im_dst
;
190 if (!(PIM_I_am_DR(pim_ifp
))) {
191 if (PIM_DEBUG_MROUTE_DETAIL
)
193 "%s: Interface is not the DR blackholing incoming traffic for %s",
194 __func__
, pim_str_sg_dump(&sg
));
197 * We are not the DR, but we are still receiving packets
198 * Let's blackhole those packets for the moment
199 * As that they will be coming up to the cpu
200 * and causing us to consider them.
202 * This *will* create a dangling channel_oil
203 * that I see no way to get rid of. Just noting
204 * this for future reference.
206 up
= pim_upstream_find_or_add(
207 &sg
, ifp
, PIM_UPSTREAM_FLAG_MASK_SRC_NOCACHE
, __func__
);
208 pim_upstream_mroute_add(up
->channel_oil
, __func__
);
213 up
= pim_upstream_find_or_add(&sg
, ifp
, PIM_UPSTREAM_FLAG_MASK_FHR
,
217 * I moved this debug till after the actual add because
218 * I want to take advantage of the up->sg_str being filled in.
220 if (PIM_DEBUG_MROUTE
) {
221 zlog_debug("%s: Adding a Route %s for WHOLEPKT consumption",
222 __func__
, up
->sg_str
);
225 PIM_UPSTREAM_FLAG_SET_SRC_STREAM(up
->flags
);
226 pim_upstream_keep_alive_timer_start(up
, pim_ifp
->pim
->keep_alive_time
);
228 up
->channel_oil
->cc
.pktcnt
++;
229 // resolve mfcc_parent prior to mroute_add in channel_add_oif
230 if (up
->rpf
.source_nexthop
.interface
&&
231 up
->channel_oil
->oil
.mfcc_parent
>= MAXVIFS
) {
232 pim_upstream_mroute_iif_update(up
->channel_oil
, __func__
);
234 pim_register_join(up
);
235 /* if we have receiver, inherit from parent */
236 pim_upstream_inherited_olist_decide(pim_ifp
->pim
, up
);
241 static int pim_mroute_msg_wholepkt(int fd
, struct interface
*ifp
,
244 struct pim_interface
*pim_ifp
;
247 const struct ip
*ip_hdr
;
248 struct pim_upstream
*up
;
252 ip_hdr
= (const struct ip
*)buf
;
254 memset(&sg
, 0, sizeof(struct prefix_sg
));
255 sg
.src
= ip_hdr
->ip_src
;
256 sg
.grp
= ip_hdr
->ip_dst
;
258 up
= pim_upstream_find(pim_ifp
->pim
, &sg
);
260 struct prefix_sg star
= sg
;
261 star
.src
.s_addr
= INADDR_ANY
;
263 up
= pim_upstream_find(pim_ifp
->pim
, &star
);
265 if (up
&& PIM_UPSTREAM_FLAG_TEST_CAN_BE_LHR(up
->flags
)) {
266 up
= pim_upstream_add(pim_ifp
->pim
, &sg
, ifp
,
267 PIM_UPSTREAM_FLAG_MASK_SRC_LHR
,
270 if (PIM_DEBUG_MROUTE
)
272 "%s: Unable to create upstream information for %s",
273 __func__
, pim_str_sg_dump(&sg
));
276 pim_upstream_keep_alive_timer_start(
277 up
, pim_ifp
->pim
->keep_alive_time
);
278 pim_upstream_inherited_olist(pim_ifp
->pim
, up
);
279 pim_upstream_update_join_desired(pim_ifp
->pim
, up
);
281 if (PIM_DEBUG_MROUTE
)
282 zlog_debug("%s: Creating %s upstream on LHR",
283 __func__
, up
->sg_str
);
286 if (PIM_DEBUG_MROUTE_DETAIL
) {
288 "%s: Unable to find upstream channel WHOLEPKT%s",
289 __func__
, pim_str_sg_dump(&sg
));
294 if (!up
->rpf
.source_nexthop
.interface
) {
295 if (PIM_DEBUG_PIM_TRACE
)
296 zlog_debug("%s: up %s RPF is not present", __func__
,
301 pim_ifp
= up
->rpf
.source_nexthop
.interface
->info
;
303 rpg
= pim_ifp
? RP(pim_ifp
->pim
, sg
.grp
) : NULL
;
305 if ((pim_rpf_addr_is_inaddr_none(rpg
)) || (!pim_ifp
)
306 || (!(PIM_I_am_DR(pim_ifp
)))) {
307 if (PIM_DEBUG_MROUTE
) {
308 zlog_debug("%s: Failed Check send packet", __func__
);
314 * If we've received a register suppress
316 if (!up
->t_rs_timer
) {
317 if (pim_is_grp_ssm(pim_ifp
->pim
, sg
.grp
)) {
318 if (PIM_DEBUG_PIM_REG
)
320 "%s register forward skipped as group is SSM",
321 pim_str_sg_dump(&sg
));
325 if (!PIM_UPSTREAM_FLAG_TEST_FHR(up
->flags
)) {
326 if (PIM_DEBUG_PIM_REG
)
328 "%s register forward skipped, not FHR",
333 pim_register_send((uint8_t *)buf
+ sizeof(struct ip
),
334 ntohs(ip_hdr
->ip_len
) - sizeof(struct ip
),
335 pim_ifp
->primary_address
, rpg
, 0, up
);
340 static int pim_mroute_msg_wrongvif(int fd
, struct interface
*ifp
,
341 const struct igmpmsg
*msg
)
343 struct pim_ifchannel
*ch
;
344 struct pim_interface
*pim_ifp
;
347 memset(&sg
, 0, sizeof(struct prefix_sg
));
348 sg
.src
= msg
->im_src
;
349 sg
.grp
= msg
->im_dst
;
352 Send Assert(S,G) on iif as response to WRONGVIF kernel upcall.
354 RFC 4601 4.8.2. PIM-SSM-Only Routers
356 iif is the incoming interface of the packet.
357 if (iif is in inherited_olist(S,G)) {
358 send Assert(S,G) on iif
363 if (PIM_DEBUG_MROUTE
)
365 "%s: WRONGVIF (S,G)=%s could not find input interface for input_vif_index=%d",
366 __func__
, pim_str_sg_dump(&sg
), msg
->im_vif
);
372 if (PIM_DEBUG_MROUTE
)
374 "%s: WRONGVIF (S,G)=%s multicast not enabled on interface %s",
375 __func__
, pim_str_sg_dump(&sg
), ifp
->name
);
379 ch
= pim_ifchannel_find(ifp
, &sg
);
381 struct prefix_sg star_g
= sg
;
382 if (PIM_DEBUG_MROUTE
)
384 "%s: WRONGVIF (S,G)=%s could not find channel on interface %s",
385 __func__
, pim_str_sg_dump(&sg
), ifp
->name
);
387 star_g
.src
.s_addr
= INADDR_ANY
;
388 ch
= pim_ifchannel_find(ifp
, &star_g
);
390 if (PIM_DEBUG_MROUTE
)
392 "%s: WRONGVIF (*,G)=%s could not find channel on interface %s",
393 __func__
, pim_str_sg_dump(&star_g
),
400 RFC 4601: 4.6.1. (S,G) Assert Message State Machine
402 Transitions from NoInfo State
404 An (S,G) data packet arrives on interface I, AND
405 CouldAssert(S,G,I)==TRUE An (S,G) data packet arrived on an
406 downstream interface that is in our (S,G) outgoing interface
407 list. We optimistically assume that we will be the assert
408 winner for this (S,G), and so we transition to the "I am Assert
409 Winner" state and perform Actions A1 (below), which will
410 initiate the assert negotiation for (S,G).
413 if (ch
->ifassert_state
!= PIM_IFASSERT_NOINFO
) {
414 if (PIM_DEBUG_MROUTE
) {
416 "%s: WRONGVIF (S,G)=%s channel is not on Assert NoInfo state for interface %s",
417 __func__
, ch
->sg_str
, ifp
->name
);
422 if (!PIM_IF_FLAG_TEST_COULD_ASSERT(ch
->flags
)) {
423 if (PIM_DEBUG_MROUTE
) {
425 "%s: WRONGVIF (S,G)=%s interface %s is not downstream for channel",
426 __func__
, ch
->sg_str
, ifp
->name
);
431 if (assert_action_a1(ch
)) {
432 if (PIM_DEBUG_MROUTE
) {
434 "%s: WRONGVIF (S,G)=%s assert_action_a1 failure on interface %s",
435 __func__
, ch
->sg_str
, ifp
->name
);
443 static int pim_mroute_msg_wrvifwhole(int fd
, struct interface
*ifp
,
446 const struct ip
*ip_hdr
= (const struct ip
*)buf
;
447 struct pim_interface
*pim_ifp
;
448 struct pim_instance
*pim
;
449 struct pim_ifchannel
*ch
;
450 struct pim_upstream
*up
;
451 struct prefix_sg star_g
;
456 memset(&sg
, 0, sizeof(struct prefix_sg
));
457 sg
.src
= ip_hdr
->ip_src
;
458 sg
.grp
= ip_hdr
->ip_dst
;
460 ch
= pim_ifchannel_find(ifp
, &sg
);
462 if (PIM_DEBUG_MROUTE
)
464 "WRVIFWHOLE (S,G)=%s found ifchannel on interface %s",
465 ch
->sg_str
, ifp
->name
);
470 star_g
.src
.s_addr
= INADDR_ANY
;
474 * If the incoming interface is the pimreg, then
475 * we know the callback is associated with a pim register
476 * packet and there is nothing to do here as that
477 * normal pim processing will see the packet and allow
478 * us to do the right thing.
480 if (ifp
== pim
->regiface
) {
484 up
= pim_upstream_find(pim_ifp
->pim
, &sg
);
486 struct pim_upstream
*parent
;
487 struct pim_nexthop source
;
488 struct pim_rpf
*rpf
= RP(pim_ifp
->pim
, sg
.grp
);
490 /* No RPF or No RPF interface or No mcast on RPF interface */
491 if (!rpf
|| !rpf
->source_nexthop
.interface
492 || !rpf
->source_nexthop
.interface
->info
)
496 * If we have received a WRVIFWHOLE and are at this
497 * point, we could be receiving the packet on the *,G
498 * tree, let's check and if so we can safely drop
501 parent
= pim_upstream_find(pim_ifp
->pim
, &star_g
);
502 if (parent
&& parent
->rpf
.source_nexthop
.interface
== ifp
)
505 pim_ifp
= rpf
->source_nexthop
.interface
->info
;
507 memset(&source
, 0, sizeof(source
));
509 * If we are the fhr that means we are getting a callback during
510 * the pimreg period, so I believe we can ignore this packet
512 if (!PIM_UPSTREAM_FLAG_TEST_FHR(up
->flags
)) {
514 * No if channel, but upstream we are at the RP.
516 * This could be a anycast RP too and we may
517 * not have received a register packet from
518 * the source here at all. So gracefully
519 * bow out of doing a nexthop lookup and
520 * setting the SPTBIT to true
522 if (up
->upstream_register
.s_addr
!= INADDR_ANY
&&
523 pim_nexthop_lookup(pim_ifp
->pim
, &source
,
524 up
->upstream_register
, 0)) {
525 pim_register_stop_send(source
.interface
, &sg
,
526 pim_ifp
->primary_address
,
527 up
->upstream_register
);
528 up
->sptbit
= PIM_UPSTREAM_SPTBIT_TRUE
;
531 pim_upstream_inherited_olist(pim_ifp
->pim
, up
);
532 if (!up
->channel_oil
->installed
)
533 pim_upstream_mroute_add(up
->channel_oil
,
536 if (I_am_RP(pim_ifp
->pim
, up
->sg
.grp
)) {
537 if (pim_nexthop_lookup(pim_ifp
->pim
, &source
,
538 up
->upstream_register
,
540 pim_register_stop_send(
541 source
.interface
, &sg
,
542 pim_ifp
->primary_address
,
543 up
->upstream_register
);
544 up
->sptbit
= PIM_UPSTREAM_SPTBIT_TRUE
;
546 pim_upstream_keep_alive_timer_start(
547 up
, pim_ifp
->pim
->keep_alive_time
);
548 pim_upstream_inherited_olist(pim_ifp
->pim
, up
);
549 pim_mroute_msg_wholepkt(fd
, ifp
, buf
);
555 if (pim_if_connected_to_source(ifp
, sg
.src
)) {
556 up
= pim_upstream_add(pim_ifp
->pim
, &sg
, ifp
,
557 PIM_UPSTREAM_FLAG_MASK_FHR
, __func__
,
560 if (PIM_DEBUG_MROUTE
)
562 "%s: WRONGVIF%s unable to create upstream on interface",
563 pim_str_sg_dump(&sg
), ifp
->name
);
566 PIM_UPSTREAM_FLAG_SET_SRC_STREAM(up
->flags
);
567 pim_upstream_keep_alive_timer_start(
568 up
, pim_ifp
->pim
->keep_alive_time
);
569 up
->channel_oil
->cc
.pktcnt
++;
570 pim_register_join(up
);
571 pim_upstream_inherited_olist(pim_ifp
->pim
, up
);
572 if (!up
->channel_oil
->installed
)
573 pim_upstream_mroute_add(up
->channel_oil
, __func__
);
575 // Send the packet to the RP
576 pim_mroute_msg_wholepkt(fd
, ifp
, buf
);
578 up
= pim_upstream_add(pim_ifp
->pim
, &sg
, ifp
,
579 PIM_UPSTREAM_FLAG_MASK_SRC_NOCACHE
,
581 if (!up
->channel_oil
->installed
)
582 pim_upstream_mroute_add(up
->channel_oil
, __func__
);
588 static int pim_mroute_msg(struct pim_instance
*pim
, const char *buf
,
589 int buf_size
, ifindex_t ifindex
)
591 struct interface
*ifp
;
592 struct pim_interface
*pim_ifp
;
593 const struct ip
*ip_hdr
;
594 const struct igmpmsg
*msg
;
595 struct in_addr ifaddr
;
596 struct gm_sock
*igmp
;
597 const struct prefix
*connected_src
;
599 if (buf_size
< (int)sizeof(struct ip
))
602 ip_hdr
= (const struct ip
*)buf
;
604 if (ip_hdr
->ip_p
== IPPROTO_IGMP
) {
606 /* We have the IP packet but we do not know which interface this
608 * received on. Find the interface that is on the same subnet as
612 ifp
= if_lookup_by_index(ifindex
, pim
->vrf
->vrf_id
);
614 if (!ifp
|| !ifp
->info
)
617 connected_src
= pim_if_connected_to_source(ifp
, ip_hdr
->ip_src
);
619 if (!connected_src
) {
620 if (PIM_DEBUG_IGMP_PACKETS
) {
621 zlog_debug("Recv IGMP packet on interface: %s from a non-connected source: %pI4",
622 ifp
->name
, &ip_hdr
->ip_src
);
628 ifaddr
= connected_src
->u
.prefix4
;
629 igmp
= pim_igmp_sock_lookup_ifaddr(pim_ifp
->socket_list
,
632 if (PIM_DEBUG_IGMP_PACKETS
) {
634 "%s(%s): igmp kernel upcall on %s(%p) for %pI4 -> %pI4",
635 __func__
, pim
->vrf
->name
, ifp
->name
, igmp
,
636 &ip_hdr
->ip_src
, &ip_hdr
->ip_dst
);
639 pim_igmp_packet(igmp
, (char *)buf
, buf_size
);
640 else if (PIM_DEBUG_IGMP_PACKETS
) {
641 zlog_debug("No IGMP socket on interface: %s with connected source: %pFX",
642 ifp
->name
, connected_src
);
644 } else if (ip_hdr
->ip_p
) {
645 if (PIM_DEBUG_MROUTE_DETAIL
) {
647 "%s: no kernel upcall proto=%d src: %pI4 dst: %pI4 msg_size=%d",
648 __func__
, ip_hdr
->ip_p
, &ip_hdr
->ip_src
, &ip_hdr
->ip_dst
,
653 msg
= (const struct igmpmsg
*)buf
;
655 ifp
= pim_if_find_by_vif_index(pim
, msg
->im_vif
);
659 if (PIM_DEBUG_MROUTE
) {
661 "%s: pim kernel upcall %s type=%d ip_p=%d from fd=%d for (S,G)=(%pI4,%pI4) on %s vifi=%d size=%d",
662 __func__
, igmpmsgtype2str
[msg
->im_msgtype
],
663 msg
->im_msgtype
, ip_hdr
->ip_p
,
664 pim
->mroute_socket
, &msg
->im_src
, &msg
->im_dst
, ifp
->name
,
665 msg
->im_vif
, buf_size
);
668 switch (msg
->im_msgtype
) {
669 case IGMPMSG_WRONGVIF
:
670 return pim_mroute_msg_wrongvif(pim
->mroute_socket
, ifp
,
672 case IGMPMSG_NOCACHE
:
673 return pim_mroute_msg_nocache(pim
->mroute_socket
, ifp
,
675 case IGMPMSG_WHOLEPKT
:
676 return pim_mroute_msg_wholepkt(pim
->mroute_socket
, ifp
,
678 case IGMPMSG_WRVIFWHOLE
:
679 return pim_mroute_msg_wrvifwhole(
680 pim
->mroute_socket
, ifp
, (const char *)msg
);
689 static int mroute_read(struct thread
*t
)
691 struct pim_instance
*pim
;
692 static long long count
;
701 rd
= pim_socket_recvfromto(pim
->mroute_socket
, (uint8_t *)buf
,
702 sizeof(buf
), NULL
, NULL
, NULL
, NULL
,
707 if (errno
== EWOULDBLOCK
|| errno
== EAGAIN
)
711 "%s: failure reading rd=%d: fd=%d: errno=%d: %s",
712 __func__
, rd
, pim
->mroute_socket
, errno
,
713 safe_strerror(errno
));
717 result
= pim_mroute_msg(pim
, buf
, rd
, ifindex
);
720 if (count
% router
->packet_process
== 0)
730 static void mroute_read_on(struct pim_instance
*pim
)
732 thread_add_read(router
->master
, mroute_read
, pim
, pim
->mroute_socket
,
736 static void mroute_read_off(struct pim_instance
*pim
)
738 THREAD_OFF(pim
->thread
);
741 int pim_mroute_socket_enable(struct pim_instance
*pim
)
745 frr_with_privs(&pimd_privs
) {
747 fd
= socket(AF_INET
, SOCK_RAW
, IPPROTO_IGMP
);
750 zlog_warn("Could not create mroute socket: errno=%d: %s",
752 safe_strerror(errno
));
756 #ifdef SO_BINDTODEVICE
757 if (pim
->vrf
->vrf_id
!= VRF_DEFAULT
758 && setsockopt(fd
, SOL_SOCKET
, SO_BINDTODEVICE
,
759 pim
->vrf
->name
, strlen(pim
->vrf
->name
))) {
760 zlog_warn("Could not setsockopt SO_BINDTODEVICE: %s",
761 safe_strerror(errno
));
769 pim
->mroute_socket
= fd
;
770 if (pim_mroute_set(pim
, 1)) {
772 "Could not enable mroute on socket fd=%d: errno=%d: %s",
773 fd
, errno
, safe_strerror(errno
));
775 pim
->mroute_socket
= -1;
779 pim
->mroute_socket_creation
= pim_time_monotonic_sec();
786 int pim_mroute_socket_disable(struct pim_instance
*pim
)
788 if (pim_mroute_set(pim
, 0)) {
790 "Could not disable mroute on socket fd=%d: errno=%d: %s",
791 pim
->mroute_socket
, errno
, safe_strerror(errno
));
795 if (close(pim
->mroute_socket
)) {
796 zlog_warn("Failure closing mroute socket: fd=%d errno=%d: %s",
797 pim
->mroute_socket
, errno
, safe_strerror(errno
));
801 mroute_read_off(pim
);
802 pim
->mroute_socket
= -1;
808 For each network interface (e.g., physical or a virtual tunnel) that
809 would be used for multicast forwarding, a corresponding multicast
810 interface must be added to the kernel.
812 int pim_mroute_add_vif(struct interface
*ifp
, struct in_addr ifaddr
,
815 struct pim_interface
*pim_ifp
= ifp
->info
;
819 if (PIM_DEBUG_MROUTE
)
820 zlog_debug("%s: Add Vif %d (%s[%s])", __func__
,
821 pim_ifp
->mroute_vif_index
, ifp
->name
,
822 pim_ifp
->pim
->vrf
->name
);
824 memset(&vc
, 0, sizeof(vc
));
825 vc
.vifc_vifi
= pim_ifp
->mroute_vif_index
;
826 #ifdef VIFF_USE_IFINDEX
827 vc
.vifc_lcl_ifindex
= ifp
->ifindex
;
829 if (ifaddr
.s_addr
== INADDR_ANY
) {
831 "%s: unnumbered interfaces are not supported on this platform",
835 memcpy(&vc
.vifc_lcl_addr
, &ifaddr
, sizeof(vc
.vifc_lcl_addr
));
837 vc
.vifc_flags
= flags
;
838 vc
.vifc_threshold
= PIM_MROUTE_MIN_TTL
;
839 vc
.vifc_rate_limit
= 0;
841 #ifdef PIM_DVMRP_TUNNEL
842 if (vc
.vifc_flags
& VIFF_TUNNEL
) {
843 memcpy(&vc
.vifc_rmt_addr
, &vif_remote_addr
,
844 sizeof(vc
.vifc_rmt_addr
));
848 err
= setsockopt(pim_ifp
->pim
->mroute_socket
, IPPROTO_IP
, MRT_ADD_VIF
,
849 (void *)&vc
, sizeof(vc
));
851 char ifaddr_str
[INET_ADDRSTRLEN
];
853 pim_inet4_dump("<ifaddr?>", ifaddr
, ifaddr_str
,
857 "%s: failure: setsockopt(fd=%d,IPPROTO_IP,MRT_ADD_VIF,vif_index=%d,ifaddr=%s,flag=%d): errno=%d: %s",
858 __func__
, pim_ifp
->pim
->mroute_socket
, ifp
->ifindex
,
859 ifaddr_str
, flags
, errno
, safe_strerror(errno
));
866 int pim_mroute_del_vif(struct interface
*ifp
)
868 struct pim_interface
*pim_ifp
= ifp
->info
;
872 if (PIM_DEBUG_MROUTE
)
873 zlog_debug("%s: Del Vif %d (%s[%s])", __func__
,
874 pim_ifp
->mroute_vif_index
, ifp
->name
,
875 pim_ifp
->pim
->vrf
->name
);
877 memset(&vc
, 0, sizeof(vc
));
878 vc
.vifc_vifi
= pim_ifp
->mroute_vif_index
;
880 err
= setsockopt(pim_ifp
->pim
->mroute_socket
, IPPROTO_IP
, MRT_DEL_VIF
,
881 (void *)&vc
, sizeof(vc
));
884 "%s %s: failure: setsockopt(fd=%d,IPPROTO_IP,MRT_DEL_VIF,vif_index=%d): errno=%d: %s",
885 __FILE__
, __func__
, pim_ifp
->pim
->mroute_socket
,
886 pim_ifp
->mroute_vif_index
, errno
, safe_strerror(errno
));
894 * Prevent creating MFC entry with OIF=IIF.
896 * This is a protection against implementation mistakes.
898 * PIM protocol implicitely ensures loopfree multicast topology.
900 * IGMP must be protected against adding looped MFC entries created
901 * by both source and receiver attached to the same interface. See
903 * We shall allow igmp to create upstream when it is DR for the intf.
904 * Assume RP reachable via non DR.
906 bool pim_mroute_allow_iif_in_oil(struct channel_oil
*c_oil
,
909 #ifdef PIM_ENFORCE_LOOPFREE_MFC
910 struct interface
*ifp_out
;
911 struct pim_interface
*pim_ifp
;
914 PIM_UPSTREAM_FLAG_TEST_ALLOW_IIF_IN_OIL(c_oil
->up
->flags
))
917 ifp_out
= pim_if_find_by_vif_index(c_oil
->pim
, oif_index
);
920 pim_ifp
= ifp_out
->info
;
923 if ((c_oil
->oif_flags
[oif_index
] & PIM_OIF_FLAG_PROTO_IGMP
) &&
924 PIM_I_am_DR(pim_ifp
))
933 static inline void pim_mroute_copy(struct mfcctl
*oil
,
934 struct channel_oil
*c_oil
)
938 oil
->mfcc_origin
= c_oil
->oil
.mfcc_origin
;
939 oil
->mfcc_mcastgrp
= c_oil
->oil
.mfcc_mcastgrp
;
940 oil
->mfcc_parent
= c_oil
->oil
.mfcc_parent
;
942 for (i
= 0; i
< MAXVIFS
; ++i
) {
943 if ((oil
->mfcc_parent
== i
) &&
944 !pim_mroute_allow_iif_in_oil(c_oil
, i
)) {
945 oil
->mfcc_ttls
[i
] = 0;
949 if (c_oil
->oif_flags
[i
] & PIM_OIF_FLAG_MUTE
)
950 oil
->mfcc_ttls
[i
] = 0;
952 oil
->mfcc_ttls
[i
] = c_oil
->oil
.mfcc_ttls
[i
];
956 /* This function must not be called directly 0
957 * use pim_upstream_mroute_add or pim_static_mroute_add instead
959 static int pim_mroute_add(struct channel_oil
*c_oil
, const char *name
)
961 struct pim_instance
*pim
= c_oil
->pim
;
962 struct mfcctl tmp_oil
= { {0} };
965 pim
->mroute_add_last
= pim_time_monotonic_sec();
966 ++pim
->mroute_add_events
;
968 /* Copy the oil to a temporary structure to fixup (without need to
969 * later restore) before sending the mroute add to the dataplane
971 pim_mroute_copy(&tmp_oil
, c_oil
);
973 /* The linux kernel *expects* the incoming
974 * vif to be part of the outgoing list
975 * in the case of a (*,G).
977 if (c_oil
->oil
.mfcc_origin
.s_addr
== INADDR_ANY
) {
978 tmp_oil
.mfcc_ttls
[c_oil
->oil
.mfcc_parent
] = 1;
982 * If we have an unresolved cache entry for the S,G
983 * it is owned by the pimreg for the incoming IIF
984 * So set pimreg as the IIF temporarily to cause
985 * the packets to be forwarded. Then set it
986 * to the correct IIF afterwords.
988 if (!c_oil
->installed
&& c_oil
->oil
.mfcc_origin
.s_addr
!= INADDR_ANY
989 && c_oil
->oil
.mfcc_parent
!= 0) {
990 tmp_oil
.mfcc_parent
= 0;
992 err
= setsockopt(pim
->mroute_socket
, IPPROTO_IP
, MRT_ADD_MFC
,
993 &tmp_oil
, sizeof(tmp_oil
));
995 if (!err
&& !c_oil
->installed
996 && c_oil
->oil
.mfcc_origin
.s_addr
!= INADDR_ANY
997 && c_oil
->oil
.mfcc_parent
!= 0) {
998 tmp_oil
.mfcc_parent
= c_oil
->oil
.mfcc_parent
;
999 err
= setsockopt(pim
->mroute_socket
, IPPROTO_IP
, MRT_ADD_MFC
,
1000 &tmp_oil
, sizeof(tmp_oil
));
1005 "%s %s: failure: setsockopt(fd=%d,IPPROTO_IP,MRT_ADD_MFC): errno=%d: %s",
1006 __FILE__
, __func__
, pim
->mroute_socket
, errno
,
1007 safe_strerror(errno
));
1011 if (PIM_DEBUG_MROUTE
) {
1013 zlog_debug("%s(%s), vrf %s Added Route: %s", __func__
, name
,
1015 pim_channel_oil_dump(c_oil
, buf
, sizeof(buf
)));
1018 if (!c_oil
->installed
) {
1019 c_oil
->installed
= 1;
1020 c_oil
->mroute_creation
= pim_time_monotonic_sec();
1026 static int pim_upstream_get_mroute_iif(struct channel_oil
*c_oil
,
1029 vifi_t iif
= MAXVIFS
;
1030 struct interface
*ifp
= NULL
;
1031 struct pim_interface
*pim_ifp
;
1032 struct pim_upstream
*up
= c_oil
->up
;
1035 if (PIM_UPSTREAM_FLAG_TEST_USE_RPT(up
->flags
)) {
1037 ifp
= up
->parent
->rpf
.source_nexthop
.interface
;
1039 ifp
= up
->rpf
.source_nexthop
.interface
;
1042 pim_ifp
= (struct pim_interface
*)ifp
->info
;
1044 iif
= pim_ifp
->mroute_vif_index
;
1050 static int pim_upstream_mroute_update(struct channel_oil
*c_oil
,
1055 if (c_oil
->oil
.mfcc_parent
>= MAXVIFS
) {
1056 /* the c_oil cannot be installed as a mroute yet */
1057 if (PIM_DEBUG_MROUTE
)
1059 "%s(%s) %s mroute not ready to be installed; %s",
1061 pim_channel_oil_dump(c_oil
, buf
,
1064 "uninstall" : "skip");
1065 /* if already installed flush it out as we are going to stop
1066 * updates to it leaving it in a stale state
1068 if (c_oil
->installed
)
1069 pim_mroute_del(c_oil
, name
);
1070 /* return success (skipped) */
1074 return pim_mroute_add(c_oil
, name
);
1077 /* IIF associated with SGrpt entries are re-evaluated when the parent
1078 * (*,G) entries IIF changes
1080 static void pim_upstream_all_sources_iif_update(struct pim_upstream
*up
)
1082 struct listnode
*listnode
;
1083 struct pim_upstream
*child
;
1085 for (ALL_LIST_ELEMENTS_RO(up
->sources
, listnode
,
1087 if (PIM_UPSTREAM_FLAG_TEST_USE_RPT(child
->flags
))
1088 pim_upstream_mroute_iif_update(child
->channel_oil
,
1093 /* In the case of "PIM state machine" added mroutes an upstream entry
1094 * must be present to decide on the SPT-forwarding vs. RPT-forwarding.
1096 int pim_upstream_mroute_add(struct channel_oil
*c_oil
, const char *name
)
1100 iif
= pim_upstream_get_mroute_iif(c_oil
, name
);
1102 if (c_oil
->oil
.mfcc_parent
!= iif
) {
1103 c_oil
->oil
.mfcc_parent
= iif
;
1104 if (c_oil
->oil
.mfcc_origin
.s_addr
== INADDR_ANY
&&
1106 pim_upstream_all_sources_iif_update(c_oil
->up
);
1108 c_oil
->oil
.mfcc_parent
= iif
;
1111 return pim_upstream_mroute_update(c_oil
, name
);
1114 /* Look for IIF changes and update the dateplane entry only if the IIF
1117 int pim_upstream_mroute_iif_update(struct channel_oil
*c_oil
, const char *name
)
1122 iif
= pim_upstream_get_mroute_iif(c_oil
, name
);
1123 if (c_oil
->oil
.mfcc_parent
== iif
) {
1127 c_oil
->oil
.mfcc_parent
= iif
;
1129 if (c_oil
->oil
.mfcc_origin
.s_addr
== INADDR_ANY
&&
1131 pim_upstream_all_sources_iif_update(c_oil
->up
);
1133 if (PIM_DEBUG_MROUTE_DETAIL
)
1134 zlog_debug("%s(%s) %s mroute iif update %d",
1136 pim_channel_oil_dump(c_oil
, buf
,
1138 /* XXX: is this hack needed? */
1139 c_oil
->oil_inherited_rescan
= 1;
1140 return pim_upstream_mroute_update(c_oil
, name
);
1143 int pim_static_mroute_add(struct channel_oil
*c_oil
, const char *name
)
1145 return pim_mroute_add(c_oil
, name
);
1148 void pim_static_mroute_iif_update(struct channel_oil
*c_oil
,
1149 int input_vif_index
,
1152 if (c_oil
->oil
.mfcc_parent
== input_vif_index
)
1155 c_oil
->oil
.mfcc_parent
= input_vif_index
;
1156 if (input_vif_index
== MAXVIFS
)
1157 pim_mroute_del(c_oil
, name
);
1159 pim_static_mroute_add(c_oil
, name
);
1162 int pim_mroute_del(struct channel_oil
*c_oil
, const char *name
)
1164 struct pim_instance
*pim
= c_oil
->pim
;
1167 pim
->mroute_del_last
= pim_time_monotonic_sec();
1168 ++pim
->mroute_del_events
;
1170 if (!c_oil
->installed
) {
1171 if (PIM_DEBUG_MROUTE
) {
1174 "%s %s: vifi %d for route is %s not installed, do not need to send del req. ",
1175 __FILE__
, __func__
, c_oil
->oil
.mfcc_parent
,
1176 pim_channel_oil_dump(c_oil
, buf
, sizeof(buf
)));
1181 err
= setsockopt(pim
->mroute_socket
, IPPROTO_IP
, MRT_DEL_MFC
,
1182 &c_oil
->oil
, sizeof(c_oil
->oil
));
1184 if (PIM_DEBUG_MROUTE
)
1186 "%s %s: failure: setsockopt(fd=%d,IPPROTO_IP,MRT_DEL_MFC): errno=%d: %s",
1187 __FILE__
, __func__
, pim
->mroute_socket
, errno
,
1188 safe_strerror(errno
));
1192 if (PIM_DEBUG_MROUTE
) {
1194 zlog_debug("%s(%s), vrf %s Deleted Route: %s", __func__
, name
,
1196 pim_channel_oil_dump(c_oil
, buf
, sizeof(buf
)));
1199 // Reset kernel installed flag
1200 c_oil
->installed
= 0;
1205 void pim_mroute_update_counters(struct channel_oil
*c_oil
)
1207 struct pim_instance
*pim
= c_oil
->pim
;
1208 struct sioc_sg_req sgreq
;
1210 c_oil
->cc
.oldpktcnt
= c_oil
->cc
.pktcnt
;
1211 c_oil
->cc
.oldbytecnt
= c_oil
->cc
.bytecnt
;
1212 c_oil
->cc
.oldwrong_if
= c_oil
->cc
.wrong_if
;
1214 if (!c_oil
->installed
) {
1215 c_oil
->cc
.lastused
= 100 * pim
->keep_alive_time
;
1216 if (PIM_DEBUG_MROUTE
) {
1217 struct prefix_sg sg
;
1219 sg
.src
= c_oil
->oil
.mfcc_origin
;
1220 sg
.grp
= c_oil
->oil
.mfcc_mcastgrp
;
1222 "Channel%s is not installed no need to collect data from kernel",
1223 pim_str_sg_dump(&sg
));
1228 memset(&sgreq
, 0, sizeof(sgreq
));
1229 sgreq
.src
= c_oil
->oil
.mfcc_origin
;
1230 sgreq
.grp
= c_oil
->oil
.mfcc_mcastgrp
;
1232 pim_zlookup_sg_statistics(c_oil
);
1233 if (ioctl(pim
->mroute_socket
, SIOCGETSGCNT
, &sgreq
)) {
1234 struct prefix_sg sg
;
1236 sg
.src
= c_oil
->oil
.mfcc_origin
;
1237 sg
.grp
= c_oil
->oil
.mfcc_mcastgrp
;
1239 zlog_warn("ioctl(SIOCGETSGCNT=%lu) failure for (S,G)=%s: errno=%d: %s",
1240 (unsigned long)SIOCGETSGCNT
, pim_str_sg_dump(&sg
),
1241 errno
, safe_strerror(errno
));
1245 c_oil
->cc
.pktcnt
= sgreq
.pktcnt
;
1246 c_oil
->cc
.bytecnt
= sgreq
.bytecnt
;
1247 c_oil
->cc
.wrong_if
= sgreq
.wrong_if
;