1 files changed, 121 insertions, 0 deletions
diff --git a/pimd/pim_bfd.c b/pimd/pim_bfd.c
new file mode 100644
index 0000000..43d9f08
--- /dev/null
+++ b/pimd/pim_bfd.c
@@ -0,0 +1,121 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+/*
+ * pim_bfd.c: PIM BFD handling routines
+ *
+ * Copyright (C) 2017 Cumulus Networks, Inc.
+ * Chirag Shah
+ */
+
+#include <zebra.h>
+
+#include "lib/json.h"
+#include "command.h"
+#include "vty.h"
+#include "zclient.h"
+
+#include "pim_instance.h"
+#include "pim_neighbor.h"
+#include "pim_vty.h"
+#include "pim_iface.h"
+#include "pim_bfd.h"
+#include "bfd.h"
+#include "pimd.h"
+#include "pim_zebra.h"
+
+/*
+ * pim_bfd_write_config - Write the interface BFD configuration.
+ */
+void pim_bfd_write_config(struct vty *vty, struct interface *ifp)
+{
+	struct pim_interface *pim_ifp = ifp->info;
+
+	if (!pim_ifp || !pim_ifp->bfd_config.enabled)
+		return;
+
+#if HAVE_BFDD == 0
+	if (pim_ifp->bfd_config.detection_multiplier != BFD_DEF_DETECT_MULT
+	    || pim_ifp->bfd_config.min_rx != BFD_DEF_MIN_RX
+	    || pim_ifp->bfd_config.min_tx != BFD_DEF_MIN_TX)
+		vty_out(vty, " " PIM_AF_NAME " pim bfd %d %d %d\n",
+			pim_ifp->bfd_config.detection_multiplier,
+			pim_ifp->bfd_config.min_rx, pim_ifp->bfd_config.min_tx);
+	else
+#endif /* ! HAVE_BFDD */
+		vty_out(vty, " " PIM_AF_NAME " pim bfd\n");
+
+	if (pim_ifp->bfd_config.profile)
+		vty_out(vty, " " PIM_AF_NAME " pim bfd profile %s\n",
+			pim_ifp->bfd_config.profile);
+}
+
+static void pim_neighbor_bfd_cb(struct bfd_session_params *bsp,
+				const struct bfd_session_status *bss, void *arg)
+{
+	struct pim_neighbor *nbr = arg;
+
+	if (PIM_DEBUG_PIM_TRACE) {
+		zlog_debug("%s: status %s old_status %s", __func__,
+			   bfd_get_status_str(bss->state),
+			   bfd_get_status_str(bss->previous_state));
+	}
+
+	if (bss->state == BFD_STATUS_DOWN
+	    && bss->previous_state == BFD_STATUS_UP)
+		pim_neighbor_delete(nbr->interface, nbr, "BFD Session Expired");
+}
+
+/*
+ * pim_bfd_info_nbr_create - Create/update BFD information for a neighbor.
+ */
+void pim_bfd_info_nbr_create(struct pim_interface *pim_ifp,
+			     struct pim_neighbor *neigh)
+{
+	/* Check if Pim Interface BFD is enabled */
+	if (!pim_ifp || !pim_ifp->bfd_config.enabled)
+		return;
+
+	if (neigh->bfd_session == NULL)
+		neigh->bfd_session = bfd_sess_new(pim_neighbor_bfd_cb, neigh);
+
+	bfd_sess_set_timers(
+		neigh->bfd_session, pim_ifp->bfd_config.detection_multiplier,
+		pim_ifp->bfd_config.min_rx, pim_ifp->bfd_config.min_tx);
+#if PIM_IPV == 4
+	bfd_sess_set_ipv4_addrs(neigh->bfd_session, NULL, &neigh->source_addr);
+#else
+	bfd_sess_set_ipv6_addrs(neigh->bfd_session, NULL, &neigh->source_addr);
+#endif
+	bfd_sess_set_interface(neigh->bfd_session, neigh->interface->name);
+	bfd_sess_set_vrf(neigh->bfd_session, neigh->interface->vrf->vrf_id);
+	bfd_sess_set_profile(neigh->bfd_session, pim_ifp->bfd_config.profile);
+	bfd_sess_install(neigh->bfd_session);
+}
+
+/*
+ * pim_bfd_reg_dereg_all_nbr - Register/Deregister all neighbors associated
+ *                              with a interface with BFD through
+ *                              zebra for starting/stopping the monitoring of
+ *                              the neighbor rechahability.
+ */
+void pim_bfd_reg_dereg_all_nbr(struct interface *ifp)
+{
+	struct pim_interface *pim_ifp = NULL;
+	struct listnode *node = NULL;
+	struct pim_neighbor *neigh = NULL;
+
+	pim_ifp = ifp->info;
+	if (!pim_ifp)
+		return;
+
+	for (ALL_LIST_ELEMENTS_RO(pim_ifp->pim_neighbor_list, node, neigh)) {
+		if (pim_ifp->bfd_config.enabled)
+			pim_bfd_info_nbr_create(pim_ifp, neigh);
+		else
+			bfd_sess_free(&neigh->bfd_session);
+	}
+}
+
+void pim_bfd_init(void)
+{
+	bfd_protocol_integration_init(pim_zebra_zclient_get(), router->master);
+}