networking/libiproute/iproute.c

   1 /* vi: set sw=4 ts=4: */
   2 /*
   3  * iproute.c            "ip route".
   4  *
   5  * Licensed under the GPL v2 or later, see the file LICENSE in this tarball.
   6  *
   7  * Authors:     Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
   8  *
   9  *
  10  * Changes:
  11  *
  12  * Rani Assaf <rani@magic.metawire.com> 980929: resolve addresses
  13  * Kunihiro Ishiguro <kunihiro@zebra.org> 001102: rtnh_ifindex was not initialized
  14  */
  15
  16 #include "ip_common.h"  /* #include "libbb.h" is inside */
  17 #include "rt_names.h"
  18 #include "utils.h"
  19
  20 #ifndef RTAX_RTTVAR
  21 #define RTAX_RTTVAR RTAX_HOPS
  22 #endif
  23
  24
  25 typedef struct filter_t {
  26         int tb;
  27         smallint flushed;
  28         char *flushb;
  29         int flushp;
  30         int flushe;
  31         struct rtnl_handle *rth;
  32         int protocol, protocolmask;
  33         int scope, scopemask;
  34         int type, typemask;
  35         int tos, tosmask;
  36         int iif, iifmask;
  37         int oif, oifmask;
  38         int realm, realmmask;
  39         inet_prefix rprefsrc;
  40         inet_prefix rvia;
  41         inet_prefix rdst;
  42         inet_prefix mdst;
  43         inet_prefix rsrc;
  44         inet_prefix msrc;
  45 } filter_t;
  46
  47 #define filter (*(filter_t*)&bb_common_bufsiz1)
  48
  49 static int flush_update(void)
  50 {
  51         if (rtnl_send(filter.rth, filter.flushb, filter.flushp) < 0) {
  52                 bb_perror_msg("failed to send flush request");
  53                 return -1;
  54         }
  55         filter.flushp = 0;
  56         return 0;
  57 }
  58
  59 static unsigned get_hz(void)
  60 {
  61         static unsigned hz_internal;
  62         FILE *fp;
  63
  64         if (hz_internal)
  65                 return hz_internal;
  66
  67         fp = fopen("/proc/net/psched", "r");
  68         if (fp) {
  69                 unsigned nom, denom;
  70
  71                 if (fscanf(fp, "%*08x%*08x%08x%08x", &nom, &denom) == 2)
  72                         if (nom == 1000000)
  73                                 hz_internal = denom;
  74                 fclose(fp);
  75         }
  76         if (!hz_internal)
  77                 hz_internal = sysconf(_SC_CLK_TCK);
  78         return hz_internal;
  79 }
  80
  81 static int print_route(const struct sockaddr_nl *who UNUSED_PARAM,
  82                 struct nlmsghdr *n, void *arg UNUSED_PARAM)
  83 {
  84         struct rtmsg *r = NLMSG_DATA(n);
  85         int len = n->nlmsg_len;
  86         struct rtattr * tb[RTA_MAX+1];
  87         char abuf[256];
  88         inet_prefix dst;
  89         inet_prefix src;
  90         int host_len = -1;
  91         SPRINT_BUF(b1);
  92
  93         if (n->nlmsg_type != RTM_NEWROUTE && n->nlmsg_type != RTM_DELROUTE) {
  94                 fprintf(stderr, "Not a route: %08x %08x %08x\n",
  95                         n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);
  96                 return 0;
  97         }
  98         if (filter.flushb && n->nlmsg_type != RTM_NEWROUTE)
  99                 return 0;
 100         len -= NLMSG_LENGTH(sizeof(*r));
 101         if (len < 0)
 102                 bb_error_msg_and_die("wrong nlmsg len %d", len);
 103
 104         if (r->rtm_family == AF_INET6)
 105                 host_len = 128;
 106         else if (r->rtm_family == AF_INET)
 107                 host_len = 32;
 108
 109         if (r->rtm_family == AF_INET6) {
 110                 if (filter.tb) {
 111                         if (filter.tb < 0) {
 112                                 if (!(r->rtm_flags & RTM_F_CLONED)) {
 113                                         return 0;
 114                                 }
 115                         } else {
 116                                 if (r->rtm_flags & RTM_F_CLONED) {
 117                                         return 0;
 118                                 }
 119                                 if (filter.tb == RT_TABLE_LOCAL) {
 120                                         if (r->rtm_type != RTN_LOCAL) {
 121                                                 return 0;
 122                                         }
 123                                 } else if (filter.tb == RT_TABLE_MAIN) {
 124                                         if (r->rtm_type == RTN_LOCAL) {
 125                                                 return 0;
 126                                         }
 127                                 } else {
 128                                         return 0;
 129                                 }
 130                         }
 131                 }
 132         } else {
 133                 if (filter.tb > 0 && filter.tb != r->rtm_table) {
 134                         return 0;
 135                 }
 136         }
 137         if (filter.rdst.family &&
 138             (r->rtm_family != filter.rdst.family || filter.rdst.bitlen > r->rtm_dst_len)) {
 139                 return 0;
 140         }
 141         if (filter.mdst.family &&
 142             (r->rtm_family != filter.mdst.family ||
 143              (filter.mdst.bitlen >= 0 && filter.mdst.bitlen < r->rtm_dst_len))) {
 144                 return 0;
 145         }
 146         if (filter.rsrc.family &&
 147             (r->rtm_family != filter.rsrc.family || filter.rsrc.bitlen > r->rtm_src_len)) {
 148                 return 0;
 149         }
 150         if (filter.msrc.family &&
 151             (r->rtm_family != filter.msrc.family ||
 152              (filter.msrc.bitlen >= 0 && filter.msrc.bitlen < r->rtm_src_len))) {
 153                 return 0;
 154         }
 155
 156         memset(tb, 0, sizeof(tb));
 157         parse_rtattr(tb, RTA_MAX, RTM_RTA(r), len);
 158
 159         if (filter.rdst.family && inet_addr_match(&dst, &filter.rdst, filter.rdst.bitlen))
 160                 return 0;
 161         if (filter.mdst.family && filter.mdst.bitlen >= 0 &&
 162             inet_addr_match(&dst, &filter.mdst, r->rtm_dst_len))
 163                 return 0;
 164
 165         if (filter.rsrc.family && inet_addr_match(&src, &filter.rsrc, filter.rsrc.bitlen))
 166                 return 0;
 167         if (filter.msrc.family && filter.msrc.bitlen >= 0 &&
 168             inet_addr_match(&src, &filter.msrc, r->rtm_src_len))
 169                 return 0;
 170
 171         if (filter.flushb &&
 172             r->rtm_family == AF_INET6 &&
 173             r->rtm_dst_len == 0 &&
 174             r->rtm_type == RTN_UNREACHABLE &&
 175             tb[RTA_PRIORITY] &&
 176             *(int*)RTA_DATA(tb[RTA_PRIORITY]) == -1)
 177                 return 0;
 178
 179         if (filter.flushb) {
 180                 struct nlmsghdr *fn;
 181                 if (NLMSG_ALIGN(filter.flushp) + n->nlmsg_len > filter.flushe) {
 182                         if (flush_update())
 183                                 bb_error_msg_and_die("flush");
 184                 }
 185                 fn = (struct nlmsghdr*)(filter.flushb + NLMSG_ALIGN(filter.flushp));
 186                 memcpy(fn, n, n->nlmsg_len);
 187                 fn->nlmsg_type = RTM_DELROUTE;
 188                 fn->nlmsg_flags = NLM_F_REQUEST;
 189                 fn->nlmsg_seq = ++filter.rth->seq;
 190                 filter.flushp = (((char*)fn) + n->nlmsg_len) - filter.flushb;
 191                 filter.flushed = 1;
 192                 return 0;
 193         }
 194
 195         if (n->nlmsg_type == RTM_DELROUTE) {
 196                 printf("Deleted ");
 197         }
 198         if (r->rtm_type != RTN_UNICAST && !filter.type) {
 199                 printf("%s ", rtnl_rtntype_n2a(r->rtm_type, b1, sizeof(b1)));
 200         }
 201
 202         if (tb[RTA_DST]) {
 203                 if (r->rtm_dst_len != host_len) {
 204                         printf("%s/%u ", rt_addr_n2a(r->rtm_family,
 205                                                 RTA_PAYLOAD(tb[RTA_DST]),
 206                                                 RTA_DATA(tb[RTA_DST]),
 207                                                 abuf, sizeof(abuf)),
 208                                         r->rtm_dst_len
 209                                         );
 210                 } else {
 211                         printf("%s ", format_host(r->rtm_family,
 212                                                 RTA_PAYLOAD(tb[RTA_DST]),
 213                                                 RTA_DATA(tb[RTA_DST]),
 214                                                 abuf, sizeof(abuf))
 215                                         );
 216                 }
 217         } else if (r->rtm_dst_len) {
 218                 printf("0/%d ", r->rtm_dst_len);
 219         } else {
 220                 printf("default ");
 221         }
 222         if (tb[RTA_SRC]) {
 223                 if (r->rtm_src_len != host_len) {
 224                         printf("from %s/%u ", rt_addr_n2a(r->rtm_family,
 225                                                 RTA_PAYLOAD(tb[RTA_SRC]),
 226                                                 RTA_DATA(tb[RTA_SRC]),
 227                                                 abuf, sizeof(abuf)),
 228                                         r->rtm_src_len
 229                                         );
 230                 } else {
 231                         printf("from %s ", format_host(r->rtm_family,
 232                                                 RTA_PAYLOAD(tb[RTA_SRC]),
 233                                                 RTA_DATA(tb[RTA_SRC]),
 234                                                 abuf, sizeof(abuf))
 235                                         );
 236                 }
 237         } else if (r->rtm_src_len) {
 238                 printf("from 0/%u ", r->rtm_src_len);
 239         }
 240         if (tb[RTA_GATEWAY] && filter.rvia.bitlen != host_len) {
 241                 printf("via %s ", format_host(r->rtm_family,
 242                                         RTA_PAYLOAD(tb[RTA_GATEWAY]),
 243                                         RTA_DATA(tb[RTA_GATEWAY]),
 244                                         abuf, sizeof(abuf)));
 245         }
 246         if (tb[RTA_OIF] && filter.oifmask != -1) {
 247                 printf("dev %s ", ll_index_to_name(*(int*)RTA_DATA(tb[RTA_OIF])));
 248         }
 249
 250         if (tb[RTA_PREFSRC] && filter.rprefsrc.bitlen != host_len) {
 251                 /* Do not use format_host(). It is our local addr
 252                    and symbolic name will not be useful.
 253                  */
 254                 printf(" src %s ", rt_addr_n2a(r->rtm_family,
 255                                         RTA_PAYLOAD(tb[RTA_PREFSRC]),
 256                                         RTA_DATA(tb[RTA_PREFSRC]),
 257                                         abuf, sizeof(abuf)));
 258         }
 259         if (tb[RTA_PRIORITY]) {
 260                 printf(" metric %d ", *(uint32_t*)RTA_DATA(tb[RTA_PRIORITY]));
 261         }
 262         if (r->rtm_family == AF_INET6) {
 263                 struct rta_cacheinfo *ci = NULL;
 264                 if (tb[RTA_CACHEINFO]) {
 265                         ci = RTA_DATA(tb[RTA_CACHEINFO]);
 266                 }
 267                 if ((r->rtm_flags & RTM_F_CLONED) || (ci && ci->rta_expires)) {
 268                         if (r->rtm_flags & RTM_F_CLONED) {
 269                                 printf("%c    cache ", _SL_);
 270                         }
 271                         if (ci->rta_expires) {
 272                                 printf(" expires %dsec", ci->rta_expires / get_hz());
 273                         }
 274                         if (ci->rta_error != 0) {
 275                                 printf(" error %d", ci->rta_error);
 276                         }
 277                 } else if (ci) {
 278                         if (ci->rta_error != 0)
 279                                 printf(" error %d", ci->rta_error);
 280                 }
 281         }
 282         if (tb[RTA_IIF] && filter.iifmask != -1) {
 283                 printf(" iif %s", ll_index_to_name(*(int*)RTA_DATA(tb[RTA_IIF])));
 284         }
 285         bb_putchar('\n');
 286         return 0;
 287 }
 288
 289 /* Return value becomes exitcode. It's okay to not return at all */
 290 static int iproute_modify(int cmd, unsigned flags, char **argv)
 291 {
 292         static const char keywords[] ALIGN1 =
 293                 "src\0""via\0""mtu\0""lock\0""protocol\0"USE_FEATURE_IP_RULE("table\0")
 294                 "dev\0""oif\0""to\0";
 295         enum {
 296                 ARG_src,
 297                 ARG_via,
 298                 ARG_mtu, PARM_lock,
 299                 ARG_protocol,
 300 USE_FEATURE_IP_RULE(ARG_table,)
 301                 ARG_dev,
 302                 ARG_oif,
 303                 ARG_to
 304         };
 305         enum {
 306                 gw_ok = 1 << 0,
 307                 dst_ok = 1 << 1,
 308                 proto_ok = 1 << 2,
 309                 type_ok = 1 << 3
 310         };
 311         struct rtnl_handle rth;
 312         struct {
 313                 struct nlmsghdr         n;
 314                 struct rtmsg            r;
 315                 char                    buf[1024];
 316         } req;
 317         char mxbuf[256];
 318         struct rtattr * mxrta = (void*)mxbuf;
 319         unsigned mxlock = 0;
 320         char *d = NULL;
 321         smalluint ok = 0;
 322         int arg;
 323
 324         memset(&req, 0, sizeof(req));
 325
 326         req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct rtmsg));
 327         req.n.nlmsg_flags = NLM_F_REQUEST | flags;
 328         req.n.nlmsg_type = cmd;
 329         req.r.rtm_family = preferred_family;
 330         if (RT_TABLE_MAIN) /* if it is zero, memset already did it */
 331                 req.r.rtm_table = RT_TABLE_MAIN;
 332         if (RT_SCOPE_NOWHERE)
 333                 req.r.rtm_scope = RT_SCOPE_NOWHERE;
 334
 335         if (cmd != RTM_DELROUTE) {
 336                 req.r.rtm_protocol = RTPROT_BOOT;
 337                 req.r.rtm_scope = RT_SCOPE_UNIVERSE;
 338                 req.r.rtm_type = RTN_UNICAST;
 339         }
 340
 341         mxrta->rta_type = RTA_METRICS;
 342         mxrta->rta_len = RTA_LENGTH(0);
 343
 344         while (*argv) {
 345                 arg = index_in_substrings(keywords, *argv);
 346                 if (arg == ARG_src) {
 347                         inet_prefix addr;
 348                         NEXT_ARG();
 349                         get_addr(&addr, *argv, req.r.rtm_family);
 350                         if (req.r.rtm_family == AF_UNSPEC)
 351                                 req.r.rtm_family = addr.family;
 352                         addattr_l(&req.n, sizeof(req), RTA_PREFSRC, &addr.data, addr.bytelen);
 353                 } else if (arg == ARG_via) {
 354                         inet_prefix addr;
 355                         ok |= gw_ok;
 356                         NEXT_ARG();
 357                         get_addr(&addr, *argv, req.r.rtm_family);
 358                         if (req.r.rtm_family == AF_UNSPEC) {
 359                                 req.r.rtm_family = addr.family;
 360                         }
 361                         addattr_l(&req.n, sizeof(req), RTA_GATEWAY, &addr.data, addr.bytelen);
 362                 } else if (arg == ARG_mtu) {
 363                         unsigned mtu;
 364                         NEXT_ARG();
 365                         if (index_in_strings(keywords, *argv) == PARM_lock) {
 366                                 mxlock |= (1 << RTAX_MTU);
 367                                 NEXT_ARG();
 368                         }
 369                         if (get_unsigned(&mtu, *argv, 0))
 370                                 invarg(*argv, "mtu");
 371                         rta_addattr32(mxrta, sizeof(mxbuf), RTAX_MTU, mtu);
 372                 } else if (arg == ARG_protocol) {
 373                         uint32_t prot;
 374                         NEXT_ARG();
 375                         if (rtnl_rtprot_a2n(&prot, *argv))
 376                                 invarg(*argv, "protocol");
 377                         req.r.rtm_protocol = prot;
 378                         ok |= proto_ok;
 379 #if ENABLE_FEATURE_IP_RULE
 380                 } else if (arg == ARG_table) {
 381                         uint32_t tid;
 382                         NEXT_ARG();
 383                         if (rtnl_rttable_a2n(&tid, *argv))
 384                                 invarg(*argv, "table");
 385                         req.r.rtm_table = tid;
 386 #endif
 387                 } else if (arg == ARG_dev || arg == ARG_oif) {
 388                         NEXT_ARG();
 389                         d = *argv;
 390                 } else {
 391                         int type;
 392                         inet_prefix dst;
 393
 394                         if (arg == ARG_to) {
 395                                 NEXT_ARG();
 396                         }
 397                         if ((**argv < '0' || **argv > '9')
 398                          && rtnl_rtntype_a2n(&type, *argv) == 0) {
 399                                 NEXT_ARG();
 400                                 req.r.rtm_type = type;
 401                                 ok |= type_ok;
 402                         }
 403
 404                         if (ok & dst_ok) {
 405                                 duparg2("to", *argv);
 406                         }
 407                         get_prefix(&dst, *argv, req.r.rtm_family);
 408                         if (req.r.rtm_family == AF_UNSPEC) {
 409                                 req.r.rtm_family = dst.family;
 410                         }
 411                         req.r.rtm_dst_len = dst.bitlen;
 412                         ok |= dst_ok;
 413                         if (dst.bytelen) {
 414                                 addattr_l(&req.n, sizeof(req), RTA_DST, &dst.data, dst.bytelen);
 415                         }
 416                 }
 417                 argv++;
 418         }
 419
 420         xrtnl_open(&rth);
 421
 422         if (d)  {
 423                 int idx;
 424
 425                 ll_init_map(&rth);
 426
 427                 if (d) {
 428                         idx = xll_name_to_index(d);
 429                         addattr32(&req.n, sizeof(req), RTA_OIF, idx);
 430                 }
 431         }
 432
 433         if (mxrta->rta_len > RTA_LENGTH(0)) {
 434                 if (mxlock) {
 435                         rta_addattr32(mxrta, sizeof(mxbuf), RTAX_LOCK, mxlock);
 436                 }
 437                 addattr_l(&req.n, sizeof(req), RTA_METRICS, RTA_DATA(mxrta), RTA_PAYLOAD(mxrta));
 438         }
 439
 440         if (req.r.rtm_type == RTN_LOCAL || req.r.rtm_type == RTN_NAT)
 441                 req.r.rtm_scope = RT_SCOPE_HOST;
 442         else if (req.r.rtm_type == RTN_BROADCAST ||
 443                         req.r.rtm_type == RTN_MULTICAST ||
 444                         req.r.rtm_type == RTN_ANYCAST)
 445                 req.r.rtm_scope = RT_SCOPE_LINK;
 446         else if (req.r.rtm_type == RTN_UNICAST || req.r.rtm_type == RTN_UNSPEC) {
 447                 if (cmd == RTM_DELROUTE)
 448                         req.r.rtm_scope = RT_SCOPE_NOWHERE;
 449                 else if (!(ok & gw_ok))
 450                         req.r.rtm_scope = RT_SCOPE_LINK;
 451         }
 452
 453         if (req.r.rtm_family == AF_UNSPEC) {
 454                 req.r.rtm_family = AF_INET;
 455         }
 456
 457         if (rtnl_talk(&rth, &req.n, 0, 0, NULL, NULL, NULL) < 0) {
 458                 return 2;
 459         }
 460
 461         return 0;
 462 }
 463
 464 static int rtnl_rtcache_request(struct rtnl_handle *rth, int family)
 465 {
 466         struct {
 467                 struct nlmsghdr nlh;
 468                 struct rtmsg rtm;
 469         } req;
 470         struct sockaddr_nl nladdr;
 471
 472         memset(&nladdr, 0, sizeof(nladdr));
 473         memset(&req, 0, sizeof(req));
 474         nladdr.nl_family = AF_NETLINK;
 475
 476         req.nlh.nlmsg_len = sizeof(req);
 477         if (RTM_GETROUTE)
 478                 req.nlh.nlmsg_type = RTM_GETROUTE;
 479         if (NLM_F_ROOT | NLM_F_REQUEST)
 480                 req.nlh.nlmsg_flags = NLM_F_ROOT | NLM_F_REQUEST;
 481         /*req.nlh.nlmsg_pid = 0; - memset did it already */
 482         req.nlh.nlmsg_seq = rth->dump = ++rth->seq;
 483         req.rtm.rtm_family = family;
 484         if (RTM_F_CLONED)
 485                 req.rtm.rtm_flags = RTM_F_CLONED;
 486
 487         return xsendto(rth->fd, (void*)&req, sizeof(req), (struct sockaddr*)&nladdr, sizeof(nladdr));
 488 }
 489
 490 static void iproute_flush_cache(void)
 491 {
 492         static const char fn[] ALIGN1 = "/proc/sys/net/ipv4/route/flush";
 493         int flush_fd = open_or_warn(fn, O_WRONLY);
 494
 495         if (flush_fd < 0) {
 496                 return;
 497         }
 498
 499         if (write(flush_fd, "-1", 2) < 2) {
 500                 bb_perror_msg("cannot flush routing cache");
 501                 return;
 502         }
 503         close(flush_fd);
 504 }
 505
 506 static void iproute_reset_filter(void)
 507 {
 508         memset(&filter, 0, sizeof(filter));
 509         filter.mdst.bitlen = -1;
 510         filter.msrc.bitlen = -1;
 511 }
 512
 513 /* Return value becomes exitcode. It's okay to not return at all */
 514 static int iproute_list_or_flush(char **argv, int flush)
 515 {
 516         int do_ipv6 = preferred_family;
 517         struct rtnl_handle rth;
 518         char *id = NULL;
 519         char *od = NULL;
 520         static const char keywords[] ALIGN1 =
 521                 /* "ip route list/flush" parameters: */
 522                 "protocol\0" "dev\0"   "oif\0"   "iif\0"
 523                 "via\0"      "table\0" "cache\0"
 524                 "from\0"     "to\0"
 525                 /* and possible further keywords */
 526                 "all\0"
 527                 "root\0"
 528                 "match\0"
 529                 "exact\0"
 530                 "main\0"
 531                 ;
 532         enum {
 533                 KW_proto, KW_dev,   KW_oif,  KW_iif,
 534                 KW_via,   KW_table, KW_cache,
 535                 KW_from,  KW_to,
 536                 /* */
 537                 KW_all,
 538                 KW_root,
 539                 KW_match,
 540                 KW_exact,
 541                 KW_main,
 542         };
 543         int arg, parm;
 544
 545         iproute_reset_filter();
 546         filter.tb = RT_TABLE_MAIN;
 547
 548         if (flush && !*argv)
 549                 bb_error_msg_and_die(bb_msg_requires_arg, "\"ip route flush\"");
 550
 551         while (*argv) {
 552                 arg = index_in_substrings(keywords, *argv);
 553                 if (arg == KW_proto) {
 554                         uint32_t prot = 0;
 555                         NEXT_ARG();
 556                         filter.protocolmask = -1;
 557                         if (rtnl_rtprot_a2n(&prot, *argv)) {
 558                                 if (index_in_strings(keywords, *argv) != KW_all)
 559                                         invarg(*argv, "protocol");
 560                                 prot = 0;
 561                                 filter.protocolmask = 0;
 562                         }
 563                         filter.protocol = prot;
 564                 } else if (arg == KW_dev || arg == KW_oif) {
 565                         NEXT_ARG();
 566                         od = *argv;
 567                 } else if (arg == KW_iif) {
 568                         NEXT_ARG();
 569                         id = *argv;
 570                 } else if (arg == KW_via) {
 571                         NEXT_ARG();
 572                         get_prefix(&filter.rvia, *argv, do_ipv6);
 573                 } else if (arg == KW_table) { /* table all/cache/main */
 574                         NEXT_ARG();
 575                         parm = index_in_substrings(keywords, *argv);
 576                         if (parm == KW_cache)
 577                                 filter.tb = -1;
 578                         else if (parm == KW_all)
 579                                 filter.tb = 0;
 580                         else if (parm != KW_main) {
 581 #if ENABLE_FEATURE_IP_RULE
 582                                 uint32_t tid;
 583                                 if (rtnl_rttable_a2n(&tid, *argv))
 584                                         invarg(*argv, "table");
 585                                 filter.tb = tid;
 586 #else
 587                                 invarg(*argv, "table");
 588 #endif
 589                         }
 590                 } else if (arg == KW_cache) {
 591                         /* The command 'ip route flush cache' is used by OpenSWAN.
 592                          * Assuming it's a synonym for 'ip route flush table cache' */
 593                         filter.tb = -1;
 594                 } else if (arg == KW_from) {
 595                         NEXT_ARG();
 596                         parm = index_in_substrings(keywords, *argv);
 597                         if (parm == KW_root) {
 598                                 NEXT_ARG();
 599                                 get_prefix(&filter.rsrc, *argv, do_ipv6);
 600                         } else if (parm == KW_match) {
 601                                 NEXT_ARG();
 602                                 get_prefix(&filter.msrc, *argv, do_ipv6);
 603                         } else {
 604                                 if (parm == KW_exact)
 605                                         NEXT_ARG();
 606                                 get_prefix(&filter.msrc, *argv, do_ipv6);
 607                                 filter.rsrc = filter.msrc;
 608                         }
 609                 } else { /* "to" is the default parameter */
 610                         if (arg == KW_to) {
 611                                 NEXT_ARG();
 612                                 arg = index_in_substrings(keywords, *argv);
 613                         }
 614                         /* parm = arg; - would be more plausible, but we reuse 'arg' here */
 615                         if (arg == KW_root) {
 616                                 NEXT_ARG();
 617                                 get_prefix(&filter.rdst, *argv, do_ipv6);
 618                         } else if (arg == KW_match) {
 619                                 NEXT_ARG();
 620                                 get_prefix(&filter.mdst, *argv, do_ipv6);
 621                         } else { /* "to exact" is the default */
 622                                 if (arg == KW_exact)
 623                                         NEXT_ARG();
 624                                 get_prefix(&filter.mdst, *argv, do_ipv6);
 625                                 filter.rdst = filter.mdst;
 626                         }
 627                 }
 628                 argv++;
 629         }
 630
 631         if (do_ipv6 == AF_UNSPEC && filter.tb) {
 632                 do_ipv6 = AF_INET;
 633         }
 634
 635         xrtnl_open(&rth);
 636         ll_init_map(&rth);
 637
 638         if (id || od)  {
 639                 int idx;
 640
 641                 if (id) {
 642                         idx = xll_name_to_index(id);
 643                         filter.iif = idx;
 644                         filter.iifmask = -1;
 645                 }
 646                 if (od) {
 647                         idx = xll_name_to_index(od);
 648                         filter.oif = idx;
 649                         filter.oifmask = -1;
 650                 }
 651         }
 652
 653         if (flush) {
 654                 char flushb[4096-512];
 655
 656                 if (filter.tb == -1) { /* "flush table cache" */
 657                         if (do_ipv6 != AF_INET6)
 658                                 iproute_flush_cache();
 659                         if (do_ipv6 == AF_INET)
 660                                 return 0;
 661                 }
 662
 663                 filter.flushb = flushb;
 664                 filter.flushp = 0;
 665                 filter.flushe = sizeof(flushb);
 666                 filter.rth = &rth;
 667
 668                 for (;;) {
 669                         xrtnl_wilddump_request(&rth, do_ipv6, RTM_GETROUTE);
 670                         filter.flushed = 0;
 671                         xrtnl_dump_filter(&rth, print_route, NULL);
 672                         if (filter.flushed == 0)
 673                                 return 0;
 674                         if (flush_update())
 675                                 return 1;
 676                 }
 677         }
 678
 679         if (filter.tb != -1) {
 680                 xrtnl_wilddump_request(&rth, do_ipv6, RTM_GETROUTE);
 681         } else if (rtnl_rtcache_request(&rth, do_ipv6) < 0) {
 682                 bb_perror_msg_and_die("cannot send dump request");
 683         }
 684         xrtnl_dump_filter(&rth, print_route, NULL);
 685
 686         return 0;
 687 }
 688
 689
 690 /* Return value becomes exitcode. It's okay to not return at all */
 691 static int iproute_get(char **argv)
 692 {
 693         struct rtnl_handle rth;
 694         struct {
 695                 struct nlmsghdr n;
 696                 struct rtmsg    r;
 697                 char            buf[1024];
 698         } req;
 699         char *idev = NULL;
 700         char *odev = NULL;
 701         bool connected = 0;
 702         bool from_ok = 0;
 703         static const char options[] ALIGN1 =
 704                 "from\0""iif\0""oif\0""dev\0""notify\0""connected\0""to\0";
 705
 706         memset(&req, 0, sizeof(req));
 707
 708         iproute_reset_filter();
 709
 710         req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct rtmsg));
 711         if (NLM_F_REQUEST)
 712                 req.n.nlmsg_flags = NLM_F_REQUEST;
 713         if (RTM_GETROUTE)
 714                 req.n.nlmsg_type = RTM_GETROUTE;
 715         req.r.rtm_family = preferred_family;
 716         /*req.r.rtm_table = 0; - memset did this already */
 717         /*req.r.rtm_protocol = 0;*/
 718         /*req.r.rtm_scope = 0;*/
 719         /*req.r.rtm_type = 0;*/
 720         /*req.r.rtm_src_len = 0;*/
 721         /*req.r.rtm_dst_len = 0;*/
 722         /*req.r.rtm_tos = 0;*/
 723
 724         while (*argv) {
 725                 switch (index_in_strings(options, *argv)) {
 726                         case 0: /* from */
 727                         {
 728                                 inet_prefix addr;
 729                                 NEXT_ARG();
 730                                 from_ok = 1;
 731                                 get_prefix(&addr, *argv, req.r.rtm_family);
 732                                 if (req.r.rtm_family == AF_UNSPEC) {
 733                                         req.r.rtm_family = addr.family;
 734                                 }
 735                                 if (addr.bytelen) {
 736                                         addattr_l(&req.n, sizeof(req), RTA_SRC, &addr.data, addr.bytelen);
 737                                 }
 738                                 req.r.rtm_src_len = addr.bitlen;
 739                                 break;
 740                         }
 741                         case 1: /* iif */
 742                                 NEXT_ARG();
 743                                 idev = *argv;
 744                                 break;
 745                         case 2: /* oif */
 746                         case 3: /* dev */
 747                                 NEXT_ARG();
 748                                 odev = *argv;
 749                                 break;
 750                         case 4: /* notify */
 751                                 req.r.rtm_flags |= RTM_F_NOTIFY;
 752                                 break;
 753                         case 5: /* connected */
 754                                 connected = 1;
 755                                 break;
 756                         case 6: /* to */
 757                                 NEXT_ARG();
 758                         default:
 759                         {
 760                                 inet_prefix addr;
 761                                 get_prefix(&addr, *argv, req.r.rtm_family);
 762                                 if (req.r.rtm_family == AF_UNSPEC) {
 763                                         req.r.rtm_family = addr.family;
 764                                 }
 765                                 if (addr.bytelen) {
 766                                         addattr_l(&req.n, sizeof(req), RTA_DST, &addr.data, addr.bytelen);
 767                                 }
 768                                 req.r.rtm_dst_len = addr.bitlen;
 769                         }
 770                         argv++;
 771                 }
 772         }
 773
 774         if (req.r.rtm_dst_len == 0) {
 775                 bb_error_msg_and_die("need at least destination address");
 776         }
 777
 778         xrtnl_open(&rth);
 779
 780         ll_init_map(&rth);
 781
 782         if (idev || odev)  {
 783                 int idx;
 784
 785                 if (idev) {
 786                         idx = xll_name_to_index(idev);
 787                         addattr32(&req.n, sizeof(req), RTA_IIF, idx);
 788                 }
 789                 if (odev) {
 790                         idx = xll_name_to_index(odev);
 791                         addattr32(&req.n, sizeof(req), RTA_OIF, idx);
 792                 }
 793         }
 794
 795         if (req.r.rtm_family == AF_UNSPEC) {
 796                 req.r.rtm_family = AF_INET;
 797         }
 798
 799         if (rtnl_talk(&rth, &req.n, 0, 0, &req.n, NULL, NULL) < 0) {
 800                 return 2;
 801         }
 802
 803         if (connected && !from_ok) {
 804                 struct rtmsg *r = NLMSG_DATA(&req.n);
 805                 int len = req.n.nlmsg_len;
 806                 struct rtattr * tb[RTA_MAX+1];
 807
 808                 print_route(NULL, &req.n, NULL);
 809
 810                 if (req.n.nlmsg_type != RTM_NEWROUTE) {
 811                         bb_error_msg_and_die("not a route?");
 812                 }
 813                 len -= NLMSG_LENGTH(sizeof(*r));
 814                 if (len < 0) {
 815                         bb_error_msg_and_die("wrong len %d", len);
 816                 }
 817
 818                 memset(tb, 0, sizeof(tb));
 819                 parse_rtattr(tb, RTA_MAX, RTM_RTA(r), len);
 820
 821                 if (tb[RTA_PREFSRC]) {
 822                         tb[RTA_PREFSRC]->rta_type = RTA_SRC;
 823                         r->rtm_src_len = 8*RTA_PAYLOAD(tb[RTA_PREFSRC]);
 824                 } else if (!tb[RTA_SRC]) {
 825                         bb_error_msg_and_die("failed to connect the route");
 826                 }
 827                 if (!odev && tb[RTA_OIF]) {
 828                         tb[RTA_OIF]->rta_type = 0;
 829                 }
 830                 if (tb[RTA_GATEWAY]) {
 831                         tb[RTA_GATEWAY]->rta_type = 0;
 832                 }
 833                 if (!idev && tb[RTA_IIF]) {
 834                         tb[RTA_IIF]->rta_type = 0;
 835                 }
 836                 req.n.nlmsg_flags = NLM_F_REQUEST;
 837                 req.n.nlmsg_type = RTM_GETROUTE;
 838
 839                 if (rtnl_talk(&rth, &req.n, 0, 0, &req.n, NULL, NULL) < 0) {
 840                         return 2;
 841                 }
 842         }
 843         print_route(NULL, &req.n, NULL);
 844         return 0;
 845 }
 846
 847 /* Return value becomes exitcode. It's okay to not return at all */
 848 int do_iproute(char **argv)
 849 {
 850         static const char ip_route_commands[] ALIGN1 =
 851         /*0-3*/ "add\0""append\0""change\0""chg\0"
 852         /*4-7*/ "delete\0""get\0""list\0""show\0"
 853         /*8..*/ "prepend\0""replace\0""test\0""flush\0";
 854         int command_num;
 855         unsigned flags = 0;
 856         int cmd = RTM_NEWROUTE;
 857
 858         if (!*argv)
 859                 return iproute_list_or_flush(argv, 0);
 860
 861         /* "Standard" 'ip r a' treats 'a' as 'add', not 'append' */
 862         /* It probably means that it is using "first match" rule */
 863         command_num = index_in_substrings(ip_route_commands, *argv);
 864
 865         switch (command_num) {
 866                 case 0: /* add */
 867                         flags = NLM_F_CREATE|NLM_F_EXCL;
 868                         break;
 869                 case 1: /* append */
 870                         flags = NLM_F_CREATE|NLM_F_APPEND;
 871                         break;
 872                 case 2: /* change */
 873                 case 3: /* chg */
 874                         flags = NLM_F_REPLACE;
 875                         break;
 876                 case 4: /* delete */
 877                         cmd = RTM_DELROUTE;
 878                         break;
 879                 case 5: /* get */
 880                         return iproute_get(argv+1);
 881                 case 6: /* list */
 882                 case 7: /* show */
 883                         return iproute_list_or_flush(argv+1, 0);
 884                 case 8: /* prepend */
 885                         flags = NLM_F_CREATE;
 886                         break;
 887                 case 9: /* replace */
 888                         flags = NLM_F_CREATE|NLM_F_REPLACE;
 889                         break;
 890                 case 10: /* test */
 891                         flags = NLM_F_EXCL;
 892                         break;
 893                 case 11: /* flush */
 894                         return iproute_list_or_flush(argv+1, 1);
 895                 default:
 896                         bb_error_msg_and_die("unknown command %s", *argv);
 897         }
 898
 899         return iproute_modify(cmd, flags, argv+1);
 900 }