mctp, mctp-netlink: allow add & remove of range routes

Add a separate parser for the route target argument, allowing
<min>-<max> ranges to be specified, and pass to the rtm_dst_len value of
the netlink rtmsg.

Fixes: #58

Signed-off-by: Jeremy Kerr <jk@codeconstruct.com.au>

Author: jk-ozlabs

CHANGELOG.md

@@ -30,6 +30,8 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
 5. `mctp` now supports gateway routes
 
+6. `mctp` route can add & delete range routes, using a <min>-<max> range format
+
 ### Changed
 
 1. tests are now run with address sanitizer enabled (-fsanitize=address)

README.md

@@ -52,10 +52,10 @@ Use `mctp help` for the list of available commands:
 
     mctp route
     mctp route show [net <network>]
-    mctp route add <eid> via <dev> [mtu <mtu>]
-    mctp route add <eid> gw <eid> [net <net>] [mtu <mtu>]
-    mctp route del <eid> via <dev>
-    mctp route del <eid> gw <eid> [net <net>]
+    mctp route add <eid>[-<eid>] via <dev> [mtu <mtu>]
+    mctp route add <eid>[-<eid>] gw <eid> [net <net>] [mtu <mtu>]
+    mctp route del <eid>[-<eid>] via <dev>
+    mctp route del <eid>[-<eid>] gw <eid> [net <net>]
 
     mctp neigh
     mctp neigh show [dev <network>]

src/mctp-netlink.c

