|
Packit |
d3f73b |
// SPDX-License-Identifier: GPL-2.0
|
|
Packit |
d3f73b |
/*
|
|
Packit |
d3f73b |
* ip nexthop
|
|
Packit |
d3f73b |
*
|
|
Packit |
d3f73b |
* Copyright (c) 2017-19 David Ahern <dsahern@gmail.com>
|
|
Packit |
d3f73b |
*/
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
#include <linux/nexthop.h>
|
|
Packit |
d3f73b |
#include <stdio.h>
|
|
Packit |
d3f73b |
#include <string.h>
|
|
Packit |
d3f73b |
#include <rt_names.h>
|
|
Packit |
d3f73b |
#include <errno.h>
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
#include "utils.h"
|
|
Packit |
d3f73b |
#include "ip_common.h"
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static struct {
|
|
Packit |
d3f73b |
unsigned int flushed;
|
|
Packit |
d3f73b |
unsigned int groups;
|
|
Packit |
d3f73b |
unsigned int ifindex;
|
|
Packit |
d3f73b |
unsigned int master;
|
|
Packit |
d3f73b |
} filter;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
enum {
|
|
Packit |
d3f73b |
IPNH_LIST,
|
|
Packit |
d3f73b |
IPNH_FLUSH,
|
|
Packit |
d3f73b |
};
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
#define RTM_NHA(h) ((struct rtattr *)(((char *)(h)) + \
|
|
Packit |
d3f73b |
NLMSG_ALIGN(sizeof(struct nhmsg))))
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static void usage(void) __attribute__((noreturn));
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static void usage(void)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
fprintf(stderr,
|
|
Packit |
d3f73b |
"Usage: ip nexthop { list | flush } SELECTOR\n"
|
|
Packit |
d3f73b |
" ip nexthop { add | replace } id ID NH [ protocol ID ]\n"
|
|
Packit |
d3f73b |
" ip nexthop { get| del } id ID\n"
|
|
Packit |
d3f73b |
"SELECTOR := [ id ID ] [ dev DEV ] [ vrf NAME ] [ master DEV ]\n"
|
|
Packit |
d3f73b |
" [ groups ]\n"
|
|
Packit |
d3f73b |
"NH := { blackhole | [ via ADDRESS ] [ dev DEV ] [ onlink ]\n"
|
|
Packit |
d3f73b |
" [ encap ENCAPTYPE ENCAPHDR ] | group GROUP ] }\n"
|
|
Packit |
d3f73b |
"GROUP := [ id[,weight]>/<id[,weight]>/... ]\n"
|
|
Packit |
d3f73b |
"ENCAPTYPE := [ mpls ]\n"
|
|
Packit |
d3f73b |
"ENCAPHDR := [ MPLSLABEL ]\n");
|
|
Packit |
d3f73b |
exit(-1);
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static int nh_dump_filter(struct nlmsghdr *nlh, int reqlen)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
int err;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (filter.ifindex) {
|
|
Packit |
d3f73b |
err = addattr32(nlh, reqlen, NHA_OIF, filter.ifindex);
|
|
Packit |
d3f73b |
if (err)
|
|
Packit |
d3f73b |
return err;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (filter.groups) {
|
|
Packit |
d3f73b |
addattr_l(nlh, reqlen, NHA_GROUPS, NULL, 0);
|
|
Packit |
d3f73b |
if (err)
|
|
Packit |
d3f73b |
return err;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (filter.master) {
|
|
Packit |
d3f73b |
addattr32(nlh, reqlen, NHA_MASTER, filter.master);
|
|
Packit |
d3f73b |
if (err)
|
|
Packit |
d3f73b |
return err;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
return 0;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static struct rtnl_handle rth_del = { .fd = -1 };
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static int delete_nexthop(__u32 id)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
struct {
|
|
Packit |
d3f73b |
struct nlmsghdr n;
|
|
Packit |
d3f73b |
struct nhmsg nhm;
|
|
Packit |
d3f73b |
char buf[64];
|
|
Packit |
d3f73b |
} req = {
|
|
Packit |
d3f73b |
.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct nhmsg)),
|
|
Packit |
d3f73b |
.n.nlmsg_flags = NLM_F_REQUEST,
|
|
Packit |
d3f73b |
.n.nlmsg_type = RTM_DELNEXTHOP,
|
|
Packit |
d3f73b |
.nhm.nh_family = AF_UNSPEC,
|
|
Packit |
d3f73b |
};
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
req.n.nlmsg_seq = ++rth_del.seq;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
addattr32(&req.n, sizeof(req), NHA_ID, id);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (rtnl_talk(&rth_del, &req.n, NULL) < 0)
|
|
Packit |
d3f73b |
return -1;
|
|
Packit |
d3f73b |
return 0;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static int flush_nexthop(struct nlmsghdr *nlh, void *arg)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
struct nhmsg *nhm = NLMSG_DATA(nlh);
|
|
Packit |
d3f73b |
struct rtattr *tb[NHA_MAX+1];
|
|
Packit |
d3f73b |
__u32 id = 0;
|
|
Packit |
d3f73b |
int len;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
len = nlh->nlmsg_len - NLMSG_SPACE(sizeof(*nhm));
|
|
Packit |
d3f73b |
if (len < 0) {
|
|
Packit |
d3f73b |
fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
|
|
Packit |
d3f73b |
return -1;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
parse_rtattr(tb, NHA_MAX, RTM_NHA(nhm), len);
|
|
Packit |
d3f73b |
if (tb[NHA_ID])
|
|
Packit |
d3f73b |
id = rta_getattr_u32(tb[NHA_ID]);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (id && !delete_nexthop(id))
|
|
Packit |
d3f73b |
filter.flushed++;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
return 0;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static int ipnh_flush(unsigned int all)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
int rc = -2;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (all) {
|
|
Packit |
d3f73b |
filter.groups = 1;
|
|
Packit |
d3f73b |
filter.ifindex = 0;
|
|
Packit |
d3f73b |
filter.master = 0;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (rtnl_open(&rth_del, 0) < 0) {
|
|
Packit |
d3f73b |
fprintf(stderr, "Cannot open rtnetlink\n");
|
|
Packit |
d3f73b |
return EXIT_FAILURE;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
again:
|
|
Packit |
d3f73b |
if (rtnl_nexthopdump_req(&rth, preferred_family, nh_dump_filter) < 0) {
|
|
Packit |
d3f73b |
perror("Cannot send dump request");
|
|
Packit |
d3f73b |
goto out;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (rtnl_dump_filter(&rth, flush_nexthop, stdout) < 0) {
|
|
Packit |
d3f73b |
fprintf(stderr, "Dump terminated. Failed to flush nexthops\n");
|
|
Packit |
d3f73b |
goto out;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
/* if deleting all, then remove groups first */
|
|
Packit |
d3f73b |
if (all && filter.groups) {
|
|
Packit |
d3f73b |
filter.groups = 0;
|
|
Packit |
d3f73b |
goto again;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
rc = 0;
|
|
Packit |
d3f73b |
out:
|
|
Packit |
d3f73b |
rtnl_close(&rth_del);
|
|
Packit |
d3f73b |
if (!filter.flushed)
|
|
Packit |
d3f73b |
printf("Nothing to flush\n");
|
|
Packit |
d3f73b |
else
|
|
Packit |
d3f73b |
printf("Flushed %d nexthops\n", filter.flushed);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
return rc;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static void print_nh_group(FILE *fp, const struct rtattr *grps_attr)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
struct nexthop_grp *nhg = RTA_DATA(grps_attr);
|
|
Packit |
d3f73b |
int num = RTA_PAYLOAD(grps_attr) / sizeof(*nhg);
|
|
Packit |
d3f73b |
int i;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (!num || num * sizeof(*nhg) != RTA_PAYLOAD(grps_attr)) {
|
|
Packit |
d3f73b |
fprintf(fp, "<invalid nexthop group>");
|
|
Packit |
d3f73b |
return;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
open_json_array(PRINT_JSON, "group");
|
|
Packit |
d3f73b |
print_string(PRINT_FP, NULL, "%s", "group ");
|
|
Packit |
d3f73b |
for (i = 0; i < num; ++i) {
|
|
Packit |
d3f73b |
open_json_object(NULL);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (i)
|
|
Packit |
d3f73b |
print_string(PRINT_FP, NULL, "%s", "/");
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
print_uint(PRINT_ANY, "id", "%u", nhg[i].id);
|
|
Packit |
d3f73b |
if (nhg[i].weight)
|
|
Packit |
d3f73b |
print_uint(PRINT_ANY, "weight", ",%u", nhg[i].weight + 1);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
close_json_object();
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
print_string(PRINT_FP, NULL, "%s", " ");
|
|
Packit |
d3f73b |
close_json_array(PRINT_JSON, NULL);
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
int print_nexthop(struct nlmsghdr *n, void *arg)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
struct nhmsg *nhm = NLMSG_DATA(n);
|
|
Packit |
d3f73b |
struct rtattr *tb[NHA_MAX+1];
|
|
Packit |
d3f73b |
FILE *fp = (FILE *)arg;
|
|
Packit |
d3f73b |
int len;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
SPRINT_BUF(b1);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (n->nlmsg_type != RTM_DELNEXTHOP &&
|
|
Packit |
d3f73b |
n->nlmsg_type != RTM_NEWNEXTHOP) {
|
|
Packit |
d3f73b |
fprintf(stderr, "Not a nexthop: %08x %08x %08x\n",
|
|
Packit |
d3f73b |
n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);
|
|
Packit |
d3f73b |
return -1;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
len = n->nlmsg_len - NLMSG_SPACE(sizeof(*nhm));
|
|
Packit |
d3f73b |
if (len < 0) {
|
|
Packit |
d3f73b |
close_json_object();
|
|
Packit |
d3f73b |
fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
|
|
Packit |
d3f73b |
return -1;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
parse_rtattr(tb, NHA_MAX, RTM_NHA(nhm), len);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
open_json_object(NULL);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (n->nlmsg_type == RTM_DELROUTE)
|
|
Packit |
d3f73b |
print_bool(PRINT_ANY, "deleted", "Deleted ", true);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (tb[NHA_ID])
|
|
Packit |
d3f73b |
print_uint(PRINT_ANY, "id", "id %u ",
|
|
Packit |
d3f73b |
rta_getattr_u32(tb[NHA_ID]));
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (tb[NHA_GROUP])
|
|
Packit |
d3f73b |
print_nh_group(fp, tb[NHA_GROUP]);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (tb[NHA_ENCAP])
|
|
Packit |
d3f73b |
lwt_print_encap(fp, tb[NHA_ENCAP_TYPE], tb[NHA_ENCAP]);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (tb[NHA_GATEWAY])
|
|
Packit |
d3f73b |
print_rta_gateway(fp, nhm->nh_family, tb[NHA_GATEWAY]);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (tb[NHA_OIF])
|
|
Packit |
d3f73b |
print_rta_if(fp, tb[NHA_OIF], "dev");
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (nhm->nh_scope != RT_SCOPE_UNIVERSE || show_details > 0) {
|
|
Packit |
d3f73b |
print_string(PRINT_ANY, "scope", "scope %s ",
|
|
Packit |
d3f73b |
rtnl_rtscope_n2a(nhm->nh_scope, b1, sizeof(b1)));
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (tb[NHA_BLACKHOLE])
|
|
Packit |
d3f73b |
print_null(PRINT_ANY, "blackhole", "blackhole ", NULL);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (nhm->nh_protocol != RTPROT_UNSPEC || show_details > 0) {
|
|
Packit |
d3f73b |
print_string(PRINT_ANY, "protocol", "proto %s ",
|
|
Packit |
d3f73b |
rtnl_rtprot_n2a(nhm->nh_protocol, b1, sizeof(b1)));
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (tb[NHA_OIF])
|
|
Packit |
d3f73b |
print_rt_flags(fp, nhm->nh_flags);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
print_string(PRINT_FP, NULL, "%s", "\n");
|
|
Packit |
d3f73b |
close_json_object();
|
|
Packit |
d3f73b |
fflush(fp);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
return 0;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static int add_nh_group_attr(struct nlmsghdr *n, int maxlen, char *argv)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
struct nexthop_grp *grps;
|
|
Packit |
d3f73b |
int count = 0, i;
|
|
Packit |
d3f73b |
char *sep, *wsep;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (*argv != '\0')
|
|
Packit |
d3f73b |
count = 1;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
/* separator is '/' */
|
|
Packit |
d3f73b |
sep = strchr(argv, '/');
|
|
Packit |
d3f73b |
while (sep) {
|
|
Packit |
d3f73b |
count++;
|
|
Packit |
d3f73b |
sep = strchr(sep + 1, '/');
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (count == 0)
|
|
Packit |
d3f73b |
return -1;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
grps = calloc(count, sizeof(*grps));
|
|
Packit |
d3f73b |
if (!grps)
|
|
Packit |
d3f73b |
return -1;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
for (i = 0; i < count; ++i) {
|
|
Packit |
d3f73b |
sep = strchr(argv, '/');
|
|
Packit |
d3f73b |
if (sep)
|
|
Packit |
d3f73b |
*sep = '\0';
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
wsep = strchr(argv, ',');
|
|
Packit |
d3f73b |
if (wsep)
|
|
Packit |
d3f73b |
*wsep = '\0';
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (get_unsigned(&grps[i].id, argv, 0))
|
|
Packit |
d3f73b |
return -1;
|
|
Packit |
d3f73b |
if (wsep) {
|
|
Packit |
d3f73b |
unsigned int w;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
wsep++;
|
|
Packit |
d3f73b |
if (get_unsigned(&w, wsep, 0) || w == 0 || w > 256)
|
|
Packit |
d3f73b |
invarg("\"weight\" is invalid\n", wsep);
|
|
Packit |
d3f73b |
grps[i].weight = w - 1;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (!sep)
|
|
Packit |
d3f73b |
break;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
argv = sep + 1;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
return addattr_l(n, maxlen, NHA_GROUP, grps, count * sizeof(*grps));
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static int ipnh_modify(int cmd, unsigned int flags, int argc, char **argv)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
struct {
|
|
Packit |
d3f73b |
struct nlmsghdr n;
|
|
Packit |
d3f73b |
struct nhmsg nhm;
|
|
Packit |
d3f73b |
char buf[1024];
|
|
Packit |
d3f73b |
} req = {
|
|
Packit |
d3f73b |
.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct nhmsg)),
|
|
Packit |
d3f73b |
.n.nlmsg_flags = NLM_F_REQUEST | flags,
|
|
Packit |
d3f73b |
.n.nlmsg_type = cmd,
|
|
Packit |
d3f73b |
.nhm.nh_family = preferred_family,
|
|
Packit |
d3f73b |
};
|
|
Packit |
d3f73b |
__u32 nh_flags = 0;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
while (argc > 0) {
|
|
Packit |
d3f73b |
if (!strcmp(*argv, "id")) {
|
|
Packit |
d3f73b |
__u32 id;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
if (get_unsigned(&id, *argv, 0))
|
|
Packit |
d3f73b |
invarg("invalid id value", *argv);
|
|
Packit |
d3f73b |
addattr32(&req.n, sizeof(req), NHA_ID, id);
|
|
Packit |
d3f73b |
} else if (!strcmp(*argv, "dev")) {
|
|
Packit |
d3f73b |
int ifindex;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
ifindex = ll_name_to_index(*argv);
|
|
Packit |
d3f73b |
if (!ifindex)
|
|
Packit |
d3f73b |
invarg("Device does not exist\n", *argv);
|
|
Packit |
d3f73b |
addattr32(&req.n, sizeof(req), NHA_OIF, ifindex);
|
|
Packit |
d3f73b |
if (req.nhm.nh_family == AF_UNSPEC)
|
|
Packit |
d3f73b |
req.nhm.nh_family = AF_INET;
|
|
Packit |
d3f73b |
} else if (strcmp(*argv, "via") == 0) {
|
|
Packit |
d3f73b |
inet_prefix addr;
|
|
Packit |
d3f73b |
int family;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
family = read_family(*argv);
|
|
Packit |
d3f73b |
if (family == AF_UNSPEC)
|
|
Packit |
d3f73b |
family = req.nhm.nh_family;
|
|
Packit |
d3f73b |
else
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
get_addr(&addr, *argv, family);
|
|
Packit |
d3f73b |
if (req.nhm.nh_family == AF_UNSPEC)
|
|
Packit |
d3f73b |
req.nhm.nh_family = addr.family;
|
|
Packit |
d3f73b |
else if (req.nhm.nh_family != addr.family)
|
|
Packit |
d3f73b |
invarg("address family mismatch\n", *argv);
|
|
Packit |
d3f73b |
addattr_l(&req.n, sizeof(req), NHA_GATEWAY,
|
|
Packit |
d3f73b |
&addr.data, addr.bytelen);
|
|
Packit |
d3f73b |
} else if (strcmp(*argv, "encap") == 0) {
|
|
Packit |
d3f73b |
char buf[1024];
|
|
Packit |
d3f73b |
struct rtattr *rta = (void *)buf;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
rta->rta_type = NHA_ENCAP;
|
|
Packit |
d3f73b |
rta->rta_len = RTA_LENGTH(0);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
lwt_parse_encap(rta, sizeof(buf), &argc, &argv,
|
|
Packit |
d3f73b |
NHA_ENCAP, NHA_ENCAP_TYPE);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (rta->rta_len > RTA_LENGTH(0)) {
|
|
Packit |
d3f73b |
addraw_l(&req.n, 1024, RTA_DATA(rta),
|
|
Packit |
d3f73b |
RTA_PAYLOAD(rta));
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
} else if (!strcmp(*argv, "blackhole")) {
|
|
Packit |
d3f73b |
addattr_l(&req.n, sizeof(req), NHA_BLACKHOLE, NULL, 0);
|
|
Packit |
d3f73b |
if (req.nhm.nh_family == AF_UNSPEC)
|
|
Packit |
d3f73b |
req.nhm.nh_family = AF_INET;
|
|
Packit |
d3f73b |
} else if (!strcmp(*argv, "onlink")) {
|
|
Packit |
d3f73b |
nh_flags |= RTNH_F_ONLINK;
|
|
Packit |
d3f73b |
} else if (!strcmp(*argv, "group")) {
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (add_nh_group_attr(&req.n, sizeof(req), *argv))
|
|
Packit |
d3f73b |
invarg("\"group\" value is invalid\n", *argv);
|
|
Packit |
d3f73b |
} else if (matches(*argv, "protocol") == 0) {
|
|
Packit |
d3f73b |
__u32 prot;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
if (rtnl_rtprot_a2n(&prot, *argv))
|
|
Packit |
d3f73b |
invarg("\"protocol\" value is invalid\n", *argv);
|
|
Packit |
d3f73b |
req.nhm.nh_protocol = prot;
|
|
Packit |
d3f73b |
} else if (strcmp(*argv, "help") == 0) {
|
|
Packit |
d3f73b |
usage();
|
|
Packit |
d3f73b |
} else {
|
|
Packit |
d3f73b |
invarg("", *argv);
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
argc--; argv++;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
req.nhm.nh_flags = nh_flags;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (rtnl_talk(&rth, &req.n, NULL) < 0)
|
|
Packit |
d3f73b |
return -2;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
return 0;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static int ipnh_get_id(__u32 id)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
struct {
|
|
Packit |
d3f73b |
struct nlmsghdr n;
|
|
Packit |
d3f73b |
struct nhmsg nhm;
|
|
Packit |
d3f73b |
char buf[1024];
|
|
Packit |
d3f73b |
} req = {
|
|
Packit |
d3f73b |
.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct nhmsg)),
|
|
Packit |
d3f73b |
.n.nlmsg_flags = NLM_F_REQUEST,
|
|
Packit |
d3f73b |
.n.nlmsg_type = RTM_GETNEXTHOP,
|
|
Packit |
d3f73b |
.nhm.nh_family = preferred_family,
|
|
Packit |
d3f73b |
};
|
|
Packit |
d3f73b |
struct nlmsghdr *answer;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
addattr32(&req.n, sizeof(req), NHA_ID, id);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (rtnl_talk(&rth, &req.n, &answer) < 0)
|
|
Packit |
d3f73b |
return -2;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
new_json_obj(json);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (print_nexthop(answer, (void *)stdout) < 0) {
|
|
Packit |
d3f73b |
free(answer);
|
|
Packit |
d3f73b |
return -1;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
delete_json_obj();
|
|
Packit |
d3f73b |
fflush(stdout);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
free(answer);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
return 0;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static int ipnh_list_flush(int argc, char **argv, int action)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
unsigned int all = (argc == 0);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
while (argc > 0) {
|
|
Packit |
d3f73b |
if (!matches(*argv, "dev")) {
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
filter.ifindex = ll_name_to_index(*argv);
|
|
Packit |
d3f73b |
if (!filter.ifindex)
|
|
Packit |
d3f73b |
invarg("Device does not exist\n", *argv);
|
|
Packit |
d3f73b |
} else if (!matches(*argv, "groups")) {
|
|
Packit |
d3f73b |
filter.groups = 1;
|
|
Packit |
d3f73b |
} else if (!matches(*argv, "master")) {
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
filter.master = ll_name_to_index(*argv);
|
|
Packit |
d3f73b |
if (!filter.master)
|
|
Packit |
d3f73b |
invarg("Device does not exist\n", *argv);
|
|
Packit |
d3f73b |
} else if (matches(*argv, "vrf") == 0) {
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
if (!name_is_vrf(*argv))
|
|
Packit |
d3f73b |
invarg("Invalid VRF\n", *argv);
|
|
Packit |
d3f73b |
filter.master = ll_name_to_index(*argv);
|
|
Packit |
d3f73b |
if (!filter.master)
|
|
Packit |
d3f73b |
invarg("VRF does not exist\n", *argv);
|
|
Packit |
d3f73b |
} else if (!strcmp(*argv, "id")) {
|
|
Packit |
d3f73b |
__u32 id;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
if (get_unsigned(&id, *argv, 0))
|
|
Packit |
d3f73b |
invarg("invalid id value", *argv);
|
|
Packit |
d3f73b |
return ipnh_get_id(id);
|
|
Packit |
d3f73b |
} else if (matches(*argv, "help") == 0) {
|
|
Packit |
d3f73b |
usage();
|
|
Packit |
d3f73b |
} else {
|
|
Packit |
d3f73b |
invarg("", *argv);
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
argc--; argv++;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (action == IPNH_FLUSH)
|
|
Packit |
d3f73b |
return ipnh_flush(all);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (rtnl_nexthopdump_req(&rth, preferred_family, nh_dump_filter) < 0) {
|
|
Packit |
d3f73b |
perror("Cannot send dump request");
|
|
Packit |
d3f73b |
return -2;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
new_json_obj(json);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (rtnl_dump_filter(&rth, print_nexthop, stdout) < 0) {
|
|
Packit |
d3f73b |
fprintf(stderr, "Dump terminated\n");
|
|
Packit |
d3f73b |
return -2;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
delete_json_obj();
|
|
Packit |
d3f73b |
fflush(stdout);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
return 0;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
static int ipnh_get(int argc, char **argv)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
__u32 id = 0;
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
while (argc > 0) {
|
|
Packit |
d3f73b |
if (!strcmp(*argv, "id")) {
|
|
Packit |
d3f73b |
NEXT_ARG();
|
|
Packit |
d3f73b |
if (get_unsigned(&id, *argv, 0))
|
|
Packit |
d3f73b |
invarg("invalid id value", *argv);
|
|
Packit |
d3f73b |
} else {
|
|
Packit |
d3f73b |
usage();
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
argc--; argv++;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (!id) {
|
|
Packit |
d3f73b |
usage();
|
|
Packit |
d3f73b |
return -1;
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
return ipnh_get_id(id);
|
|
Packit |
d3f73b |
}
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
int do_ipnh(int argc, char **argv)
|
|
Packit |
d3f73b |
{
|
|
Packit |
d3f73b |
if (argc < 1)
|
|
Packit |
d3f73b |
return ipnh_list_flush(0, NULL, IPNH_LIST);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (!matches(*argv, "add"))
|
|
Packit |
d3f73b |
return ipnh_modify(RTM_NEWNEXTHOP, NLM_F_CREATE|NLM_F_EXCL,
|
|
Packit |
d3f73b |
argc-1, argv+1);
|
|
Packit |
d3f73b |
if (!matches(*argv, "replace"))
|
|
Packit |
d3f73b |
return ipnh_modify(RTM_NEWNEXTHOP, NLM_F_CREATE|NLM_F_REPLACE,
|
|
Packit |
d3f73b |
argc-1, argv+1);
|
|
Packit |
d3f73b |
if (!matches(*argv, "delete"))
|
|
Packit |
d3f73b |
return ipnh_modify(RTM_DELNEXTHOP, 0, argc-1, argv+1);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (!matches(*argv, "list") ||
|
|
Packit |
d3f73b |
!matches(*argv, "show") ||
|
|
Packit |
d3f73b |
!matches(*argv, "lst"))
|
|
Packit |
d3f73b |
return ipnh_list_flush(argc-1, argv+1, IPNH_LIST);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (!matches(*argv, "get"))
|
|
Packit |
d3f73b |
return ipnh_get(argc-1, argv+1);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (!matches(*argv, "flush"))
|
|
Packit |
d3f73b |
return ipnh_list_flush(argc-1, argv+1, IPNH_FLUSH);
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
if (!matches(*argv, "help"))
|
|
Packit |
d3f73b |
usage();
|
|
Packit |
d3f73b |
|
|
Packit |
d3f73b |
fprintf(stderr,
|
|
Packit |
d3f73b |
"Command \"%s\" is unknown, try \"ip nexthop help\".\n", *argv);
|
|
Packit |
d3f73b |
exit(-1);
|
|
Packit |
d3f73b |
}
|