A patch from John F. Kelly to add in a utility for configuring
[oweals/busybox.git] / networking / libiproute / ipaddress.c
index 055aadfee05e570ac9461d3b9ab4912e7f7296ae..88438179d9c4a0bbb4b17e3ad3f1fa5ec0c8f0bf 100644 (file)
  *     Laszlo Valko <valko@linux.karinthy.hu> 990223: address label must be zero terminated
  */
 
-#include <stdio.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include <syslog.h>
-#include <fcntl.h>
-#include <sys/ioctl.h>
 #include <sys/socket.h>
 #include <sys/ioctl.h>
-#include <netinet/in.h>
-#include <arpa/inet.h>
-#include <string.h>
+
 #include <fnmatch.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
 
-#include <linux/netdevice.h>
-#include <linux/if_arp.h>
-#include <linux/sockios.h>
+#include <arpa/inet.h>
+
+#include <net/if.h>
+#include <net/if_arp.h>
 
 #include "rt_names.h"
 #include "utils.h"
-#include "ll_map.h"
-#include "ip_common.h"
 
-#include "busybox.h"
+#include "libbb.h"
 
 static struct
 {
@@ -47,11 +41,13 @@ static struct
        int flags, flagmask;
        int up;
        char *label;
+       int flushed;
+       char *flushb;
+       int flushp;
+       int flushe;
        struct rtnl_handle *rth;
 } filter;
 
-static int do_link;
-
 void print_link_flags(FILE *fp, unsigned flags, unsigned mdown)
 {
        fprintf(fp, "<");
@@ -84,7 +80,7 @@ void print_link_flags(FILE *fp, unsigned flags, unsigned mdown)
        fprintf(fp, "> ");
 }
 
-void print_queuelen(char *name)
+static void print_queuelen(char *name)
 {
        struct ifreq ifr;
        int s;
@@ -106,7 +102,7 @@ void print_queuelen(char *name)
                printf("qlen %d", ifr.ifr_qlen);
 }
 
