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
20 #ifndef PIM_UPSTREAM_H
21 #define PIM_UPSTREAM_H
29 #include "pim_ifchannel.h"
31 #define PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED (1 << 0)
32 #define PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED_UPDATED (1 << 1)
33 #define PIM_UPSTREAM_FLAG_MASK_FHR (1 << 2)
34 #define PIM_UPSTREAM_FLAG_MASK_SRC_IGMP (1 << 3)
35 #define PIM_UPSTREAM_FLAG_MASK_SRC_PIM (1 << 4)
36 #define PIM_UPSTREAM_FLAG_MASK_SRC_STREAM (1 << 5)
37 #define PIM_UPSTREAM_FLAG_MASK_SRC_MSDP (1 << 6)
38 #define PIM_UPSTREAM_FLAG_MASK_SEND_SG_RPT_PRUNE (1 << 7)
39 #define PIM_UPSTREAM_FLAG_MASK_SRC_LHR (1 << 8)
40 /* In the case of pim vxlan we prime the pump by registering the
41 * vxlan source and keeping the SPT (FHR-RP) alive by sending periodic
42 * NULL registers. So we need to prevent KAT expiry because of the
43 * lack of BUM traffic.
45 #define PIM_UPSTREAM_FLAG_MASK_DISABLE_KAT_EXPIRY (1 << 9)
46 /* for pim vxlan we need to pin the IIF to lo or MLAG-ISL on the
47 * originating VTEP. This flag allows that by setting IIF to the
48 * value specified and preventing next-hop-tracking on the entry
50 #define PIM_UPSTREAM_FLAG_MASK_STATIC_IIF (1 << 10)
51 #define PIM_UPSTREAM_FLAG_MASK_ALLOW_IIF_IN_OIL (1 << 11)
52 /* Disable pimreg encasulation for a flow */
53 #define PIM_UPSTREAM_FLAG_MASK_NO_PIMREG_DATA (1 << 12)
54 /* For some MDTs we need to register the router as a source even
55 * if the not DR or directly connected on the IIF. This is typically
56 * needed on a VxLAN-AA (MLAG) setup.
58 #define PIM_UPSTREAM_FLAG_MASK_FORCE_PIMREG (1 << 13)
59 /* VxLAN origination mroute - SG was registered by EVPN where S is the
60 * local VTEP IP and G is the BUM multicast group address
62 #define PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_ORIG (1 << 14)
63 /* VxLAN termination mroute - *G entry where G is the BUM multicast group
66 #define PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_TERM (1 << 15)
67 /* MLAG mroute - synced to the MLAG peer and subject to DF (designated
70 #define PIM_UPSTREAM_FLAG_MASK_MLAG_VXLAN (1 << 16)
71 /* MLAG mroute that lost the DF election with peer and is installed in
72 * a dormant state i.e. MLAG OIFs are removed from the MFC.
73 * In most cases the OIL is empty (but not not always) simply
74 * blackholing the traffic pulled down to the LHR.
76 #define PIM_UPSTREAM_FLAG_MASK_MLAG_NON_DF (1 << 17)
77 /* MLAG mroute rxed from the peer MLAG switch */
78 #define PIM_UPSTREAM_FLAG_MASK_MLAG_PEER (1 << 18)
80 * We are creating a non-joined upstream data structure
81 * for this S,G as that we want to have a channel oil
82 * associated with an upstream
84 #define PIM_UPSTREAM_FLAG_MASK_SRC_NOCACHE (1 << 19)
85 /* By default as SG entry will use the SPT for forwarding traffic
86 * unless it was setup as a result of a Prune(S,G,rpt) from a
87 * downstream router and has JoinDesired(S,G) as False.
88 * This flag is only relevant for (S,G) entries.
90 #define PIM_UPSTREAM_FLAG_MASK_USE_RPT (1 << 20)
91 /* PIM Syncs upstream entries to peer Nodes via MLAG in 2 cases.
92 * one is to support plain PIM Redundancy and another one is to support
95 #define PIM_UPSTREAM_FLAG_MASK_MLAG_INTERFACE (1 << 21)
98 #define PIM_UPSTREAM_FLAG_ALL 0xFFFFFFFF
100 #define PIM_UPSTREAM_FLAG_TEST_DR_JOIN_DESIRED(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED)
101 #define PIM_UPSTREAM_FLAG_TEST_DR_JOIN_DESIRED_UPDATED(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED_UPDATED)
102 #define PIM_UPSTREAM_FLAG_TEST_FHR(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_FHR)
103 #define PIM_UPSTREAM_FLAG_TEST_SRC_IGMP(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_IGMP)
104 #define PIM_UPSTREAM_FLAG_TEST_SRC_PIM(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_PIM)
105 #define PIM_UPSTREAM_FLAG_TEST_SRC_STREAM(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_STREAM)
106 #define PIM_UPSTREAM_FLAG_TEST_SRC_MSDP(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_MSDP)
107 #define PIM_UPSTREAM_FLAG_TEST_SEND_SG_RPT_PRUNE(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SEND_SG_RPT_PRUNE)
108 #define PIM_UPSTREAM_FLAG_TEST_SRC_LHR(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_LHR)
109 #define PIM_UPSTREAM_FLAG_TEST_DISABLE_KAT_EXPIRY(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_DISABLE_KAT_EXPIRY)
110 #define PIM_UPSTREAM_FLAG_TEST_STATIC_IIF(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_STATIC_IIF)
111 #define PIM_UPSTREAM_FLAG_TEST_ALLOW_IIF_IN_OIL(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_ALLOW_IIF_IN_OIL)
112 #define PIM_UPSTREAM_FLAG_TEST_NO_PIMREG_DATA(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_NO_PIMREG_DATA)
113 #define PIM_UPSTREAM_FLAG_TEST_FORCE_PIMREG(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_FORCE_PIMREG)
114 #define PIM_UPSTREAM_FLAG_TEST_SRC_VXLAN_ORIG(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_ORIG)
115 #define PIM_UPSTREAM_FLAG_TEST_SRC_VXLAN_TERM(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_TERM)
116 #define PIM_UPSTREAM_FLAG_TEST_SRC_VXLAN(flags) ((flags) & (PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_ORIG | PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_TERM))
117 #define PIM_UPSTREAM_FLAG_TEST_MLAG_VXLAN(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_MLAG_VXLAN)
118 #define PIM_UPSTREAM_FLAG_TEST_MLAG_NON_DF(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_MLAG_NON_DF)
119 #define PIM_UPSTREAM_FLAG_TEST_MLAG_PEER(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_MLAG_PEER)
120 #define PIM_UPSTREAM_FLAG_TEST_SRC_NOCACHE(flags) ((flags) &PIM_UPSTREAM_FLAG_MASK_SRC_NOCACHE)
121 #define PIM_UPSTREAM_FLAG_TEST_USE_RPT(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_USE_RPT)
122 #define PIM_UPSTREAM_FLAG_TEST_CAN_BE_LHR(flags) ((flags) & (PIM_UPSTREAM_FLAG_MASK_SRC_IGMP | PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_TERM))
123 #define PIM_UPSTREAM_FLAG_TEST_MLAG_INTERFACE(flags) ((flags)&PIM_UPSTREAM_FLAG_MASK_MLAG_INTERFACE)
125 #define PIM_UPSTREAM_FLAG_SET_DR_JOIN_DESIRED(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED)
126 #define PIM_UPSTREAM_FLAG_SET_DR_JOIN_DESIRED_UPDATED(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED_UPDATED)
127 #define PIM_UPSTREAM_FLAG_SET_FHR(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_FHR)
128 #define PIM_UPSTREAM_FLAG_SET_SRC_IGMP(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_IGMP)
129 #define PIM_UPSTREAM_FLAG_SET_SRC_PIM(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_PIM)
130 #define PIM_UPSTREAM_FLAG_SET_SRC_STREAM(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_STREAM)
131 #define PIM_UPSTREAM_FLAG_SET_SRC_MSDP(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_MSDP)
132 #define PIM_UPSTREAM_FLAG_SET_SEND_SG_RPT_PRUNE(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SEND_SG_RPT_PRUNE)
133 #define PIM_UPSTREAM_FLAG_SET_SRC_LHR(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_LHR)
134 #define PIM_UPSTREAM_FLAG_SET_DISABLE_KAT_EXPIRY(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_DISABLE_KAT_EXPIRY)
135 #define PIM_UPSTREAM_FLAG_SET_STATIC_IIF(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_STATIC_IIF)
136 #define PIM_UPSTREAM_FLAG_SET_ALLOW_IIF_IN_OIL(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_ALLOW_IIF_IN_OIL)
137 #define PIM_UPSTREAM_FLAG_SET_NO_PIMREG_DATA(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_NO_PIMREG_DATA)
138 #define PIM_UPSTREAM_FLAG_SET_FORCE_PIMREG(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_FORCE_PIMREG)
139 #define PIM_UPSTREAM_FLAG_SET_SRC_VXLAN_ORIG(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_ORIG)
140 #define PIM_UPSTREAM_FLAG_SET_SRC_VXLAN_TERM(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_TERM)
141 #define PIM_UPSTREAM_FLAG_SET_MLAG_VXLAN(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_MLAG_VXLAN)
142 #define PIM_UPSTREAM_FLAG_SET_MLAG_NON_DF(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_MLAG_NON_DF)
143 #define PIM_UPSTREAM_FLAG_SET_MLAG_PEER(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_MLAG_PEER)
144 #define PIM_UPSTREAM_FLAG_SET_USE_RPT(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_USE_RPT)
145 #define PIM_UPSTREAM_FLAG_SET_MLAG_INTERFACE(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_MLAG_INTERFACE)
147 #define PIM_UPSTREAM_FLAG_UNSET_DR_JOIN_DESIRED(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED)
148 #define PIM_UPSTREAM_FLAG_UNSET_DR_JOIN_DESIRED_UPDATED(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED_UPDATED)
149 #define PIM_UPSTREAM_FLAG_UNSET_FHR(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_FHR)
150 #define PIM_UPSTREAM_FLAG_UNSET_SRC_IGMP(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_IGMP)
151 #define PIM_UPSTREAM_FLAG_UNSET_SRC_PIM(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_PIM)
152 #define PIM_UPSTREAM_FLAG_UNSET_SRC_STREAM(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_STREAM)
153 #define PIM_UPSTREAM_FLAG_UNSET_SRC_MSDP(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_MSDP)
154 #define PIM_UPSTREAM_FLAG_UNSET_SEND_SG_RPT_PRUNE(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SEND_SG_RPT_PRUNE)
155 #define PIM_UPSTREAM_FLAG_UNSET_SRC_LHR(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_LHR)
156 #define PIM_UPSTREAM_FLAG_UNSET_DISABLE_KAT_EXPIRY(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_DISABLE_KAT_EXPIRY)
157 #define PIM_UPSTREAM_FLAG_UNSET_STATIC_IIF(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_STATIC_IIF)
158 #define PIM_UPSTREAM_FLAG_UNSET_ALLOW_IIF_IN_OIL(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_ALLOW_IIF_IN_OIL)
159 #define PIM_UPSTREAM_FLAG_UNSET_NO_PIMREG_DATA(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_NO_PIMREG_DATA)
160 #define PIM_UPSTREAM_FLAG_UNSET_FORCE_PIMREG(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_FORCE_PIMREG)
161 #define PIM_UPSTREAM_FLAG_UNSET_SRC_VXLAN_ORIG(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_ORIG)
162 #define PIM_UPSTREAM_FLAG_UNSET_SRC_VXLAN_TERM(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_VXLAN_TERM)
163 #define PIM_UPSTREAM_FLAG_UNSET_MLAG_VXLAN(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_MLAG_VXLAN)
164 #define PIM_UPSTREAM_FLAG_UNSET_MLAG_NON_DF(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_MLAG_NON_DF)
165 #define PIM_UPSTREAM_FLAG_UNSET_MLAG_PEER(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_MLAG_PEER)
166 #define PIM_UPSTREAM_FLAG_UNSET_SRC_NOCACHE(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_NOCACHE)
167 #define PIM_UPSTREAM_FLAG_UNSET_USE_RPT(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_USE_RPT)
168 #define PIM_UPSTREAM_FLAG_UNSET_MLAG_INTERFACE(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_MLAG_INTERFACE)
170 /* The RPF cost is incremented by 10 if the RPF interface is the peerlink-rif.
171 * This is used to force the MLAG switch with the lowest cost to the RPF
172 * to become the MLAG DF.
174 #define PIM_UPSTREAM_MLAG_PEERLINK_PLUS_METRIC 10
176 enum pim_upstream_state
{
177 PIM_UPSTREAM_NOTJOINED
,
184 PIM_REG_JOIN_PENDING
,
188 enum pim_upstream_sptbit
{
189 PIM_UPSTREAM_SPTBIT_FALSE
,
190 PIM_UPSTREAM_SPTBIT_TRUE
194 /* MRIB.metric(S) from the peer switch. This is used for DF election
195 * and switch with the lowest cost wins.
197 uint32_t peer_mrib_metric
;
200 PREDECL_RBTREE_UNIQ(rb_pim_upstream
);
202 Upstream (S,G) channel in Joined state
203 (S,G) in the "Not Joined" state is not represented
204 See RFC 4601: 4.5.7. Sending (S,G) Join/Prune Message
206 upstream_addr : Who we are talking to.
207 For (*, G), upstream_addr is RP address or INADDR_ANY(if RP not configured)
208 For (S, G), upstream_addr is source address
210 rpf: contains the nexthop information to whom we are talking to.
212 join_state: JOINED/NOTJOINED
214 In the case when FRR receives IGMP/PIM (*, G) join for group G and RP is not
215 configured, then create a pim_upstream with the below information.
216 pim_upstream->upstream address: INADDR_ANY
217 pim_upstream->rpf: Unknown
218 pim_upstream->state: NOTJOINED
220 When a new RP gets configured for G, find the corresponding pim upstream (*,G)
221 entries and update the upstream address as new RP address if it the better one
224 When RP becomes reachable, populate the nexthop information in
225 pim_upstream->rpf and update the state to JOINED.
228 struct pim_upstream
{
229 struct pim_instance
*pim
;
230 struct rb_pim_upstream_item upstream_rb
;
231 struct pim_upstream
*parent
;
232 pim_addr upstream_addr
; /* Who we are talking to */
233 pim_addr upstream_register
; /*Who we received a register from*/
234 pim_sgaddr sg
; /* (S,G) group key */
235 char sg_str
[PIM_SG_LEN
];
237 struct channel_oil
*channel_oil
;
238 struct list
*sources
;
239 struct list
*ifchannels
;
240 /* Counter for Dual active ifchannels*/
241 uint32_t dualactive_ifchannel_count
;
243 enum pim_upstream_state join_state
;
244 enum pim_reg_state reg_state
;
245 enum pim_upstream_sptbit sptbit
;
251 struct pim_up_mlag mlag
;
253 struct thread
*t_join_timer
;
258 struct thread
*t_rs_timer
;
259 #define PIM_REGISTER_SUPPRESSION_PERIOD (60)
260 #define PIM_REGISTER_PROBE_PERIOD (5)
265 struct thread
*t_ka_timer
;
266 #define PIM_KEEPALIVE_PERIOD (210)
267 #define PIM_RP_KEEPALIVE_PERIOD \
268 (3 * router->register_suppress_time + router->register_probe_time)
270 /* on the RP we restart a timer to indicate if registers are being rxed
272 * SG. This is needed by MSDP to determine its local SA cache */
273 struct thread
*t_msdp_reg_timer
;
274 #define PIM_MSDP_REG_RXED_PERIOD (3 * (1.5 * router->register_suppress_time))
276 int64_t state_transition
; /* Record current state uptime */
279 static inline bool pim_upstream_is_kat_running(struct pim_upstream
*up
)
281 return (up
->t_ka_timer
!= NULL
);
284 static inline bool pim_up_mlag_is_local(struct pim_upstream
*up
)
286 /* XXX: extend this to also return true if the channel-oil has
289 return (up
->flags
& (PIM_UPSTREAM_FLAG_MASK_MLAG_VXLAN
290 | PIM_UPSTREAM_FLAG_MASK_MLAG_INTERFACE
));
293 struct pim_upstream
*pim_upstream_find(struct pim_instance
*pim
,
295 struct pim_upstream
*pim_upstream_find_or_add(pim_sgaddr
*sg
,
296 struct interface
*ifp
, int flags
,
298 struct pim_upstream
*pim_upstream_add(struct pim_instance
*pim
, pim_sgaddr
*sg
,
299 struct interface
*ifp
, int flags
,
301 struct pim_ifchannel
*ch
);
302 void pim_upstream_ref(struct pim_upstream
*up
,
303 int flags
, const char *name
);
304 struct pim_upstream
*pim_upstream_del(struct pim_instance
*pim
,
305 struct pim_upstream
*up
,
308 bool pim_upstream_evaluate_join_desired(struct pim_instance
*pim
,
309 struct pim_upstream
*up
);
310 int pim_upstream_evaluate_join_desired_interface(struct pim_upstream
*up
,
311 struct pim_ifchannel
*ch
,
312 struct pim_ifchannel
*starch
);
313 int pim_upstream_eval_inherit_if(struct pim_upstream
*up
,
314 struct pim_ifchannel
*ch
,
315 struct pim_ifchannel
*starch
);
316 void pim_upstream_update_join_desired(struct pim_instance
*pim
,
317 struct pim_upstream
*up
);
319 void pim_update_suppress_timers(uint32_t suppress_time
);
320 void pim_upstream_join_suppress(struct pim_upstream
*up
, pim_addr rpf
,
323 void pim_upstream_join_timer_decrease_to_t_override(const char *debug_label
,
324 struct pim_upstream
*up
);
326 void pim_upstream_join_timer_restart(struct pim_upstream
*up
,
327 struct pim_rpf
*old
);
328 void pim_upstream_rpf_genid_changed(struct pim_instance
*pim
,
329 pim_addr neigh_addr
);
330 void pim_upstream_rpf_interface_changed(struct pim_upstream
*up
,
331 struct interface
*old_rpf_ifp
);
333 void pim_upstream_update_could_assert(struct pim_upstream
*up
);
334 void pim_upstream_update_my_assert_metric(struct pim_upstream
*up
);
336 void pim_upstream_keep_alive_timer_start(struct pim_upstream
*up
,
339 int pim_upstream_switch_to_spt_desired_on_rp(struct pim_instance
*pim
,
341 #define SwitchToSptDesiredOnRp(pim, sg) pim_upstream_switch_to_spt_desired_on_rp (pim, sg)
342 int pim_upstream_is_sg_rpt(struct pim_upstream
*up
);
344 void pim_upstream_set_sptbit(struct pim_upstream
*up
,
345 struct interface
*incoming
);
347 void pim_upstream_start_register_stop_timer(struct pim_upstream
*up
,
350 void pim_upstream_send_join(struct pim_upstream
*up
);
352 void pim_upstream_switch(struct pim_instance
*pim
, struct pim_upstream
*up
,
353 enum pim_upstream_state new_state
);
355 const char *pim_upstream_state2str(enum pim_upstream_state join_state
);
356 #define PIM_REG_STATE_STR_LEN 12
357 const char *pim_reg_state2str(enum pim_reg_state state
, char *state_str
,
358 size_t state_str_len
);
360 int pim_upstream_inherited_olist_decide(struct pim_instance
*pim
,
361 struct pim_upstream
*up
);
362 int pim_upstream_inherited_olist(struct pim_instance
*pim
,
363 struct pim_upstream
*up
);
364 int pim_upstream_empty_inherited_olist(struct pim_upstream
*up
);
366 void pim_upstream_find_new_rpf(struct pim_instance
*pim
);
367 void pim_upstream_msdp_reg_timer_start(struct pim_upstream
*up
);
369 void pim_upstream_init(struct pim_instance
*pim
);
370 void pim_upstream_terminate(struct pim_instance
*pim
);
372 void join_timer_start(struct pim_upstream
*up
);
373 int pim_upstream_compare(const struct pim_upstream
*up1
,
374 const struct pim_upstream
*up2
);
375 DECLARE_RBTREE_UNIQ(rb_pim_upstream
, struct pim_upstream
, upstream_rb
,
376 pim_upstream_compare
);
378 void pim_upstream_register_reevaluate(struct pim_instance
*pim
);
380 void pim_upstream_add_lhr_star_pimreg(struct pim_instance
*pim
);
381 void pim_upstream_remove_lhr_star_pimreg(struct pim_instance
*pim
,
384 void pim_upstream_spt_prefix_list_update(struct pim_instance
*pim
,
385 struct prefix_list
*pl
);
387 unsigned int pim_upstream_hash_key(const void *arg
);
388 bool pim_upstream_equal(const void *arg1
, const void *arg2
);
389 struct pim_upstream
*pim_upstream_keep_alive_timer_proc(
390 struct pim_upstream
*up
);
391 void pim_upstream_fill_static_iif(struct pim_upstream
*up
,
392 struct interface
*incoming
);
393 void pim_upstream_update_use_rpt(struct pim_upstream
*up
,
395 uint32_t pim_up_mlag_local_cost(struct pim_upstream
*up
);
396 uint32_t pim_up_mlag_peer_cost(struct pim_upstream
*up
);
397 void pim_upstream_reeval_use_rpt(struct pim_instance
*pim
);
398 int pim_upstream_could_register(struct pim_upstream
*up
);
399 #endif /* PIM_UPSTREAM_H */