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
16 along with this program; see the file COPYING; if not, write to the
17 Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston,
21 #ifndef PIM_UPSTREAM_H
22 #define PIM_UPSTREAM_H
27 #include <pimd/pim_rpf.h>
29 #define PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED (1 << 0)
30 #define PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED_UPDATED (1 << 1)
31 #define PIM_UPSTREAM_FLAG_MASK_FHR (1 << 2)
32 #define PIM_UPSTREAM_FLAG_MASK_SRC_IGMP (1 << 3)
33 #define PIM_UPSTREAM_FLAG_MASK_SRC_PIM (1 << 4)
34 #define PIM_UPSTREAM_FLAG_MASK_SRC_STREAM (1 << 5)
35 #define PIM_UPSTREAM_FLAG_MASK_SRC_MSDP (1 << 6)
37 #define PIM_UPSTREAM_FLAG_TEST_DR_JOIN_DESIRED(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED)
38 #define PIM_UPSTREAM_FLAG_TEST_DR_JOIN_DESIRED_UPDATED(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED_UPDATED)
39 #define PIM_UPSTREAM_FLAG_TEST_FHR(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_FHR)
40 #define PIM_UPSTREAM_FLAG_TEST_SRC_IGMP(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_IGMP)
41 #define PIM_UPSTREAM_FLAG_TEST_SRC_PIM(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_PIM)
42 #define PIM_UPSTREAM_FLAG_TEST_SRC_STREAM(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_STREAM)
43 #define PIM_UPSTREAM_FLAG_TEST_SRC_MSDP(flags) ((flags) & PIM_UPSTREAM_FLAG_MASK_SRC_MSDP)
45 #define PIM_UPSTREAM_FLAG_SET_DR_JOIN_DESIRED(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED)
46 #define PIM_UPSTREAM_FLAG_SET_DR_JOIN_DESIRED_UPDATED(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED_UPDATED)
47 #define PIM_UPSTREAM_FLAG_SET_FHR(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_FHR)
48 #define PIM_UPSTREAM_FLAG_SET_SRC_IGMP(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_IGMP)
49 #define PIM_UPSTREAM_FLAG_SET_SRC_PIM(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_PIM)
50 #define PIM_UPSTREAM_FLAG_SET_SRC_STREAM(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_STREAM)
51 #define PIM_UPSTREAM_FLAG_SET_SRC_MSDP(flags) ((flags) |= PIM_UPSTREAM_FLAG_MASK_SRC_MSDP)
53 #define PIM_UPSTREAM_FLAG_UNSET_DR_JOIN_DESIRED(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED)
54 #define PIM_UPSTREAM_FLAG_UNSET_DR_JOIN_DESIRED_UPDATED(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_DR_JOIN_DESIRED_UPDATED)
55 #define PIM_UPSTREAM_FLAG_UNSET_FHR(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_FHR)
56 #define PIM_UPSTREAM_FLAG_UNSET_SRC_IGMP(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_IGMP)
57 #define PIM_UPSTREAM_FLAG_UNSET_SRC_PIM(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_PIM)
58 #define PIM_UPSTREAM_FLAG_UNSET_SRC_STREAM(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_STREAM)
59 #define PIM_UPSTREAM_FLAG_UNSET_SRC_MSDP(flags) ((flags) &= ~PIM_UPSTREAM_FLAG_MASK_SRC_MSDP)
61 enum pim_upstream_state
{
62 PIM_UPSTREAM_NOTJOINED
,
73 enum pim_upstream_sptbit
{
74 PIM_UPSTREAM_SPTBIT_FALSE
,
75 PIM_UPSTREAM_SPTBIT_TRUE
79 Upstream (S,G) channel in Joined state
81 (S,G) in the "Not Joined" state is not represented
83 See RFC 4601: 4.5.7. Sending (S,G) Join/Prune Message
86 struct pim_upstream
*parent
;
87 struct in_addr upstream_addr
;/* Who we are talking to */
88 struct in_addr upstream_register
; /*Who we received a register from*/
89 struct prefix_sg sg
; /* (S,G) group key */
90 char sg_str
[PIM_SG_LEN
];
92 struct channel_oil
*channel_oil
;
95 enum pim_upstream_state join_state
;
96 enum pim_reg_state reg_state
;
97 enum pim_upstream_sptbit sptbit
;
103 struct thread
*t_join_timer
;
108 struct thread
*t_rs_timer
;
109 #define PIM_REGISTER_SUPPRESSION_PERIOD (60)
110 #define PIM_REGISTER_PROBE_PERIOD (15)
115 struct thread
*t_ka_timer
;
116 #define PIM_KEEPALIVE_PERIOD (210)
117 #define PIM_RP_KEEPALIVE_PERIOD ( 3 * qpim_register_suppress_time + qpim_register_probe_time )
119 /* on the RP we restart a timer to indicate if registers are being rxed for
120 * SG. This is needed by MSDP to determine its local SA cache */
121 struct thread
*t_msdp_reg_timer
;
122 #define PIM_MSDP_REG_RXED_PERIOD (3 * (1.5 * qpim_register_suppress_time))
124 int64_t state_transition
; /* Record current state uptime */
127 struct list
*pim_upstream_list
;
128 struct hash
*pim_upstream_hash
;
130 void pim_upstream_free(struct pim_upstream
*up
);
131 struct pim_upstream
*pim_upstream_find (struct prefix_sg
*sg
);
132 struct pim_upstream
*pim_upstream_add (struct prefix_sg
*sg
,
133 struct interface
*ifp
, int flags
,
135 void pim_upstream_del(struct pim_upstream
*up
, const char *name
);
137 int pim_upstream_evaluate_join_desired(struct pim_upstream
*up
);
138 int pim_upstream_evaluate_join_desired_interface(struct pim_upstream
*up
,
139 struct pim_ifchannel
*ch
);
140 void pim_upstream_update_join_desired(struct pim_upstream
*up
);
142 void pim_upstream_join_suppress(struct pim_upstream
*up
,
143 struct in_addr rpf_addr
,
146 void pim_upstream_join_timer_decrease_to_t_override(const char *debug_label
,
147 struct pim_upstream
*up
);
149 void pim_upstream_join_timer_restart(struct pim_upstream
*up
, struct pim_rpf
*old
);
150 void pim_upstream_rpf_genid_changed(struct in_addr neigh_addr
);
151 void pim_upstream_rpf_interface_changed(struct pim_upstream
*up
,
152 struct interface
*old_rpf_ifp
);
154 void pim_upstream_update_could_assert(struct pim_upstream
*up
);
155 void pim_upstream_update_my_assert_metric(struct pim_upstream
*up
);
157 void pim_upstream_keep_alive_timer_start (struct pim_upstream
*up
, uint32_t time
);
159 int pim_upstream_switch_to_spt_desired (struct prefix_sg
*sg
);
160 #define SwitchToSptDesired(sg) pim_upstream_switch_to_spt_desired (sg)
161 int pim_upstream_is_sg_rpt (struct pim_upstream
*up
);
163 void pim_upstream_set_sptbit (struct pim_upstream
*up
, struct interface
*incoming
);
165 void pim_upstream_start_register_stop_timer (struct pim_upstream
*up
, int null_register
);
167 void pim_upstream_send_join (struct pim_upstream
*up
);
169 void pim_upstream_switch (struct pim_upstream
*up
, enum pim_upstream_state new_state
);
171 const char *pim_upstream_state2str (enum pim_upstream_state join_state
);
172 #define PIM_REG_STATE_STR_LEN 12
173 const char *pim_reg_state2str (enum pim_reg_state state
, char *state_str
);
175 int pim_upstream_inherited_olist_decide (struct pim_upstream
*up
);
176 int pim_upstream_inherited_olist (struct pim_upstream
*up
);
177 int pim_upstream_empty_inherited_olist (struct pim_upstream
*up
);
179 void pim_upstream_find_new_rpf (void);
180 void pim_upstream_msdp_reg_timer_start(struct pim_upstream
*up
);
182 void pim_upstream_init (void);
183 void pim_upstream_terminate (void);
185 void join_timer_start (struct pim_upstream
*up
);
186 #endif /* PIM_UPSTREAM_H */