diff options
Diffstat (limited to 'lib/bfd.c')
| -rw-r--r-- | lib/bfd.c | 715 |
1 files changed, 341 insertions, 374 deletions
@@ -41,469 +41,436 @@ struct bfd_gbl bfd_gbl; /* * bfd_gbl_init - Initialize the BFD global structure */ -void -bfd_gbl_init(void) +void bfd_gbl_init(void) { - memset(&bfd_gbl, 0, sizeof (struct bfd_gbl)); + memset(&bfd_gbl, 0, sizeof(struct bfd_gbl)); } /* * bfd_gbl_exit - Called when daemon exits */ -void -bfd_gbl_exit(void) +void bfd_gbl_exit(void) { - SET_FLAG (bfd_gbl.flags, BFD_GBL_FLAG_IN_SHUTDOWN); + SET_FLAG(bfd_gbl.flags, BFD_GBL_FLAG_IN_SHUTDOWN); } /* * bfd_info_create - Allocate the BFD information */ -struct bfd_info * -bfd_info_create(void) +struct bfd_info *bfd_info_create(void) { - struct bfd_info *bfd_info; + struct bfd_info *bfd_info; - bfd_info = XCALLOC (MTYPE_BFD_INFO, sizeof (struct bfd_info)); - assert(bfd_info); + bfd_info = XCALLOC(MTYPE_BFD_INFO, sizeof(struct bfd_info)); + assert(bfd_info); - bfd_info->status = BFD_STATUS_UNKNOWN; - bfd_info->type = BFD_TYPE_NOT_CONFIGURED; - bfd_info->last_update = 0; - return bfd_info; + bfd_info->status = BFD_STATUS_UNKNOWN; + bfd_info->type = BFD_TYPE_NOT_CONFIGURED; + bfd_info->last_update = 0; + return bfd_info; } /* * bfd_info_free - Free the BFD information. */ -void -bfd_info_free(struct bfd_info **bfd_info) +void bfd_info_free(struct bfd_info **bfd_info) { - if (*bfd_info) - { - XFREE (MTYPE_BFD_INFO, *bfd_info); - *bfd_info = NULL; - } + if (*bfd_info) { + XFREE(MTYPE_BFD_INFO, *bfd_info); + *bfd_info = NULL; + } } /* * bfd_validate_param - Validate the BFD paramter information. */ -int -bfd_validate_param(struct vty *vty, const char *dm_str, const char *rx_str, - const char *tx_str, u_int8_t *dm_val, u_int32_t *rx_val, - u_int32_t *tx_val) +int bfd_validate_param(struct vty *vty, const char *dm_str, const char *rx_str, + const char *tx_str, u_int8_t *dm_val, u_int32_t *rx_val, + u_int32_t *tx_val) { - VTY_GET_INTEGER_RANGE ("detect-mul", *dm_val, dm_str, - BFD_MIN_DETECT_MULT, BFD_MAX_DETECT_MULT); - VTY_GET_INTEGER_RANGE ("min-rx", *rx_val, rx_str, - BFD_MIN_MIN_RX, BFD_MAX_MIN_RX); - VTY_GET_INTEGER_RANGE ("min-tx", *tx_val, tx_str, - BFD_MIN_MIN_TX, BFD_MAX_MIN_TX); - return CMD_SUCCESS; + VTY_GET_INTEGER_RANGE("detect-mul", *dm_val, dm_str, + BFD_MIN_DETECT_MULT, BFD_MAX_DETECT_MULT); + VTY_GET_INTEGER_RANGE("min-rx", *rx_val, rx_str, BFD_MIN_MIN_RX, + BFD_MAX_MIN_RX); + VTY_GET_INTEGER_RANGE("min-tx", *tx_val, tx_str, BFD_MIN_MIN_TX, + BFD_MAX_MIN_TX); + return CMD_SUCCESS; } /* * bfd_set_param - Set the configured BFD paramter values */ -void -bfd_set_param (struct bfd_info **bfd_info, u_int32_t min_rx, u_int32_t min_tx, - u_int8_t detect_mult, int defaults, int *command) +void bfd_set_param(struct bfd_info **bfd_info, u_int32_t min_rx, + u_int32_t min_tx, u_int8_t detect_mult, int defaults, + int *command) { - if (!*bfd_info) - { - *bfd_info = bfd_info_create(); - *command = ZEBRA_BFD_DEST_REGISTER; - } - else - { - if (((*bfd_info)->required_min_rx != min_rx) || - ((*bfd_info)->desired_min_tx != min_tx) || - ((*bfd_info)->detect_mult != detect_mult)) - *command = ZEBRA_BFD_DEST_UPDATE; - } - - if (*command) - { - (*bfd_info)->required_min_rx = min_rx; - (*bfd_info)->desired_min_tx = min_tx; - (*bfd_info)->detect_mult = detect_mult; - } - - if (!defaults) - SET_FLAG ((*bfd_info)->flags, BFD_FLAG_PARAM_CFG); - else - UNSET_FLAG ((*bfd_info)->flags, BFD_FLAG_PARAM_CFG); + if (!*bfd_info) { + *bfd_info = bfd_info_create(); + *command = ZEBRA_BFD_DEST_REGISTER; + } else { + if (((*bfd_info)->required_min_rx != min_rx) + || ((*bfd_info)->desired_min_tx != min_tx) + || ((*bfd_info)->detect_mult != detect_mult)) + *command = ZEBRA_BFD_DEST_UPDATE; + } + + if (*command) { + (*bfd_info)->required_min_rx = min_rx; + (*bfd_info)->desired_min_tx = min_tx; + (*bfd_info)->detect_mult = detect_mult; + } + + if (!defaults) + SET_FLAG((*bfd_info)->flags, BFD_FLAG_PARAM_CFG); + else + UNSET_FLAG((*bfd_info)->flags, BFD_FLAG_PARAM_CFG); } /* * bfd_peer_sendmsg - Format and send a peer register/Unregister * command to Zebra to be forwarded to BFD */ -void -bfd_peer_sendmsg (struct zclient *zclient, struct bfd_info *bfd_info, - int family, void *dst_ip, void *src_ip, char *if_name, - int ttl, int multihop, int command, int set_flag, - vrf_id_t vrf_id) +void bfd_peer_sendmsg(struct zclient *zclient, struct bfd_info *bfd_info, + int family, void *dst_ip, void *src_ip, char *if_name, + int ttl, int multihop, int command, int set_flag, + vrf_id_t vrf_id) { - struct stream *s; - int ret; - int len; - - /* Individual reg/dereg messages are supressed during shutdown. */ - if (CHECK_FLAG (bfd_gbl.flags, BFD_GBL_FLAG_IN_SHUTDOWN)) - { - if (bfd_debug) - zlog_debug("%s: Suppressing BFD peer reg/dereg messages", __FUNCTION__); - return; - } - - /* Check socket. */ - if (!zclient || zclient->sock < 0) - { - if (bfd_debug) - zlog_debug("%s: Can't send BFD peer register, Zebra client not " - "established", __FUNCTION__); - return; - } - - s = zclient->obuf; - stream_reset (s); - zclient_create_header (s, command, vrf_id); - - stream_putl(s, getpid()); - - stream_putw(s, family); - switch (family) - { - case AF_INET: - stream_put_in_addr (s, (struct in_addr *)dst_ip); - break; - case AF_INET6: - stream_put(s, dst_ip, 16); - break; - default: - break; - } - - if (command != ZEBRA_BFD_DEST_DEREGISTER) - { - stream_putl(s, bfd_info->required_min_rx); - stream_putl(s, bfd_info->desired_min_tx); - stream_putc(s, bfd_info->detect_mult); - } - - if (multihop) - { - stream_putc(s, 1); - /* Multi-hop destination send the source IP address to BFD */ - if (src_ip) - { - stream_putw(s, family); - switch (family) - { - case AF_INET: - stream_put_in_addr (s, (struct in_addr *) src_ip); - break; - case AF_INET6: - stream_put(s, src_ip, 16); - break; - default: - break; - } - } - stream_putc(s, ttl); - } - else - { - stream_putc(s, 0); - if ((family == AF_INET6) && (src_ip)) - { - stream_putw(s, family); - stream_put(s, src_ip, 16); - } - if (if_name) - { - len = strlen(if_name); - stream_putc(s, len); - stream_put(s, if_name, len); - } - else - { - stream_putc(s, 0); - } - } - - stream_putw_at (s, 0, stream_get_endp (s)); - - ret = zclient_send_message(zclient); - - if (ret < 0) - { - if (bfd_debug) - zlog_debug("bfd_peer_sendmsg: zclient_send_message() failed"); - return; - } - - if (set_flag) - { - if (command == ZEBRA_BFD_DEST_REGISTER) - SET_FLAG(bfd_info->flags, BFD_FLAG_BFD_REG); - else if (command == ZEBRA_BFD_DEST_DEREGISTER) - UNSET_FLAG(bfd_info->flags, BFD_FLAG_BFD_REG); - } - - return; + struct stream *s; + int ret; + int len; + + /* Individual reg/dereg messages are supressed during shutdown. */ + if (CHECK_FLAG(bfd_gbl.flags, BFD_GBL_FLAG_IN_SHUTDOWN)) { + if (bfd_debug) + zlog_debug( + "%s: Suppressing BFD peer reg/dereg messages", + __FUNCTION__); + return; + } + + /* Check socket. */ + if (!zclient || zclient->sock < 0) { + if (bfd_debug) + zlog_debug( + "%s: Can't send BFD peer register, Zebra client not " + "established", + __FUNCTION__); + return; + } + + s = zclient->obuf; + stream_reset(s); + zclient_create_header(s, command, vrf_id); + + stream_putl(s, getpid()); + + stream_putw(s, family); + switch (family) { + case AF_INET: + stream_put_in_addr(s, (struct in_addr *)dst_ip); + break; + case AF_INET6: + stream_put(s, dst_ip, 16); + break; + default: + break; + } + + if (command != ZEBRA_BFD_DEST_DEREGISTER) { + stream_putl(s, bfd_info->required_min_rx); + stream_putl(s, bfd_info->desired_min_tx); + stream_putc(s, bfd_info->detect_mult); + } + + if (multihop) { + stream_putc(s, 1); + /* Multi-hop destination send the source IP address to BFD */ + if (src_ip) { + stream_putw(s, family); + switch (family) { + case AF_INET: + stream_put_in_addr(s, (struct in_addr *)src_ip); + break; + case AF_INET6: + stream_put(s, src_ip, 16); + break; + default: + break; + } + } + stream_putc(s, ttl); + } else { + stream_putc(s, 0); + if ((family == AF_INET6) && (src_ip)) { + stream_putw(s, family); + stream_put(s, src_ip, 16); + } + if (if_name) { + len = strlen(if_name); + stream_putc(s, len); + stream_put(s, if_name, len); + } else { + stream_putc(s, 0); + } + } + + stream_putw_at(s, 0, stream_get_endp(s)); + + ret = zclient_send_message(zclient); + + if (ret < 0) { + if (bfd_debug) + zlog_debug( + "bfd_peer_sendmsg: zclient_send_message() failed"); + return; + } + + if (set_flag) { + if (command == ZEBRA_BFD_DEST_REGISTER) + SET_FLAG(bfd_info->flags, BFD_FLAG_BFD_REG); + else if (command == ZEBRA_BFD_DEST_DEREGISTER) + UNSET_FLAG(bfd_info->flags, BFD_FLAG_BFD_REG); + } + + return; } /* * bfd_get_command_dbg_str - Convert command to a debug string. */ -const char * -bfd_get_command_dbg_str(int command) +const char *bfd_get_command_dbg_str(int command) { - switch (command) - { - case ZEBRA_BFD_DEST_REGISTER: - return "Register"; - case ZEBRA_BFD_DEST_DEREGISTER: - return "Deregister"; - case ZEBRA_BFD_DEST_UPDATE: - return "Update"; - default: - return "Unknown"; - } + switch (command) { + case ZEBRA_BFD_DEST_REGISTER: + return "Register"; + case ZEBRA_BFD_DEST_DEREGISTER: + return "Deregister"; + case ZEBRA_BFD_DEST_UPDATE: + return "Update"; + default: + return "Unknown"; + } } /* * bfd_get_peer_info - Extract the Peer information for which the BFD session * went down from the message sent from Zebra to clients. */ -struct interface * -bfd_get_peer_info (struct stream *s, struct prefix *dp, struct prefix *sp, - int *status, vrf_id_t vrf_id) +struct interface *bfd_get_peer_info(struct stream *s, struct prefix *dp, + struct prefix *sp, int *status, + vrf_id_t vrf_id) { - unsigned int ifindex; - struct interface *ifp = NULL; - int plen; - - /* Get interface index. */ - ifindex = stream_getl (s); - - /* Lookup index. */ - if (ifindex != 0) - { - ifp = if_lookup_by_index (ifindex, vrf_id); - if (ifp == NULL) - { - if (bfd_debug) - zlog_debug ("zebra_interface_bfd_read: " - "Can't find interface by ifindex: %d ", ifindex); - return NULL; - } - } - - /* Fetch destination address. */ - dp->family = stream_getc (s); - - plen = prefix_blen (dp); - stream_get (&dp->u.prefix, s, plen); - dp->prefixlen = stream_getc (s); - - /* Get BFD status. */ - *status = stream_getl (s); - - if (sp) - { - sp->family = stream_getc (s); - - plen = prefix_blen (sp); - stream_get (&sp->u.prefix, s, plen); - sp->prefixlen = stream_getc (s); - } - return ifp; + unsigned int ifindex; + struct interface *ifp = NULL; + int plen; + + /* Get interface index. */ + ifindex = stream_getl(s); + + /* Lookup index. */ + if (ifindex != 0) { + ifp = if_lookup_by_index(ifindex, vrf_id); + if (ifp == NULL) { + if (bfd_debug) + zlog_debug( + "zebra_interface_bfd_read: " + "Can't find interface by ifindex: %d ", + ifindex); + return NULL; + } + } + + /* Fetch destination address. */ + dp->family = stream_getc(s); + + plen = prefix_blen(dp); + stream_get(&dp->u.prefix, s, plen); + dp->prefixlen = stream_getc(s); + + /* Get BFD status. */ + *status = stream_getl(s); + + if (sp) { + sp->family = stream_getc(s); + + plen = prefix_blen(sp); + stream_get(&sp->u.prefix, s, plen); + sp->prefixlen = stream_getc(s); + } + return ifp; } /* * bfd_get_status_str - Convert BFD status to a display string. */ -const char * -bfd_get_status_str(int status) +const char *bfd_get_status_str(int status) { - switch (status) - { - case BFD_STATUS_DOWN: - return "Down"; - case BFD_STATUS_UP: - return "Up"; - case BFD_STATUS_UNKNOWN: - default: - return "Unknown"; - } + switch (status) { + case BFD_STATUS_DOWN: + return "Down"; + case BFD_STATUS_UP: + return "Up"; + case BFD_STATUS_UNKNOWN: + default: + return "Unknown"; + } } /* * bfd_last_update - Calculate the last BFD update time and convert it * into a dd:hh:mm:ss display format. */ -static void -bfd_last_update (time_t last_update, char *buf, size_t len) +static void bfd_last_update(time_t last_update, char *buf, size_t len) { - time_t curr; - time_t diff; - struct tm *tm; - struct timeval tv; - - /* If no BFD satatus update has ever been received, print `never'. */ - if (last_update == 0) - { - snprintf (buf, len, "never"); - return; - } - - /* Get current time. */ - monotime(&tv); - curr = tv.tv_sec; - diff = curr - last_update; - tm = gmtime (&diff); - - snprintf (buf, len, "%d:%02d:%02d:%02d", - tm->tm_yday, tm->tm_hour, tm->tm_min, tm->tm_sec); + time_t curr; + time_t diff; + struct tm *tm; + struct timeval tv; + + /* If no BFD satatus update has ever been received, print `never'. */ + if (last_update == 0) { + snprintf(buf, len, "never"); + return; + } + + /* Get current time. */ + monotime(&tv); + curr = tv.tv_sec; + diff = curr - last_update; + tm = gmtime(&diff); + + snprintf(buf, len, "%d:%02d:%02d:%02d", tm->tm_yday, tm->tm_hour, + tm->tm_min, tm->tm_sec); } /* * bfd_show_param - Show the BFD parameter information. */ -void -bfd_show_param(struct vty *vty, struct bfd_info *bfd_info, int bfd_tag, - int extra_space, u_char use_json, json_object *json_obj) +void bfd_show_param(struct vty *vty, struct bfd_info *bfd_info, int bfd_tag, + int extra_space, u_char use_json, json_object *json_obj) { - json_object *json_bfd = NULL; - - if (!bfd_info) - return; - - if (use_json) - { - if (bfd_tag) - json_bfd = json_object_new_object(); - else - json_bfd = json_obj; - - json_object_int_add(json_bfd, "detectMultiplier", bfd_info->detect_mult); - json_object_int_add(json_bfd, "rxMinInterval", bfd_info->required_min_rx); - json_object_int_add(json_bfd, "txMinInterval", bfd_info->desired_min_tx); - if (bfd_tag) - json_object_object_add(json_obj, "peerBfdInfo", json_bfd); - } - else - { - vty_out (vty, " %s%sDetect Mul: %d, Min Rx interval: %d," - " Min Tx interval: %d%s", - (extra_space) ? " ": "", (bfd_tag) ? "BFD: " : " ", - bfd_info->detect_mult, bfd_info->required_min_rx, - bfd_info->desired_min_tx, VTY_NEWLINE); - } + json_object *json_bfd = NULL; + + if (!bfd_info) + return; + + if (use_json) { + if (bfd_tag) + json_bfd = json_object_new_object(); + else + json_bfd = json_obj; + + json_object_int_add(json_bfd, "detectMultiplier", + bfd_info->detect_mult); + json_object_int_add(json_bfd, "rxMinInterval", + bfd_info->required_min_rx); + json_object_int_add(json_bfd, "txMinInterval", + bfd_info->desired_min_tx); + if (bfd_tag) + json_object_object_add(json_obj, "peerBfdInfo", + json_bfd); + } else { + vty_out(vty, + " %s%sDetect Mul: %d, Min Rx interval: %d," + " Min Tx interval: %d%s", + (extra_space) ? " " : "", (bfd_tag) ? "BFD: " : " ", + bfd_info->detect_mult, bfd_info->required_min_rx, + bfd_info->desired_min_tx, VTY_NEWLINE); + } } /* * bfd_show_status - Show the BFD status information. */ -static void -bfd_show_status(struct vty *vty, struct bfd_info *bfd_info, int bfd_tag, - int extra_space, u_char use_json, json_object *json_bfd) +static void bfd_show_status(struct vty *vty, struct bfd_info *bfd_info, + int bfd_tag, int extra_space, u_char use_json, + json_object *json_bfd) { - char time_buf[32]; - - if (!bfd_info) - return; - - bfd_last_update(bfd_info->last_update, time_buf, 32); - if (use_json) - { - json_object_string_add(json_bfd, "status", - bfd_get_status_str(bfd_info->status)); - json_object_string_add(json_bfd, "lastUpdate", time_buf); - } - else - { - vty_out (vty, " %s%sStatus: %s, Last update: %s%s", - (extra_space) ? " ": "", (bfd_tag) ? "BFD: " : " ", - bfd_get_status_str(bfd_info->status), time_buf, VTY_NEWLINE); - } + char time_buf[32]; + + if (!bfd_info) + return; + + bfd_last_update(bfd_info->last_update, time_buf, 32); + if (use_json) { + json_object_string_add(json_bfd, "status", + bfd_get_status_str(bfd_info->status)); + json_object_string_add(json_bfd, "lastUpdate", time_buf); + } else { + vty_out(vty, " %s%sStatus: %s, Last update: %s%s", + (extra_space) ? " " : "", (bfd_tag) ? "BFD: " : " ", + bfd_get_status_str(bfd_info->status), time_buf, + VTY_NEWLINE); + } } /* * bfd_show_info - Show the BFD information. */ -void -bfd_show_info(struct vty *vty, struct bfd_info *bfd_info, int multihop, - int extra_space, u_char use_json, json_object *json_obj) +void bfd_show_info(struct vty *vty, struct bfd_info *bfd_info, int multihop, + int extra_space, u_char use_json, json_object *json_obj) { - json_object *json_bfd = NULL; - - if (!bfd_info) - return; - - if (use_json) - { - json_bfd = json_object_new_object(); - if (multihop) - json_object_string_add(json_bfd, "type", "multi hop"); - else - json_object_string_add(json_bfd, "type", "single hop"); - } - else - { - vty_out (vty, " %sBFD: Type: %s%s", (extra_space) ? " " : "", - (multihop) ? "multi hop" : "single hop", VTY_NEWLINE); - } - - bfd_show_param(vty, bfd_info, 0, extra_space, use_json, json_bfd); - bfd_show_status(vty, bfd_info, 0, extra_space, use_json, json_bfd); - - if (use_json) - json_object_object_add(json_obj, "peerBfdInfo", json_bfd); - else - vty_out (vty, "%s", VTY_NEWLINE); + json_object *json_bfd = NULL; + + if (!bfd_info) + return; + + if (use_json) { + json_bfd = json_object_new_object(); + if (multihop) + json_object_string_add(json_bfd, "type", "multi hop"); + else + json_object_string_add(json_bfd, "type", "single hop"); + } else { + vty_out(vty, " %sBFD: Type: %s%s", (extra_space) ? " " : "", + (multihop) ? "multi hop" : "single hop", VTY_NEWLINE); + } + + bfd_show_param(vty, bfd_info, 0, extra_space, use_json, json_bfd); + bfd_show_status(vty, bfd_info, 0, extra_space, use_json, json_bfd); + + if (use_json) + json_object_object_add(json_obj, "peerBfdInfo", json_bfd); + else + vty_out(vty, "%s", VTY_NEWLINE); } /* * bfd_client_sendmsg - Format and send a client register * command to Zebra to be forwarded to BFD */ -void -bfd_client_sendmsg (struct zclient *zclient, int command) +void bfd_client_sendmsg(struct zclient *zclient, int command) { - struct stream *s; - int ret; - - /* Check socket. */ - if (!zclient || zclient->sock < 0) - { - if (bfd_debug) - zlog_debug ("%s: Can't send BFD client register, Zebra client not " - "established", __FUNCTION__); - return; - } - - s = zclient->obuf; - stream_reset (s); - zclient_create_header (s, command, VRF_DEFAULT); - - stream_putl(s, getpid()); - - stream_putw_at (s, 0, stream_get_endp (s)); - - ret = zclient_send_message(zclient); - - if (ret < 0) - { - if (bfd_debug) - zlog_debug ("bfd_client_sendmsg %ld: zclient_send_message() failed", - (long) getpid()); - return; - } - - return; + struct stream *s; + int ret; + + /* Check socket. */ + if (!zclient || zclient->sock < 0) { + if (bfd_debug) + zlog_debug( + "%s: Can't send BFD client register, Zebra client not " + "established", + __FUNCTION__); + return; + } + + s = zclient->obuf; + stream_reset(s); + zclient_create_header(s, command, VRF_DEFAULT); + + stream_putl(s, getpid()); + + stream_putw_at(s, 0, stream_get_endp(s)); + + ret = zclient_send_message(zclient); + + if (ret < 0) { + if (bfd_debug) + zlog_debug( + "bfd_client_sendmsg %ld: zclient_send_message() failed", + (long)getpid()); + return; + } + + return; } |