@@ -1152,7 +1152,8 @@ struct mctp_rtalter_msg {
 };
 static int fill_rtalter_args(struct mctp_nl *nl, struct mctp_rtalter_msg *msg,
 	struct rtattr **prta, size_t *prta_len,
-	mctp_eid_t eid, const char* linkstr, const struct mctp_fq_addr *gw)
+	mctp_eid_t eid, unsigned int extent,
+	const char* linkstr, const struct mctp_fq_addr *gw)
 {
 	struct rtattr *rta;
 	int ifindex = 0;
@@ -1169,13 +1170,17 @@ static int fill_rtalter_args(struct mctp_nl *nl, struct mctp_rtalter_msg *msg,
 		return -1;
 	}
 
+	if (extent > 0xff || (unsigned int)eid + extent > 0xfe) {
+		warnx("invalid route extent");
+		return -1;
+	}
+
 	memset(msg, 0x0, sizeof(*msg));
 	msg->nh.nlmsg_flags = NLM_F_REQUEST | NLM_F_ACK;
 
 	msg->rtmsg.rtm_family = AF_MCTP;
 	msg->rtmsg.rtm_type = RTN_UNICAST;
-	// TODO add eid range handling
-	msg->rtmsg.rtm_dst_len = 0;
+	msg->rtmsg.rtm_dst_len = extent;
 	msg->rtmsg.rtm_type = RTN_UNICAST;
 
 	msg->nh.nlmsg_len = NLMSG_LENGTH(sizeof(msg->rtmsg));
@@ -1200,15 +1205,17 @@ static int fill_rtalter_args(struct mctp_nl *nl, struct mctp_rtalter_msg *msg,
 	return 0;
 }
 
-int mctp_nl_route_add(struct mctp_nl *nl, uint8_t eid, const char* ifname,
-		      const struct mctp_fq_addr *gw, uint32_t mtu)
+int mctp_nl_route_add(struct mctp_nl *nl, uint8_t eid, unsigned int extent,
+		      const char* ifname, const struct mctp_fq_addr *gw,
+		      uint32_t mtu)
 {
 	struct mctp_rtalter_msg msg;
 	struct rtattr *rta;
 	size_t rta_len;
 	int rc;
 
-	rc = fill_rtalter_args(nl, &msg, &rta, &rta_len, eid, ifname, gw);
+	rc = fill_rtalter_args(nl, &msg, &rta, &rta_len, eid, extent, ifname,
+			       gw);
 	if (rc) {
 		return -1;
 	}
@@ -1237,13 +1244,13 @@ int mctp_nl_route_add(struct mctp_nl *nl, uint8_t eid, const char* ifname,
 
 }
 
-int mctp_nl_route_del(struct mctp_nl *nl, uint8_t eid, const char* ifname,
-		      const struct mctp_fq_addr *gw)
+int mctp_nl_route_del(struct mctp_nl *nl, uint8_t eid, unsigned int extent,
+		      const char* ifname, const struct mctp_fq_addr *gw)
 {
 	struct mctp_rtalter_msg msg;
 	int rc;
 
-	rc = fill_rtalter_args(nl, &msg, NULL, NULL, eid, ifname, gw);
+	rc = fill_rtalter_args(nl, &msg, NULL, NULL, eid, extent, ifname, gw);
 	if (rc) {
 		return rc;
 	}

src/mctp-netlink.h

@@ -99,10 +99,11 @@ void *mctp_nl_get_link_userdata(const mctp_nl *nl, int ifindex);
 void *mctp_nl_get_link_userdata_byname(const mctp_nl *nl, const char *ifname);
 
 /* MCTP route helper */
-int mctp_nl_route_add(struct mctp_nl *nl, uint8_t eid, const char* ifname,
-		      const struct mctp_fq_addr *gw, uint32_t mtu);
-int mctp_nl_route_del(struct mctp_nl *nl, uint8_t eid, const char* ifname,
-		      const struct mctp_fq_addr *gw);
+int mctp_nl_route_add(struct mctp_nl *nl, uint8_t eid, unsigned int extent,
+		      const char* ifname, const struct mctp_fq_addr *gw,
+		      uint32_t mtu);
+int mctp_nl_route_del(struct mctp_nl *nl, uint8_t eid, unsigned int extent,
+		      const char* ifname, const struct mctp_fq_addr *gw);
 
 /* Helpers */
 

src/mctp.c

@@ -892,9 +892,55 @@ static int parse_eid(const char *str, mctp_eid_t *eid)
 	return 0;
 }
 
+static int parse_eid_range(const char *str, mctp_eid_t *eid,
+			   unsigned int *extent)
+{
+	char tmp[10]; /* sufficient length to handle "100-101" */
+	mctp_eid_t min, max;
+	size_t len;
+	char *sep;
+	int rc;
+
+	len = strlen(str);
+	if (len >= sizeof(tmp) - 1)
+		return -1;
+
+	strncpy(tmp, str, sizeof(tmp) - 1);
+	tmp[sizeof(tmp) - 1] = '\0';
+
+	sep = strchr(tmp, '-');
+	if (sep) {
+		rc = parse_eid(sep + 1, &max);
+		if (rc)
+			return rc;
+
+		if (max >= 0xff)
+			return -1;
+
+		*sep = '\0';
+	}
+
+	rc = parse_eid(tmp, &min);
+	if (rc)
+		return rc;
+
+	*eid = min;
+	if (sep) {
+		if (max < min)
+			return -1;
+		*extent = max - min;
+	} else {
+		*extent = 0;
+	}
+
+	return 0;
+}
+
+
 static int parse_route_args(struct ctx *ctx, int argc, const char **argv,
-			    mctp_eid_t *eidp, const char **linkstrp,
-			    struct mctp_fq_addr *gwp, unsigned int *mtup)
+			    mctp_eid_t *eidp, unsigned int *extent,
+			    const char **linkstrp, struct mctp_fq_addr *gwp,
+			    unsigned int *mtup)
 {
 	const char *eidstr, *linkstr = NULL;
 	struct mctp_fq_addr gw = { 0 };
@@ -907,9 +953,9 @@ static int parse_route_args(struct ctx *ctx, int argc, const char **argv,
 		return -1;
 
 	eidstr = argv[0];
-	rc = parse_eid(eidstr, &eid);
+	rc = parse_eid_range(eidstr, &eid, extent);
 	if (rc) {
-		warnx("Invalid EID '%s'", eidstr);
+		warnx("Invalid EID/range '%s'", eidstr);
 		return -1;
 	}
 
@@ -972,35 +1018,37 @@ static int parse_route_args(struct ctx *ctx, int argc, const char **argv,
 static int cmd_route_add(struct ctx *ctx, int argc, const char **argv)
 {
 	struct mctp_fq_addr gw = { 0 };
+	unsigned int extent, mtu = 0;
 	const char *linkstr = NULL;
-	unsigned int mtu = 0;
 	mctp_eid_t eid;
 	int rc;
 
-	rc = parse_route_args(ctx, argc - 1, argv + 1, &eid, &linkstr, &gw, &mtu);
+	rc = parse_route_args(ctx, argc - 1, argv + 1, &eid, &extent,
+			      &linkstr, &gw, &mtu);
 	if (rc) {
 		warnx("add: invalid command line arguments");
 		return -1;
 	}
 
-	return mctp_nl_route_add(ctx->nl, eid, linkstr, &gw, mtu);
+	return mctp_nl_route_add(ctx->nl, eid, extent, linkstr, &gw, mtu);
 }
 
 static int cmd_route_del(struct ctx *ctx, int argc, const char **argv)
 {
 	struct mctp_fq_addr gw = { 0 };
+	unsigned int extent, mtu = 0;
 	const char *linkstr = NULL;
-	unsigned int mtu = 0;
 	mctp_eid_t eid;
 	int rc;
 
-	rc = parse_route_args(ctx, argc - 1, argv + 1, &eid, &linkstr, &gw, &mtu);
+	rc = parse_route_args(ctx, argc - 1, argv + 1, &eid, &extent,
+			      &linkstr, &gw, &mtu);
 	if (rc) {
 		warnx("del: invalid command line arguments");
 		return -1;
 	}
 
-	return mctp_nl_route_del(ctx->nl, eid, linkstr, &gw);
+	return mctp_nl_route_del(ctx->nl, eid, extent, linkstr, &gw);
 }
 
 static int cmd_route(struct ctx *ctx, int argc, const char **argv)
@@ -1009,11 +1057,14 @@ static int cmd_route(struct ctx *ctx, int argc, const char **argv)
 	if (argc == 2 && !strcmp(argv[1], "help")) {
 		fprintf(stderr, "%s route\n", ctx->top_cmd);
 		fprintf(stderr, "%s route show [net <network>]\n", ctx->top_cmd);
-		fprintf(stderr, "%s route add <eid> via <dev> [mtu <mtu>]\n", ctx->top_cmd);
-		fprintf(stderr, "%s route add <eid> gw <eid> [net <net>] [mtu <mtu>]\n",
+		fprintf(stderr, "%s route add <eid>[-<eid>] via <dev> [mtu <mtu>]\n",
+			ctx->top_cmd);
+		fprintf(stderr, "%s route add <eid>[-<eid>] gw <eid> [net <net>] [mtu <mtu>]\n",
+			ctx->top_cmd);
+		fprintf(stderr, "%s route del <eid>[-<eid>] via <dev>\n",
+			ctx->top_cmd);
+		fprintf(stderr, "%s route del <eid>[-<eid>] gw <eid> [net <net>]\n",
 			ctx->top_cmd);
-		fprintf(stderr, "%s route del <eid> via <dev>\n", ctx->top_cmd);
-		fprintf(stderr, "%s route del <eid> gw <eid> [net <net>]\n", ctx->top_cmd);
 		return 255;
 	}
 

src/mctpd.c

@@ -1536,15 +1536,15 @@ static int peer_set_mtu(struct ctx *ctx, struct peer *peer, uint32_t mtu) {
 		return -EPROTO;
 	}
 
-	rc = mctp_nl_route_del(ctx->nl_query, peer->eid, ifname, NULL);
+	rc = mctp_nl_route_del(ctx->nl_query, peer->eid, 0, ifname, NULL);
 	if (rc < 0 && rc != -ENOENT) {
 		warnx("%s, Failed removing existing route for eid %d %s",
 			__func__,
 			peer->phys.ifindex, ifname);
 		// Continue regardless, route_add will likely fail with EEXIST
 	}
 
-	rc = mctp_nl_route_add(ctx->nl_query, peer->eid, ifname, NULL, mtu);
+	rc = mctp_nl_route_add(ctx->nl_query, peer->eid, 0, ifname, NULL, mtu);
 	if (rc >= 0) {
 		peer->mtu = mtu;
 	}
@@ -2243,10 +2243,10 @@ static int peer_route_update(struct peer *peer, uint16_t type)
 	}
 
 	if (type == RTM_NEWROUTE) {
-		return mctp_nl_route_add(peer->ctx->nl_query, peer->eid,
+		return mctp_nl_route_add(peer->ctx->nl_query, peer->eid, 0,
 					 link, NULL, peer->mtu);
 	} else if (type == RTM_DELROUTE) {
-		return mctp_nl_route_del(peer->ctx->nl_query, peer->eid,
+		return mctp_nl_route_del(peer->ctx->nl_query, peer->eid, 0,
 					 link, NULL);
 	}