[mirror_iproute2.git] / ip / ipneigh.c

/*
 * ipneigh.c		"ip neigh".
 *
 *		This program is free software; you can redistribute it and/or
 *		modify it under the terms of the GNU General Public License
 *		as published by the Free Software Foundation; either version
 *		2 of the License, or (at your option) any later version.
 *
 * Authors:	Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
 *
 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>

#include "rt_names.h"
#include "utils.h"
#include "ip_common.h"
#include "json_print.h"

#define NUD_VALID	(NUD_PERMANENT|NUD_NOARP|NUD_REACHABLE|NUD_PROBE|NUD_STALE|NUD_DELAY)
#define MAX_ROUNDS	10

static struct
{
	int family;
	int index;
	int state;
	int unused_only;
	inet_prefix pfx;
	int flushed;
	char *flushb;
	int flushp;
	int flushe;
	int master;
	int protocol;
	__u8 ndm_flags;
} filter;

static void usage(void) __attribute__((noreturn));

static void usage(void)
{
	fprintf(stderr, "Usage: ip neigh { add | del | change | replace }\n"
			"                { ADDR [ lladdr LLADDR ] [ nud STATE ] | proxy ADDR } [ dev DEV ]\n");
	fprintf(stderr, "                [ router ] [ extern_learn ] [ protocol PROTO ]\n\n");
	fprintf(stderr, "       ip neigh { show | flush } [ proxy ] [ to PREFIX ] [ dev DEV ] [ nud STATE ]\n");
	fprintf(stderr, "                                 [ vrf NAME ]\n\n");
	fprintf(stderr, "STATE := { permanent | noarp | stale | reachable | none |\n"
			"           incomplete | delay | probe | failed }\n");
	exit(-1);
}

static int nud_state_a2n(unsigned int *state, const char *arg)
{
	if (matches(arg, "permanent") == 0)
		*state = NUD_PERMANENT;
	else if (matches(arg, "reachable") == 0)
		*state = NUD_REACHABLE;
	else if (strcmp(arg, "noarp") == 0)
		*state = NUD_NOARP;
	else if (strcmp(arg, "none") == 0)
		*state = NUD_NONE;
	else if (strcmp(arg, "stale") == 0)
		*state = NUD_STALE;
	else if (strcmp(arg, "incomplete") == 0)
		*state = NUD_INCOMPLETE;
	else if (strcmp(arg, "delay") == 0)
		*state = NUD_DELAY;
	else if (strcmp(arg, "probe") == 0)
		*state = NUD_PROBE;
	else if (matches(arg, "failed") == 0)
		*state = NUD_FAILED;
	else {
		if (get_unsigned(state, arg, 0))
			return -1;
		if (*state >= 0x100 || (*state&((*state)-1)))
			return -1;
	}
	return 0;
}

static int flush_update(void)
{
	if (rtnl_send_check(&rth, filter.flushb, filter.flushp) < 0) {
		perror("Failed to send flush request");
		return -1;
	}
	filter.flushp = 0;
	return 0;
}


static int ipneigh_modify(int cmd, int flags, int argc, char **argv)
{
	struct {
		struct nlmsghdr	n;
		struct ndmsg		ndm;
		char			buf[256];
	} req = {
		.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct ndmsg)),
		.n.nlmsg_flags = NLM_F_REQUEST | flags,
		.n.nlmsg_type = cmd,
		.ndm.ndm_family = preferred_family,
		.ndm.ndm_state = NUD_PERMANENT,
	};
	char  *dev = NULL;
	int dst_ok = 0;
	int dev_ok = 0;
	int lladdr_ok = 0;
	char *lla = NULL;
	inet_prefix dst;

	while (argc > 0) {
		if (matches(*argv, "lladdr") == 0) {
			NEXT_ARG();
			if (lladdr_ok)
				duparg("lladdr", *argv);
			lla = *argv;
			lladdr_ok = 1;
		} else if (strcmp(*argv, "nud") == 0) {
			unsigned int state;

			NEXT_ARG();
			if (nud_state_a2n(&state, *argv))
				invarg("nud state is bad", *argv);
			req.ndm.ndm_state = state;
		} else if (matches(*argv, "proxy") == 0) {
			NEXT_ARG();
			if (matches(*argv, "help") == 0)
				usage();
			if (dst_ok)
				duparg("address", *argv);
			get_addr(&dst, *argv, preferred_family);
			dst_ok = 1;
			dev_ok = 1;
			req.ndm.ndm_flags |= NTF_PROXY;
		} else if (strcmp(*argv, "router") == 0) {
			req.ndm.ndm_flags |= NTF_ROUTER;
		} else if (matches(*argv, "extern_learn") == 0) {
			req.ndm.ndm_flags |= NTF_EXT_LEARNED;
		} else if (strcmp(*argv, "dev") == 0) {
			NEXT_ARG();
			dev = *argv;
			dev_ok = 1;
		} else if (matches(*argv, "protocol") == 0) {
			__u32 proto;

			NEXT_ARG();
			if (rtnl_rtprot_a2n(&proto, *argv))
				invarg("\"protocol\" value is invalid\n", *argv);
			if (addattr8(&req.n, sizeof(req), NDA_PROTOCOL, proto))
				return -1;
		} else {
			if (strcmp(*argv, "to") == 0) {
				NEXT_ARG();
			}
			if (matches(*argv, "help") == 0) {
				NEXT_ARG();
			}
			if (dst_ok)
				duparg2("to", *argv);
			get_addr(&dst, *argv, preferred_family);
			dst_ok = 1;
		}
		argc--; argv++;
	}
	if (!dev_ok || !dst_ok || dst.family == AF_UNSPEC) {
		fprintf(stderr, "Device and destination are required arguments.\n");
		exit(-1);
	}
	req.ndm.ndm_family = dst.family;
	if (addattr_l(&req.n, sizeof(req), NDA_DST, &dst.data, dst.bytelen) < 0)
		return -1;

	if (lla && strcmp(lla, "null")) {
		char llabuf[20];
		int l;

		l = ll_addr_a2n(llabuf, sizeof(llabuf), lla);
		if (l < 0)
			return -1;

		if (addattr_l(&req.n, sizeof(req), NDA_LLADDR, llabuf, l) < 0)
			return -1;
	}

	ll_init_map(&rth);

	if (dev) {
		req.ndm.ndm_ifindex = ll_name_to_index(dev);
		if (!req.ndm.ndm_ifindex)
			return nodev(dev);
	}

	if (rtnl_talk(&rth, &req.n, NULL) < 0)
		exit(2);

	return 0;
}

static void print_cacheinfo(const struct nda_cacheinfo *ci)
{
	static int hz;

	if (!hz)
		hz = get_user_hz();

	if (ci->ndm_refcnt)
		print_uint(PRINT_ANY, "refcnt",
				" ref %u", ci->ndm_refcnt);

	print_uint(PRINT_ANY, "used", " used %u", ci->ndm_used / hz);
	print_uint(PRINT_ANY, "confirmed", "/%u", ci->ndm_confirmed / hz);
	print_uint(PRINT_ANY, "updated", "/%u", ci->ndm_updated / hz);
}

static void print_neigh_state(unsigned int nud)
{

	open_json_array(PRINT_JSON,
			is_json_context() ?  "state" : "");

#define PRINT_FLAG(f)						\
	if (nud & NUD_##f) {					\
		nud &= ~NUD_##f;				\
		print_string(PRINT_ANY, NULL, " %s", #f);	\
	}

	PRINT_FLAG(INCOMPLETE);
	PRINT_FLAG(REACHABLE);
	PRINT_FLAG(STALE);
	PRINT_FLAG(DELAY);
	PRINT_FLAG(PROBE);
	PRINT_FLAG(FAILED);
	PRINT_FLAG(NOARP);
	PRINT_FLAG(PERMANENT);
#undef PRINT_FLAG

	close_json_array(PRINT_JSON, NULL);
}

int print_neigh(struct nlmsghdr *n, void *arg)
{
	FILE *fp = (FILE *)arg;
	struct ndmsg *r = NLMSG_DATA(n);
	int len = n->nlmsg_len;
	struct rtattr *tb[NDA_MAX+1];
	static int logit = 1;
	__u8 protocol = 0;

	if (n->nlmsg_type != RTM_NEWNEIGH && n->nlmsg_type != RTM_DELNEIGH &&
	    n->nlmsg_type != RTM_GETNEIGH) {
		fprintf(stderr, "Not RTM_NEWNEIGH: %08x %08x %08x\n",
			n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);

		return 0;
	}
	len -= NLMSG_LENGTH(sizeof(*r));
	if (len < 0) {
		fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
		return -1;
	}

	if (filter.flushb && n->nlmsg_type != RTM_NEWNEIGH)
		return 0;

	if (filter.family && filter.family != r->ndm_family)
		return 0;
	if (filter.index && filter.index != r->ndm_ifindex)
		return 0;
	if (!(filter.state&r->ndm_state) &&
	    !(r->ndm_flags & NTF_PROXY) &&
	    !(r->ndm_flags & NTF_EXT_LEARNED) &&
	    (r->ndm_state || !(filter.state&0x100)) &&
	    (r->ndm_family != AF_DECnet))
		return 0;

	if (filter.master && !(n->nlmsg_flags & NLM_F_DUMP_FILTERED)) {
		if (logit) {
			logit = 0;
			fprintf(fp,
				"\nWARNING: Kernel does not support filtering by master device\n\n");
		}
	}

	parse_rtattr(tb, NDA_MAX, NDA_RTA(r), n->nlmsg_len - NLMSG_LENGTH(sizeof(*r)));

	if (inet_addr_match_rta(&filter.pfx, tb[NDA_DST]))
		return 0;

	if (tb[NDA_PROTOCOL])
		protocol = rta_getattr_u8(tb[NDA_PROTOCOL]);

	if (filter.protocol && filter.protocol != protocol)
		return 0;

	if (filter.unused_only && tb[NDA_CACHEINFO]) {
		struct nda_cacheinfo *ci = RTA_DATA(tb[NDA_CACHEINFO]);

		if (ci->ndm_refcnt)
			return 0;
	}

	if (filter.flushb) {
		struct nlmsghdr *fn;

		if (NLMSG_ALIGN(filter.flushp) + n->nlmsg_len > filter.flushe) {
			if (flush_update())
				return -1;
		}
		fn = (struct nlmsghdr *)(filter.flushb + NLMSG_ALIGN(filter.flushp));
		memcpy(fn, n, n->nlmsg_len);
		fn->nlmsg_type = RTM_DELNEIGH;
		fn->nlmsg_flags = NLM_F_REQUEST;
		fn->nlmsg_seq = ++rth.seq;
		filter.flushp = (((char *)fn) + n->nlmsg_len) - filter.flushb;
		filter.flushed++;
		if (show_stats < 2)
			return 0;
	}

	open_json_object(NULL);
	if (n->nlmsg_type == RTM_DELNEIGH)
		print_bool(PRINT_ANY, "deleted", "Deleted ", true);
	else if (n->nlmsg_type == RTM_GETNEIGH)
		print_null(PRINT_ANY, "miss", "%s ", "miss");

	if (tb[NDA_DST]) {
		const char *dst;
		int family = r->ndm_family;

		if (family == AF_BRIDGE) {
			if (RTA_PAYLOAD(tb[NDA_DST]) == sizeof(struct in6_addr))
				family = AF_INET6;
			else
				family = AF_INET;
		}

		dst = format_host_rta(family, tb[NDA_DST]);
		print_color_string(PRINT_ANY,
				   ifa_family_color(family),
				   "dst", "%s ", dst);
	}

	if (!filter.index && r->ndm_ifindex) {
		if (!is_json_context())
			fprintf(fp, "dev ");

		print_color_string(PRINT_ANY, COLOR_IFNAME,
				   "dev", "%s ",
				   ll_index_to_name(r->ndm_ifindex));
	}

	if (tb[NDA_LLADDR]) {
		const char *lladdr;
		SPRINT_BUF(b1);

		lladdr = ll_addr_n2a(RTA_DATA(tb[NDA_LLADDR]),
				     RTA_PAYLOAD(tb[NDA_LLADDR]),
				     ll_index_to_type(r->ndm_ifindex),
				     b1, sizeof(b1));

		if (!is_json_context())
			fprintf(fp, "lladdr ");

		print_color_string(PRINT_ANY, COLOR_MAC,
				   "lladdr", "%s", lladdr);
	}

	if (r->ndm_flags & NTF_ROUTER)
		print_null(PRINT_ANY, "router", " %s", "router");

	if (r->ndm_flags & NTF_PROXY)
		print_null(PRINT_ANY, "proxy", " %s", "proxy");

	if (r->ndm_flags & NTF_EXT_LEARNED)
		print_null(PRINT_ANY, "extern_learn", " %s ", "extern_learn");

	if (show_stats) {
		if (tb[NDA_CACHEINFO])
			print_cacheinfo(RTA_DATA(tb[NDA_CACHEINFO]));

		if (tb[NDA_PROBES])
			print_uint(PRINT_ANY, "probes", " probes %u",
				   rta_getattr_u32(tb[NDA_PROBES]));
	}

	if (r->ndm_state)
		print_neigh_state(r->ndm_state);

	if (protocol) {
		SPRINT_BUF(b1);

		print_string(PRINT_ANY, "protocol", " proto %s ",
			     rtnl_rtprot_n2a(protocol, b1, sizeof(b1)));
	}

	print_string(PRINT_FP, NULL, "\n", "");
	close_json_object();
	fflush(stdout);

	return 0;
}

void ipneigh_reset_filter(int ifindex)
{
	memset(&filter, 0, sizeof(filter));
	filter.state = ~0;
	filter.index = ifindex;
}

static int ipneigh_dump_filter(struct nlmsghdr *nlh, int reqlen)
{
	struct ndmsg *ndm = NLMSG_DATA(nlh);
	int err;

	ndm->ndm_flags = filter.ndm_flags;

	if (filter.index) {
		err = addattr32(nlh, reqlen, NDA_IFINDEX, filter.index);
		if (err)
			return err;
	}
	if (filter.master) {
		err = addattr32(nlh, reqlen, NDA_MASTER, filter.master);
		if (err)
			return err;
	}

	return 0;
}

static int do_show_or_flush(int argc, char **argv, int flush)
{
	char *filter_dev = NULL;
	int state_given = 0;

	ipneigh_reset_filter(0);

	if (!filter.family)
		filter.family = preferred_family;

	if (flush) {
		if (argc <= 0) {
			fprintf(stderr, "Flush requires arguments.\n");
			return -1;
		}
		filter.state = ~(NUD_PERMANENT|NUD_NOARP);
	} else
		filter.state = 0xFF & ~NUD_NOARP;

	while (argc > 0) {
		if (strcmp(*argv, "dev") == 0) {
			NEXT_ARG();
			if (filter_dev)
				duparg("dev", *argv);
			filter_dev = *argv;
		} else if (strcmp(*argv, "master") == 0) {
			int ifindex;

			NEXT_ARG();
			ifindex = ll_name_to_index(*argv);
			if (!ifindex)
				invarg("Device does not exist\n", *argv);
			filter.master = ifindex;
		} else if (strcmp(*argv, "vrf") == 0) {
			int ifindex;

			NEXT_ARG();
			ifindex = ll_name_to_index(*argv);
			if (!ifindex)
				invarg("Not a valid VRF name\n", *argv);
			if (!name_is_vrf(*argv))
				invarg("Not a valid VRF name\n", *argv);
			filter.master = ifindex;
		} else if (strcmp(*argv, "unused") == 0) {
			filter.unused_only = 1;
		} else if (strcmp(*argv, "nud") == 0) {
			unsigned int state;

			NEXT_ARG();
			if (!state_given) {
				state_given = 1;
				filter.state = 0;
			}
			if (nud_state_a2n(&state, *argv)) {
				if (strcmp(*argv, "all") != 0)
					invarg("nud state is bad", *argv);
				state = ~0;
				if (flush)
					state &= ~NUD_NOARP;
			}
			if (state == 0)
				state = 0x100;
			filter.state |= state;
		} else if (strcmp(*argv, "proxy") == 0) {
			filter.ndm_flags = NTF_PROXY;
		} else if (matches(*argv, "protocol") == 0) {
			__u32 prot;

			NEXT_ARG();
			if (rtnl_rtprot_a2n(&prot, *argv)) {
				if (strcmp(*argv, "all"))
					invarg("invalid \"protocol\"\n", *argv);
				prot = 0;
			}
			filter.protocol = prot;
		} else {
			if (strcmp(*argv, "to") == 0) {
				NEXT_ARG();
			}
			if (matches(*argv, "help") == 0)
				usage();
			if (get_prefix(&filter.pfx, *argv, filter.family))
				invarg("to value is invalid\n", *argv);
			if (filter.family == AF_UNSPEC)
				filter.family = filter.pfx.family;
		}
		argc--; argv++;
	}

	ll_init_map(&rth);

	if (filter_dev) {
		filter.index = ll_name_to_index(filter_dev);
		if (!filter.index)
			return nodev(filter_dev);
	}

	if (flush) {
		int round = 0;
		char flushb[4096-512];

		filter.flushb = flushb;
		filter.flushp = 0;
		filter.flushe = sizeof(flushb);

		while (round < MAX_ROUNDS) {
			if (rtnl_neighdump_req(&rth, filter.family,
					       ipneigh_dump_filter) < 0) {
				perror("Cannot send dump request");
				exit(1);
			}
			filter.flushed = 0;
			if (rtnl_dump_filter(&rth, print_neigh, stdout) < 0) {
				fprintf(stderr, "Flush terminated\n");
				exit(1);
			}
			if (filter.flushed == 0) {
				if (show_stats) {
					if (round == 0)
						printf("Nothing to flush.\n");
					else
						printf("*** Flush is complete after %d round%s ***\n", round, round > 1?"s":"");
				}
				fflush(stdout);
				return 0;
			}
			round++;
			if (flush_update() < 0)
				exit(1);
			if (show_stats) {
				printf("\n*** Round %d, deleting %d entries ***\n", round, filter.flushed);
				fflush(stdout);
			}
			filter.state &= ~NUD_FAILED;
		}
		printf("*** Flush not complete bailing out after %d rounds\n",
			MAX_ROUNDS);
		return 1;
	}

	if (rtnl_neighdump_req(&rth, filter.family, ipneigh_dump_filter) < 0) {
		perror("Cannot send dump request");
		exit(1);
	}

	new_json_obj(json);
	if (rtnl_dump_filter(&rth, print_neigh, stdout) < 0) {
		fprintf(stderr, "Dump terminated\n");
		exit(1);
	}
	delete_json_obj();

	return 0;
}

int do_ipneigh(int argc, char **argv)
{
	if (argc > 0) {
		if (matches(*argv, "add") == 0)
			return ipneigh_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_EXCL, argc-1, argv+1);
		if (matches(*argv, "change") == 0 ||
		    strcmp(*argv, "chg") == 0)
			return ipneigh_modify(RTM_NEWNEIGH, NLM_F_REPLACE, argc-1, argv+1);
		if (matches(*argv, "replace") == 0)
			return ipneigh_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_REPLACE, argc-1, argv+1);
		if (matches(*argv, "delete") == 0)
			return ipneigh_modify(RTM_DELNEIGH, 0, argc-1, argv+1);
		if (matches(*argv, "get") == 0) {
			fprintf(stderr, "Sorry, \"neigh get\" is not implemented :-(\n");
			return -1;
		}
		if (matches(*argv, "show") == 0 ||
		    matches(*argv, "lst") == 0 ||
		    matches(*argv, "list") == 0)
			return do_show_or_flush(argc-1, argv+1, 0);
		if (matches(*argv, "flush") == 0)
			return do_show_or_flush(argc-1, argv+1, 1);
		if (matches(*argv, "help") == 0)
			usage();
	} else
		return do_show_or_flush(0, NULL, 0);

	fprintf(stderr, "Command \"%s\" is unknown, try \"ip neigh help\".\n", *argv);
	exit(-1);
}
Commit	Line	Data
aba5acdf SH	1	/*
	2	* ipneigh.c "ip neigh".
	3	*
	4	* This program is free software; you can redistribute it and/or
	5	* modify it under the terms of the GNU General Public License
	6	* as published by the Free Software Foundation; either version
	7	* 2 of the License, or (at your option) any later version.
	8	*
	9	* Authors: Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
	10	*
aba5acdf SH	11	*/
	12
	13	#include <stdio.h>
	14	#include <stdlib.h>
	15	#include <unistd.h>
