3 * Copyright (C) 2008 Everton da Silva Marques
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation; either version 2 of the License, or
7 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful, but
10 * WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * General Public License for more details.
14 * You should have received a copy of the GNU General Public License along
15 * with this program; see the file COPYING; if not, write to the Free Software
16 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
33 #include "pim_instance.h"
34 #include "pim_zebra.h"
35 #include "pim_iface.h"
37 #include "pim_mroute.h"
41 #include "pim_neighbor.h"
42 #include "pim_ifchannel.h"
45 #include "pim_ssmpingd.h"
48 #include "pim_jp_agg.h"
50 static void pim_if_igmp_join_del_all(struct interface
*ifp
);
51 static int igmp_join_sock(const char *ifname
, ifindex_t ifindex
,
52 struct in_addr group_addr
,
53 struct in_addr source_addr
);
55 void pim_if_init(struct pim_instance
*pim
)
59 for (i
= 0; i
< MAXVIFS
; i
++)
60 pim
->iface_vif_index
[i
] = 0;
63 void pim_if_terminate(struct pim_instance
*pim
)
65 // Nothing to do at this moment
69 static void *if_list_clean(struct pim_interface
*pim_ifp
)
71 struct pim_ifchannel
*ch
;
73 if (pim_ifp
->igmp_join_list
)
74 list_delete(pim_ifp
->igmp_join_list
);
76 if (pim_ifp
->igmp_socket_list
)
77 list_delete(pim_ifp
->igmp_socket_list
);
79 if (pim_ifp
->pim_neighbor_list
)
80 list_delete(pim_ifp
->pim_neighbor_list
);
82 if (pim_ifp
->upstream_switch_list
)
83 list_delete(pim_ifp
->upstream_switch_list
);
85 if (pim_ifp
->sec_addr_list
)
86 list_delete(pim_ifp
->sec_addr_list
);
88 while ((ch
= RB_ROOT(pim_ifchannel_rb
,
89 &pim_ifp
->ifchannel_rb
)) != NULL
)
90 pim_ifchannel_delete(ch
);
92 XFREE(MTYPE_PIM_INTERFACE
, pim_ifp
);
97 static void pim_sec_addr_free(struct pim_secondary_addr
*sec_addr
)
99 XFREE(MTYPE_PIM_SEC_ADDR
, sec_addr
);
102 static int pim_sec_addr_comp(const void *p1
, const void *p2
)
104 const struct pim_secondary_addr
*sec1
= p1
;
105 const struct pim_secondary_addr
*sec2
= p2
;
107 if (sec1
->addr
.family
== AF_INET
&& sec2
->addr
.family
== AF_INET6
)
110 if (sec1
->addr
.family
== AF_INET6
&& sec2
->addr
.family
== AF_INET
)
113 if (sec1
->addr
.family
== AF_INET
) {
114 if (ntohl(sec1
->addr
.u
.prefix4
.s_addr
)
115 < ntohl(sec2
->addr
.u
.prefix4
.s_addr
))
118 if (ntohl(sec1
->addr
.u
.prefix4
.s_addr
)
119 > ntohl(sec2
->addr
.u
.prefix4
.s_addr
))
122 return memcmp(&sec1
->addr
.u
.prefix6
, &sec2
->addr
.u
.prefix6
,
123 sizeof(struct in6_addr
));
129 struct pim_interface
*pim_if_new(struct interface
*ifp
, int igmp
, int pim
)
131 struct pim_interface
*pim_ifp
;
136 pim_ifp
= XCALLOC(MTYPE_PIM_INTERFACE
, sizeof(*pim_ifp
));
138 zlog_err("PIM XCALLOC(%zu) failure", sizeof(*pim_ifp
));
142 pim_ifp
->options
= 0;
143 pim_ifp
->pim
= pim_get_pim_instance(ifp
->vrf_id
);
144 pim_ifp
->mroute_vif_index
= -1;
146 pim_ifp
->igmp_version
= IGMP_DEFAULT_VERSION
;
147 pim_ifp
->igmp_default_robustness_variable
=
148 IGMP_DEFAULT_ROBUSTNESS_VARIABLE
;
149 pim_ifp
->igmp_default_query_interval
= IGMP_GENERAL_QUERY_INTERVAL
;
150 pim_ifp
->igmp_query_max_response_time_dsec
=
151 IGMP_QUERY_MAX_RESPONSE_TIME_DSEC
;
152 pim_ifp
->igmp_specific_query_max_response_time_dsec
=
153 IGMP_SPECIFIC_QUERY_MAX_RESPONSE_TIME_DSEC
;
156 RFC 3376: 8.3. Query Response Interval
157 The number of seconds represented by the [Query Response Interval]
158 must be less than the [Query Interval].
160 zassert(pim_ifp
->igmp_query_max_response_time_dsec
161 < pim_ifp
->igmp_default_query_interval
);
164 PIM_IF_DO_PIM(pim_ifp
->options
);
166 PIM_IF_DO_IGMP(pim_ifp
->options
);
168 PIM_IF_DO_IGMP_LISTEN_ALLROUTERS(pim_ifp
->options
);
170 pim_ifp
->igmp_join_list
= NULL
;
171 pim_ifp
->igmp_socket_list
= NULL
;
172 pim_ifp
->pim_neighbor_list
= NULL
;
173 pim_ifp
->upstream_switch_list
= NULL
;
174 pim_ifp
->pim_generation_id
= 0;
176 /* list of struct igmp_sock */
177 pim_ifp
->igmp_socket_list
= list_new();
178 if (!pim_ifp
->igmp_socket_list
) {
179 zlog_err("%s: failure: igmp_socket_list=list_new()",
180 __PRETTY_FUNCTION__
);
181 return if_list_clean(pim_ifp
);
183 pim_ifp
->igmp_socket_list
->del
= (void (*)(void *))igmp_sock_free
;
185 /* list of struct pim_neighbor */
186 pim_ifp
->pim_neighbor_list
= list_new();
187 if (!pim_ifp
->pim_neighbor_list
) {
188 zlog_err("%s: failure: pim_neighbor_list=list_new()",
189 __PRETTY_FUNCTION__
);
190 return if_list_clean(pim_ifp
);
192 pim_ifp
->pim_neighbor_list
->del
= (void (*)(void *))pim_neighbor_free
;
194 pim_ifp
->upstream_switch_list
= list_new();
195 if (!pim_ifp
->upstream_switch_list
) {
196 zlog_err("%s: failure: upstream_switch_list=list_new()",
197 __PRETTY_FUNCTION__
);
198 return if_list_clean(pim_ifp
);
200 pim_ifp
->upstream_switch_list
->del
=
201 (void (*)(void *))pim_jp_agg_group_list_free
;
202 pim_ifp
->upstream_switch_list
->cmp
= pim_jp_agg_group_list_cmp
;
204 pim_ifp
->sec_addr_list
= list_new();
205 if (!pim_ifp
->sec_addr_list
) {
206 zlog_err("%s: failure: secondary addresslist",
207 __PRETTY_FUNCTION__
);
209 pim_ifp
->sec_addr_list
->del
= (void (*)(void *))pim_sec_addr_free
;
210 pim_ifp
->sec_addr_list
->cmp
=
211 (int (*)(void *, void *))pim_sec_addr_comp
;
213 RB_INIT(pim_ifchannel_rb
, &pim_ifp
->ifchannel_rb
);
224 void pim_if_delete(struct interface
*ifp
)
226 struct pim_interface
*pim_ifp
;
227 struct pim_ifchannel
*ch
;
233 if (pim_ifp
->igmp_join_list
) {
234 pim_if_igmp_join_del_all(ifp
);
237 pim_ifchannel_delete_all(ifp
);
238 igmp_sock_delete_all(ifp
);
240 pim_neighbor_delete_all(ifp
, "Interface removed from configuration");
244 list_delete(pim_ifp
->igmp_socket_list
);
245 list_delete(pim_ifp
->pim_neighbor_list
);
246 list_delete(pim_ifp
->upstream_switch_list
);
247 list_delete(pim_ifp
->sec_addr_list
);
249 if (pim_ifp
->boundary_oil_plist
)
250 XFREE(MTYPE_PIM_INTERFACE
, pim_ifp
->boundary_oil_plist
);
252 while ((ch
= RB_ROOT(pim_ifchannel_rb
,
253 &pim_ifp
->ifchannel_rb
)) != NULL
)
254 pim_ifchannel_delete(ch
);
256 XFREE(MTYPE_PIM_INTERFACE
, pim_ifp
);
261 void pim_if_update_could_assert(struct interface
*ifp
)
263 struct pim_interface
*pim_ifp
;
264 struct pim_ifchannel
*ch
;
269 RB_FOREACH (ch
, pim_ifchannel_rb
, &pim_ifp
->ifchannel_rb
) {
270 pim_ifchannel_update_could_assert(ch
);
274 static void pim_if_update_my_assert_metric(struct interface
*ifp
)
276 struct pim_interface
*pim_ifp
;
277 struct pim_ifchannel
*ch
;
282 RB_FOREACH (ch
, pim_ifchannel_rb
, &pim_ifp
->ifchannel_rb
) {
283 pim_ifchannel_update_my_assert_metric(ch
);
287 static void pim_addr_change(struct interface
*ifp
)
289 struct pim_interface
*pim_ifp
;
294 pim_if_dr_election(ifp
); /* router's own DR Priority (addr) changes --
296 pim_if_update_join_desired(pim_ifp
); /* depends on DR */
297 pim_if_update_could_assert(ifp
); /* depends on DR */
298 pim_if_update_my_assert_metric(ifp
); /* depends on could_assert */
299 pim_if_update_assert_tracking_desired(
300 ifp
); /* depends on DR, join_desired */
303 RFC 4601: 4.3.1. Sending Hello Messages
305 1) Before an interface goes down or changes primary IP address, a
306 Hello message with a zero HoldTime should be sent immediately
307 (with the old IP address if the IP address changed).
308 -- FIXME See CAVEAT C13
310 2) After an interface has changed its IP address, it MUST send a
311 Hello message with its new IP address.
314 3) If an interface changes one of its secondary IP addresses, a
315 Hello message with an updated Address_List option and a non-zero
316 HoldTime should be sent immediately.
317 -- FIXME See TODO T31
319 pim_ifp
->pim_ifstat_hello_sent
= 0; /* reset hello counter */
320 if (pim_ifp
->pim_sock_fd
< 0)
322 pim_hello_restart_now(ifp
); /* send hello and restart timer */
325 static int detect_primary_address_change(struct interface
*ifp
,
326 int force_prim_as_any
,
329 struct pim_interface
*pim_ifp
= ifp
->info
;
330 struct in_addr new_prim_addr
;
333 if (force_prim_as_any
)
334 new_prim_addr
.s_addr
= INADDR_ANY
;
336 new_prim_addr
= pim_find_primary_addr(ifp
);
338 changed
= new_prim_addr
.s_addr
!= pim_ifp
->primary_address
.s_addr
;
340 if (PIM_DEBUG_ZEBRA
) {
341 char new_prim_str
[INET_ADDRSTRLEN
];
342 char old_prim_str
[INET_ADDRSTRLEN
];
343 pim_inet4_dump("<new?>", new_prim_addr
, new_prim_str
,
344 sizeof(new_prim_str
));
345 pim_inet4_dump("<old?>", pim_ifp
->primary_address
, old_prim_str
,
346 sizeof(old_prim_str
));
347 zlog_debug("%s: old=%s new=%s on interface %s: %s",
348 __PRETTY_FUNCTION__
, old_prim_str
, new_prim_str
,
349 ifp
->name
, changed
? "changed" : "unchanged");
353 pim_ifp
->primary_address
= new_prim_addr
;
359 static struct pim_secondary_addr
*
360 pim_sec_addr_find(struct pim_interface
*pim_ifp
, struct prefix
*addr
)
362 struct pim_secondary_addr
*sec_addr
;
363 struct listnode
*node
;
365 for (ALL_LIST_ELEMENTS_RO(pim_ifp
->sec_addr_list
, node
, sec_addr
)) {
366 if (prefix_cmp(&sec_addr
->addr
, addr
)) {
374 static void pim_sec_addr_del(struct pim_interface
*pim_ifp
,
375 struct pim_secondary_addr
*sec_addr
)
377 listnode_delete(pim_ifp
->sec_addr_list
, sec_addr
);
378 pim_sec_addr_free(sec_addr
);
381 static int pim_sec_addr_add(struct pim_interface
*pim_ifp
, struct prefix
*addr
)
384 struct pim_secondary_addr
*sec_addr
;
386 sec_addr
= pim_sec_addr_find(pim_ifp
, addr
);
388 sec_addr
->flags
&= ~PIM_SEC_ADDRF_STALE
;
392 sec_addr
= XCALLOC(MTYPE_PIM_SEC_ADDR
, sizeof(*sec_addr
));
397 sec_addr
->addr
= *addr
;
398 listnode_add_sort(pim_ifp
->sec_addr_list
, sec_addr
);
403 static int pim_sec_addr_del_all(struct pim_interface
*pim_ifp
)
407 if (!list_isempty(pim_ifp
->sec_addr_list
)) {
409 /* remove all nodes and free up the list itself */
410 list_delete_all_node(pim_ifp
->sec_addr_list
);
416 static int pim_sec_addr_update(struct interface
*ifp
)
418 struct pim_interface
*pim_ifp
= ifp
->info
;
419 struct connected
*ifc
;
420 struct listnode
*node
;
421 struct listnode
*nextnode
;
422 struct pim_secondary_addr
*sec_addr
;
425 for (ALL_LIST_ELEMENTS_RO(pim_ifp
->sec_addr_list
, node
,
427 sec_addr
->flags
|= PIM_SEC_ADDRF_STALE
;
430 for (ALL_LIST_ELEMENTS_RO(ifp
->connected
, node
, ifc
)) {
431 struct prefix
*p
= ifc
->address
;
433 if (PIM_INADDR_IS_ANY(p
->u
.prefix4
)) {
437 if (pim_ifp
->primary_address
.s_addr
== p
->u
.prefix4
.s_addr
) {
438 /* don't add the primary address into the secondary
443 if (pim_sec_addr_add(pim_ifp
, p
)) {
448 /* Drop stale entries */
449 for (ALL_LIST_ELEMENTS(pim_ifp
->sec_addr_list
, node
, nextnode
,
451 if (sec_addr
->flags
& PIM_SEC_ADDRF_STALE
) {
452 pim_sec_addr_del(pim_ifp
, sec_addr
);
460 static int detect_secondary_address_change(struct interface
*ifp
,
461 int force_prim_as_any
,
464 struct pim_interface
*pim_ifp
= ifp
->info
;
467 if (force_prim_as_any
) {
468 /* if primary address is being forced to zero just flush the
469 * secondary address list */
470 changed
= pim_sec_addr_del_all(pim_ifp
);
472 /* re-evaluate the secondary address list */
473 changed
= pim_sec_addr_update(ifp
);
479 static void detect_address_change(struct interface
*ifp
, int force_prim_as_any
,
483 struct pim_interface
*pim_ifp
;
489 if (detect_primary_address_change(ifp
, force_prim_as_any
, caller
)) {
493 if (detect_secondary_address_change(ifp
, force_prim_as_any
, caller
)) {
499 if (!PIM_IF_TEST_PIM(pim_ifp
->options
)) {
503 pim_addr_change(ifp
);
506 /* XXX: if we have unnumbered interfaces we need to run detect address
507 * address change on all of them when the lo address changes */
510 int pim_update_source_set(struct interface
*ifp
, struct in_addr source
)
512 struct pim_interface
*pim_ifp
= ifp
->info
;
515 return PIM_IFACE_NOT_FOUND
;
518 if (pim_ifp
->update_source
.s_addr
== source
.s_addr
) {
519 return PIM_UPDATE_SOURCE_DUP
;
522 pim_ifp
->update_source
= source
;
523 detect_address_change(ifp
, 0 /* force_prim_as_any */,
524 __PRETTY_FUNCTION__
);
529 void pim_if_addr_add(struct connected
*ifc
)
531 struct pim_interface
*pim_ifp
;
532 struct interface
*ifp
;
533 struct in_addr ifaddr
;
543 if (!if_is_operative(ifp
))
546 if (PIM_DEBUG_ZEBRA
) {
548 prefix2str(ifc
->address
, buf
, BUFSIZ
);
549 zlog_debug("%s: %s ifindex=%d connected IP address %s %s",
550 __PRETTY_FUNCTION__
, ifp
->name
, ifp
->ifindex
, buf
,
551 CHECK_FLAG(ifc
->flags
, ZEBRA_IFA_SECONDARY
)
556 ifaddr
= ifc
->address
->u
.prefix4
;
558 detect_address_change(ifp
, 0, __PRETTY_FUNCTION__
);
560 // if (ifc->address->family != AF_INET)
563 if (PIM_IF_TEST_IGMP(pim_ifp
->options
)) {
564 struct igmp_sock
*igmp
;
566 /* lookup IGMP socket */
567 igmp
= pim_igmp_sock_lookup_ifaddr(pim_ifp
->igmp_socket_list
,
570 /* if addr new, add IGMP socket */
571 if (ifc
->address
->family
== AF_INET
)
572 pim_igmp_sock_add(pim_ifp
->igmp_socket_list
,
576 /* Replay Static IGMP groups */
577 if (pim_ifp
->igmp_join_list
) {
578 struct listnode
*node
;
579 struct listnode
*nextnode
;
580 struct igmp_join
*ij
;
583 for (ALL_LIST_ELEMENTS(pim_ifp
->igmp_join_list
, node
,
585 /* Close socket and reopen with Source and Group
588 join_fd
= igmp_join_sock(
589 ifp
->name
, ifp
->ifindex
, ij
->group_addr
,
592 char group_str
[INET_ADDRSTRLEN
];
593 char source_str
[INET_ADDRSTRLEN
];
594 pim_inet4_dump("<grp?>", ij
->group_addr
,
598 "<src?>", ij
->source_addr
,
599 source_str
, sizeof(source_str
));
601 "%s: igmp_join_sock() failure for IGMP group %s source %s on interface %s",
602 __PRETTY_FUNCTION__
, group_str
,
603 source_str
, ifp
->name
);
606 ij
->sock_fd
= join_fd
;
611 if (PIM_IF_TEST_PIM(pim_ifp
->options
)) {
613 if (PIM_INADDR_ISNOT_ANY(pim_ifp
->primary_address
)) {
615 /* Interface has a valid socket ? */
616 if (pim_ifp
->pim_sock_fd
< 0) {
617 if (pim_sock_add(ifp
)) {
619 "Failure creating PIM socket for interface %s",
623 struct pim_nexthop_cache
*pnc
= NULL
;
625 struct zclient
*zclient
= NULL
;
627 zclient
= pim_zebra_zclient_get();
628 /* RP config might come prior to (local RP's interface)
630 In this case, pnc would not have pim enabled
632 Once Interface is UP and pim info is available,
634 with RNH address to receive update and add the
635 interface as nexthop. */
636 memset(&rpf
, 0, sizeof(struct pim_rpf
));
637 rpf
.rpf_addr
.family
= AF_INET
;
638 rpf
.rpf_addr
.prefixlen
= IPV4_MAX_BITLEN
;
639 rpf
.rpf_addr
.u
.prefix4
= ifc
->address
->u
.prefix4
;
640 pnc
= pim_nexthop_cache_find(pim_ifp
->pim
, &rpf
);
642 pim_sendmsg_zebra_rnh(pim_ifp
->pim
, zclient
,
644 ZEBRA_NEXTHOP_REGISTER
);
649 PIM or IGMP is enabled on interface, and there is at least one
650 address assigned, then try to create a vif_index.
652 if (pim_ifp
->mroute_vif_index
< 0) {
655 pim_ifchannel_scan_forward_start(ifp
);
658 static void pim_if_addr_del_igmp(struct connected
*ifc
)
660 struct pim_interface
*pim_ifp
= ifc
->ifp
->info
;
661 struct igmp_sock
*igmp
;
662 struct in_addr ifaddr
;
664 if (ifc
->address
->family
!= AF_INET
) {
665 /* non-IPv4 address */
670 /* IGMP not enabled on interface */
674 ifaddr
= ifc
->address
->u
.prefix4
;
676 /* lookup IGMP socket */
677 igmp
= pim_igmp_sock_lookup_ifaddr(pim_ifp
->igmp_socket_list
, ifaddr
);
679 /* if addr found, del IGMP socket */
680 igmp_sock_delete(igmp
);
684 static void pim_if_addr_del_pim(struct connected
*ifc
)
686 struct pim_interface
*pim_ifp
= ifc
->ifp
->info
;
688 if (ifc
->address
->family
!= AF_INET
) {
689 /* non-IPv4 address */
694 /* PIM not enabled on interface */
698 if (PIM_INADDR_ISNOT_ANY(pim_ifp
->primary_address
)) {
699 /* Interface keeps a valid primary address */
703 if (pim_ifp
->pim_sock_fd
< 0) {
704 /* Interface does not hold a valid socket any longer */
709 pim_sock_delete() closes the socket, stops read and timer threads,
710 and kills all neighbors.
712 pim_sock_delete(ifc
->ifp
,
713 "last address has been removed from interface");
716 void pim_if_addr_del(struct connected
*ifc
, int force_prim_as_any
)
718 struct interface
*ifp
;
724 if (PIM_DEBUG_ZEBRA
) {
726 prefix2str(ifc
->address
, buf
, BUFSIZ
);
727 zlog_debug("%s: %s ifindex=%d disconnected IP address %s %s",
728 __PRETTY_FUNCTION__
, ifp
->name
, ifp
->ifindex
, buf
,
729 CHECK_FLAG(ifc
->flags
, ZEBRA_IFA_SECONDARY
)
734 detect_address_change(ifp
, force_prim_as_any
, __PRETTY_FUNCTION__
);
736 pim_if_addr_del_igmp(ifc
);
737 pim_if_addr_del_pim(ifc
);
740 void pim_if_addr_add_all(struct interface
*ifp
)
742 struct connected
*ifc
;
743 struct listnode
*node
;
744 struct listnode
*nextnode
;
747 struct pim_interface
*pim_ifp
= ifp
->info
;
750 /* PIM/IGMP enabled ? */
754 for (ALL_LIST_ELEMENTS(ifp
->connected
, node
, nextnode
, ifc
)) {
755 struct prefix
*p
= ifc
->address
;
757 if (p
->family
!= AF_INET
)
761 pim_if_addr_add(ifc
);
764 if (!v4_addrs
&& v6_addrs
&& !if_is_loopback(ifp
)) {
765 if (PIM_IF_TEST_PIM(pim_ifp
->options
)) {
767 /* Interface has a valid primary address ? */
768 if (PIM_INADDR_ISNOT_ANY(pim_ifp
->primary_address
)) {
770 /* Interface has a valid socket ? */
771 if (pim_ifp
->pim_sock_fd
< 0) {
772 if (pim_sock_add(ifp
)) {
774 "Failure creating PIM socket for interface %s",
782 * PIM or IGMP is enabled on interface, and there is at least one
783 * address assigned, then try to create a vif_index.
785 if (pim_ifp
->mroute_vif_index
< 0) {
788 pim_ifchannel_scan_forward_start(ifp
);
790 pim_rp_setup(pim_ifp
->pim
);
791 pim_rp_check_on_if_add(pim_ifp
);
794 void pim_if_addr_del_all(struct interface
*ifp
)
796 struct connected
*ifc
;
797 struct listnode
*node
;
798 struct listnode
*nextnode
;
799 struct vrf
*vrf
= vrf_lookup_by_id(ifp
->vrf_id
);
800 struct pim_instance
*pim
= vrf
->info
;
802 /* PIM/IGMP enabled ? */
806 for (ALL_LIST_ELEMENTS(ifp
->connected
, node
, nextnode
, ifc
)) {
807 struct prefix
*p
= ifc
->address
;
809 if (p
->family
!= AF_INET
)
812 pim_if_addr_del(ifc
, 1 /* force_prim_as_any=true */);
816 pim_i_am_rp_re_evaluate(pim
);
819 void pim_if_addr_del_all_igmp(struct interface
*ifp
)
821 struct connected
*ifc
;
822 struct listnode
*node
;
823 struct listnode
*nextnode
;
825 /* PIM/IGMP enabled ? */
829 for (ALL_LIST_ELEMENTS(ifp
->connected
, node
, nextnode
, ifc
)) {
830 struct prefix
*p
= ifc
->address
;
832 if (p
->family
!= AF_INET
)
835 pim_if_addr_del_igmp(ifc
);
839 void pim_if_addr_del_all_pim(struct interface
*ifp
)
841 struct connected
*ifc
;
842 struct listnode
*node
;
843 struct listnode
*nextnode
;
845 /* PIM/IGMP enabled ? */
849 for (ALL_LIST_ELEMENTS(ifp
->connected
, node
, nextnode
, ifc
)) {
850 struct prefix
*p
= ifc
->address
;
852 if (p
->family
!= AF_INET
)
855 pim_if_addr_del_pim(ifc
);
859 struct in_addr
pim_find_primary_addr(struct interface
*ifp
)
861 struct connected
*ifc
;
862 struct listnode
*node
;
866 struct pim_interface
*pim_ifp
= ifp
->info
;
867 struct vrf
*vrf
= vrf_lookup_by_id(ifp
->vrf_id
);
869 if (pim_ifp
&& PIM_INADDR_ISNOT_ANY(pim_ifp
->update_source
)) {
870 return pim_ifp
->update_source
;
873 for (ALL_LIST_ELEMENTS_RO(ifp
->connected
, node
, ifc
)) {
874 struct prefix
*p
= ifc
->address
;
876 if (p
->family
!= AF_INET
) {
881 if (PIM_INADDR_IS_ANY(p
->u
.prefix4
)) {
883 "%s: null IPv4 address connected to interface %s",
884 __PRETTY_FUNCTION__
, ifp
->name
);
890 if (CHECK_FLAG(ifc
->flags
, ZEBRA_IFA_SECONDARY
))
897 * If we have no v4_addrs and v6 is configured
898 * We probably are using unnumbered
899 * So let's grab the loopbacks v4 address
900 * and use that as the primary address
902 if (!v4_addrs
&& v6_addrs
&& !if_is_loopback(ifp
)) {
903 struct interface
*lo_ifp
;
904 // DBS - Come back and check here
905 if (ifp
->vrf_id
== VRF_DEFAULT
)
906 lo_ifp
= if_lookup_by_name("lo", vrf
->vrf_id
);
908 lo_ifp
= if_lookup_by_name(vrf
->name
, vrf
->vrf_id
);
911 return pim_find_primary_addr(lo_ifp
);
914 addr
.s_addr
= PIM_NET_INADDR_ANY
;
919 static int pim_iface_next_vif_index(struct interface
*ifp
)
921 struct pim_interface
*pim_ifp
= ifp
->info
;
922 struct pim_instance
*pim
= pim_ifp
->pim
;
926 * The pimreg vif is always going to be in index 0
929 if (ifp
->ifindex
== PIM_OIF_PIM_REGISTER_VIF
)
932 for (i
= 1; i
< MAXVIFS
; i
++) {
933 if (pim
->iface_vif_index
[i
] == 0)
940 pim_if_add_vif() uses ifindex as vif_index
942 see also pim_if_find_vifindex_by_ifindex()
944 int pim_if_add_vif(struct interface
*ifp
)
946 struct pim_interface
*pim_ifp
= ifp
->info
;
947 struct in_addr ifaddr
;
948 unsigned char flags
= 0;
952 if (pim_ifp
->mroute_vif_index
> 0) {
953 zlog_warn("%s: vif_index=%d > 0 on interface %s ifindex=%d",
954 __PRETTY_FUNCTION__
, pim_ifp
->mroute_vif_index
,
955 ifp
->name
, ifp
->ifindex
);
959 if (ifp
->ifindex
< 0) {
960 zlog_warn("%s: ifindex=%d < 1 on interface %s",
961 __PRETTY_FUNCTION__
, ifp
->ifindex
, ifp
->name
);
965 ifaddr
= pim_ifp
->primary_address
;
966 if (ifp
->ifindex
!= PIM_OIF_PIM_REGISTER_VIF
967 && PIM_INADDR_IS_ANY(ifaddr
)) {
969 "%s: could not get address for interface %s ifindex=%d",
970 __PRETTY_FUNCTION__
, ifp
->name
, ifp
->ifindex
);
974 pim_ifp
->mroute_vif_index
= pim_iface_next_vif_index(ifp
);
976 if (pim_ifp
->mroute_vif_index
>= MAXVIFS
) {
978 "%s: Attempting to configure more than MAXVIFS=%d on pim enabled interface %s",
979 __PRETTY_FUNCTION__
, MAXVIFS
, ifp
->name
);
983 if (ifp
->ifindex
== PIM_OIF_PIM_REGISTER_VIF
)
984 flags
= VIFF_REGISTER
;
985 #ifdef VIFF_USE_IFINDEX
987 flags
= VIFF_USE_IFINDEX
;
990 if (pim_mroute_add_vif(ifp
, ifaddr
, flags
)) {
991 /* pim_mroute_add_vif reported error */
995 pim_ifp
->pim
->iface_vif_index
[pim_ifp
->mroute_vif_index
] = 1;
999 int pim_if_del_vif(struct interface
*ifp
)
1001 struct pim_interface
*pim_ifp
= ifp
->info
;
1003 if (pim_ifp
->mroute_vif_index
< 1) {
1004 zlog_warn("%s: vif_index=%d < 1 on interface %s ifindex=%d",
1005 __PRETTY_FUNCTION__
, pim_ifp
->mroute_vif_index
,
1006 ifp
->name
, ifp
->ifindex
);
1010 pim_mroute_del_vif(ifp
);
1015 pim_ifp
->pim
->iface_vif_index
[pim_ifp
->mroute_vif_index
] = 0;
1017 pim_ifp
->mroute_vif_index
= -1;
1023 struct interface
*pim_if_find_by_vif_index(struct pim_instance
*pim
,
1024 ifindex_t vif_index
)
1026 struct listnode
*ifnode
;
1027 struct interface
*ifp
;
1029 for (ALL_LIST_ELEMENTS_RO(vrf_iflist(pim
->vrf_id
), ifnode
, ifp
)) {
1031 struct pim_interface
*pim_ifp
;
1032 pim_ifp
= ifp
->info
;
1034 if (vif_index
== pim_ifp
->mroute_vif_index
)
1043 pim_if_add_vif() uses ifindex as vif_index
1045 int pim_if_find_vifindex_by_ifindex(struct pim_instance
*pim
, ifindex_t ifindex
)
1047 struct pim_interface
*pim_ifp
;
1048 struct interface
*ifp
;
1050 ifp
= if_lookup_by_index(ifindex
, pim
->vrf_id
);
1051 if (!ifp
|| !ifp
->info
)
1053 pim_ifp
= ifp
->info
;
1055 return pim_ifp
->mroute_vif_index
;
1058 int pim_if_lan_delay_enabled(struct interface
*ifp
)
1060 struct pim_interface
*pim_ifp
;
1062 pim_ifp
= ifp
->info
;
1064 zassert(pim_ifp
->pim_number_of_nonlandelay_neighbors
>= 0);
1066 return pim_ifp
->pim_number_of_nonlandelay_neighbors
== 0;
1069 uint16_t pim_if_effective_propagation_delay_msec(struct interface
*ifp
)
1071 if (pim_if_lan_delay_enabled(ifp
)) {
1072 struct pim_interface
*pim_ifp
;
1073 pim_ifp
= ifp
->info
;
1074 return pim_ifp
->pim_neighbors_highest_propagation_delay_msec
;
1076 return PIM_DEFAULT_PROPAGATION_DELAY_MSEC
;
1080 uint16_t pim_if_effective_override_interval_msec(struct interface
*ifp
)
1082 if (pim_if_lan_delay_enabled(ifp
)) {
1083 struct pim_interface
*pim_ifp
;
1084 pim_ifp
= ifp
->info
;
1085 return pim_ifp
->pim_neighbors_highest_override_interval_msec
;
1087 return PIM_DEFAULT_OVERRIDE_INTERVAL_MSEC
;
1091 int pim_if_t_override_msec(struct interface
*ifp
)
1093 int effective_override_interval_msec
;
1094 int t_override_msec
;
1096 effective_override_interval_msec
=
1097 pim_if_effective_override_interval_msec(ifp
);
1099 t_override_msec
= random() % (effective_override_interval_msec
+ 1);
1101 return t_override_msec
;
1104 uint16_t pim_if_jp_override_interval_msec(struct interface
*ifp
)
1106 return pim_if_effective_propagation_delay_msec(ifp
)
1107 + pim_if_effective_override_interval_msec(ifp
);
1111 RFC 4601: 4.1.6. State Summarization Macros
1113 The function NBR( I, A ) uses information gathered through PIM Hello
1114 messages to map the IP address A of a directly connected PIM
1115 neighbor router on interface I to the primary IP address of the same
1116 router (Section 4.3.4). The primary IP address of a neighbor is the
1117 address that it uses as the source of its PIM Hello messages.
1119 struct pim_neighbor
*pim_if_find_neighbor(struct interface
*ifp
,
1120 struct in_addr addr
)
1122 struct listnode
*neighnode
;
1123 struct pim_neighbor
*neigh
;
1124 struct pim_interface
*pim_ifp
;
1129 pim_ifp
= ifp
->info
;
1131 zlog_warn("%s: multicast not enabled on interface %s",
1132 __PRETTY_FUNCTION__
, ifp
->name
);
1138 p
.prefixlen
= IPV4_MAX_PREFIXLEN
;
1140 for (ALL_LIST_ELEMENTS_RO(pim_ifp
->pim_neighbor_list
, neighnode
,
1143 /* primary address ? */
1144 if (neigh
->source_addr
.s_addr
== addr
.s_addr
)
1147 /* secondary address ? */
1148 if (pim_neighbor_find_secondary(neigh
, &p
))
1152 if (PIM_DEBUG_PIM_TRACE
) {
1153 char addr_str
[INET_ADDRSTRLEN
];
1154 pim_inet4_dump("<addr?>", addr
, addr_str
, sizeof(addr_str
));
1156 "%s: neighbor not found for address %s on interface %s",
1157 __PRETTY_FUNCTION__
, addr_str
, ifp
->name
);
1163 long pim_if_t_suppressed_msec(struct interface
*ifp
)
1165 struct pim_interface
*pim_ifp
;
1166 long t_suppressed_msec
;
1167 uint32_t ramount
= 0;
1169 pim_ifp
= ifp
->info
;
1172 /* join suppression disabled ? */
1173 if (PIM_IF_TEST_PIM_CAN_DISABLE_JOIN_SUPRESSION(pim_ifp
->options
))
1176 /* t_suppressed = t_periodic * rand(1.1, 1.4) */
1177 ramount
= 1100 + (random() % (1400 - 1100 + 1));
1178 t_suppressed_msec
= qpim_t_periodic
* ramount
;
1180 return t_suppressed_msec
;
1183 static void igmp_join_free(struct igmp_join
*ij
)
1185 XFREE(MTYPE_PIM_IGMP_JOIN
, ij
);
1188 static struct igmp_join
*igmp_join_find(struct list
*join_list
,
1189 struct in_addr group_addr
,
1190 struct in_addr source_addr
)
1192 struct listnode
*node
;
1193 struct igmp_join
*ij
;
1197 for (ALL_LIST_ELEMENTS_RO(join_list
, node
, ij
)) {
1198 if ((group_addr
.s_addr
== ij
->group_addr
.s_addr
)
1199 && (source_addr
.s_addr
== ij
->source_addr
.s_addr
))
1206 static int igmp_join_sock(const char *ifname
, ifindex_t ifindex
,
1207 struct in_addr group_addr
, struct in_addr source_addr
)
1211 join_fd
= pim_socket_raw(IPPROTO_IGMP
);
1216 if (pim_socket_join_source(join_fd
, ifindex
, group_addr
, source_addr
,
1225 static struct igmp_join
*igmp_join_new(struct interface
*ifp
,
1226 struct in_addr group_addr
,
1227 struct in_addr source_addr
)
1229 struct pim_interface
*pim_ifp
;
1230 struct igmp_join
*ij
;
1233 pim_ifp
= ifp
->info
;
1236 join_fd
= igmp_join_sock(ifp
->name
, ifp
->ifindex
, group_addr
,
1239 char group_str
[INET_ADDRSTRLEN
];
1240 char source_str
[INET_ADDRSTRLEN
];
1241 pim_inet4_dump("<grp?>", group_addr
, group_str
,
1243 pim_inet4_dump("<src?>", source_addr
, source_str
,
1244 sizeof(source_str
));
1246 "%s: igmp_join_sock() failure for IGMP group %s source %s on interface %s",
1247 __PRETTY_FUNCTION__
, group_str
, source_str
, ifp
->name
);
1251 ij
= XCALLOC(MTYPE_PIM_IGMP_JOIN
, sizeof(*ij
));
1253 char group_str
[INET_ADDRSTRLEN
];
1254 char source_str
[INET_ADDRSTRLEN
];
1255 pim_inet4_dump("<grp?>", group_addr
, group_str
,
1257 pim_inet4_dump("<src?>", source_addr
, source_str
,
1258 sizeof(source_str
));
1260 "%s: XCALLOC(%zu) failure for IGMP group %s source %s on interface %s",
1261 __PRETTY_FUNCTION__
, sizeof(*ij
), group_str
, source_str
,
1267 ij
->sock_fd
= join_fd
;
1268 ij
->group_addr
= group_addr
;
1269 ij
->source_addr
= source_addr
;
1270 ij
->sock_creation
= pim_time_monotonic_sec();
1272 listnode_add(pim_ifp
->igmp_join_list
, ij
);
1277 ferr_r
pim_if_igmp_join_add(struct interface
*ifp
, struct in_addr group_addr
,
1278 struct in_addr source_addr
)
1280 struct pim_interface
*pim_ifp
;
1281 struct igmp_join
*ij
;
1283 pim_ifp
= ifp
->info
;
1285 return ferr_cfg_invalid("multicast not enabled on interface %s",
1289 if (!pim_ifp
->igmp_join_list
) {
1290 pim_ifp
->igmp_join_list
= list_new();
1291 if (!pim_ifp
->igmp_join_list
) {
1292 return ferr_cfg_invalid("Insufficient memory");
1294 pim_ifp
->igmp_join_list
->del
= (void (*)(void *))igmp_join_free
;
1297 ij
= igmp_join_find(pim_ifp
->igmp_join_list
, group_addr
, source_addr
);
1299 /* This interface has already been configured to join this IGMP group
1305 ij
= igmp_join_new(ifp
, group_addr
, source_addr
);
1307 return ferr_cfg_invalid(
1308 "Failure to create new join data structure, see log file for more information");
1311 if (PIM_DEBUG_IGMP_EVENTS
) {
1312 char group_str
[INET_ADDRSTRLEN
];
1313 char source_str
[INET_ADDRSTRLEN
];
1314 pim_inet4_dump("<grp?>", group_addr
, group_str
,
1316 pim_inet4_dump("<src?>", source_addr
, source_str
,
1317 sizeof(source_str
));
1319 "%s: issued static igmp join for channel (S,G)=(%s,%s) on interface %s",
1320 __PRETTY_FUNCTION__
, source_str
, group_str
, ifp
->name
);
1327 int pim_if_igmp_join_del(struct interface
*ifp
, struct in_addr group_addr
,
1328 struct in_addr source_addr
)
1330 struct pim_interface
*pim_ifp
;
1331 struct igmp_join
*ij
;
1333 pim_ifp
= ifp
->info
;
1335 zlog_warn("%s: multicast not enabled on interface %s",
1336 __PRETTY_FUNCTION__
, ifp
->name
);
1340 if (!pim_ifp
->igmp_join_list
) {
1341 zlog_warn("%s: no IGMP join on interface %s",
1342 __PRETTY_FUNCTION__
, ifp
->name
);
1346 ij
= igmp_join_find(pim_ifp
->igmp_join_list
, group_addr
, source_addr
);
1348 char group_str
[INET_ADDRSTRLEN
];
1349 char source_str
[INET_ADDRSTRLEN
];
1350 pim_inet4_dump("<grp?>", group_addr
, group_str
,
1352 pim_inet4_dump("<src?>", source_addr
, source_str
,
1353 sizeof(source_str
));
1355 "%s: could not find IGMP group %s source %s on interface %s",
1356 __PRETTY_FUNCTION__
, group_str
, source_str
, ifp
->name
);
1360 if (close(ij
->sock_fd
)) {
1361 char group_str
[INET_ADDRSTRLEN
];
1362 char source_str
[INET_ADDRSTRLEN
];
1363 pim_inet4_dump("<grp?>", group_addr
, group_str
,
1365 pim_inet4_dump("<src?>", source_addr
, source_str
,
1366 sizeof(source_str
));
1368 "%s: failure closing sock_fd=%d for IGMP group %s source %s on interface %s: errno=%d: %s",
1369 __PRETTY_FUNCTION__
, ij
->sock_fd
, group_str
, source_str
,
1370 ifp
->name
, errno
, safe_strerror(errno
));
1373 listnode_delete(pim_ifp
->igmp_join_list
, ij
);
1375 if (listcount(pim_ifp
->igmp_join_list
) < 1) {
1376 list_delete(pim_ifp
->igmp_join_list
);
1377 pim_ifp
->igmp_join_list
= 0;
1383 static void pim_if_igmp_join_del_all(struct interface
*ifp
)
1385 struct pim_interface
*pim_ifp
;
1386 struct listnode
*node
;
1387 struct listnode
*nextnode
;
1388 struct igmp_join
*ij
;
1390 pim_ifp
= ifp
->info
;
1392 zlog_warn("%s: multicast not enabled on interface %s",
1393 __PRETTY_FUNCTION__
, ifp
->name
);
1397 if (!pim_ifp
->igmp_join_list
)
1400 for (ALL_LIST_ELEMENTS(pim_ifp
->igmp_join_list
, node
, nextnode
, ij
))
1401 pim_if_igmp_join_del(ifp
, ij
->group_addr
, ij
->source_addr
);
1407 Transitions from "I am Assert Loser" State
1409 Current Winner's GenID Changes or NLT Expires
1411 The Neighbor Liveness Timer associated with the current winner
1412 expires or we receive a Hello message from the current winner
1413 reporting a different GenID from the one it previously reported.
1414 This indicates that the current winner's interface or router has
1415 gone down (and may have come back up), and so we must assume it no
1416 longer knows it was the winner.
1418 void pim_if_assert_on_neighbor_down(struct interface
*ifp
,
1419 struct in_addr neigh_addr
)
1421 struct pim_interface
*pim_ifp
;
1422 struct pim_ifchannel
*ch
;
1424 pim_ifp
= ifp
->info
;
1427 RB_FOREACH (ch
, pim_ifchannel_rb
, &pim_ifp
->ifchannel_rb
) {
1428 /* Is (S,G,I) assert loser ? */
1429 if (ch
->ifassert_state
!= PIM_IFASSERT_I_AM_LOSER
)
1431 /* Dead neighbor was winner ? */
1432 if (ch
->ifassert_winner
.s_addr
!= neigh_addr
.s_addr
)
1435 assert_action_a5(ch
);
1439 void pim_if_update_join_desired(struct pim_interface
*pim_ifp
)
1441 struct pim_ifchannel
*ch
;
1443 /* clear off flag from interface's upstreams */
1444 RB_FOREACH (ch
, pim_ifchannel_rb
, &pim_ifp
->ifchannel_rb
) {
1445 PIM_UPSTREAM_FLAG_UNSET_DR_JOIN_DESIRED_UPDATED(
1446 ch
->upstream
->flags
);
1449 /* scan per-interface (S,G,I) state on this I interface */
1450 RB_FOREACH (ch
, pim_ifchannel_rb
, &pim_ifp
->ifchannel_rb
) {
1451 struct pim_upstream
*up
= ch
->upstream
;
1453 if (PIM_UPSTREAM_FLAG_TEST_DR_JOIN_DESIRED_UPDATED(up
->flags
))
1456 /* update join_desired for the global (S,G) state */
1457 pim_upstream_update_join_desired(pim_ifp
->pim
, up
);
1458 PIM_UPSTREAM_FLAG_SET_DR_JOIN_DESIRED_UPDATED(up
->flags
);
1462 void pim_if_update_assert_tracking_desired(struct interface
*ifp
)
1464 struct pim_interface
*pim_ifp
;
1465 struct pim_ifchannel
*ch
;
1467 pim_ifp
= ifp
->info
;
1471 RB_FOREACH (ch
, pim_ifchannel_rb
, &pim_ifp
->ifchannel_rb
) {
1472 pim_ifchannel_update_assert_tracking_desired(ch
);
1477 * PIM wants to have an interface pointer for everything it does.
1478 * The pimreg is a special interface that we have that is not
1479 * quite an inteface but a VIF is created for it.
1481 void pim_if_create_pimreg(struct pim_instance
*pim
)
1483 char pimreg_name
[100];
1485 if (!pim
->regiface
) {
1486 if (pim
->vrf_id
== VRF_DEFAULT
)
1487 strcpy(pimreg_name
, "pimreg");
1489 sprintf(pimreg_name
, "pimreg%d",
1490 pim
->vrf
->data
.l
.table_id
);
1492 pim
->regiface
= if_create(pimreg_name
, strlen(pimreg_name
),
1494 pim
->regiface
->ifindex
= PIM_OIF_PIM_REGISTER_VIF
;
1496 pim_if_new(pim
->regiface
, 0, 0);
1500 int pim_if_connected_to_source(struct interface
*ifp
, struct in_addr src
)
1502 struct listnode
*cnode
;
1503 struct connected
*c
;
1511 p
.prefixlen
= IPV4_MAX_BITLEN
;
1513 for (ALL_LIST_ELEMENTS_RO(ifp
->connected
, cnode
, c
)) {
1514 if ((c
->address
->family
== AF_INET
)
1515 && prefix_match(CONNECTED_PREFIX(c
), &p
)) {
1523 int pim_if_is_loopback(struct pim_instance
*pim
, struct interface
*ifp
)
1525 if (if_is_loopback(ifp
))
1528 if (strcmp(ifp
->name
, pim
->vrf
->name
) == 0)
1534 int pim_if_is_vrf_device(struct interface
*ifp
)
1538 RB_FOREACH (vrf
, vrf_name_head
, &vrfs_by_name
) {
1539 if (strncmp(ifp
->name
, vrf
->name
, strlen(ifp
->name
)) == 0)
1546 int pim_if_ifchannel_count(struct pim_interface
*pim_ifp
)
1548 struct pim_ifchannel
*ch
;
1551 RB_FOREACH (ch
, pim_ifchannel_rb
, &pim_ifp
->ifchannel_rb
) {