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