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
34 #include "pim_zebra.h"
35 #include "pim_iface.h"
41 #include "pim_zlookup.h"
42 #include "pim_ifchannel.h"
44 #include "pim_igmpv3.h"
45 #include "pim_jp_agg.h"
48 #include "pim_vxlan.h"
51 #undef PIM_DEBUG_IFADDR_DUMP
52 #define PIM_DEBUG_IFADDR_DUMP
54 struct zclient
*zclient
;
57 /* Router-id update message from zebra. */
58 static int pim_router_id_update_zebra(ZAPI_CALLBACK_ARGS
)
60 struct prefix router_id
;
62 zebra_router_id_update_read(zclient
->ibuf
, &router_id
);
67 static int pim_zebra_interface_vrf_update(ZAPI_CALLBACK_ARGS
)
69 struct interface
*ifp
;
72 ifp
= zebra_interface_vrf_update_read(zclient
->ibuf
, vrf_id
,
78 zlog_debug("%s: %s updating from %u to %u", __func__
, ifp
->name
,
81 if_update_to_new_vrf(ifp
, new_vrf_id
);
86 #ifdef PIM_DEBUG_IFADDR_DUMP
87 static void dump_if_address(struct interface
*ifp
)
89 struct connected
*ifc
;
90 struct listnode
*node
;
92 zlog_debug("%s %s: interface %s addresses:", __FILE__
, __func__
,
95 for (ALL_LIST_ELEMENTS_RO(ifp
->connected
, node
, ifc
)) {
96 struct prefix
*p
= ifc
->address
;
98 if (p
->family
!= AF_INET
)
101 zlog_debug("%s %s: interface %s address %pI4 %s", __FILE__
,
102 __func__
, ifp
->name
, &p
->u
.prefix4
,
103 CHECK_FLAG(ifc
->flags
, ZEBRA_IFA_SECONDARY
)
110 static int pim_zebra_if_address_add(ZAPI_CALLBACK_ARGS
)
114 struct pim_interface
*pim_ifp
;
115 struct pim_instance
*pim
;
118 zebra api notifies address adds/dels events by using the same call
119 interface_add_read below, see comments in lib/zclient.c
121 zebra_interface_address_read(ZEBRA_INTERFACE_ADDRESS_ADD, ...)
122 will add address to interface list by calling
123 connected_add_by_prefix()
125 c
= zebra_interface_address_read(cmd
, zclient
->ibuf
, vrf_id
);
129 pim_ifp
= c
->ifp
->info
;
132 if (PIM_DEBUG_ZEBRA
) {
133 zlog_debug("%s: %s(%u) connected IP address %pFX flags %u %s",
134 __func__
, c
->ifp
->name
, vrf_id
, p
, c
->flags
,
135 CHECK_FLAG(c
->flags
, ZEBRA_IFA_SECONDARY
)
139 #ifdef PIM_DEBUG_IFADDR_DUMP
140 dump_if_address(c
->ifp
);
144 if (!CHECK_FLAG(c
->flags
, ZEBRA_IFA_SECONDARY
)) {
145 /* trying to add primary address */
147 struct in_addr primary_addr
= pim_find_primary_addr(c
->ifp
);
148 if (p
->family
!= AF_INET
149 || primary_addr
.s_addr
!= p
->u
.prefix4
.s_addr
) {
152 "%s: %s : forcing secondary flag on %pFX",
153 __func__
, c
->ifp
->name
, p
);
154 SET_FLAG(c
->flags
, ZEBRA_IFA_SECONDARY
);
160 pim
= pim_get_pim_instance(vrf_id
);
163 pim_rp_check_on_if_add(pim_ifp
);
166 if (if_is_loopback(c
->ifp
)) {
167 struct vrf
*vrf
= vrf_lookup_by_id(vrf_id
);
168 struct interface
*ifp
;
170 FOR_ALL_INTERFACES (vrf
, ifp
) {
171 if (!if_is_loopback(ifp
) && if_is_operative(ifp
))
172 pim_if_addr_add_all(ifp
);
179 static int pim_zebra_if_address_del(ZAPI_CALLBACK_ARGS
)
183 struct vrf
*vrf
= vrf_lookup_by_id(vrf_id
);
184 struct pim_instance
*pim
;
191 zebra api notifies address adds/dels events by using the same call
192 interface_add_read below, see comments in lib/zclient.c
194 zebra_interface_address_read(ZEBRA_INTERFACE_ADDRESS_DELETE, ...)
195 will remove address from interface list by calling
196 connected_delete_by_prefix()
198 c
= zebra_interface_address_read(cmd
, zclient
->ibuf
, vrf_id
);
203 if (p
->family
== AF_INET
) {
204 if (PIM_DEBUG_ZEBRA
) {
206 "%s: %s(%u) disconnected IP address %pFX flags %u %s",
207 __func__
, c
->ifp
->name
, vrf_id
, p
, c
->flags
,
208 CHECK_FLAG(c
->flags
, ZEBRA_IFA_SECONDARY
)
212 #ifdef PIM_DEBUG_IFADDR_DUMP
213 dump_if_address(c
->ifp
);
217 pim_if_addr_del(c
, 0);
219 pim_i_am_rp_re_evaluate(pim
);
226 void pim_zebra_update_all_interfaces(struct pim_instance
*pim
)
228 struct interface
*ifp
;
230 FOR_ALL_INTERFACES (pim
->vrf
, ifp
) {
231 struct pim_interface
*pim_ifp
= ifp
->info
;
232 struct pim_iface_upstream_switch
*us
;
233 struct listnode
*node
;
238 for (ALL_LIST_ELEMENTS_RO(pim_ifp
->upstream_switch_list
, node
,
242 rpf
.source_nexthop
.interface
= ifp
;
243 rpf
.rpf_addr
.u
.prefix4
= us
->address
;
244 pim_joinprune_send(&rpf
, us
->us
);
245 pim_jp_agg_clear_group(us
->us
);
250 void pim_zebra_upstream_rpf_changed(struct pim_instance
*pim
,
251 struct pim_upstream
*up
,
254 if (old
->source_nexthop
.interface
) {
255 struct pim_neighbor
*nbr
;
257 nbr
= pim_neighbor_find(old
->source_nexthop
.interface
,
258 old
->rpf_addr
.u
.prefix4
);
260 pim_jp_agg_remove_group(nbr
->upstream_jp_agg
, up
, nbr
);
263 * We have detected a case where we might need
264 * to rescan the inherited o_list so do it.
266 if (up
->channel_oil
->oil_inherited_rescan
) {
267 pim_upstream_inherited_olist_decide(pim
, up
);
268 up
->channel_oil
->oil_inherited_rescan
= 0;
271 if (up
->join_state
== PIM_UPSTREAM_JOINED
) {
273 * If we come up real fast we can be here
274 * where the mroute has not been installed
277 if (!up
->channel_oil
->installed
)
278 pim_upstream_mroute_add(up
->channel_oil
,
282 * RFC 4601: 4.5.7. Sending (S,G)
283 * Join/Prune Messages
285 * Transitions from Joined State
287 * RPF'(S,G) changes not due to an Assert
289 * The upstream (S,G) state machine remains
290 * in Joined state. Send Join(S,G) to the new
291 * upstream neighbor, which is the new value
292 * of RPF'(S,G). Send Prune(S,G) to the old
293 * upstream neighbor, which is the old value
294 * of RPF'(S,G). Set the Join Timer (JT) to
295 * expire after t_periodic seconds.
297 pim_jp_agg_switch_interface(old
, &up
->rpf
, up
);
299 pim_upstream_join_timer_restart(up
, old
);
300 } /* up->join_state == PIM_UPSTREAM_JOINED */
305 * We have detected a case where we might need
306 * to rescan the inherited o_list so do it.
308 if (up
->channel_oil
->oil_inherited_rescan
) {
309 pim_upstream_inherited_olist_decide(pim
, up
);
310 up
->channel_oil
->oil_inherited_rescan
= 0;
313 if (up
->join_state
== PIM_UPSTREAM_JOINED
)
314 pim_jp_agg_switch_interface(old
, &up
->rpf
, up
);
316 if (!up
->channel_oil
->installed
)
317 pim_upstream_mroute_add(up
->channel_oil
, __func__
);
320 /* FIXME can join_desired actually be changed by pim_rpf_update()
321 * returning PIM_RPF_CHANGED ?
323 pim_upstream_update_join_desired(pim
, up
);
326 static int pim_zebra_vxlan_sg_proc(ZAPI_CALLBACK_ARGS
)
329 struct pim_instance
*pim
;
332 pim
= pim_get_pim_instance(vrf_id
);
339 sg
.prefixlen
= stream_getl(s
);
340 stream_get(&sg
.src
.s_addr
, s
, sg
.prefixlen
);
341 stream_get(&sg
.grp
.s_addr
, s
, sg
.prefixlen
);
343 if (PIM_DEBUG_ZEBRA
) {
344 char sg_str
[PIM_SG_LEN
];
346 pim_str_sg_set(&sg
, sg_str
);
347 zlog_debug("%u:recv SG %s %s", vrf_id
,
348 (cmd
== ZEBRA_VXLAN_SG_ADD
)?"add":"del",
352 if (cmd
== ZEBRA_VXLAN_SG_ADD
)
353 pim_vxlan_sg_add(pim
, &sg
);
355 pim_vxlan_sg_del(pim
, &sg
);
360 static void pim_zebra_vxlan_replay(void)
362 struct stream
*s
= NULL
;
365 if (!zclient
|| zclient
->sock
< 0)
371 zclient_create_header(s
, ZEBRA_VXLAN_SG_REPLAY
, VRF_DEFAULT
);
372 stream_putw_at(s
, 0, stream_get_endp(s
));
374 zclient_send_message(zclient
);
377 void pim_scan_oil(struct pim_instance
*pim
)
379 struct channel_oil
*c_oil
;
381 pim
->scan_oil_last
= pim_time_monotonic_sec();
382 ++pim
->scan_oil_events
;
384 frr_each (rb_pim_oil
, &pim
->channel_oil_head
, c_oil
)
385 pim_upstream_mroute_iif_update(c_oil
, __func__
);
388 static int on_rpf_cache_refresh(struct thread
*t
)
390 struct pim_instance
*pim
= THREAD_ARG(t
);
392 /* update kernel multicast forwarding cache (MFC) */
395 pim
->rpf_cache_refresh_last
= pim_time_monotonic_sec();
396 ++pim
->rpf_cache_refresh_events
;
398 // It is called as part of pim_neighbor_add
403 void sched_rpf_cache_refresh(struct pim_instance
*pim
)
405 ++pim
->rpf_cache_refresh_requests
;
407 pim_rpf_set_refresh_time(pim
);
409 if (pim
->rpf_cache_refresher
) {
410 /* Refresh timer is already running */
414 /* Start refresh timer */
416 if (PIM_DEBUG_ZEBRA
) {
417 zlog_debug("%s: triggering %ld msec timer", __func__
,
418 router
->rpf_cache_refresh_delay_msec
);
421 thread_add_timer_msec(router
->master
, on_rpf_cache_refresh
, pim
,
422 router
->rpf_cache_refresh_delay_msec
,
423 &pim
->rpf_cache_refresher
);
426 static void pim_zebra_connected(struct zclient
*zclient
)
428 /* Send the client registration */
429 bfd_client_sendmsg(zclient
, ZEBRA_BFD_CLIENT_REGISTER
, router
->vrf_id
);
431 zclient_send_reg_requests(zclient
, router
->vrf_id
);
433 /* request for VxLAN BUM group addresses */
434 pim_zebra_vxlan_replay();
437 static void pim_zebra_capabilities(struct zclient_capabilities
*cap
)
439 router
->mlag_role
= cap
->role
;
442 static zclient_handler
*const pim_handlers
[] = {
443 [ZEBRA_ROUTER_ID_UPDATE
] = pim_router_id_update_zebra
,
444 [ZEBRA_INTERFACE_ADDRESS_ADD
] = pim_zebra_if_address_add
,
445 [ZEBRA_INTERFACE_ADDRESS_DELETE
] = pim_zebra_if_address_del
,
446 [ZEBRA_INTERFACE_VRF_UPDATE
] = pim_zebra_interface_vrf_update
,
447 [ZEBRA_NEXTHOP_UPDATE
] = pim_parse_nexthop_update
,
449 [ZEBRA_VXLAN_SG_ADD
] = pim_zebra_vxlan_sg_proc
,
450 [ZEBRA_VXLAN_SG_DEL
] = pim_zebra_vxlan_sg_proc
,
452 [ZEBRA_MLAG_PROCESS_UP
] = pim_zebra_mlag_process_up
,
453 [ZEBRA_MLAG_PROCESS_DOWN
] = pim_zebra_mlag_process_down
,
454 [ZEBRA_MLAG_FORWARD_MSG
] = pim_zebra_mlag_handle_msg
,
457 void pim_zebra_init(void)
459 /* Socket for receiving updates from Zebra daemon */
460 zclient
= zclient_new(router
->master
, &zclient_options_default
,
461 pim_handlers
, array_size(pim_handlers
));
463 zclient
->zebra_capabilities
= pim_zebra_capabilities
;
464 zclient
->zebra_connected
= pim_zebra_connected
;
466 zclient_init(zclient
, ZEBRA_ROUTE_PIM
, 0, &pimd_privs
);
467 if (PIM_DEBUG_PIM_TRACE
) {
468 zlog_notice("%s: zclient socket initialized", __func__
);
471 zclient_lookup_new();
474 void igmp_anysource_forward_start(struct pim_instance
*pim
,
475 struct igmp_group
*group
)
477 struct igmp_source
*source
;
478 struct in_addr src_addr
= {.s_addr
= 0};
479 /* Any source (*,G) is forwarded only if mode is EXCLUDE {empty} */
480 assert(group
->group_filtermode_isexcl
);
481 assert(listcount(group
->group_source_list
) < 1);
483 source
= igmp_get_source_by_addr(group
, src_addr
, NULL
);
485 zlog_warn("%s: Failure to create * source", __func__
);
489 igmp_source_forward_start(pim
, source
);
492 void igmp_anysource_forward_stop(struct igmp_group
*group
)
494 struct igmp_source
*source
;
495 struct in_addr star
= {.s_addr
= 0};
497 source
= igmp_find_source_by_addr(group
, star
);
499 igmp_source_forward_stop(source
);
502 static void igmp_source_forward_reevaluate_one(struct pim_instance
*pim
,
503 struct igmp_source
*source
)
506 struct igmp_group
*group
= source
->source_group
;
507 struct pim_ifchannel
*ch
;
509 if ((source
->source_addr
.s_addr
!= INADDR_ANY
)
510 || !IGMP_SOURCE_TEST_FORWARDING(source
->source_flags
))
513 memset(&sg
, 0, sizeof(struct prefix_sg
));
514 sg
.src
= source
->source_addr
;
515 sg
.grp
= group
->group_addr
;
517 ch
= pim_ifchannel_find(group
->interface
, &sg
);
518 if (pim_is_grp_ssm(pim
, group
->group_addr
)) {
519 /* If SSM group withdraw local membership */
521 && (ch
->local_ifmembership
== PIM_IFMEMBERSHIP_INCLUDE
)) {
522 if (PIM_DEBUG_PIM_EVENTS
)
524 "local membership del for %s as G is now SSM",
525 pim_str_sg_dump(&sg
));
526 pim_ifchannel_local_membership_del(group
->interface
,
530 /* If ASM group add local membership */
532 || (ch
->local_ifmembership
== PIM_IFMEMBERSHIP_NOINFO
)) {
533 if (PIM_DEBUG_PIM_EVENTS
)
535 "local membership add for %s as G is now ASM",
536 pim_str_sg_dump(&sg
));
537 pim_ifchannel_local_membership_add(
538 group
->interface
, &sg
, false /*is_vxlan*/);
543 void igmp_source_forward_reevaluate_all(struct pim_instance
*pim
)
545 struct interface
*ifp
;
547 FOR_ALL_INTERFACES (pim
->vrf
, ifp
) {
548 struct pim_interface
*pim_ifp
= ifp
->info
;
549 struct listnode
*grpnode
;
550 struct igmp_group
*grp
;
551 struct pim_ifchannel
*ch
, *ch_temp
;
556 /* scan igmp groups */
557 for (ALL_LIST_ELEMENTS_RO(pim_ifp
->igmp_group_list
, grpnode
,
559 struct listnode
*srcnode
;
560 struct igmp_source
*src
;
562 /* scan group sources */
563 for (ALL_LIST_ELEMENTS_RO(grp
->group_source_list
,
565 igmp_source_forward_reevaluate_one(pim
, src
);
566 } /* scan group sources */
567 } /* scan igmp groups */
569 RB_FOREACH_SAFE (ch
, pim_ifchannel_rb
, &pim_ifp
->ifchannel_rb
,
571 if (pim_is_grp_ssm(pim
, ch
->sg
.grp
)) {
572 if (ch
->sg
.src
.s_addr
== INADDR_ANY
)
573 pim_ifchannel_delete(ch
);
576 } /* scan interfaces */
579 void igmp_source_forward_start(struct pim_instance
*pim
,
580 struct igmp_source
*source
)
582 struct pim_interface
*pim_oif
;
583 struct igmp_group
*group
;
586 int input_iface_vif_index
= 0;
588 memset(&sg
, 0, sizeof(struct prefix_sg
));
589 sg
.src
= source
->source_addr
;
590 sg
.grp
= source
->source_group
->group_addr
;
592 if (PIM_DEBUG_IGMP_TRACE
) {
593 zlog_debug("%s: (S,G)=%s oif=%s fwd=%d", __func__
,
594 pim_str_sg_dump(&sg
),
595 source
->source_group
->interface
->name
,
596 IGMP_SOURCE_TEST_FORWARDING(source
->source_flags
));
599 /* Prevent IGMP interface from installing multicast route multiple
601 if (IGMP_SOURCE_TEST_FORWARDING(source
->source_flags
)) {
605 group
= source
->source_group
;
606 pim_oif
= group
->interface
->info
;
608 if (PIM_DEBUG_IGMP_TRACE
) {
609 zlog_debug("%s: multicast not enabled on oif=%s ?",
611 source
->source_group
->interface
->name
);
616 if (!source
->source_channel_oil
) {
617 struct in_addr vif_source
;
618 struct prefix src
, grp
;
619 struct pim_nexthop nexthop
;
620 struct pim_upstream
*up
= NULL
;
622 if (!pim_rp_set_upstream_addr(pim
, &vif_source
,
623 source
->source_addr
, sg
.grp
)) {
624 /*Create a dummy channel oil */
625 source
->source_channel_oil
=
626 pim_channel_oil_add(pim
, &sg
, __func__
);
630 src
.family
= AF_INET
;
631 src
.prefixlen
= IPV4_MAX_BITLEN
;
632 src
.u
.prefix4
= vif_source
; // RP or Src address
633 grp
.family
= AF_INET
;
634 grp
.prefixlen
= IPV4_MAX_BITLEN
;
635 grp
.u
.prefix4
= sg
.grp
;
637 up
= pim_upstream_find(pim
, &sg
);
639 memcpy(&nexthop
, &up
->rpf
.source_nexthop
,
640 sizeof(struct pim_nexthop
));
641 pim_ecmp_nexthop_lookup(pim
, &nexthop
, &src
,
643 if (nexthop
.interface
)
644 input_iface_vif_index
=
645 pim_if_find_vifindex_by_ifindex(
647 nexthop
.interface
->ifindex
);
649 input_iface_vif_index
=
650 pim_ecmp_fib_lookup_if_vif_index(
653 if (PIM_DEBUG_ZEBRA
) {
654 char buf2
[INET_ADDRSTRLEN
];
656 pim_inet4_dump("<source?>", vif_source
, buf2
,
659 "%s: NHT %s vif_source %s vif_index:%d ",
660 __func__
, pim_str_sg_dump(&sg
), buf2
,
661 input_iface_vif_index
);
664 if (input_iface_vif_index
< 1) {
665 if (PIM_DEBUG_IGMP_TRACE
) {
666 char source_str
[INET_ADDRSTRLEN
];
667 pim_inet4_dump("<source?>",
669 source_str
, sizeof(source_str
));
671 "%s %s: could not find input interface for source %s",
672 __FILE__
, __func__
, source_str
);
674 source
->source_channel_oil
=
675 pim_channel_oil_add(pim
, &sg
, __func__
);
680 * Protect IGMP against adding looped MFC
681 * entries created by both source and receiver
682 * attached to the same interface. See TODO
683 * T22. Block only when the intf is non DR
684 * DR must create upstream.
686 if ((input_iface_vif_index
==
687 pim_oif
->mroute_vif_index
) &&
688 !(PIM_I_am_DR(pim_oif
))) {
689 /* ignore request for looped MFC entry
691 if (PIM_DEBUG_IGMP_TRACE
) {
693 "%s: ignoring request for looped MFC entry (S,G)=%s: oif=%s vif_index=%d",
695 pim_str_sg_dump(&sg
),
698 input_iface_vif_index
);
703 source
->source_channel_oil
=
704 pim_channel_oil_add(pim
, &sg
, __func__
);
705 if (!source
->source_channel_oil
) {
706 if (PIM_DEBUG_IGMP_TRACE
) {
708 "%s %s: could not create OIL for channel (S,G)=%s",
710 pim_str_sg_dump(&sg
));
718 if (PIM_I_am_DR(pim_oif
) || PIM_I_am_DualActive(pim_oif
)) {
719 result
= pim_channel_add_oif(source
->source_channel_oil
,
721 PIM_OIF_FLAG_PROTO_IGMP
, __func__
);
723 if (PIM_DEBUG_MROUTE
) {
724 zlog_warn("%s: add_oif() failed with return=%d",
730 if (PIM_DEBUG_IGMP_TRACE
)
732 "%s: %s was received on %s interface but we are not DR for that interface",
733 __func__
, pim_str_sg_dump(&sg
),
734 group
->interface
->name
);
739 Feed IGMPv3-gathered local membership information into PIM
740 per-interface (S,G) state.
742 if (!pim_ifchannel_local_membership_add(group
->interface
, &sg
,
743 false /*is_vxlan*/)) {
744 if (PIM_DEBUG_MROUTE
)
745 zlog_warn("%s: Failure to add local membership for %s",
746 __func__
, pim_str_sg_dump(&sg
));
748 pim_channel_del_oif(source
->source_channel_oil
,
749 group
->interface
, PIM_OIF_FLAG_PROTO_IGMP
,
754 IGMP_SOURCE_DO_FORWARDING(source
->source_flags
);
758 igmp_source_forward_stop: stop fowarding, but keep the source
759 igmp_source_delete: stop fowarding, and delete the source
761 void igmp_source_forward_stop(struct igmp_source
*source
)
763 struct igmp_group
*group
;
767 memset(&sg
, 0, sizeof(struct prefix_sg
));
768 sg
.src
= source
->source_addr
;
769 sg
.grp
= source
->source_group
->group_addr
;
771 if (PIM_DEBUG_IGMP_TRACE
) {
772 zlog_debug("%s: (S,G)=%s oif=%s fwd=%d", __func__
,
773 pim_str_sg_dump(&sg
),
774 source
->source_group
->interface
->name
,
775 IGMP_SOURCE_TEST_FORWARDING(source
->source_flags
));
778 /* Prevent IGMP interface from removing multicast route multiple
780 if (!IGMP_SOURCE_TEST_FORWARDING(source
->source_flags
)) {
784 group
= source
->source_group
;
787 It appears that in certain circumstances that
788 igmp_source_forward_stop is called when IGMP forwarding
789 was not enabled in oif_flags for this outgoing interface.
790 Possibly because of multiple calls. When that happens, we
791 enter the below if statement and this function returns early
792 which in turn triggers the calling function to assert.
793 Making the call to pim_channel_del_oif and ignoring the return code
794 fixes the issue without ill effect, similar to
795 pim_forward_stop below.
797 result
= pim_channel_del_oif(source
->source_channel_oil
,
798 group
->interface
, PIM_OIF_FLAG_PROTO_IGMP
,
801 if (PIM_DEBUG_IGMP_TRACE
)
803 "%s: pim_channel_del_oif() failed with return=%d",
809 Feed IGMPv3-gathered local membership information into PIM
810 per-interface (S,G) state.
812 pim_ifchannel_local_membership_del(group
->interface
, &sg
);
814 IGMP_SOURCE_DONT_FORWARDING(source
->source_flags
);
817 void pim_forward_start(struct pim_ifchannel
*ch
)
819 struct pim_upstream
*up
= ch
->upstream
;
822 if (PIM_DEBUG_PIM_TRACE
) {
823 char source_str
[INET_ADDRSTRLEN
];
824 char group_str
[INET_ADDRSTRLEN
];
825 char upstream_str
[INET_ADDRSTRLEN
];
827 pim_inet4_dump("<source?>", ch
->sg
.src
, source_str
,
829 pim_inet4_dump("<group?>", ch
->sg
.grp
, group_str
,
831 pim_inet4_dump("<upstream?>", up
->upstream_addr
, upstream_str
,
832 sizeof(upstream_str
));
833 zlog_debug("%s: (S,G)=(%s,%s) oif=%s (%pI4)", __func__
,
834 source_str
, group_str
, ch
->interface
->name
,
838 if (PIM_IF_FLAG_TEST_PROTO_IGMP(ch
->flags
))
839 mask
= PIM_OIF_FLAG_PROTO_IGMP
;
841 if (PIM_IF_FLAG_TEST_PROTO_PIM(ch
->flags
))
842 mask
|= PIM_OIF_FLAG_PROTO_PIM
;
844 pim_channel_add_oif(up
->channel_oil
, ch
->interface
,
848 void pim_forward_stop(struct pim_ifchannel
*ch
, bool install_it
)
850 struct pim_upstream
*up
= ch
->upstream
;
852 if (PIM_DEBUG_PIM_TRACE
) {
853 zlog_debug("%s: (S,G)=%s oif=%s install_it: %d installed: %d",
854 __func__
, ch
->sg_str
, ch
->interface
->name
,
855 install_it
, up
->channel_oil
->installed
);
859 * If a channel is being removed, check to see if we still need
860 * to inherit the interface. If so make sure it is added in
862 if (pim_upstream_evaluate_join_desired_interface(up
, ch
, ch
->parent
))
863 pim_channel_add_oif(up
->channel_oil
, ch
->interface
,
864 PIM_OIF_FLAG_PROTO_PIM
, __func__
);
866 pim_channel_del_oif(up
->channel_oil
, ch
->interface
,
867 PIM_OIF_FLAG_PROTO_PIM
, __func__
);
869 if (install_it
&& !up
->channel_oil
->installed
)
870 pim_upstream_mroute_add(up
->channel_oil
, __func__
);
873 void pim_zebra_zclient_update(struct vty
*vty
)
875 vty_out(vty
, "Zclient update socket: ");
878 vty_out(vty
, "%d failures=%d\n", zclient
->sock
, zclient
->fail
);
880 vty_out(vty
, "<null zclient>\n");
884 struct zclient
*pim_zebra_zclient_get(void)
892 void pim_zebra_interface_set_master(struct interface
*vrf
,
893 struct interface
*ifp
)
895 zclient_interface_set_master(zclient
, vrf
, ifp
);