]>
Commit | Line | Data |
---|---|---|
52df8228 CF |
1 | /* |
2 | * IS-IS Rout(e)ing protocol - BFD support | |
52df8228 CF |
3 | * Copyright (C) 2018 Christian Franke |
4 | * | |
d04f9fbf CF |
5 | * This program is free software; you can redistribute it and/or modify it |
6 | * under the terms of the GNU General Public License as published by the Free | |
7 | * Software Foundation; either version 2 of the License, or (at your option) | |
8 | * any later version. | |
52df8228 | 9 | * |
d04f9fbf CF |
10 | * This program is distributed in the hope that it will be useful, but WITHOUT |
11 | * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or | |
12 | * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for | |
13 | * more details. | |
52df8228 CF |
14 | * |
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 | |
18 | */ | |
19 | #include <zebra.h> | |
20 | ||
21 | #include "zclient.h" | |
22 | #include "bfd.h" | |
23 | ||
24 | #include "isisd/isis_bfd.h" | |
25 | #include "isisd/isis_zebra.h" | |
215eccb0 CF |
26 | #include "isisd/isis_common.h" |
27 | #include "isisd/isis_constants.h" | |
28 | #include "isisd/isis_adjacency.h" | |
29 | #include "isisd/isis_circuit.h" | |
3015e3d1 | 30 | #include "isisd/isisd.h" |
215eccb0 | 31 | #include "isisd/fabricd.h" |
52df8228 | 32 | |
20a42f01 CF |
33 | DEFINE_MTYPE_STATIC(ISISD, BFD_SESSION, "ISIS BFD Session") |
34 | ||
35 | struct bfd_session { | |
36 | struct in_addr dst_ip; | |
37 | struct in_addr src_ip; | |
a5eba4e9 | 38 | int status; |
20a42f01 CF |
39 | }; |
40 | ||
41 | static struct bfd_session *bfd_session_new(struct in_addr *dst_ip, | |
42 | struct in_addr *src_ip) | |
43 | { | |
44 | struct bfd_session *rv; | |
45 | ||
a5eba4e9 | 46 | rv = XCALLOC(MTYPE_BFD_SESSION, sizeof(*rv)); |
20a42f01 CF |
47 | rv->dst_ip = *dst_ip; |
48 | rv->src_ip = *src_ip; | |
49 | return rv; | |
50 | } | |
51 | ||
52 | static void bfd_session_free(struct bfd_session **session) | |
53 | { | |
54 | if (!*session) | |
55 | return; | |
56 | ||
57 | XFREE(MTYPE_BFD_SESSION, *session); | |
58 | *session = NULL; | |
59 | } | |
60 | ||
a5eba4e9 CF |
61 | static void bfd_adj_event(struct isis_adjacency *adj, struct prefix *dst, |
62 | int new_status) | |
63 | { | |
64 | if (!adj->bfd_session) | |
65 | return; | |
66 | ||
67 | if (adj->bfd_session->dst_ip.s_addr != dst->u.prefix4.s_addr) | |
68 | return; | |
69 | ||
70 | int old_status = adj->bfd_session->status; | |
a5eba4e9 | 71 | |
5489eb45 | 72 | adj->bfd_session->status = new_status; |
a5eba4e9 CF |
73 | if (old_status == new_status) |
74 | return; | |
75 | ||
76 | if (isis->debugs & DEBUG_BFD) { | |
77 | char dst_str[INET6_ADDRSTRLEN]; | |
78 | ||
79 | inet_ntop(AF_INET, &adj->bfd_session->dst_ip, | |
80 | dst_str, sizeof(dst_str)); | |
81 | zlog_debug("ISIS-BFD: Peer %s on %s changed from %s to %s", | |
82 | dst_str, adj->circuit->interface->name, | |
83 | bfd_get_status_str(old_status), | |
84 | bfd_get_status_str(new_status)); | |
85 | } | |
86 | ||
87 | if (old_status != BFD_STATUS_UP | |
88 | || new_status != BFD_STATUS_DOWN) { | |
89 | return; | |
90 | } | |
91 | ||
92 | isis_adj_state_change(adj, ISIS_ADJ_DOWN, "bfd session went down"); | |
93 | } | |
94 | ||
52df8228 CF |
95 | static int isis_bfd_interface_dest_update(int command, struct zclient *zclient, |
96 | zebra_size_t length, vrf_id_t vrf_id) | |
97 | { | |
2815f817 CF |
98 | struct interface *ifp; |
99 | struct prefix dst_ip; | |
100 | int status; | |
101 | ||
102 | ifp = bfd_get_peer_info(zclient->ibuf, &dst_ip, NULL, &status, vrf_id); | |
103 | if (!ifp || dst_ip.family != AF_INET) | |
104 | return 0; | |
105 | ||
106 | if (isis->debugs & DEBUG_BFD) { | |
107 | char dst_buf[INET6_ADDRSTRLEN]; | |
5489eb45 | 108 | |
2815f817 CF |
109 | inet_ntop(AF_INET, &dst_ip.u.prefix4, |
110 | dst_buf, sizeof(dst_buf)); | |
111 | ||
112 | zlog_debug("ISIS-BFD: Received update for %s on %s: Changed state to %s", | |
113 | dst_buf, ifp->name, bfd_get_status_str(status)); | |
114 | } | |
115 | ||
a5eba4e9 | 116 | struct isis_circuit *circuit = circuit_scan_by_ifp(ifp); |
5489eb45 | 117 | |
a5eba4e9 CF |
118 | if (!circuit) |
119 | return 0; | |
120 | ||
121 | if (circuit->circ_type == CIRCUIT_T_BROADCAST) { | |
122 | for (int level = ISIS_LEVEL1; level <= ISIS_LEVEL2; level++) { | |
123 | struct list *adjdb = circuit->u.bc.adjdb[level - 1]; | |
124 | ||
125 | struct listnode *node, *nnode; | |
126 | struct isis_adjacency *adj; | |
127 | ||
128 | for (ALL_LIST_ELEMENTS(adjdb, node, nnode, adj)) | |
129 | bfd_adj_event(adj, &dst_ip, status); | |
130 | } | |
131 | } else if (circuit->circ_type == CIRCUIT_T_P2P) { | |
132 | if (circuit->u.p2p.neighbor) { | |
133 | bfd_adj_event(circuit->u.p2p.neighbor, | |
134 | &dst_ip, status); | |
135 | } | |
136 | } | |
137 | ||
52df8228 CF |
138 | return 0; |
139 | } | |
140 | ||
141 | static int isis_bfd_nbr_replay(int command, struct zclient *zclient, | |
142 | zebra_size_t length, vrf_id_t vrf_id) | |
143 | { | |
144 | bfd_client_sendmsg(zclient, ZEBRA_BFD_CLIENT_REGISTER); | |
ab880eaf CF |
145 | |
146 | struct listnode *anode; | |
147 | struct isis_area *area; | |
148 | ||
2815f817 CF |
149 | if (isis->debugs & DEBUG_BFD) |
150 | zlog_debug("ISIS-BFD: Got neighbor replay request, resending neighbors."); | |
151 | ||
ab880eaf CF |
152 | for (ALL_LIST_ELEMENTS_RO(isis->area_list, anode, area)) { |
153 | struct listnode *cnode; | |
154 | struct isis_circuit *circuit; | |
155 | ||
156 | for (ALL_LIST_ELEMENTS_RO(area->circuit_list, cnode, circuit)) | |
157 | isis_bfd_circuit_cmd(circuit, ZEBRA_BFD_DEST_UPDATE); | |
158 | } | |
159 | ||
2815f817 CF |
160 | if (isis->debugs & DEBUG_BFD) |
161 | zlog_debug("ISIS-BFD: Done with replay."); | |
162 | ||
52df8228 CF |
163 | return 0; |
164 | } | |
165 | ||
166 | static void (*orig_zebra_connected)(struct zclient *); | |
167 | static void isis_bfd_zebra_connected(struct zclient *zclient) | |
168 | { | |
169 | if (orig_zebra_connected) | |
170 | orig_zebra_connected(zclient); | |
171 | ||
172 | bfd_client_sendmsg(zclient, ZEBRA_BFD_CLIENT_REGISTER); | |
173 | } | |
174 | ||
2815f817 CF |
175 | static void bfd_debug(struct in_addr *dst, struct in_addr *src, |
176 | const char *interface, int command) | |
177 | { | |
178 | if (!(isis->debugs & DEBUG_BFD)) | |
179 | return; | |
180 | ||
181 | char dst_str[INET6_ADDRSTRLEN]; | |
182 | char src_str[INET6_ADDRSTRLEN]; | |
183 | ||
184 | inet_ntop(AF_INET, dst, dst_str, sizeof(dst_str)); | |
185 | inet_ntop(AF_INET, src, src_str, sizeof(src_str)); | |
186 | ||
187 | const char *command_str; | |
188 | ||
189 | switch (command) { | |
190 | case ZEBRA_BFD_DEST_REGISTER: | |
191 | command_str = "Register"; | |
192 | break; | |
193 | case ZEBRA_BFD_DEST_DEREGISTER: | |
194 | command_str = "Deregister"; | |
195 | break; | |
196 | case ZEBRA_BFD_DEST_UPDATE: | |
197 | command_str = "Update"; | |
198 | break; | |
199 | default: | |
200 | command_str = "Unknown-Cmd"; | |
201 | break; | |
202 | } | |
203 | ||
204 | zlog_debug("ISIS-BFD: %s peer %s on %s (src %s)", | |
205 | command_str, dst_str, interface, src_str); | |
206 | } | |
207 | ||
20a42f01 CF |
208 | static void bfd_handle_adj_down(struct isis_adjacency *adj) |
209 | { | |
210 | if (!adj->bfd_session) | |
211 | return; | |
212 | ||
2815f817 CF |
213 | bfd_debug(&adj->bfd_session->dst_ip, &adj->bfd_session->src_ip, |
214 | adj->circuit->interface->name, ZEBRA_BFD_DEST_DEREGISTER); | |
215 | ||
20a42f01 CF |
216 | bfd_peer_sendmsg(zclient, NULL, AF_INET, |
217 | &adj->bfd_session->dst_ip, | |
218 | &adj->bfd_session->src_ip, | |
219 | adj->circuit->interface->name, | |
220 | 0, /* ttl */ | |
221 | 0, /* multihop */ | |
222 | ZEBRA_BFD_DEST_DEREGISTER, | |
223 | 0, /* set_flag */ | |
224 | VRF_DEFAULT); | |
225 | bfd_session_free(&adj->bfd_session); | |
226 | } | |
227 | ||
228 | static void bfd_handle_adj_up(struct isis_adjacency *adj, int command) | |
215eccb0 | 229 | { |
20a42f01 CF |
230 | struct isis_circuit *circuit = adj->circuit; |
231 | ||
232 | if (!circuit->bfd_info | |
233 | || !circuit->ip_router | |
234 | || !adj->ipv4_address_count) | |
235 | goto out; | |
236 | ||
237 | struct list *local_ips = fabricd_ip_addrs(adj->circuit); | |
5489eb45 | 238 | |
20a42f01 CF |
239 | if (!local_ips) |
240 | goto out; | |
241 | ||
242 | struct in_addr *dst_ip = &adj->ipv4_addresses[0]; | |
243 | struct prefix_ipv4 *local_ip = listgetdata(listhead(local_ips)); | |
244 | struct in_addr *src_ip = &local_ip->prefix; | |
245 | ||
246 | if (adj->bfd_session) { | |
247 | if (adj->bfd_session->dst_ip.s_addr != dst_ip->s_addr | |
248 | || adj->bfd_session->src_ip.s_addr != src_ip->s_addr) | |
249 | bfd_handle_adj_down(adj); | |
250 | } | |
251 | ||
252 | if (!adj->bfd_session) | |
253 | adj->bfd_session = bfd_session_new(dst_ip, src_ip); | |
254 | ||
2815f817 CF |
255 | bfd_debug(&adj->bfd_session->dst_ip, &adj->bfd_session->src_ip, |
256 | circuit->interface->name, command); | |
20a42f01 CF |
257 | bfd_peer_sendmsg(zclient, circuit->bfd_info, AF_INET, |
258 | &adj->bfd_session->dst_ip, | |
259 | &adj->bfd_session->src_ip, | |
260 | circuit->interface->name, | |
261 | 0, /* ttl */ | |
262 | 0, /* multihop */ | |
263 | command, | |
264 | 0, /* set flag */ | |
265 | VRF_DEFAULT); | |
215eccb0 | 266 | return; |
20a42f01 CF |
267 | out: |
268 | bfd_handle_adj_down(adj); | |
269 | } | |
270 | ||
271 | static int bfd_handle_adj_state_change(struct isis_adjacency *adj) | |
272 | { | |
273 | if (adj->adj_state == ISIS_ADJ_UP) | |
274 | bfd_handle_adj_up(adj, ZEBRA_BFD_DEST_REGISTER); | |
275 | else | |
276 | bfd_handle_adj_down(adj); | |
277 | return 0; | |
278 | } | |
279 | ||
280 | static void bfd_adj_cmd(struct isis_adjacency *adj, int command) | |
281 | { | |
282 | if (adj->adj_state == ISIS_ADJ_UP | |
283 | && command != ZEBRA_BFD_DEST_DEREGISTER) { | |
284 | bfd_handle_adj_up(adj, command); | |
285 | } else { | |
286 | bfd_handle_adj_down(adj); | |
287 | } | |
288 | } | |
289 | ||
290 | void isis_bfd_circuit_cmd(struct isis_circuit *circuit, int command) | |
291 | { | |
292 | switch (circuit->circ_type) { | |
293 | case CIRCUIT_T_BROADCAST: | |
294 | for (int level = ISIS_LEVEL1; level <= ISIS_LEVEL2; level++) { | |
295 | struct list *adjdb = circuit->u.bc.adjdb[level - 1]; | |
296 | ||
297 | struct listnode *node; | |
298 | struct isis_adjacency *adj; | |
5489eb45 | 299 | |
20a42f01 CF |
300 | for (ALL_LIST_ELEMENTS_RO(adjdb, node, adj)) |
301 | bfd_adj_cmd(adj, command); | |
302 | } | |
303 | break; | |
304 | case CIRCUIT_T_P2P: | |
305 | if (circuit->u.p2p.neighbor) | |
306 | bfd_adj_cmd(circuit->u.p2p.neighbor, command); | |
307 | break; | |
308 | default: | |
309 | break; | |
310 | } | |
215eccb0 CF |
311 | } |
312 | ||
313 | void isis_bfd_circuit_param_set(struct isis_circuit *circuit, | |
314 | uint32_t min_rx, uint32_t min_tx, | |
315 | uint32_t detect_mult, int defaults) | |
316 | { | |
317 | int command = 0; | |
318 | ||
319 | bfd_set_param(&circuit->bfd_info, min_rx, | |
320 | min_tx, detect_mult, defaults, &command); | |
321 | ||
322 | if (command) | |
323 | isis_bfd_circuit_cmd(circuit, command); | |
324 | } | |
325 | ||
3015e3d1 CF |
326 | static int bfd_circuit_write_settings(struct isis_circuit *circuit, |
327 | struct vty *vty) | |
328 | { | |
329 | struct bfd_info *bfd_info = circuit->bfd_info; | |
330 | ||
331 | if (!bfd_info) | |
332 | return 0; | |
333 | ||
490a6fc7 | 334 | vty_out(vty, " %s bfd\n", PROTO_NAME); |
3015e3d1 CF |
335 | return 1; |
336 | } | |
337 | ||
52df8228 CF |
338 | void isis_bfd_init(void) |
339 | { | |
340 | bfd_gbl_init(); | |
341 | ||
342 | orig_zebra_connected = zclient->zebra_connected; | |
343 | zclient->zebra_connected = isis_bfd_zebra_connected; | |
344 | zclient->interface_bfd_dest_update = isis_bfd_interface_dest_update; | |
345 | zclient->bfd_dest_replay = isis_bfd_nbr_replay; | |
20a42f01 CF |
346 | hook_register(isis_adj_state_change_hook, |
347 | bfd_handle_adj_state_change); | |
3015e3d1 CF |
348 | hook_register(isis_circuit_config_write, |
349 | bfd_circuit_write_settings); | |
52df8228 | 350 | } |