/*
* 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, uint8_t *dm_val, uint32_t *rx_val,
+ uint32_t *tx_val)
{
- *dm_val = strtoul(dm_str, NULL, 10);
- *rx_val = strtoul(rx_str, NULL, 10);
- *tx_val = strtoul(tx_str, NULL, 10);
- return CMD_SUCCESS;
+ *dm_val = strtoul(dm_str, NULL, 10);
+ *rx_val = strtoul(rx_str, NULL, 10);
+ *tx_val = strtoul(tx_str, NULL, 10);
+ 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, uint32_t min_rx, uint32_t min_tx,
+ uint8_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 suppressed 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, bool 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 Multiplier: %d, Min Rx interval: %d,"
+ " Min Tx interval: %d\n",
+ (extra_space) ? " " : "", (bfd_tag) ? "BFD: " : " ",
+ bfd_info->detect_mult, bfd_info->required_min_rx,
+ bfd_info->desired_min_tx);
+ }
}
/*
* 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, bool 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\n",
+ (extra_space) ? " " : "", (bfd_tag) ? "BFD: " : " ",
+ bfd_get_status_str(bfd_info->status), time_buf);
+ }
}
/*
* 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, bool 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\n", (extra_space) ? " " : "",
+ (multihop) ? "multi hop" : "single hop");
+ }
+
+ 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, "\n");
}
/*
* 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;
}
projects / mirror_frr.git / blobdiff