aba5acdf SH	16	#include <fcntl.h>
	17	#include <string.h>
	18	#include <sys/time.h>
aba5acdf SH	19	#include <sys/socket.h>
	20	#include <netinet/in.h>
	21	#include <netinet/ip.h>
	22
	23	#include "rt_names.h"
	24	#include "utils.h"
	25	#include "ip_common.h"
aac7f725	26	#include "json_print.h"
aba5acdf SH	27
aba5acdf SH	28	#define NUD_VALID (NUD_PERMANENT\|NUD_NOARP\|NUD_REACHABLE\|NUD_PROBE\|NUD_STALE\|NUD_DELAY)
66081849	29	#define MAX_ROUNDS 10
aba5acdf SH	30
	31	static struct
	32	{
	33	int family;
56f5daac	34	int index;
aba5acdf SH	35	int state;
	36	int unused_only;
	37	inet_prefix pfx;
	38	int flushed;
	39	char *flushb;
	40	int flushp;
	41	int flushe;
0d238ca2	42	int master;
6b83edc0	43	int protocol;
101ec10a	44	__u8 ndm_flags;
aba5acdf SH	45	} filter;
	46
	47	static void usage(void) __attribute__((noreturn));
	48
	49	static void usage(void)
	50	{
03a0cf20 PS	51	fprintf(stderr, "Usage: ip neigh { add \| del \| change \| replace }\n"
03a0cf20 PS	52	" { ADDR [ lladdr LLADDR ] [ nud STATE ] \| proxy ADDR } [ dev DEV ]\n");
6b83edc0	53	fprintf(stderr, " [ router ] [ extern_learn ] [ protocol PROTO ]\n\n");
5db1adae DA	54	fprintf(stderr, " ip neigh { show \| flush } [ proxy ] [ to PREFIX ] [ dev DEV ] [ nud STATE ]\n");
5db1adae DA	55	fprintf(stderr, " [ vrf NAME ]\n\n");
03a0cf20	56	fprintf(stderr, "STATE := { permanent \| noarp \| stale \| reachable \| none \|\n"
56f5daac	57	" incomplete \| delay \| probe \| failed }\n");
aba5acdf SH	58	exit(-1);
	59	}
	60
