2 * ipneigh.c "ip neigh".
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.
9 * Authors: Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
14 * Rani Assaf <rani@magic.metawire.com> 980929: resolve addresses
25 #include <sys/socket.h>
26 #include <netinet/in.h>
27 #include <netinet/ip.h>
31 #include "ip_common.h"
33 #define NUD_VALID (NUD_PERMANENT|NUD_NOARP|NUD_REACHABLE|NUD_PROBE|NUD_STALE|NUD_DELAY)
49 static void usage(void) __attribute__((noreturn));
51 static void usage(void)
53 fprintf(stderr, "Usage: ip neigh { add | del | change | replace } { ADDR [ lladdr LLADDR ]\n"
54 " [ nud { permanent | noarp | stale | reachable } ]\n"
55 " | proxy ADDR } [ dev DEV ]\n");
56 fprintf(stderr, " ip neigh {show|flush} [ to PREFIX ] [ dev DEV ] [ nud STATE ]\n");
60 int nud_state_a2n(unsigned *state, char *arg)
62 if (matches(arg, "permanent") == 0)
63 *state = NUD_PERMANENT;
64 else if (matches(arg, "reachable") == 0)
65 *state = NUD_REACHABLE;
66 else if (strcmp(arg, "noarp") == 0)
68 else if (strcmp(arg, "none") == 0)
70 else if (strcmp(arg, "stale") == 0)
72 else if (strcmp(arg, "incomplete") == 0)
73 *state = NUD_INCOMPLETE;
74 else if (strcmp(arg, "delay") == 0)
76 else if (strcmp(arg, "probe") == 0)
78 else if (matches(arg, "failed") == 0)
81 if (get_unsigned(state, arg, 0))
83 if (*state>=0x100 || (*state&((*state)-1)))
89 static int flush_update(void)
91 if (rtnl_send(&rth, filter.flushb, filter.flushp) < 0) {
92 perror("Failed to send flush request\n");
100 static int ipneigh_modify(int cmd, int flags, int argc, char **argv)
113 memset(&req, 0, sizeof(req));
115 req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct ndmsg));
116 req.n.nlmsg_flags = NLM_F_REQUEST|flags;
117 req.n.nlmsg_type = cmd;
118 req.ndm.ndm_family = preferred_family;
119 req.ndm.ndm_state = NUD_PERMANENT;
122 if (matches(*argv, "lladdr") == 0) {
125 duparg("lladdr", *argv);
128 } else if (strcmp(*argv, "nud") == 0) {
131 if (nud_state_a2n(&state, *argv))
132 invarg("nud state is bad", *argv);
133 req.ndm.ndm_state = state;
134 } else if (matches(*argv, "proxy") == 0) {
136 if (matches(*argv, "help") == 0)
139 duparg("address", *argv);
140 get_addr(&dst, *argv, preferred_family);
142 req.ndm.ndm_flags |= NTF_PROXY;
143 } else if (strcmp(*argv, "dev") == 0) {
147 if (strcmp(*argv, "to") == 0) {
150 if (matches(*argv, "help") == 0) {
154 duparg2("to", *argv);
155 get_addr(&dst, *argv, preferred_family);
160 if (d == NULL || !dst_ok || dst.family == AF_UNSPEC) {
161 fprintf(stderr, "Device and destination are required arguments.\n");
164 req.ndm.ndm_family = dst.family;
165 addattr_l(&req.n, sizeof(req), NDA_DST, &dst.data, dst.bytelen);
167 if (lla && strcmp(lla, "null")) {
171 l = ll_addr_a2n(llabuf, sizeof(llabuf), lla);
172 addattr_l(&req.n, sizeof(req), NDA_LLADDR, llabuf, l);
177 if ((req.ndm.ndm_ifindex = ll_name_to_index(d)) == 0) {
178 fprintf(stderr, "Cannot find device \"%s\"\n", d);
182 if (rtnl_talk(&rth, &req.n, 0, 0, NULL, NULL, NULL) < 0)
189 int print_neigh(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
191 FILE *fp = (FILE*)arg;
192 struct ndmsg *r = NLMSG_DATA(n);
193 int len = n->nlmsg_len;
194 struct rtattr * tb[NDA_MAX+1];
197 if (n->nlmsg_type != RTM_NEWNEIGH && n->nlmsg_type != RTM_DELNEIGH) {
198 fprintf(stderr, "Not RTM_NEWNEIGH: %08x %08x %08x\n",
199 n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);
203 len -= NLMSG_LENGTH(sizeof(*r));
205 fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
209 if (filter.flushb && n->nlmsg_type != RTM_NEWNEIGH)
212 if (filter.family && filter.family != r->ndm_family)
214 if (filter.index && filter.index != r->ndm_ifindex)
216 if (!(filter.state&r->ndm_state) &&
217 (r->ndm_state || !(filter.state&0x100)) &&
218 (r->ndm_family != AF_DECnet))
221 parse_rtattr(tb, NDA_MAX, NDA_RTA(r), n->nlmsg_len - NLMSG_LENGTH(sizeof(*r)));
224 if (filter.pfx.family) {
226 memset(&dst, 0, sizeof(dst));
227 dst.family = r->ndm_family;
228 memcpy(&dst.data, RTA_DATA(tb[NDA_DST]), RTA_PAYLOAD(tb[NDA_DST]));
229 if (inet_addr_match(&dst, &filter.pfx, filter.pfx.bitlen))
233 if (filter.unused_only && tb[NDA_CACHEINFO]) {
234 struct nda_cacheinfo *ci = RTA_DATA(tb[NDA_CACHEINFO]);
241 if (NLMSG_ALIGN(filter.flushp) + n->nlmsg_len > filter.flushe) {
245 fn = (struct nlmsghdr*)(filter.flushb + NLMSG_ALIGN(filter.flushp));
246 memcpy(fn, n, n->nlmsg_len);
247 fn->nlmsg_type = RTM_DELNEIGH;
248 fn->nlmsg_flags = NLM_F_REQUEST;
249 fn->nlmsg_seq = ++rth.seq;
250 filter.flushp = (((char*)fn) + n->nlmsg_len) - filter.flushb;
258 format_host(r->ndm_family,
259 RTA_PAYLOAD(tb[NDA_DST]),
260 RTA_DATA(tb[NDA_DST]),
261 abuf, sizeof(abuf)));
263 if (!filter.index && r->ndm_ifindex)
264 fprintf(fp, "dev %s ", ll_index_to_name(r->ndm_ifindex));
265 if (tb[NDA_LLADDR]) {
267 fprintf(fp, "lladdr %s", ll_addr_n2a(RTA_DATA(tb[NDA_LLADDR]),
268 RTA_PAYLOAD(tb[NDA_LLADDR]),
269 ll_index_to_type(r->ndm_ifindex),
272 if (r->ndm_flags & NTF_ROUTER) {
273 fprintf(fp, " router");
275 if (tb[NDA_CACHEINFO] && show_stats) {
277 struct nda_cacheinfo *ci = RTA_DATA(tb[NDA_CACHEINFO]);
281 printf(" ref %d", ci->ndm_refcnt);
282 fprintf(fp, " used %d/%d/%d", ci->ndm_used/hz,
283 ci->ndm_confirmed/hz, ci->ndm_updated/hz);
287 if (tb[NDA_PROBES] && show_stats) {
288 __u32 p = *(__u32 *) RTA_DATA(tb[NDA_PROBES]);
289 fprintf(fp, " probes %u", p);
294 int nud = r->ndm_state;
297 #define PRINT_FLAG(f) if (nud & NUD_##f) { \
298 nud &= ~NUD_##f; fprintf(fp, #f "%s", nud ? "," : ""); }
299 PRINT_FLAG(INCOMPLETE);
300 PRINT_FLAG(REACHABLE);
306 PRINT_FLAG(PERMANENT);
315 void ipneigh_reset_filter()
317 memset(&filter, 0, sizeof(filter));
321 int do_show_or_flush(int argc, char **argv, int flush)
323 char *filter_dev = NULL;
326 ipneigh_reset_filter();
329 filter.family = preferred_family;
333 fprintf(stderr, "Flush requires arguments.\n");
336 filter.state = ~(NUD_PERMANENT|NUD_NOARP);
338 filter.state = 0xFF & ~NUD_NOARP;
341 if (strcmp(*argv, "dev") == 0) {
344 duparg("dev", *argv);
346 } else if (strcmp(*argv, "unused") == 0) {
347 filter.unused_only = 1;
348 } else if (strcmp(*argv, "nud") == 0) {
355 if (nud_state_a2n(&state, *argv)) {
356 if (strcmp(*argv, "all") != 0)
357 invarg("nud state is bad", *argv);
364 filter.state |= state;
366 if (strcmp(*argv, "to") == 0) {
369 if (matches(*argv, "help") == 0)
371 get_prefix(&filter.pfx, *argv, filter.family);
372 if (filter.family == AF_UNSPEC)
373 filter.family = filter.pfx.family;
381 if ((filter.index = ll_name_to_index(filter_dev)) == 0) {
382 fprintf(stderr, "Cannot find device \"%s\"\n", filter_dev);
389 char flushb[4096-512];
391 filter.flushb = flushb;
393 filter.flushe = sizeof(flushb);
394 filter.state &= ~NUD_FAILED;
396 while (round < MAX_ROUNDS) {
397 if (rtnl_wilddump_request(&rth, filter.family, RTM_GETNEIGH) < 0) {
398 perror("Cannot send dump request");
402 if (rtnl_dump_filter(&rth, print_neigh, stdout, NULL, NULL) < 0) {
403 fprintf(stderr, "Flush terminated\n");
406 if (filter.flushed == 0) {
408 fprintf(stderr, "Nothing to flush.\n");
409 } else if (show_stats)
410 printf("*** Flush is complete after %d round%s ***\n", round, round>1?"s":"");
415 if (flush_update() < 0)
418 printf("\n*** Round %d, deleting %d entries ***\n", round, filter.flushed);
422 printf("*** Flush not complete bailing out after %d rounds\n",
427 if (rtnl_wilddump_request(&rth, filter.family, RTM_GETNEIGH) < 0) {
428 perror("Cannot send dump request");
432 if (rtnl_dump_filter(&rth, print_neigh, stdout, NULL, NULL) < 0) {
433 fprintf(stderr, "Dump terminated\n");
440 int do_ipneigh(int argc, char **argv)
443 if (matches(*argv, "add") == 0)
444 return ipneigh_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_EXCL, argc-1, argv+1);
445 if (matches(*argv, "change") == 0 ||
446 strcmp(*argv, "chg") == 0)
447 return ipneigh_modify(RTM_NEWNEIGH, NLM_F_REPLACE, argc-1, argv+1);
448 if (matches(*argv, "replace") == 0)
449 return ipneigh_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_REPLACE, argc-1, argv+1);
450 if (matches(*argv, "delete") == 0)
451 return ipneigh_modify(RTM_DELNEIGH, 0, argc-1, argv+1);
452 if (matches(*argv, "get") == 0) {
453 fprintf(stderr, "Sorry, \"neigh get\" is not implemented :-(\n");
456 if (matches(*argv, "show") == 0 ||
457 matches(*argv, "lst") == 0 ||
458 matches(*argv, "list") == 0)
459 return do_show_or_flush(argc-1, argv+1, 0);
460 if (matches(*argv, "flush") == 0)
461 return do_show_or_flush(argc-1, argv+1, 1);
462 if (matches(*argv, "help") == 0)
465 return do_show_or_flush(0, NULL, 0);
467 fprintf(stderr, "Command \"%s\" is unknown, try \"ip neigh help\".\n", *argv);