1 /*********************************************************************
2 * Copyright 2014,2015,2016,2017 Cumulus Networks, Inc. All rights reserved.
4 * This program is free software; you can redistribute it and/or modify it
5 * under the terms of the GNU General Public License as published by the Free
6 * Software Foundation; either version 2 of the License, or (at your option)
9 * This program is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
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
18 * bfd.h: implements the BFD protocol.
24 #include <netinet/in.h>
31 #include "lib/libfrr.h"
33 #include "lib/queue.h"
37 #define ETHERNET_ADDRESS_LENGTH 6
40 #define BFDD_JSON_CONV_OPTIONS (JSON_C_TO_STRING_PRETTY)
42 #define BFDD_JSON_CONV_OPTIONS (0)
46 DECLARE_MTYPE(BFDD_TMP
);
47 DECLARE_MTYPE(BFDD_CONFIG
);
48 DECLARE_MTYPE(BFDD_LABEL
);
49 DECLARE_MTYPE(BFDD_CONTROL
);
50 DECLARE_MTYPE(BFDD_NOTIFICATION
);
53 uint32_t desired_min_tx
;
54 uint32_t required_min_rx
;
55 uint32_t required_min_echo
;
60 uint32_t remote_discr
;
64 * Format of control packet. From section 4)
76 struct bfd_discrs discrs
;
77 struct bfd_timers timers
;
81 * Format of Echo packet.
97 /* Macros for manipulating control packets */
98 #define BFD_VERMASK 0x03
99 #define BFD_DIAGMASK 0x1F
100 #define BFD_GETVER(diag) ((diag >> 5) & BFD_VERMASK)
101 #define BFD_SETVER(diag, val) ((diag) |= (val & BFD_VERMASK) << 5)
102 #define BFD_VERSION 1
103 #define BFD_PBIT 0x20
104 #define BFD_FBIT 0x10
105 #define BFD_CBIT 0x08
106 #define BFD_ABIT 0x04
107 #define BFD_DEMANDBIT 0x02
108 #define BFD_DIAGNEIGHDOWN 3
109 #define BFD_DIAGDETECTTIME 1
110 #define BFD_DIAGADMINDOWN 7
111 #define BFD_SETDEMANDBIT(flags, val) \
114 flags |= BFD_DEMANDBIT; \
116 #define BFD_SETPBIT(flags, val) \
121 #define BFD_GETPBIT(flags) (flags & BFD_PBIT)
122 #define BFD_SETFBIT(flags, val) \
127 #define BFD_GETFBIT(flags) (flags & BFD_FBIT)
128 #define BFD_SETSTATE(flags, val) \
131 flags |= (val & 0x3) << 6; \
133 #define BFD_GETSTATE(flags) ((flags >> 6) & 0x3)
134 #define BFD_ECHO_VERSION 1
135 #define BFD_ECHO_PKT_LEN sizeof(struct bfd_echo_pkt)
136 #define BFD_CTRL_PKT_LEN sizeof(struct bfd_pkt)
137 #define IP_HDR_LEN 20
138 #define UDP_HDR_LEN 8
139 #define ETH_HDR_LEN 14
140 #define VXLAN_HDR_LEN 8
141 #define HEADERS_MIN_LEN (ETH_HDR_LEN + IP_HDR_LEN + UDP_HDR_LEN)
142 #define BFD_ECHO_PKT_TOT_LEN \
143 ((int)(ETH_HDR_LEN + IP_HDR_LEN + UDP_HDR_LEN + BFD_ECHO_PKT_LEN))
144 #define BFD_VXLAN_PKT_TOT_LEN \
145 ((int)(VXLAN_HDR_LEN + ETH_HDR_LEN + IP_HDR_LEN + UDP_HDR_LEN \
147 #define BFD_RX_BUF_LEN 160
149 /* BFD session flags */
150 enum bfd_session_flags
{
151 BFD_SESS_FLAG_NONE
= 0,
152 BFD_SESS_FLAG_ECHO
= 1 << 0, /* BFD Echo functionality */
153 BFD_SESS_FLAG_ECHO_ACTIVE
= 1 << 1, /* BFD Echo Packets are being sent
156 BFD_SESS_FLAG_MH
= 1 << 2, /* BFD Multi-hop session */
157 BFD_SESS_FLAG_VXLAN
= 1 << 3, /* BFD Multi-hop session which is
158 * used to monitor vxlan tunnel
160 BFD_SESS_FLAG_IPV6
= 1 << 4, /* BFD IPv6 session */
161 BFD_SESS_FLAG_SEND_EVT_ACTIVE
= 1 << 5, /* send event timer active */
162 BFD_SESS_FLAG_SEND_EVT_IGNORE
= 1 << 6, /* ignore send event when timer
165 BFD_SESS_FLAG_SHUTDOWN
= 1 << 7, /* disable BGP peer function */
168 #define BFD_SET_FLAG(field, flag) (field |= flag)
169 #define BFD_UNSET_FLAG(field, flag) (field &= ~flag)
170 #define BFD_CHECK_FLAG(field, flag) (field & flag)
172 /* BFD session hash keys */
173 struct bfd_shop_key
{
174 struct sockaddr_any peer
;
175 char port_name
[MAXNAMELEN
+ 1];
178 struct bfd_mhop_key
{
179 struct sockaddr_any peer
;
180 struct sockaddr_any local
;
181 char vrf_name
[MAXNAMELEN
+ 1];
184 struct bfd_session_stats
{
185 uint64_t rx_ctrl_pkt
;
186 uint64_t tx_ctrl_pkt
;
187 uint64_t rx_echo_pkt
;
188 uint64_t tx_echo_pkt
;
190 uint64_t session_down
;
191 uint64_t znotification
;
194 struct bfd_session_vxlan_info
{
196 uint32_t decay_min_rx
;
197 uint8_t forwarding_if_rx
;
199 uint8_t check_tnl_key
;
200 uint8_t local_dst_mac
[ETHERNET_ADDRESS_LENGTH
];
201 uint8_t peer_dst_mac
[ETHERNET_ADDRESS_LENGTH
];
202 struct in_addr local_dst_ip
;
203 struct in_addr peer_dst_ip
;
206 /* bfd_session shortcut label forwarding. */
210 * Session state information
214 /* protocol state per RFC 5880*/
216 struct bfd_discrs discrs
;
220 uint8_t remote_detect_mult
;
224 struct bfd_timers timers
;
225 struct bfd_timers new_timers
;
228 struct thread
*echo_recvtimer_ev
;
229 struct thread
*recvtimer_ev
;
231 uint64_t echo_xmt_TO
;
232 struct thread
*xmttimer_ev
;
233 struct thread
*echo_xmttimer_ev
;
234 uint64_t echo_detect_TO
;
236 /* software object state */
239 /* This and the localDiscr are the keys to state info */
240 struct peer_label
*pl
;
242 struct bfd_shop_key shop
;
243 struct bfd_mhop_key mhop
;
247 struct sockaddr_any local_address
;
248 struct sockaddr_any local_ip
;
250 uint8_t local_mac
[ETHERNET_ADDRESS_LENGTH
];
251 uint8_t peer_mac
[ETHERNET_ADDRESS_LENGTH
];
254 /* BFD session flags */
255 enum bfd_session_flags flags
;
257 uint8_t echo_pkt
[BFD_ECHO_PKT_TOT_LEN
]; /* Save the Echo Packet
258 * which will be transmitted
260 struct bfd_session_stats stats
;
261 struct bfd_session_vxlan_info vxlan_info
;
263 struct timeval uptime
; /* last up time */
264 struct timeval downtime
; /* last down time */
266 /* Remote peer data (for debugging mostly) */
268 struct bfd_timers remote_timers
;
270 uint64_t refcount
; /* number of pointers referencing this. */
272 /* VTY context data. */
275 DECLARE_QOBJ_TYPE(bfd_session
);
278 TAILQ_ENTRY(peer_label
) pl_entry
;
280 struct bfd_session
*pl_bs
;
281 char pl_label
[MAXNAMELEN
];
283 TAILQ_HEAD(pllist
, peer_label
);
285 struct bfd_diag_str_list
{
290 struct bfd_state_str_list
{
297 char name
[MAXNAMELEN
+ 1];
302 char ifname
[MAXNAMELEN
+ 1];
306 /* States defined per 4.1 */
307 #define PTM_BFD_ADM_DOWN 0
308 #define PTM_BFD_DOWN 1
309 #define PTM_BFD_INIT 2
313 /* Various constants */
314 /* Retrieved from ptm_timer.h from Cumulus PTM sources. */
315 #define MSEC_PER_SEC 1000L
316 #define NSEC_PER_MSEC 1000000L
318 #define BFD_DEF_DEMAND 0
319 #define BFD_DEFDETECTMULT 3
320 #define BFD_DEFDESIREDMINTX (300 * MSEC_PER_SEC)
321 #define BFD_DEFREQUIREDMINRX (300 * MSEC_PER_SEC)
322 #define BFD_DEF_REQ_MIN_ECHO (50 * MSEC_PER_SEC)
323 #define BFD_DEF_SLOWTX (2000 * MSEC_PER_SEC)
324 #define BFD_DEF_MHOP_TTL 5
325 #define BFD_PKT_LEN 24 /* Length of control packet */
326 #define BFD_TTL_VAL 255
327 #define BFD_RCV_TTL_VAL 1
328 #define BFD_TOS_VAL 0xC0
329 #define BFD_PKT_INFO_VAL 1
330 #define BFD_IPV6_PKT_INFO_VAL 1
331 #define BFD_IPV6_ONLY_VAL 1
332 #define BFD_SRCPORTINIT 49142
333 #define BFD_SRCPORTMAX 65536
334 #define BFD_DEFDESTPORT 3784
335 #define BFD_DEF_ECHO_PORT 3785
336 #define BFD_DEF_MHOP_DEST_PORT 4784
337 #define BFD_CMD_STRING_LEN (MAXNAMELEN + 50)
338 #define BFD_BUFFER_LEN (BFD_CMD_STRING_LEN + MAXNAMELEN + 1)
343 * Daemon control code to speak with local consumers.
346 /* See 'bfdctrl.h' for client protocol definitions. */
348 struct bfd_control_buffer
{
352 struct bfd_control_msg
*bcb_bcm
;
357 struct bfd_control_queue
{
358 TAILQ_ENTRY(bfd_control_queue
) bcq_entry
;
360 struct bfd_control_buffer bcq_bcb
;
362 TAILQ_HEAD(bcqueue
, bfd_control_queue
);
364 struct bfd_notify_peer
{
365 TAILQ_ENTRY(bfd_notify_peer
) bnp_entry
;
367 struct bfd_session
*bnp_bs
;
369 TAILQ_HEAD(bnplist
, bfd_notify_peer
);
371 struct bfd_control_socket
{
372 TAILQ_ENTRY(bfd_control_socket
) bcs_entry
;
375 struct thread
*bcs_ev
;
376 struct thread
*bcs_outev
;
377 struct bcqueue bcs_bcqueue
;
379 /* Notification data */
381 struct bnplist bcs_bnplist
;
383 enum bc_msg_version bcs_version
;
384 enum bc_msg_type bcs_type
;
386 /* Message buffering */
387 struct bfd_control_buffer bcs_bin
;
388 struct bfd_control_buffer
*bcs_bout
;
390 TAILQ_HEAD(bcslist
, bfd_control_socket
);
392 int control_init(const char *path
);
393 void control_shutdown(void);
394 int control_notify(struct bfd_session
*bs
);
395 int control_notify_config(const char *op
, struct bfd_session
*bs
);
396 int control_accept(struct thread
*t
);
402 * Daemon specific code.
411 struct thread
*bg_ev
[6];
414 struct thread
*bg_csockev
;
415 struct bcslist bg_bcslist
;
417 struct pllist bg_pllist
;
419 extern struct bfd_global bglobal
;
420 extern struct bfd_diag_str_list diag_list
[];
421 extern struct bfd_state_str_list state_list
[];
423 void socket_close(int *s
);
429 * Contains the code related with loading/reloading configuration.
431 int parse_config(const char *fname
);
432 int config_request_add(const char *jsonstr
);
433 int config_request_del(const char *jsonstr
);
434 char *config_response(const char *status
, const char *error
);
435 char *config_notify(struct bfd_session
*bs
);
436 char *config_notify_config(const char *op
, struct bfd_session
*bs
);
438 typedef int (*bpc_handle
)(struct bfd_peer_cfg
*, void *arg
);
439 int config_notify_request(struct bfd_control_socket
*bcs
, const char *jsonstr
,
442 struct peer_label
*pl_new(const char *label
, struct bfd_session
*bs
);
443 struct peer_label
*pl_find(const char *label
);
444 void pl_free(struct peer_label
*pl
);
450 * Contains code that does the logging procedures. Might implement multiple
451 * backends (e.g. zebra log, syslog or other logging lib).
454 /* level vs syslog equivalent */
455 BLOG_DEBUG
= 0, /* LOG_DEBUG */
456 BLOG_INFO
= 1, /* LOG_INFO */
457 BLOG_WARNING
= 2, /* LOG_WARNING */
458 BLOG_ERROR
= 3, /* LOG_ERR */
459 BLOG_FATAL
= 4, /* LOG_CRIT */
462 void log_init(int foreground
, enum blog_level level
,
463 struct frr_daemon_info
*fdi
);
464 void log_info(const char *fmt
, ...);
465 void log_debug(const char *fmt
, ...);
466 void log_warning(const char *fmt
, ...);
467 void log_error(const char *fmt
, ...);
468 void log_fatal(const char *fmt
, ...);
474 * Contains the code related with receiving/seding, packing/unpacking BFD data.
476 int bp_set_ttlv6(int sd
);
477 int bp_set_ttl(int sd
);
478 int bp_set_tosv6(int sd
);
479 int bp_set_tos(int sd
);
480 int bp_bind_dev(int sd
, const char *dev
);
482 int bp_udp_shop(void);
483 int bp_udp_mhop(void);
484 int bp_udp6_shop(void);
485 int bp_udp6_mhop(void);
486 int bp_peer_socket(struct bfd_peer_cfg
*bpc
);
487 int bp_peer_socketv6(struct bfd_peer_cfg
*bpc
);
489 void ptm_bfd_snd(struct bfd_session
*bfd
, int fbit
);
490 void ptm_bfd_echo_snd(struct bfd_session
*bfd
);
492 int bfd_recv_cb(struct thread
*t
);
494 uint16_t checksum(uint16_t *buf
, int len
);
500 * Contains the code related with event loop.
502 typedef void (*bfd_ev_cb
)(struct thread
*t
);
504 void bfd_recvtimer_update(struct bfd_session
*bs
);
505 void bfd_echo_recvtimer_update(struct bfd_session
*bs
);
506 void bfd_xmttimer_update(struct bfd_session
*bs
, uint64_t jitter
);
507 void bfd_echo_xmttimer_update(struct bfd_session
*bs
, uint64_t jitter
);
509 void bfd_xmttimer_delete(struct bfd_session
*bs
);
510 void bfd_echo_xmttimer_delete(struct bfd_session
*bs
);
511 void bfd_recvtimer_delete(struct bfd_session
*bs
);
512 void bfd_echo_recvtimer_delete(struct bfd_session
*bs
);
514 void bfd_recvtimer_assign(struct bfd_session
*bs
, bfd_ev_cb cb
, int sd
);
515 void bfd_echo_recvtimer_assign(struct bfd_session
*bs
, bfd_ev_cb cb
, int sd
);
516 void bfd_xmttimer_assign(struct bfd_session
*bs
, bfd_ev_cb cb
);
517 void bfd_echo_xmttimer_assign(struct bfd_session
*bs
, bfd_ev_cb cb
);
523 * BFD protocol specific code.
525 struct bfd_session
*ptm_bfd_sess_new(struct bfd_peer_cfg
*bpc
);
526 int ptm_bfd_ses_del(struct bfd_peer_cfg
*bpc
);
527 void ptm_bfd_ses_dn(struct bfd_session
*bfd
, uint8_t diag
);
528 void ptm_bfd_ses_up(struct bfd_session
*bfd
);
529 void fetch_portname_from_ifindex(int ifindex
, char *ifname
, size_t ifnamelen
);
530 void ptm_bfd_echo_stop(struct bfd_session
*bfd
, int polling
);
531 void ptm_bfd_echo_start(struct bfd_session
*bfd
);
532 void ptm_bfd_xmt_TO(struct bfd_session
*bfd
, int fbit
);
533 void ptm_bfd_start_xmt_timer(struct bfd_session
*bfd
, bool is_echo
);
534 struct bfd_session
*ptm_bfd_sess_find(struct bfd_pkt
*cp
, char *port_name
,
535 struct sockaddr_any
*peer
,
536 struct sockaddr_any
*local
,
537 char *vrf_name
, bool is_mhop
);
539 struct bfd_session
*bs_peer_find(struct bfd_peer_cfg
*bpc
);
540 int bfd_session_update_label(struct bfd_session
*bs
, const char *nlabel
);
541 void bfd_set_polling(struct bfd_session
*bs
);
542 const char *satostr(struct sockaddr_any
*sa
);
543 const char *diag2str(uint8_t diag
);
544 int strtosa(const char *addr
, struct sockaddr_any
*sa
);
545 void integer2timestr(uint64_t time
, char *buf
, size_t buflen
);
546 const char *bs_to_string(struct bfd_session
*bs
);
548 /* BFD hash data structures interface */
549 void bfd_initialize(void);
550 void bfd_shutdown(void);
551 struct bfd_session
*bfd_id_lookup(uint32_t id
);
552 struct bfd_session
*bfd_shop_lookup(struct bfd_shop_key shop
);
553 struct bfd_session
*bfd_mhop_lookup(struct bfd_mhop_key mhop
);
554 struct bfd_vrf
*bfd_vrf_lookup(int vrf_id
);
555 struct bfd_iface
*bfd_iface_lookup(const char *ifname
);
557 struct bfd_session
*bfd_id_delete(uint32_t id
);
558 struct bfd_session
*bfd_shop_delete(struct bfd_shop_key shop
);
559 struct bfd_session
*bfd_mhop_delete(struct bfd_mhop_key mhop
);
560 struct bfd_vrf
*bfd_vrf_delete(int vrf_id
);
561 struct bfd_iface
*bfd_iface_delete(const char *ifname
);
563 bool bfd_id_insert(struct bfd_session
*bs
);
564 bool bfd_shop_insert(struct bfd_session
*bs
);
565 bool bfd_mhop_insert(struct bfd_session
*bs
);
566 bool bfd_vrf_insert(struct bfd_vrf
*vrf
);
567 bool bfd_iface_insert(struct bfd_iface
*iface
);
569 typedef void (*hash_iter_func
)(struct hash_backet
*hb
, void *arg
);
570 void bfd_id_iterate(hash_iter_func hif
, void *arg
);
571 void bfd_shop_iterate(hash_iter_func hif
, void *arg
);
572 void bfd_mhop_iterate(hash_iter_func hif
, void *arg
);
573 void bfd_vrf_iterate(hash_iter_func hif
, void *arg
);
574 void bfd_iface_iterate(hash_iter_func hif
, void *arg
);
576 /* Export callback functions for `event.c`. */
577 extern struct thread_master
*master
;
579 int bfd_recvtimer_cb(struct thread
*t
);
580 int bfd_echo_recvtimer_cb(struct thread
*t
);
581 int bfd_xmt_cb(struct thread
*t
);
582 int bfd_echo_xmt_cb(struct thread
*t
);
588 * BFD daemon vty shell commands.
590 void bfdd_vty_init(void);
596 void bfdd_zclient_init(struct zebra_privs_t
*bfdd_priv
);
597 void bfdd_zclient_stop(void);
599 int ptm_bfd_notify(struct bfd_session
*bs
);
603 * OS compatibility functions.
605 struct udp_psuedo_header
{
613 #define UDP_PSUEDO_HDR_LEN sizeof(struct udp_psuedo_header)
615 #if defined(BFD_LINUX) || defined(BFD_BSD)
616 int ptm_bfd_fetch_ifindex(const char *ifname
);
617 void ptm_bfd_fetch_local_mac(const char *ifname
, uint8_t *mac
);
618 void fetch_portname_from_ifindex(int ifindex
, char *ifname
, size_t ifnamelen
);
619 int ptm_bfd_echo_sock_init(void);
620 int ptm_bfd_vxlan_sock_init(void);
621 #endif /* BFD_LINUX || BFD_BSD */
624 uint16_t udp4_checksum(struct iphdr
*iph
, uint8_t *buf
, int len
);
625 #endif /* BFD_LINUX */
628 uint16_t udp4_checksum(struct ip
*ip
, uint8_t *buf
, int len
);
629 ssize_t
bsd_echo_sock_read(int sd
, uint8_t *buf
, ssize_t
*buflen
,
630 struct sockaddr_storage
*ss
, socklen_t
*sslen
,
631 uint8_t *ttl
, uint32_t *id
);