56f5daac	61	static int nud_state_a2n(unsigned int state, const char arg)
aba5acdf SH	62	{
	63	if (matches(arg, "permanent") == 0)
	64	*state = NUD_PERMANENT;
	65	else if (matches(arg, "reachable") == 0)
	66	*state = NUD_REACHABLE;
	67	else if (strcmp(arg, "noarp") == 0)
	68	*state = NUD_NOARP;
	69	else if (strcmp(arg, "none") == 0)
	70	*state = NUD_NONE;
	71	else if (strcmp(arg, "stale") == 0)
	72	*state = NUD_STALE;
	73	else if (strcmp(arg, "incomplete") == 0)
	74	*state = NUD_INCOMPLETE;
	75	else if (strcmp(arg, "delay") == 0)
	76	*state = NUD_DELAY;
	77	else if (strcmp(arg, "probe") == 0)
	78	*state = NUD_PROBE;
	79	else if (matches(arg, "failed") == 0)
	80	*state = NUD_FAILED;
	81	else {
	82	if (get_unsigned(state, arg, 0))
	83	return -1;
56f5daac	84	if (state >= 0x100 \|\| (state&((*state)-1)))
aba5acdf SH	85	return -1;
	86	}
	87	return 0;
	88	}
	89
aba5acdf SH	90	static int flush_update(void)
aba5acdf SH	91	{
f31a37f7	92	if (rtnl_send_check(&rth, filter.flushb, filter.flushp) < 0) {
1fb0a998	93	perror("Failed to send flush request");
aba5acdf SH	94	return -1;
	95	}
	96	filter.flushp = 0;
	97	return 0;
	98	}
	99
	100
	101	static int ipneigh_modify(int cmd, int flags, int argc, char **argv)
	102	{
aba5acdf	103	struct {
4806867a SH	104	struct nlmsghdr n;
4806867a SH	105	struct ndmsg ndm;
56f5daac	106	char buf[256];
d17b136f PS	107	} req = {
	108	.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct ndmsg)),
	109	.n.nlmsg_flags = NLM_F_REQUEST \| flags,
	110	.n.nlmsg_type = cmd,
	111	.ndm.ndm_family = preferred_family,
	112	.ndm.ndm_state = NUD_PERMANENT,
	113	};
