Welcome eigrpd

The eigrpd daemon will support the Enhanced Interior Gateway Routing Protocol.

Built using the imsg/three process framework and heavily based on ospfd(8), ospf6d(8) and ldpd(8).

The current status of eigrpd(8) is as follows:
* Almost full compliance with the specification: DUAL FSM, RTP, CR mode, SIA, etc
* Support for both IPv4 and IPv6
* Support for multiple instances (different ASes/AFs) within the same process
* Support for rdomains (one process per rdomain)
* RIB/FIB synchronization
* Basic redistribution support

Not implemented features (yet):
* Configuration reload support (partially implemented)
* Route summarization
* Advanced route redistribution/filtering
* Carp integration
* Authentication (draft is missing information)
* Stub (not released by Cisco)

Not yet connected to the builds.

ok deraadt@ claudio@

1 files changed, 269 insertions, 0 deletions

diff --git a/usr.sbin/eigrpd/neighbor.c b/usr.sbin/eigrpd/neighbor.c
new file mode 100644
index 00000000000..bc61672105f
--- /dev/null
+++ b/usr.sbin/eigrpd/neighbor.c
@@ -0,0 +1,269 @@
+/*	$OpenBSD: neighbor.c,v 1.1 2015/10/02 04:26:47 renato Exp $ */
+
+/*
+ * Copyright (c) 2015 Renato Westphal <renato@openbsd.org>
+ *
+ * Permission to use, copy, modify, and distribute this software for any
+ * purpose with or without fee is hereby granted, provided that the above
+ * copyright notice and this permission notice appear in all copies.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+ * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+ * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+ * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+ * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+ * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+ * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+ */
+
+#include <stdlib.h>
+#include <sys/socket.h>
+#include <arpa/inet.h>
+#include <string.h>
+
+#include "eigrpd.h"
+#include "eigrp.h"
+#include "eigrpe.h"
+#include "rde.h"
+#include "log.h"
+
+static __inline int nbr_compare(struct nbr *, struct nbr *);
+static __inline int nbr_pid_compare(struct nbr *, struct nbr *);
+
+RB_PROTOTYPE(nbr_addr_head, nbr, addr_tree, nbr_compare)
+RB_GENERATE(nbr_addr_head, nbr, addr_tree, nbr_compare)
+RB_PROTOTYPE(nbr_pid_head, nbr, pid_tree, nbr_pid_compare)
+RB_GENERATE(nbr_pid_head, nbr, pid_tree, nbr_pid_compare)
+
+static __inline int
+nbr_compare(struct nbr *a, struct nbr *b)
+{
+	int		 i;
+
+	if (a->ei->eigrp->af < b->ei->eigrp->af)
+		return (-1);
+	if (a->ei->eigrp->af > b->ei->eigrp->af)
+		return (1);
+	if (a->ei->iface->ifindex < b->ei->iface->ifindex)
+		return (-1);
+	if (a->ei->iface->ifindex > b->ei->iface->ifindex)
+		return (1);
+	if (a->ei->eigrp->as < b->ei->eigrp->as)
+		return (-1);
+	if (a->ei->eigrp->as > b->ei->eigrp->as)
+		return (1);
+
+	switch (a->ei->eigrp->af) {
+	case AF_INET:
+		if (ntohl(a->addr.v4.s_addr) < ntohl(b->addr.v4.s_addr))
+			return (-1);
+		if (ntohl(a->addr.v4.s_addr) > ntohl(b->addr.v4.s_addr))
+			return (1);
+		break;
+	case AF_INET6:
+		i = memcmp(&a->addr.v6, &b->addr.v6, sizeof(struct in6_addr));
+		if (i > 0)
+			return (1);
+		if (i < 0)
+			return (-1);
+		break;
+	default:
+		log_debug("%s: unexpected address-family", __func__);
+		break;
+	}
+
+	return (0);
+}
+
+static __inline int
+nbr_pid_compare(struct nbr *a, struct nbr *b)
+{
+	return (a->peerid - b->peerid);
+}
+
+struct nbr_pid_head nbrs_by_pid = RB_INITIALIZER(&nbrs_by_pid);
+
+uint32_t	peercnt = NBR_CNTSTART;
+
+extern struct eigrpd_conf	*econf;
+
+struct nbr *
+nbr_new(struct eigrp_iface *ei, union eigrpd_addr *addr, uint16_t holdtime,
+    int self)
+{
+	struct eigrp		*eigrp = ei->eigrp;
+	struct nbr		*nbr;
+
+	if (!self)
+		log_debug("%s: interface %s addr %s as %u", __func__,
+		    ei->iface->name, log_addr(eigrp->af, addr), eigrp->as);
+
+	if ((nbr = calloc(1, sizeof(*nbr))) == NULL)
+		fatal("nbr_new");
+
+	nbr->ei = ei;
+	TAILQ_INSERT_TAIL(&ei->nbr_list, nbr, entry);
+	memcpy(&nbr->addr, addr, sizeof(nbr->addr));
+	nbr->peerid = 0;
+	nbr->hello_holdtime = holdtime;
+	nbr->flags = F_EIGRP_NBR_PENDING;
+	if (self)
+		nbr->flags |= F_EIGRP_NBR_SELF;
+	TAILQ_INIT(&nbr->update_list);
+	TAILQ_INIT(&nbr->query_list);
+	TAILQ_INIT(&nbr->reply_list);
+	TAILQ_INIT(&nbr->retrans_list);
+
+	if (RB_INSERT(nbr_addr_head, &eigrp->nbrs, nbr) != NULL)
+		fatalx("nbr_new: RB_INSERT(eigrp->nbrs) failed");
+
+	/* timeout handling */
+	if (!self) {
+		evtimer_set(&nbr->ev_ack, rtp_ack_timer, nbr);
+		evtimer_set(&nbr->ev_hello_timeout, nbr_timeout, nbr);
+		nbr_start_timeout(nbr);
+	}
+
+	return (nbr);
+}
+
+void
+nbr_init(struct nbr *nbr)
+{
+	struct timeval		 now;
+	struct rde_nbr		 rnbr;
+
+	nbr->flags &= ~F_EIGRP_NBR_PENDING;
+
+	gettimeofday(&now, NULL);
+	nbr->uptime = now.tv_sec;
+
+	nbr_update_peerid(nbr);
+
+	memset(&rnbr, 0, sizeof(rnbr));
+	memcpy(&rnbr.addr, &nbr->addr, sizeof(rnbr.addr));
+	rnbr.ifaceid = nbr->ei->ifaceid;
+	if (nbr->flags & F_EIGRP_NBR_SELF)
+		rnbr.flags = F_RDE_NBR_SELF;
+
+	/* rde is not aware of pending nbrs */
+	eigrpe_imsg_compose_rde(IMSG_NEIGHBOR_UP, nbr->peerid, 0, &rnbr,
+	    sizeof(rnbr));
+}
+
+void
+nbr_del(struct nbr *nbr)
+{
+	struct eigrp		*eigrp = nbr->ei->eigrp;
+	struct packet		*pkt;
+
+	if (!(nbr->flags & F_EIGRP_NBR_SELF))
+		log_debug("%s: addr %s", __func__,
+		    log_addr(eigrp->af, &nbr->addr));
+
+	eigrpe_imsg_compose_rde(IMSG_NEIGHBOR_DOWN, nbr->peerid, 0, NULL, 0);
+
+	nbr_stop_timeout(nbr);
+
+	/* clear retransmission list */
+	while ((pkt = TAILQ_FIRST(&nbr->retrans_list)) != NULL)
+		rtp_packet_del(pkt);
+
+	if (nbr->peerid)
+		RB_REMOVE(nbr_pid_head, &nbrs_by_pid, nbr);
+	RB_REMOVE(nbr_addr_head, &eigrp->nbrs, nbr);
+	TAILQ_REMOVE(&nbr->ei->nbr_list, nbr, entry);
+
+	free(nbr);
+}
+
+void
+nbr_update_peerid(struct nbr *nbr)
+{
+	if (nbr->peerid)
+		RB_REMOVE(nbr_pid_head, &nbrs_by_pid, nbr);
+
+	/* get next unused peerid */
+	while (nbr_find_peerid(++peercnt))
+		;
+	nbr->peerid = peercnt;
+
+	if (RB_INSERT(nbr_pid_head, &nbrs_by_pid, nbr) != NULL)
+		fatalx("nbr_new: RB_INSERT(nbrs_by_pid) failed");
+}
+
+struct nbr *
+nbr_find(struct eigrp_iface *ei, union eigrpd_addr *addr)
+{
+	struct nbr		 n;
+	struct eigrp_iface	 i;
+	struct eigrp		 e;
+
+	e.af = ei->eigrp->af;
+	e.as = ei->eigrp->as;
+	i.eigrp = &e;
+	i.iface = ei->iface;
+	n.ei = &i;
+	memcpy(&n.addr, addr, sizeof(n.addr));
+
+	return (RB_FIND(nbr_addr_head, &ei->eigrp->nbrs, &n));
+}
+
+struct nbr *
+nbr_find_peerid(uint32_t peerid)
+{
+	struct nbr	n;
+	n.peerid = peerid;
+	return (RB_FIND(nbr_pid_head, &nbrs_by_pid, &n));
+}
+
+struct ctl_nbr *
+nbr_to_ctl(struct nbr *nbr)
+{
+	static struct ctl_nbr	 nctl;
+	struct timeval		 now;
+
+	nctl.af = nbr->ei->eigrp->af;
+	nctl.as = nbr->ei->eigrp->as;
+	memcpy(nctl.ifname, nbr->ei->iface->name, sizeof(nctl.ifname));
+	memcpy(&nctl.addr, &nbr->addr, sizeof(nctl.addr));
+	nctl.hello_holdtime = nbr->hello_holdtime;
+	gettimeofday(&now, NULL);
+	nctl.uptime = now.tv_sec - nbr->uptime;
+
+	return (&nctl);
+}
+
+/* timers */
+
+/* ARGSUSED */
+void
+nbr_timeout(int fd, short event, void *arg)
+{
+	struct nbr	*nbr = arg;
+	struct eigrp	*eigrp = nbr->ei->eigrp;
+
+	log_debug("%s: neighbor %s", __func__, log_addr(eigrp->af, &nbr->addr));
+
+	nbr_del(nbr);
+}
+
+void
+nbr_start_timeout(struct nbr *nbr)
+{
+	struct timeval	tv;
+
+	timerclear(&tv);
+	tv.tv_sec = nbr->hello_holdtime;
+
+	if (evtimer_add(&nbr->ev_hello_timeout, &tv) == -1)
+		fatal("nbr_start_timeout");
+}
+
+void
+nbr_stop_timeout(struct nbr *nbr)
+{
+	if (evtimer_pending(&nbr->ev_hello_timeout, NULL) &&
+	    evtimer_del(&nbr->ev_hello_timeout) == -1)
+		fatal("nbr_stop_timeout");
+}