Warning: it is still a draft! :) The output is ugly, I just want to prove it works.
Cc: Herbert Xu <[email protected]> Cc: Stephen Hemminger <[email protected]> Cc: "David S. Miller" <[email protected]> Cc: Thomas Graf <[email protected]> Cc: Jesper Dangaard Brouer <[email protected]> Signed-off-by: Cong Wang <[email protected]> --- bridge/Makefile | 2 +- bridge/br_common.h | 1 + bridge/bridge.c | 1 + bridge/mdb.c | 200 +++++++++++++++++++++++++++++++++++++++++++++ include/linux/rtnetlink.h | 3 + 5 files changed, 206 insertions(+), 1 deletions(-) create mode 100644 bridge/mdb.c diff --git a/bridge/Makefile b/bridge/Makefile index 9a6743e..67aceb4 100644 --- a/bridge/Makefile +++ b/bridge/Makefile @@ -1,4 +1,4 @@ -BROBJ = bridge.o fdb.o monitor.o link.o +BROBJ = bridge.o fdb.o monitor.o link.o mdb.o include ../Config diff --git a/bridge/br_common.h b/bridge/br_common.h index 718ecb9..67fd75c 100644 --- a/bridge/br_common.h +++ b/bridge/br_common.h @@ -5,6 +5,7 @@ extern int print_fdb(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg); extern int do_fdb(int argc, char **argv); +extern int do_mdb(int argc, char **argv); extern int do_monitor(int argc, char **argv); extern int preferred_family; diff --git a/bridge/bridge.c b/bridge/bridge.c index e2c33b0..1fcd365 100644 --- a/bridge/bridge.c +++ b/bridge/bridge.c @@ -43,6 +43,7 @@ static const struct cmd { int (*func)(int argc, char **argv); } cmds[] = { { "fdb", do_fdb }, + { "mdb", do_mdb }, { "monitor", do_monitor }, { "help", do_help }, { 0 } diff --git a/bridge/mdb.c b/bridge/mdb.c new file mode 100644 index 0000000..7873128 --- /dev/null +++ b/bridge/mdb.c @@ -0,0 +1,200 @@ +/* + * Get mdb table with netlink + */ + +#include <stdio.h> +#include <stdlib.h> +#include <unistd.h> +#include <time.h> +#include <fcntl.h> +#include <sys/socket.h> +#include <sys/time.h> +#include <net/if.h> +#include <netinet/in.h> +#include <linux/if_bridge.h> +#include <linux/if_ether.h> +#include <linux/neighbour.h> +#include <string.h> +#include <arpa/inet.h> + +#include "libnetlink.h" +#include "br_common.h" +#include "rt_names.h" +#include "utils.h" + +int filter_index; + +static void usage(void) +{ + fprintf(stderr, " bridge mdb {show} [ dev DEV ]\n"); + exit(-1); +} + +/* Bridge multicast database attributes + * [MDBA_MDB] = { + * [MDBA_MCADDR] + * [MDBA_BRPORT] = { + * [MDBA_BRPORT_NO] + * } + * } + * [MDBA_ROUTER] = { + * [MDBA_BRPORT] = { + * [MDBA_BRPORT_NO] + * } + * } + */ +enum { + MDBA_UNSPEC, + MDBA_MDB, + MDBA_ROUTER, + __MDBA_MAX, +}; +#define MDBA_MAX (__MDBA_MAX - 1) + +enum { + MDBA_MDB_UNSPEC, + MDBA_MDB_MCADDR, + MDBA_MDB_BRPORT, + __MDBA_MDB_MAX, +}; +#define MDBA_MDB_MAX (__MDBA_MDB_MAX - 1) + +enum { + MDBA_BRPORT_UNSPEC, + MDBA_BRPORT_NO, + __MDBA_BRPORT_MAX, +}; +#define MDBA_BRPORT_MAX (__MDBA_BRPORT_MAX - 1) + + +struct br_port_msg { + int ifindex; +}; + +#ifndef MDBA_RTA +#define MDBA_RTA(r) \ + ((struct rtattr*)(((char*)(r)) + NLMSG_ALIGN(sizeof(struct br_port_msg)))) +#endif + +static void br_print_ports(FILE *f, struct rtattr *attr) +{ + uint16_t *port_no; + struct rtattr *i; + int rem; + + fprintf(f, "\n { "); + + rem = RTA_PAYLOAD(attr); + for (i = RTA_DATA(attr); RTA_OK(i, rem); i = RTA_NEXT(i, rem)) { + port_no = RTA_DATA(i); + fprintf(f, "%u ", *port_no); + } + fprintf(f, "} "); +} + +int print_mdb(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg) +{ + FILE *fp = arg; + struct br_port_msg *r = NLMSG_DATA(n); + int len = n->nlmsg_len; + struct rtattr * tb[MDBA_MAX+1]; + struct rtattr * ports[MDBA_MDB_MAX+1]; + SPRINT_BUF(abuf); + + if (n->nlmsg_type != RTM_GETMDB) { + fprintf(stderr, "Not RTM_MDB: %08x %08x %08x\n", + n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags); + + return 0; + } + + len -= NLMSG_LENGTH(sizeof(*r)); + if (len < 0) { + fprintf(stderr, "BUG: wrong nlmsg len %d\n", len); + return -1; + } + + if (filter_index && filter_index != r->ifindex) + return 0; + + if (!filter_index && r->ifindex) + fprintf(fp, "bridge dev %s ", ll_index_to_name(r->ifindex)); + + parse_rtattr(tb, MDBA_MAX, MDBA_RTA(r), n->nlmsg_len - NLMSG_LENGTH(sizeof(*r))); + + if (tb[MDBA_MDB]) { + parse_rtattr_nested(ports, MDBA_MDB_MAX, tb[MDBA_MDB]); + + if (ports[MDBA_MDB_MCADDR]) { + uint32_t addr = rta_getattr_u32(ports[MDBA_MDB_MCADDR]); + fprintf(fp, "multicast addr: %s ", inet_ntop(AF_INET, &addr, abuf, sizeof(abuf))); + } + + if (ports[MDBA_MDB_BRPORT]) + br_print_ports(fp, ports[MDBA_MDB_BRPORT]); + } + + if (tb[MDBA_ROUTER]) { + parse_rtattr_nested(ports, MDBA_MDB_MAX, tb[MDBA_ROUTER]); + + if (ports[MDBA_MDB_BRPORT]) + br_print_ports(fp, ports[MDBA_MDB_BRPORT]); + } + + fprintf(fp, "\n"); + return 0; +} + +static int mdb_show(int argc, char **argv) +{ + char *filter_dev = NULL; + + while (argc > 0) { + if (strcmp(*argv, "dev") == 0) { + NEXT_ARG(); + if (filter_dev) + duparg("dev", *argv); + filter_dev = *argv; + } + argc--; argv++; + } + + if (filter_dev) { + filter_index = if_nametoindex(filter_dev); + if (filter_index == 0) { + fprintf(stderr, "Cannot find device \"%s\"\n", + filter_dev); + return -1; + } + } + + if (rtnl_wilddump_request(&rth, PF_BRIDGE, RTM_GETMDB) < 0) { + perror("Cannot send dump request"); + exit(1); + } + + if (rtnl_dump_filter(&rth, print_mdb, stdout) < 0) { + fprintf(stderr, "Dump terminated\n"); + exit(1); + } + + return 0; +} + +int do_mdb(int argc, char **argv) +{ + ll_init_map(&rth); + + if (argc > 0) { + if (matches(*argv, "show") == 0 || + matches(*argv, "lst") == 0 || + matches(*argv, "list") == 0) + return mdb_show(argc-1, argv+1); + if (matches(*argv, "help") == 0) + usage(); + } else + return mdb_show(0, NULL); + + fprintf(stderr, "Command \"%s\" is unknown, try \"bridge mdb help\".\n", *argv); + exit(-1); +} diff --git a/include/linux/rtnetlink.h b/include/linux/rtnetlink.h index 0e3e0c1..f400b5e 100644 --- a/include/linux/rtnetlink.h +++ b/include/linux/rtnetlink.h @@ -120,6 +120,9 @@ enum { RTM_SETDCB, #define RTM_SETDCB RTM_SETDCB + RTM_GETMDB = 86, +#define RTM_GETMDB RTM_GETMDB + __RTM_MAX, #define RTM_MAX (((__RTM_MAX + 3) & ~3) - 1) }; -- 1.7.7.6