e834eb8e	114	char *dev = NULL;
aba5acdf	115	int dst_ok = 0;
e834eb8e	116	int dev_ok = 0;
aba5acdf	117	int lladdr_ok = 0;
56f5daac	118	char *lla = NULL;
aba5acdf SH	119	inet_prefix dst;
aba5acdf SH	120
aba5acdf SH	121	while (argc > 0) {
	122	if (matches(*argv, "lladdr") == 0) {
	123	NEXT_ARG();
	124	if (lladdr_ok)
	125	duparg("lladdr", *argv);
	126	lla = *argv;
	127	lladdr_ok = 1;
	128	} else if (strcmp(*argv, "nud") == 0) {
56f5daac SH	129	unsigned int state;
56f5daac SH	130
aba5acdf SH	131	NEXT_ARG();
	132	if (nud_state_a2n(&state, *argv))
	133	invarg("nud state is bad", *argv);
	134	req.ndm.ndm_state = state;
	135	} else if (matches(*argv, "proxy") == 0) {
	136	NEXT_ARG();
	137	if (matches(*argv, "help") == 0)
	138	usage();
	139	if (dst_ok)
	140	duparg("address", *argv);
	141	get_addr(&dst, *argv, preferred_family);
	142	dst_ok = 1;
e834eb8e	143	dev_ok = 1;
aba5acdf	144	req.ndm.ndm_flags \|= NTF_PROXY;
c2cd14ac RP	145	} else if (strcmp(*argv, "router") == 0) {
c2cd14ac RP	146	req.ndm.ndm_flags \|= NTF_ROUTER;
4c45b684 RP	147	} else if (matches(*argv, "extern_learn") == 0) {
4c45b684 RP	148	req.ndm.ndm_flags \|= NTF_EXT_LEARNED;
aba5acdf SH	149	} else if (strcmp(*argv, "dev") == 0) {
aba5acdf SH	150	NEXT_ARG();
e834eb8e KK	151	dev = *argv;
e834eb8e KK	152	dev_ok = 1;
6b83edc0 DA	153	} else if (matches(*argv, "protocol") == 0) {
	154	__u32 proto;
	155
	156	NEXT_ARG();
	157	if (rtnl_rtprot_a2n(&proto, *argv))
	158	invarg("\"protocol\" value is invalid\n", *argv);
	159	if (addattr8(&req.n, sizeof(req), NDA_PROTOCOL, proto))
	160	return -1;
aba5acdf SH	161	} else {
	162	if (strcmp(*argv, "to") == 0) {
	163	NEXT_ARG();
	164	}
	165	if (matches(*argv, "help") == 0) {
	166	NEXT_ARG();
	167	}
	168	if (dst_ok)
	169	duparg2("to", *argv);
	170	get_addr(&dst, *argv, preferred_family);
	171	dst_ok = 1;
	172	}
	173	argc--; argv++;
	174	}