-int print_linkinfo(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
+static int print_linkinfo(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
 {
        FILE *fp = (FILE*)arg;
        struct ifinfomsg *ifi = NLMSG_DATA(n);
@@ -198,7 +194,17 @@ int print_linkinfo(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
        return 0;
 }
 
-int print_addrinfo(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
+static int flush_update(void)
+{
+       if (rtnl_send(filter.rth, filter.flushb, filter.flushp) < 0) {
+               perror("Failed to send flush request\n");
+               return -1;
+       }
+       filter.flushp = 0;
+       return 0;
+}
+
+static int print_addrinfo(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
 {
        FILE *fp = (FILE*)arg;
        struct ifaddrmsg *ifa = NLMSG_DATA(n);
@@ -215,6 +221,9 @@ int print_addrinfo(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
                return -1;
        }
 
+       if (filter.flushb && n->nlmsg_type != RTM_NEWADDR)
+               return 0;
+
        memset(rta_tb, 0, sizeof(rta_tb));
        parse_rtattr(rta_tb, IFA_MAX, IFA_RTA(ifa), n->nlmsg_len - NLMSG_LENGTH(sizeof(*ifa)));
 
@@ -249,6 +258,22 @@ int print_addrinfo(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
                }
        }
 
+       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_DELADDR;
+               fn->nlmsg_flags = NLM_F_REQUEST;
+               fn->nlmsg_seq = ++filter.rth->seq;
+               filter.flushp = (((char*)fn) + n->nlmsg_len) - filter.flushb;
+               filter.flushed++;
+               return 0;
+       }
+
        if (n->nlmsg_type == RTM_DELADDR)
                fprintf(fp, "Deleted ");
 
@@ -341,7 +366,7 @@ struct nlmsg_list
        struct nlmsghdr   h;
 };
 
-int print_selected_addrinfo(int ifindex, struct nlmsg_list *ainfo, FILE *fp)
+static int print_selected_addrinfo(int ifindex, struct nlmsg_list *ainfo, FILE *fp)
 {
        for ( ;ainfo ;  ainfo = ainfo->next) {
                struct nlmsghdr *n = &ainfo->h;
@@ -363,7 +388,7 @@ int print_selected_addrinfo(int ifindex, struct nlmsg_list *ainfo, FILE *fp)
 }
 
 
-int store_nlmsg(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
+static int store_nlmsg(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
 {
        struct nlmsg_list **linfo = (struct nlmsg_list**)arg;
        struct nlmsg_list *h;
@@ -383,8 +408,15 @@ int store_nlmsg(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
        return 0;
 }
 
-int ipaddr_list(int argc, char **argv)
+static void ipaddr_reset_filter(int _oneline)
 {
+       memset(&filter, 0, sizeof(filter));
+       filter.oneline = _oneline;
+}
+
+extern int ipaddr_list_or_flush(int argc, char **argv, int flush)
+{
+       const char *option[] = { "to", "scope", "up", "label", "dev", 0 };
        struct nlmsg_list *linfo = NULL;
        struct nlmsg_list *ainfo = NULL;
        struct nlmsg_list *l;
@@ -398,37 +430,59 @@ int ipaddr_list(int argc, char **argv)
        if (filter.family == AF_UNSPEC)
                filter.family = preferred_family;
 
+       if (flush) {
+               if (argc <= 0) {
+                       fprintf(stderr, "Flush requires arguments.\n");
+                       return -1;
+               }
+               if (filter.family == AF_PACKET) {
+                       fprintf(stderr, "Cannot flush link addresses.\n");
+                       return -1;
+               }
+       }
+
        while (argc > 0) {
-               if (strcmp(*argv, "to") == 0) {
-                       NEXT_ARG();
-                       get_prefix(&filter.pfx, *argv, filter.family);
-                       if (filter.family == AF_UNSPEC)
-                               filter.family = filter.pfx.family;
-               } else if (strcmp(*argv, "scope") == 0) {
-                       int scope = 0;
-                       NEXT_ARG();
-                       filter.scopemask = -1;
-                       if (rtnl_rtscope_a2n(&scope, *argv)) {
-                               if (strcmp(*argv, "all") != 0)
-                                       invarg("invalid \"scope\"\n", *argv);
-                               scope = RT_SCOPE_NOWHERE;
-                               filter.scopemask = 0;
-                       }
-                       filter.scope = scope;
-               } else if (strcmp(*argv, "up") == 0) {
-                       filter.up = 1;
-               } else if (strcmp(*argv, "label") == 0) {
-                       NEXT_ARG();
-                       filter.label = *argv;
-               } else {
-                       if (strcmp(*argv, "dev") == 0) {
+               const unsigned short option_num = compare_string_array(option, *argv);
+               switch (option_num) {
+                       case 0: /* to */
+                               NEXT_ARG();
+                               get_prefix(&filter.pfx, *argv, filter.family);
+                               if (filter.family == AF_UNSPEC) {
+                                       filter.family = filter.pfx.family;
+                               }
+                               break;
+                       case 1: /* scope */
+                       {
+                               int scope = 0;
                                NEXT_ARG();
+                               filter.scopemask = -1;
+                               if (rtnl_rtscope_a2n(&scope, *argv)) {
+                                       if (strcmp(*argv, "all") != 0) {
+                                               invarg("invalid \"scope\"\n", *argv);
+                                       }
+                                       scope = RT_SCOPE_NOWHERE;
+                                       filter.scopemask = 0;
+                               }
+                               filter.scope = scope;
+                               break;
                        }
-                       if (filter_dev)
-                               duparg2("dev", *argv);
-                       filter_dev = *argv;
+                       case 2: /* up */
+                               filter.up = 1;
+                               break;
+                       case 3: /* label */
+                               NEXT_ARG();
+                               filter.label = *argv;
+                               break;
+                       case 4: /* dev */
+                               NEXT_ARG();
+                       default:
+                               if (filter_dev) {
+                                       duparg2("dev", *argv);
+                               }
+                               filter_dev = *argv;
                }
-               argv++; argc--;
+               argv++;
+               argc--;
        }
 
        if (rtnl_open(&rth, 0) < 0)
@@ -450,6 +504,37 @@ int ipaddr_list(int argc, char **argv)
                }
        }
 
+       if (flush) {
+               int round = 0;
+               char flushb[4096-512];
+
+               filter.flushb = flushb;
+               filter.flushp = 0;
+               filter.flushe = sizeof(flushb);
+               filter.rth = &rth;
+
+               for (;;) {
+                       if (rtnl_wilddump_request(&rth, filter.family, RTM_GETADDR) < 0) {
+                               perror("Cannot send dump request");
+                               exit(1);
+                       }
+                       filter.flushed = 0;
+                       if (rtnl_dump_filter(&rth, print_addrinfo, stdout, NULL, NULL) < 0) {
+                               fprintf(stderr, "Flush terminated\n");
+                               exit(1);
+                       }
+                       if (filter.flushed == 0) {
+                               if (round == 0)
+                                       fprintf(stderr, "Nothing to flush.\n");
+                               fflush(stdout);
+                               return 0;
+                       }
+                       round++;
+                       if (flush_update() < 0)
+                               exit(1);
+               }
+       }
+
        if (filter.family != AF_PACKET) {
                if (rtnl_wilddump_request(&rth, filter.family, RTM_GETADDR) < 0) {
                        perror_msg_and_die("Cannot send dump request");
@@ -533,20 +618,7 @@ int ipaddr_list(int argc, char **argv)
        exit(0);
 }
 
-int ipaddr_list_link(int argc, char **argv)
-{
-       preferred_family = AF_PACKET;
-       do_link = 1;
-       return ipaddr_list(argc, argv);
-}
-
-void ipaddr_reset_filter(int _oneline)
-{
-       memset(&filter, 0, sizeof(filter));
-       filter.oneline = _oneline;
-}
-
-int default_scope(inet_prefix *lcl)
+static int default_scope(inet_prefix *lcl)
 {
        if (lcl->family == AF_INET) {
                if (lcl->bytelen >= 1 && *(__u8*)&lcl->data == 127)
@@ -555,8 +627,10 @@ int default_scope(inet_prefix *lcl)
        return 0;
 }
 
-int ipaddr_modify(int cmd, int argc, char **argv)
+static int ipaddr_modify(int cmd, int argc, char **argv)
 {
+       const char *option[] = { "peer", "remote", "broadcast", "brd",
+               "anycast", "scope", "dev", "label", "local", 0 };
        struct rtnl_handle rth;
        struct {
                struct nlmsghdr         n;
@@ -581,73 +655,97 @@ int ipaddr_modify(int cmd, int argc, char **argv)
        req.ifa.ifa_family = preferred_family;
 
        while (argc > 0) {
-               if (strcmp(*argv, "peer") == 0 ||
-                   strcmp(*argv, "remote") == 0) {
-                       NEXT_ARG();
-
-                       if (peer_len)
-                               duparg("peer", *argv);
-                       get_prefix(&peer, *argv, req.ifa.ifa_family);
-                       peer_len = peer.bytelen;
-                       if (req.ifa.ifa_family == AF_UNSPEC)
-                               req.ifa.ifa_family = peer.family;
-                       addattr_l(&req.n, sizeof(req), IFA_ADDRESS, &peer.data, peer.bytelen);
-                       req.ifa.ifa_prefixlen = peer.bitlen;
-               } else if (matches(*argv, "broadcast") == 0 ||
-                          strcmp(*argv, "brd") == 0) {
-                       inet_prefix addr;
-                       NEXT_ARG();
-                       if (brd_len)
-                               duparg("broadcast", *argv);
-                       if (strcmp(*argv, "+") == 0)
-                               brd_len = -1;
-                       else if (strcmp(*argv, "-") == 0)
-                               brd_len = -2;
-                       else {
+               const unsigned short option_num = compare_string_array(option, *argv);
+               switch (option_num) {
+                       case 0: /* peer */
+                       case 1: /* remote */
+                               NEXT_ARG();
+
+                               if (peer_len) {
+                                       duparg("peer", *argv);
+                               }
+                               get_prefix(&peer, *argv, req.ifa.ifa_family);
+                               peer_len = peer.bytelen;
+                               if (req.ifa.ifa_family == AF_UNSPEC) {
+                                       req.ifa.ifa_family = peer.family;
+                               }
+                               addattr_l(&req.n, sizeof(req), IFA_ADDRESS, &peer.data, peer.bytelen);
+                               req.ifa.ifa_prefixlen = peer.bitlen;
+                               break;
+                       case 2: /* broadcast */
+                       case 3: /* brd */
+                       {
+                               inet_prefix addr;
+                               NEXT_ARG();
+                               if (brd_len) {
+                                       duparg("broadcast", *argv);
+                               }
+                               if (strcmp(*argv, "+") == 0) {
+                                       brd_len = -1;
+                               }
+                               else if (strcmp(*argv, "-") == 0) {
+                                       brd_len = -2;
+                               } else {
+                                       get_addr(&addr, *argv, req.ifa.ifa_family);
+                                       if (req.ifa.ifa_family == AF_UNSPEC)
+                                               req.ifa.ifa_family = addr.family;
+                                       addattr_l(&req.n, sizeof(req), IFA_BROADCAST, &addr.data, addr.bytelen);
+                                       brd_len = addr.bytelen;
+                               }
+                               break;
+                       }
+                       case 4: /* anycast */
+                       {
+                               inet_prefix addr;
+                               NEXT_ARG();
+                               if (any_len) {
+                                       duparg("anycast", *argv);
+                               }
                                get_addr(&addr, *argv, req.ifa.ifa_family);
-                               if (req.ifa.ifa_family == AF_UNSPEC)
+                               if (req.ifa.ifa_family == AF_UNSPEC) {
                                        req.ifa.ifa_family = addr.family;
-                               addattr_l(&req.n, sizeof(req), IFA_BROADCAST, &addr.data, addr.bytelen);
-                               brd_len = addr.bytelen;
+                               }
+                               addattr_l(&req.n, sizeof(req), IFA_ANYCAST, &addr.data, addr.bytelen);
+                               any_len = addr.bytelen;
+                               break;
                        }
-               } else if (strcmp(*argv, "anycast") == 0) {
-                       inet_prefix addr;
-                       NEXT_ARG();
-                       if (any_len)
-                               duparg("anycast", *argv);
-                       get_addr(&addr, *argv, req.ifa.ifa_family);
-                       if (req.ifa.ifa_family == AF_UNSPEC)
-                               req.ifa.ifa_family = addr.family;
-                       addattr_l(&req.n, sizeof(req), IFA_ANYCAST, &addr.data, addr.bytelen);
-                       any_len = addr.bytelen;
-               } else if (strcmp(*argv, "scope") == 0) {
-                       int scope = 0;
-                       NEXT_ARG();
-                       if (rtnl_rtscope_a2n(&scope, *argv))
-                               invarg(*argv, "invalid scope value.");
-                       req.ifa.ifa_scope = scope;
-                       scoped = 1;
-               } else if (strcmp(*argv, "dev") == 0) {
-                       NEXT_ARG();
-                       d = *argv;
-               } else if (strcmp(*argv, "label") == 0) {
-                       NEXT_ARG();
-                       l = *argv;
-                       addattr_l(&req.n, sizeof(req), IFA_LABEL, l, strlen(l)+1);
-               } else {
-                       if (strcmp(*argv, "local") == 0) {
+                       case 5: /* scope */
+                       {
+                               int scope = 0;
                                NEXT_ARG();
+                               if (rtnl_rtscope_a2n(&scope, *argv)) {
+                                       invarg(*argv, "invalid scope value.");
+                               }
+                               req.ifa.ifa_scope = scope;
+                               scoped = 1;
+                               break;
                        }
-                       if (local_len)
-                               duparg2("local", *argv);
-                       get_prefix(&lcl, *argv, req.ifa.ifa_family);
-                       if (req.ifa.ifa_family == AF_UNSPEC)
-                               req.ifa.ifa_family = lcl.family;
-                       addattr_l(&req.n, sizeof(req), IFA_LOCAL, &lcl.data, lcl.bytelen);
-                       local_len = lcl.bytelen;
+                       case 6: /* dev */
+                               NEXT_ARG();
+                               d = *argv;
+                               break;
+                       case 7: /* label */
+                               NEXT_ARG();
+                               l = *argv;
+                               addattr_l(&req.n, sizeof(req), IFA_LABEL, l, strlen(l)+1);
+                               break;
+                       case 8: /* local */
+                               NEXT_ARG();
+                       default:
+                               if (local_len) {
+                                       duparg2("local", *argv);
+                               }
+                               get_prefix(&lcl, *argv, req.ifa.ifa_family);
+                               if (req.ifa.ifa_family == AF_UNSPEC) {
+                                       req.ifa.ifa_family = lcl.family;
+                               }
+                               addattr_l(&req.n, sizeof(req), IFA_LOCAL, &lcl.data, lcl.bytelen);
+                               local_len = lcl.bytelen;
                }
-               argc--; argv++;
+               argc--;
+               argv++;
        }
+
        if (d == NULL) {
                error_msg("Not enough information: \"dev\" argument is required.");
                return -1;
@@ -701,17 +799,25 @@ int ipaddr_modify(int cmd, int argc, char **argv)
        exit(0);
 }
 
-int do_ipaddr(int argc, char **argv)
+extern int do_ipaddr(int argc, char **argv)
 {
-       if (argc < 1)
-               return ipaddr_list(0, NULL);
-       if (matches(*argv, "add") == 0)
-               return ipaddr_modify(RTM_NEWADDR, argc-1, argv+1);
-       if (matches(*argv, "delete") == 0)
-               return ipaddr_modify(RTM_DELADDR, argc-1, argv+1);
-       if (matches(*argv, "list") == 0 || matches(*argv, "show") == 0
-           || matches(*argv, "lst") == 0)
-               return ipaddr_list(argc-1, argv+1);
-       error_msg("Command \"%s\" is unknown, try \"ip address help\".", *argv);
-       exit(-1);
+       const char *commands[] = { "add", "delete", "list", "show", "lst", "flush", 0 };
+       unsigned short command_num = 2;
+
+       if (*argv) {
+               command_num = compare_string_array(commands, *argv);
+       }
+       switch (command_num) {
+               case 0: /* add */
+                       return ipaddr_modify(RTM_NEWADDR, argc-1, argv+1);
+               case 1: /* delete */
+                       return ipaddr_modify(RTM_DELADDR, argc-1, argv+1);
+               case 2: /* list */
+               case 3: /* show */
+               case 4: /* lst */
+                       return ipaddr_list_or_flush(argc-1, argv+1, 0);
+               case 5: /* flush */
+                       return ipaddr_list_or_flush(argc-1, argv+1, 1);
+       }
+       error_msg_and_die("Unknown command %s", *argv);
 }