bridge/fdb.c

   1 /*
   2  * Get/set/delete fdb table with netlink
   3  *
   4  * TODO: merge/replace this with ip neighbour
   5  *
   6  * Authors:     Stephen Hemminger <shemminger@vyatta.com>
   7  */
   8
   9 #include <stdio.h>
  10 #include <stdlib.h>
  11 #include <unistd.h>
  12 #include <netdb.h>
  13 #include <time.h>
  14 #include <fcntl.h>
  15 #include <sys/socket.h>
  16 #include <sys/time.h>
  17 #include <net/if.h>
  18 #include <netinet/in.h>
  19 #include <linux/if_bridge.h>
  20 #include <linux/if_ether.h>
  21 #include <linux/neighbour.h>
  22 #include <string.h>
  23 #include <limits.h>
  24
  25 #include "libnetlink.h"
  26 #include "br_common.h"
  27 #include "rt_names.h"
  28 #include "utils.h"
  29
  30 static unsigned int filter_index;
  31
  32 static void usage(void)
  33 {
  34         fprintf(stderr, "Usage: bridge fdb { add | append | del | replace } ADDR dev DEV\n"
  35                         "              [ self ] [ master ] [ use ] [ router ]\n"
  36                         "              [ local | static | dynamic ] [ dst IPADDR ] [ vlan VID ]\n"
  37                         "              [ port PORT] [ vni VNI ] [ via DEV ]\n");
  38         fprintf(stderr, "       bridge fdb [ show [ br BRDEV ] [ brport DEV ] ]\n");
  39         exit(-1);
  40 }
  41
  42 static const char *state_n2a(unsigned s)
  43 {
  44         static char buf[32];
  45
  46         if (s & NUD_PERMANENT)
  47                 return "permanent";
  48
  49         if (s & NUD_NOARP)
  50                 return "static";
  51
  52         if (s & NUD_STALE)
  53                 return "stale";
  54
  55         if (s & NUD_REACHABLE)
  56                 return "";
  57
  58         sprintf(buf, "state=%#x", s);
  59         return buf;
  60 }
  61
  62 int print_fdb(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
  63 {
  64         FILE *fp = arg;
  65         struct ndmsg *r = NLMSG_DATA(n);
  66         int len = n->nlmsg_len;
  67         struct rtattr * tb[NDA_MAX+1];
  68
  69         if (n->nlmsg_type != RTM_NEWNEIGH && n->nlmsg_type != RTM_DELNEIGH) {
  70                 fprintf(stderr, "Not RTM_NEWNEIGH: %08x %08x %08x\n",
  71                         n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);
  72
  73                 return 0;
  74         }
  75
  76         len -= NLMSG_LENGTH(sizeof(*r));
  77         if (len < 0) {
  78                 fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
  79                 return -1;
  80         }
  81
  82         if (r->ndm_family != AF_BRIDGE)
  83                 return 0;
  84
  85         if (filter_index && filter_index != r->ndm_ifindex)
  86                 return 0;
  87
  88         parse_rtattr(tb, NDA_MAX, NDA_RTA(r),
  89                      n->nlmsg_len - NLMSG_LENGTH(sizeof(*r)));
  90
  91         if (n->nlmsg_type == RTM_DELNEIGH)
  92                 fprintf(fp, "Deleted ");
  93
  94         if (tb[NDA_LLADDR]) {
  95                 SPRINT_BUF(b1);
  96                 fprintf(fp, "%s ",
  97                         ll_addr_n2a(RTA_DATA(tb[NDA_LLADDR]),
  98                                     RTA_PAYLOAD(tb[NDA_LLADDR]),
  99                                     ll_index_to_type(r->ndm_ifindex),
 100                                     b1, sizeof(b1)));
 101         }
 102
 103         if (!filter_index && r->ndm_ifindex)
 104                 fprintf(fp, "dev %s ", ll_index_to_name(r->ndm_ifindex));
 105
 106         if (tb[NDA_DST]) {
 107                 SPRINT_BUF(abuf);
 108                 int family = AF_INET;
 109
 110                 if (RTA_PAYLOAD(tb[NDA_DST]) == sizeof(struct in6_addr))
 111                         family = AF_INET6;
 112
 113                 fprintf(fp, "dst %s ",
 114                         format_host(family,
 115                                     RTA_PAYLOAD(tb[NDA_DST]),
 116                                     RTA_DATA(tb[NDA_DST]),
 117                                     abuf, sizeof(abuf)));
 118         }
 119
 120         if (tb[NDA_VLAN]) {
 121                 __u16 vid = rta_getattr_u16(tb[NDA_VLAN]);
 122                 fprintf(fp, "vlan %hu ", vid);
 123         }
 124
 125         if (tb[NDA_PORT])
 126                 fprintf(fp, "port %d ", ntohs(rta_getattr_u16(tb[NDA_PORT])));
 127         if (tb[NDA_VNI])
 128                 fprintf(fp, "vni %d ", rta_getattr_u32(tb[NDA_VNI]));
 129         if (tb[NDA_IFINDEX]) {
 130                 unsigned int ifindex = rta_getattr_u32(tb[NDA_IFINDEX]);
 131
 132                 if (ifindex) {
 133                         char ifname[IF_NAMESIZE];
 134
 135                         if (!tb[NDA_LINK_NETNSID] &&
 136                             if_indextoname(ifindex, ifname))
 137                                 fprintf(fp, "via %s ", ifname);
 138                         else
 139                                 fprintf(fp, "via ifindex %u ", ifindex);
 140                 }
 141         }
 142         if (tb[NDA_LINK_NETNSID])
 143                 fprintf(fp, "link-netnsid %d ",
 144                         rta_getattr_u32(tb[NDA_LINK_NETNSID]));
 145
 146         if (show_stats && tb[NDA_CACHEINFO]) {
 147                 struct nda_cacheinfo *ci = RTA_DATA(tb[NDA_CACHEINFO]);
 148                 int hz = get_user_hz();
 149
 150                 fprintf(fp, "used %d/%d ", ci->ndm_used/hz,
 151                        ci->ndm_updated/hz);
 152         }
 153         if (r->ndm_flags & NTF_SELF)
 154                 fprintf(fp, "self ");
 155         if (tb[NDA_MASTER])
 156                 fprintf(fp, "master %s ",
 157                         ll_index_to_name(rta_getattr_u32(tb[NDA_MASTER])));
 158         else if (r->ndm_flags & NTF_MASTER)
 159                 fprintf(fp, "master ");
 160         if (r->ndm_flags & NTF_ROUTER)
 161                 fprintf(fp, "router ");
 162         if (r->ndm_flags & NTF_EXT_LEARNED)
 163                 fprintf(fp, "offload ");
 164
 165         fprintf(fp, "%s\n", state_n2a(r->ndm_state));
 166         fflush(fp);
 167
 168         return 0;
 169 }
 170
 171 static int fdb_show(int argc, char **argv)
 172 {
 173         struct {
 174                 struct nlmsghdr         n;
 175                 struct ifinfomsg        ifm;
 176                 char                    buf[256];
 177         } req;
 178
 179         char *filter_dev = NULL;
 180         char *br = NULL;
 181         int msg_size = sizeof(struct ifinfomsg);
 182
 183         memset(&req, 0, sizeof(req));
 184         req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct ifinfomsg));
 185         req.ifm.ifi_family = PF_BRIDGE;
 186
 187         while (argc > 0) {
 188                 if ((strcmp(*argv, "brport") == 0) || strcmp(*argv, "dev") == 0) {
 189                         NEXT_ARG();
 190                         filter_dev = *argv;
 191                 } else if (strcmp(*argv, "br") == 0) {
 192                         NEXT_ARG();
 193                         br = *argv;
 194                 } else {
 195                         if (matches(*argv, "help") == 0)
 196                                 usage();
 197                 }
 198                 argc--; argv++;
 199         }
 200
 201         if (br) {
 202                 int br_ifindex = ll_name_to_index(br);
 203                 if (br_ifindex == 0) {
 204                         fprintf(stderr, "Cannot find bridge device \"%s\"\n", br);
 205                         return -1;
 206                 }
 207                 addattr32(&req.n, sizeof(req), IFLA_MASTER, br_ifindex);
 208                 msg_size += RTA_LENGTH(4);
 209         }
 210
 211         /*we'll keep around filter_dev for older kernels */
 212         if (filter_dev) {
 213                 filter_index = if_nametoindex(filter_dev);
 214                 if (filter_index == 0) {
 215                         fprintf(stderr, "Cannot find device \"%s\"\n",
 216                                 filter_dev);
 217                         return -1;
 218                 }
 219                 req.ifm.ifi_index = filter_index;
 220         }
 221
 222         if (rtnl_dump_request(&rth, RTM_GETNEIGH, &req.ifm, msg_size) < 0) {
 223                 perror("Cannot send dump request");
 224                 exit(1);
 225         }
 226
 227         if (rtnl_dump_filter(&rth, print_fdb, stdout) < 0) {
 228                 fprintf(stderr, "Dump terminated\n");
 229                 exit(1);
 230         }
 231
 232         return 0;
 233 }
 234
 235 static int fdb_modify(int cmd, int flags, int argc, char **argv)
 236 {
 237         struct {
 238                 struct nlmsghdr         n;
 239                 struct ndmsg            ndm;
 240                 char                    buf[256];
 241         } req;
 242         char *addr = NULL;
 243         char *d = NULL;
 244         char abuf[ETH_ALEN];
 245         int dst_ok = 0;
 246         inet_prefix dst;
 247         unsigned long port = 0;
 248         unsigned long vni = ~0;
 249         unsigned int via = 0;
 250         char *endptr;
 251         short vid = -1;
 252
 253         memset(&req, 0, sizeof(req));
 254
 255         req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct ndmsg));
 256         req.n.nlmsg_flags = NLM_F_REQUEST|flags;
 257         req.n.nlmsg_type = cmd;
 258         req.ndm.ndm_family = PF_BRIDGE;
 259         req.ndm.ndm_state = NUD_NOARP;
 260
 261         while (argc > 0) {
 262                 if (strcmp(*argv, "dev") == 0) {
 263                         NEXT_ARG();
 264                         d = *argv;
 265                 } else if (strcmp(*argv, "dst") == 0) {
 266                         NEXT_ARG();
 267                         if (dst_ok)
 268                                 duparg2("dst", *argv);
 269                         get_addr(&dst, *argv, preferred_family);
 270                         dst_ok = 1;
 271                 } else if (strcmp(*argv, "port") == 0) {
 272
 273                         NEXT_ARG();
 274                         port = strtoul(*argv, &endptr, 0);
 275                         if (endptr && *endptr) {
 276                                 struct servent *pse;
 277
 278                                 pse = getservbyname(*argv, "udp");
 279                                 if (!pse)
 280                                         invarg("invalid port\n", *argv);
 281                                 port = ntohs(pse->s_port);
 282                         } else if (port > 0xffff)
 283                                 invarg("invalid port\n", *argv);
 284                 } else if (strcmp(*argv, "vni") == 0) {
 285                         NEXT_ARG();
 286                         vni = strtoul(*argv, &endptr, 0);
 287                         if ((endptr && *endptr) ||
 288                             (vni >> 24) || vni == ULONG_MAX)
 289                                 invarg("invalid VNI\n", *argv);
 290                 } else if (strcmp(*argv, "via") == 0) {
 291                         NEXT_ARG();
 292                         via = if_nametoindex(*argv);
 293                         if (via == 0)
 294                                 invarg("invalid device\n", *argv);
 295                 } else if (strcmp(*argv, "self") == 0) {
 296                         req.ndm.ndm_flags |= NTF_SELF;
 297                 } else if (matches(*argv, "master") == 0) {
 298                         req.ndm.ndm_flags |= NTF_MASTER;
 299                 } else if (matches(*argv, "router") == 0) {
 300                         req.ndm.ndm_flags |= NTF_ROUTER;
 301                 } else if (matches(*argv, "local") == 0||
 302                            matches(*argv, "permanent") == 0) {
 303                         req.ndm.ndm_state |= NUD_PERMANENT;
 304                 } else if (matches(*argv, "temp") == 0 ||
 305                            matches(*argv, "static") == 0) {
 306                         req.ndm.ndm_state |= NUD_REACHABLE;
 307                 } else if (matches(*argv, "dynamic") == 0) {
 308                         req.ndm.ndm_state |= NUD_REACHABLE;
 309                         req.ndm.ndm_state &= ~NUD_NOARP;
 310                 } else if (matches(*argv, "vlan") == 0) {
 311                         if (vid >= 0)
 312                                 duparg2("vlan", *argv);
 313                         NEXT_ARG();
 314                         vid = atoi(*argv);
 315                 } else if (matches(*argv, "use") == 0) {
 316                         req.ndm.ndm_flags |= NTF_USE;
 317                 } else {
 318                         if (strcmp(*argv, "to") == 0) {
 319                                 NEXT_ARG();
 320                         }
 321                         if (matches(*argv, "help") == 0)
 322                                 usage();
 323                         if (addr)
 324                                 duparg2("to", *argv);
 325                         addr = *argv;
 326                 }
 327                 argc--; argv++;
 328         }
 329
 330         if (d == NULL || addr == NULL) {
 331                 fprintf(stderr, "Device and address are required arguments.\n");
 332                 return -1;
 333         }
 334
 335         /* Assume self */
 336         if (!(req.ndm.ndm_flags&(NTF_SELF|NTF_MASTER)))
 337                 req.ndm.ndm_flags |= NTF_SELF;
 338
 339         /* Assume permanent */
 340         if (!(req.ndm.ndm_state&(NUD_PERMANENT|NUD_REACHABLE)))
 341                 req.ndm.ndm_state |= NUD_PERMANENT;
 342
 343         if (sscanf(addr, "%hhx:%hhx:%hhx:%hhx:%hhx:%hhx",
 344                    abuf, abuf+1, abuf+2,
 345                    abuf+3, abuf+4, abuf+5) != 6) {
 346                 fprintf(stderr, "Invalid mac address %s\n", addr);
 347                 return -1;
 348         }
 349
 350         addattr_l(&req.n, sizeof(req), NDA_LLADDR, abuf, ETH_ALEN);
 351         if (dst_ok)
 352                 addattr_l(&req.n, sizeof(req), NDA_DST, &dst.data, dst.bytelen);
 353
 354         if (vid >= 0)
 355                 addattr16(&req.n, sizeof(req), NDA_VLAN, vid);
 356
 357         if (port) {
 358                 unsigned short dport;
 359
 360                 dport = htons((unsigned short)port);
 361                 addattr16(&req.n, sizeof(req), NDA_PORT, dport);
 362         }
 363         if (vni != ~0)
 364                 addattr32(&req.n, sizeof(req), NDA_VNI, vni);
 365         if (via)
 366                 addattr32(&req.n, sizeof(req), NDA_IFINDEX, via);
 367
 368         req.ndm.ndm_ifindex = ll_name_to_index(d);
 369         if (req.ndm.ndm_ifindex == 0) {
 370                 fprintf(stderr, "Cannot find device \"%s\"\n", d);
 371                 return -1;
 372         }
 373
 374         if (rtnl_talk(&rth, &req.n, NULL, 0) < 0)
 375                 return -1;
 376
 377         return 0;
 378 }
 379
 380 int do_fdb(int argc, char **argv)
 381 {
 382         ll_init_map(&rth);
 383
 384         if (argc > 0) {
 385                 if (matches(*argv, "add") == 0)
 386                         return fdb_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_EXCL, argc-1, argv+1);
 387                 if (matches(*argv, "append") == 0)
 388                         return fdb_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_APPEND, argc-1, argv+1);
 389                 if (matches(*argv, "replace") == 0)
 390                         return fdb_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_REPLACE, argc-1, argv+1);
 391                 if (matches(*argv, "delete") == 0)
 392                         return fdb_modify(RTM_DELNEIGH, 0, argc-1, argv+1);
 393                 if (matches(*argv, "show") == 0 ||
 394                     matches(*argv, "lst") == 0 ||
 395                     matches(*argv, "list") == 0)
 396                         return fdb_show(argc-1, argv+1);
 397                 if (matches(*argv, "help") == 0)
 398                         usage();
 399         } else
 400                 return fdb_show(0, NULL);
 401
 402         fprintf(stderr, "Command \"%s\" is unknown, try \"bridge fdb help\".\n", *argv);
 403         exit(-1);
 404 }