e834eb8e	175	if (!dev_ok \|\| !dst_ok \|\| dst.family == AF_UNSPEC) {
aba5acdf SH	176	fprintf(stderr, "Device and destination are required arguments.\n");
	177	exit(-1);
	178	}
	179	req.ndm.ndm_family = dst.family;
542b0cc7 SH	180	if (addattr_l(&req.n, sizeof(req), NDA_DST, &dst.data, dst.bytelen) < 0)
542b0cc7 SH	181	return -1;
aba5acdf SH	182
aba5acdf SH	183	if (lla && strcmp(lla, "null")) {
7b565754	184	char llabuf[20];
aba5acdf SH	185	int l;
	186
	187	l = ll_addr_a2n(llabuf, sizeof(llabuf), lla);
542b0cc7 SH	188	if (l < 0)
	189	return -1;
	190
	191	if (addattr_l(&req.n, sizeof(req), NDA_LLADDR, llabuf, l) < 0)
	192	return -1;
aba5acdf SH	193	}
aba5acdf SH	194
aba5acdf SH	195	ll_init_map(&rth);
aba5acdf SH	196
fe99adbc SP	197	if (dev) {
	198	req.ndm.ndm_ifindex = ll_name_to_index(dev);
	199	if (!req.ndm.ndm_ifindex)
	200	return nodev(dev);
aba5acdf SH	201	}
aba5acdf SH	202
86bf43c7	203	if (rtnl_talk(&rth, &req.n, NULL) < 0)
aba5acdf SH	204	exit(2);
aba5acdf SH	205
351efcde	206	return 0;
aba5acdf SH	207	}
aba5acdf SH	208
aac7f725 SH	209	static void print_cacheinfo(const struct nda_cacheinfo *ci)
	210	{
	211	static int hz;
	212
	213	if (!hz)
	214	hz = get_user_hz();
	215
	216	if (ci->ndm_refcnt)
	217	print_uint(PRINT_ANY, "refcnt",
	218	" ref %u", ci->ndm_refcnt);
	219
	220	print_uint(PRINT_ANY, "used", " used %u", ci->ndm_used / hz);
	221	print_uint(PRINT_ANY, "confirmed", "/%u", ci->ndm_confirmed / hz);
7cd3f08b	222	print_uint(PRINT_ANY, "updated", "/%u", ci->ndm_updated / hz);
aac7f725 SH	223	}
	224
	225	static void print_neigh_state(unsigned int nud)
	226	{
	227
	228	open_json_array(PRINT_JSON,
	229	is_json_context() ? "state" : "");
	230
	231	#define PRINT_FLAG(f) \
	232	if (nud & NUD_##f) { \
	233	nud &= ~NUD_##f; \
	234	print_string(PRINT_ANY, NULL, " %s", #f); \
	235	}
	236
	237	PRINT_FLAG(INCOMPLETE);
	238	PRINT_FLAG(REACHABLE);
	239	PRINT_FLAG(STALE);
	240	PRINT_FLAG(DELAY);
	241	PRINT_FLAG(PROBE);
	242	PRINT_FLAG(FAILED);
	243	PRINT_FLAG(NOARP);
	244	PRINT_FLAG(PERMANENT);
	245	#undef PRINT_FLAG
	246
	247	close_json_array(PRINT_JSON, NULL);
	248	}
aba5acdf	249
cd554f2c	250	int print_neigh(struct nlmsghdr n, void arg)
aba5acdf	251	{
56f5daac	252	FILE fp = (FILE )arg;
aba5acdf SH	253	struct ndmsg *r = NLMSG_DATA(n);
aba5acdf SH	254	int len = n->nlmsg_len;
56f5daac	255	struct rtattr *tb[NDA_MAX+1];
0d238ca2	256	static int logit = 1;
6b83edc0	257	__u8 protocol = 0;
aba5acdf	258
1556e29d DS	259	if (n->nlmsg_type != RTM_NEWNEIGH && n->nlmsg_type != RTM_DELNEIGH &&
1556e29d DS	260	n->nlmsg_type != RTM_GETNEIGH) {
aba5acdf SH	261	fprintf(stderr, "Not RTM_NEWNEIGH: %08x %08x %08x\n",
aba5acdf SH	262	n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);
ae665a52	263
aba5acdf SH	264	return 0;
	265	}
	266	len -= NLMSG_LENGTH(sizeof(*r));
	267	if (len < 0) {
	268	fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
	269	return -1;
	270	}
	271
	272	if (filter.flushb && n->nlmsg_type != RTM_NEWNEIGH)
	273	return 0;
	274
	275	if (filter.family && filter.family != r->ndm_family)
	276	return 0;
	277	if (filter.index && filter.index != r->ndm_ifindex)
	278	return 0;
	279	if (!(filter.state&r->ndm_state) &&
1dac7817	280	!(r->ndm_flags & NTF_PROXY) &&
9c6a6d84	281	!(r->ndm_flags & NTF_EXT_LEARNED) &&
aba5acdf	282	(r->ndm_state \|\| !(filter.state&0x100)) &&
aac7f725	283	(r->ndm_family != AF_DECnet))
aba5acdf SH	284	return 0;
aba5acdf SH	285
0d238ca2 DA	286	if (filter.master && !(n->nlmsg_flags & NLM_F_DUMP_FILTERED)) {
	287	if (logit) {
	288	logit = 0;
	289	fprintf(fp,
	290	"\nWARNING: Kernel does not support filtering by master device\n\n");
	291	}
	292	}
	293
aba5acdf SH	294	parse_rtattr(tb, NDA_MAX, NDA_RTA(r), n->nlmsg_len - NLMSG_LENGTH(sizeof(*r)));
aba5acdf SH	295
a4270fd8 SP	296	if (inet_addr_match_rta(&filter.pfx, tb[NDA_DST]))
a4270fd8 SP	297	return 0;
56f5daac	298
6b83edc0 DA	299	if (tb[NDA_PROTOCOL])
	300	protocol = rta_getattr_u8(tb[NDA_PROTOCOL]);
	301
	302	if (filter.protocol && filter.protocol != protocol)
	303	return 0;
	304
aba5acdf SH	305	if (filter.unused_only && tb[NDA_CACHEINFO]) {
aba5acdf SH	306	struct nda_cacheinfo *ci = RTA_DATA(tb[NDA_CACHEINFO]);
56f5daac	307
aba5acdf SH	308	if (ci->ndm_refcnt)
	309	return 0;
	310	}
	311
	312	if (filter.flushb) {
	313	struct nlmsghdr *fn;
56f5daac	314
aba5acdf SH	315	if (NLMSG_ALIGN(filter.flushp) + n->nlmsg_len > filter.flushe) {
	316	if (flush_update())
	317	return -1;
	318	}
56f5daac	319	fn = (struct nlmsghdr *)(filter.flushb + NLMSG_ALIGN(filter.flushp));
aba5acdf SH	320	memcpy(fn, n, n->nlmsg_len);
	321	fn->nlmsg_type = RTM_DELNEIGH;
	322	fn->nlmsg_flags = NLM_F_REQUEST;
351efcde	323	fn->nlmsg_seq = ++rth.seq;
56f5daac	324	filter.flushp = (((char *)fn) + n->nlmsg_len) - filter.flushb;
aba5acdf SH	325	filter.flushed++;
	326	if (show_stats < 2)
	327	return 0;
	328	}
	329
aac7f725	330	open_json_object(NULL);
6ea3ebaf	331	if (n->nlmsg_type == RTM_DELNEIGH)
aac7f725	332	print_bool(PRINT_ANY, "deleted", "Deleted ", true);
1556e29d	333	else if (n->nlmsg_type == RTM_GETNEIGH)
aac7f725 SH	334	print_null(PRINT_ANY, "miss", "%s ", "miss");
aac7f725 SH	335
aba5acdf	336	if (tb[NDA_DST]) {
aac7f725	337	const char *dst;
c9159af5	338	int family = r->ndm_family;
aac7f725	339
c9159af5 TJ	340	if (family == AF_BRIDGE) {
	341	if (RTA_PAYLOAD(tb[NDA_DST]) == sizeof(struct in6_addr))
	342	family = AF_INET6;
	343	else
	344	family = AF_INET;
	345	}
	346
	347	dst = format_host_rta(family, tb[NDA_DST]);
aac7f725	348	print_color_string(PRINT_ANY,
c9159af5	349	ifa_family_color(family),
aac7f725	350	"dst", "%s ", dst);
aba5acdf	351	}
aac7f725 SH	352
	353	if (!filter.index && r->ndm_ifindex) {
	354	if (!is_json_context())
	355	fprintf(fp, "dev ");
	356
	357	print_color_string(PRINT_ANY, COLOR_IFNAME,
	358	"dev", "%s ",
	359	ll_index_to_name(r->ndm_ifindex));
	360	}
	361
aba5acdf	362	if (tb[NDA_LLADDR]) {
aac7f725	363	const char *lladdr;
aba5acdf	364	SPRINT_BUF(b1);
6a34d291	365
aac7f725 SH	366	lladdr = ll_addr_n2a(RTA_DATA(tb[NDA_LLADDR]),
	367	RTA_PAYLOAD(tb[NDA_LLADDR]),
	368	ll_index_to_type(r->ndm_ifindex),
	369	b1, sizeof(b1));
aba5acdf	370
aac7f725 SH	371	if (!is_json_context())
aac7f725 SH	372	fprintf(fp, "lladdr ");
56f5daac	373
aac7f725 SH	374	print_color_string(PRINT_ANY, COLOR_MAC,
aac7f725 SH	375	"lladdr", "%s", lladdr);
69410a49	376	}
69410a49	377
aac7f725 SH	378	if (r->ndm_flags & NTF_ROUTER)
	379	print_null(PRINT_ANY, "router", " %s", "router");
	380
	381	if (r->ndm_flags & NTF_PROXY)
	382	print_null(PRINT_ANY, "proxy", " %s", "proxy");
	383
4c45b684 RP	384	if (r->ndm_flags & NTF_EXT_LEARNED)
	385	print_null(PRINT_ANY, "extern_learn", " %s ", "extern_learn");
	386
aac7f725 SH	387	if (show_stats) {
	388	if (tb[NDA_CACHEINFO])
	389	print_cacheinfo(RTA_DATA(tb[NDA_CACHEINFO]));
	390
	391	if (tb[NDA_PROBES])
	392	print_uint(PRINT_ANY, "probes", " probes %u",
	393	rta_getattr_u32(tb[NDA_PROBES]));
aba5acdf	394	}
aba5acdf	395
aac7f725 SH	396	if (r->ndm_state)
	397	print_neigh_state(r->ndm_state);
	398
6b83edc0 DA	399	if (protocol) {
	400	SPRINT_BUF(b1);
	401
	402	print_string(PRINT_ANY, "protocol", " proto %s ",
	403	rtnl_rtprot_n2a(protocol, b1, sizeof(b1)));
	404	}
	405
aac7f725 SH	406	print_string(PRINT_FP, NULL, "\n", "");
	407	close_json_object();
	408	fflush(stdout);
	409
aba5acdf SH	410	return 0;
	411	}
	412
093b7646	413	void ipneigh_reset_filter(int ifindex)
aba5acdf SH	414	{
	415	memset(&filter, 0, sizeof(filter));
	416	filter.state = ~0;
093b7646	417	filter.index = ifindex;
aba5acdf SH	418	}
aba5acdf SH	419
101ec10a DA	420	static int ipneigh_dump_filter(struct nlmsghdr *nlh, int reqlen)
	421	{
	422	struct ndmsg *ndm = NLMSG_DATA(nlh);
	423	int err;
	424
	425	ndm->ndm_flags = filter.ndm_flags;
	426
	427	if (filter.index) {
	428	err = addattr32(nlh, reqlen, NDA_IFINDEX, filter.index);
	429	if (err)
	430	return err;
	431	}
	432	if (filter.master) {
	433	err = addattr32(nlh, reqlen, NDA_MASTER, filter.master);
	434	if (err)
	435	return err;
	436	}
	437
	438	return 0;
	439	}
	440
d1f28cf1	441	static int do_show_or_flush(int argc, char **argv, int flush)
aba5acdf SH	442	{
aba5acdf SH	443	char *filter_dev = NULL;
aba5acdf	444	int state_given = 0;
0d238ca2	445
093b7646	446	ipneigh_reset_filter(0);
aba5acdf SH	447
	448	if (!filter.family)
	449	filter.family = preferred_family;
	450
	451	if (flush) {
	452	if (argc <= 0) {
	453	fprintf(stderr, "Flush requires arguments.\n");
	454	return -1;
	455	}
	456	filter.state = ~(NUD_PERMANENT\|NUD_NOARP);
	457	} else
	458	filter.state = 0xFF & ~NUD_NOARP;
	459
	460	while (argc > 0) {
	461	if (strcmp(*argv, "dev") == 0) {
	462	NEXT_ARG();
	463	if (filter_dev)
	464	duparg("dev", *argv);
	465	filter_dev = *argv;
0d238ca2 DA	466	} else if (strcmp(*argv, "master") == 0) {
0d238ca2 DA	467	int ifindex;
56f5daac	468
0d238ca2 DA	469	NEXT_ARG();
	470	ifindex = ll_name_to_index(*argv);
	471	if (!ifindex)
	472	invarg("Device does not exist\n", *argv);
0d238ca2	473	filter.master = ifindex;
5db1adae DA	474	} else if (strcmp(*argv, "vrf") == 0) {
	475	int ifindex;
	476
	477	NEXT_ARG();
	478	ifindex = ll_name_to_index(*argv);
	479	if (!ifindex)
	480	invarg("Not a valid VRF name\n", *argv);
	481	if (!name_is_vrf(*argv))
	482	invarg("Not a valid VRF name\n", *argv);
5db1adae	483	filter.master = ifindex;
aba5acdf SH	484	} else if (strcmp(*argv, "unused") == 0) {
	485	filter.unused_only = 1;
	486	} else if (strcmp(*argv, "nud") == 0) {
56f5daac SH	487	unsigned int state;
56f5daac SH	488
aba5acdf SH	489	NEXT_ARG();
	490	if (!state_given) {
	491	state_given = 1;
	492	filter.state = 0;
	493	}
	494	if (nud_state_a2n(&state, *argv)) {
	495	if (strcmp(*argv, "all") != 0)
	496	invarg("nud state is bad", *argv);
	497	state = ~0;
	498	if (flush)
	499	state &= ~NUD_NOARP;
	500	}
	501	if (state == 0)
	502	state = 0x100;
	503	filter.state \|= state;
6b83edc0	504	} else if (strcmp(*argv, "proxy") == 0) {
101ec10a	505	filter.ndm_flags = NTF_PROXY;
6b83edc0 DA	506	} else if (matches(*argv, "protocol") == 0) {
	507	__u32 prot;
	508
	509	NEXT_ARG();
	510	if (rtnl_rtprot_a2n(&prot, *argv)) {
	511	if (strcmp(*argv, "all"))
	512	invarg("invalid \"protocol\"\n", *argv);
	513	prot = 0;
	514	}
	515	filter.protocol = prot;
	516	} else {
aba5acdf SH	517	if (strcmp(*argv, "to") == 0) {
	518	NEXT_ARG();
	519	}
	520	if (matches(*argv, "help") == 0)
	521	usage();
a4270fd8 SP	522	if (get_prefix(&filter.pfx, *argv, filter.family))
a4270fd8 SP	523	invarg("to value is invalid\n", *argv);
aba5acdf SH	524	if (filter.family == AF_UNSPEC)
	525	filter.family = filter.pfx.family;
	526	}
	527	argc--; argv++;
	528	}
	529
aba5acdf SH	530	ll_init_map(&rth);
	531
	532	if (filter_dev) {
fe99adbc SP	533	filter.index = ll_name_to_index(filter_dev);
	534	if (!filter.index)
	535	return nodev(filter_dev);
aba5acdf SH	536	}
	537
	538	if (flush) {
	539	int round = 0;
	540	char flushb[4096-512];
	541
	542	filter.flushb = flushb;
	543	filter.flushp = 0;
	544	filter.flushe = sizeof(flushb);
aba5acdf	545
66081849	546	while (round < MAX_ROUNDS) {
101ec10a DA	547	if (rtnl_neighdump_req(&rth, filter.family,
101ec10a DA	548	ipneigh_dump_filter) < 0) {
aba5acdf SH	549	perror("Cannot send dump request");
	550	exit(1);
	551	}
	552	filter.flushed = 0;
cd70f3f5	553	if (rtnl_dump_filter(&rth, print_neigh, stdout) < 0) {
aba5acdf SH	554	fprintf(stderr, "Flush terminated\n");
	555	exit(1);
	556	}
	557	if (filter.flushed == 0) {
f0b34d2d AH	558	if (show_stats) {
	559	if (round == 0)
	560	printf("Nothing to flush.\n");
	561	else
56f5daac	562	printf("* Flush is complete after %d round%s *\n", round, round > 1?"s":"");
f0b34d2d	563	}
aba5acdf SH	564	fflush(stdout);
	565	return 0;
	566	}
	567	round++;
	568	if (flush_update() < 0)
	569	exit(1);
	570	if (show_stats) {
	571	printf("\n* Round %d, deleting %d entries *\n", round, filter.flushed);
	572	fflush(stdout);
	573	}
ad0a6a2c	574	filter.state &= ~NUD_FAILED;
aba5acdf	575	}
66081849 SH	576	printf("*** Flush not complete bailing out after %d rounds\n",
	577	MAX_ROUNDS);
	578	return 1;
aba5acdf SH	579	}
aba5acdf SH	580
101ec10a	581	if (rtnl_neighdump_req(&rth, filter.family, ipneigh_dump_filter) < 0) {
aba5acdf SH	582	perror("Cannot send dump request");
	583	exit(1);
	584	}
	585
aac7f725	586	new_json_obj(json);
cd70f3f5	587	if (rtnl_dump_filter(&rth, print_neigh, stdout) < 0) {
aba5acdf SH	588	fprintf(stderr, "Dump terminated\n");
	589	exit(1);
	590	}
aac7f725	591	delete_json_obj();
aba5acdf SH	592
	593	return 0;
	594	}
	595
	596	int do_ipneigh(int argc, char **argv)
	597	{
	598	if (argc > 0) {
	599	if (matches(*argv, "add") == 0)
	600	return ipneigh_modify(RTM_NEWNEIGH, NLM_F_CREATE\|NLM_F_EXCL, argc-1, argv+1);
	601	if (matches(*argv, "change") == 0 \|\|
	602	strcmp(*argv, "chg") == 0)
	603	return ipneigh_modify(RTM_NEWNEIGH, NLM_F_REPLACE, argc-1, argv+1);
	604	if (matches(*argv, "replace") == 0)
	605	return ipneigh_modify(RTM_NEWNEIGH, NLM_F_CREATE\|NLM_F_REPLACE, argc-1, argv+1);
	606	if (matches(*argv, "delete") == 0)
	607	return ipneigh_modify(RTM_DELNEIGH, 0, argc-1, argv+1);
	608	if (matches(*argv, "get") == 0) {
	609	fprintf(stderr, "Sorry, \"neigh get\" is not implemented :-(\n");
	610	return -1;
	611	}
	612	if (matches(*argv, "show") == 0 \|\|
	613	matches(*argv, "lst") == 0 \|\|
	614	matches(*argv, "list") == 0)
	615	return do_show_or_flush(argc-1, argv+1, 0);
	616	if (matches(*argv, "flush") == 0)
	617	return do_show_or_flush(argc-1, argv+1, 1);
	618	if (matches(*argv, "help") == 0)
	619	usage();
	620	} else
	621	return do_show_or_flush(0, NULL, 0);
	622
	623	fprintf(stderr, "Command \"%s\" is unknown, try \"ip neigh help\".\n", *argv);
	624	exit(-1);
	625	}