[mirror_iproute2.git] / bridge / mdb.c

/*
 * Get mdb table with netlink
 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <net/if.h>
#include <netinet/in.h>
#include <linux/if_bridge.h>
#include <linux/if_ether.h>
#include <string.h>
#include <arpa/inet.h>

#include "libnetlink.h"
#include "br_common.h"
#include "rt_names.h"
#include "utils.h"

#ifndef MDBA_RTA
#define MDBA_RTA(r) \
	((struct rtattr*)(((char*)(r)) + NLMSG_ALIGN(sizeof(struct br_port_msg))))
#endif

static unsigned int filter_index;

static void usage(void)
{
	fprintf(stderr, "Usage: bridge mdb { add | del } dev DEV port PORT grp GROUP [permanent | temp] [vid VID]\n");
	fprintf(stderr, "       bridge mdb {show} [ dev DEV ]\n");
	exit(-1);
}

static void br_print_router_ports(FILE *f, struct rtattr *attr)
{
	uint32_t *port_ifindex;
	struct rtattr *i;
	int rem;

	rem = RTA_PAYLOAD(attr);
	for (i = RTA_DATA(attr); RTA_OK(i, rem); i = RTA_NEXT(i, rem)) {
		port_ifindex = RTA_DATA(i);
		fprintf(f, "%s ", ll_index_to_name(*port_ifindex));
	}

	fprintf(f, "\n");
}

static void print_mdb_entry(FILE *f, int ifindex, struct br_mdb_entry *e,
			    struct nlmsghdr *n, struct rtattr **tb)
{
	SPRINT_BUF(abuf);
	const void *src;
	int af;

	af = e->addr.proto == htons(ETH_P_IP) ? AF_INET : AF_INET6;
	src = af == AF_INET ? (const void *)&e->addr.u.ip4 :
			      (const void *)&e->addr.u.ip6;
	if (n->nlmsg_type == RTM_DELMDB)
		fprintf(f, "Deleted ");
	fprintf(f, "dev %s port %s grp %s %s", ll_index_to_name(ifindex),
		ll_index_to_name(e->ifindex),
		inet_ntop(af, src, abuf, sizeof(abuf)),
		(e->state & MDB_PERMANENT) ? "permanent" : "temp");
	if (e->vid)
		fprintf(f, " vid %hu", e->vid);
	if (show_stats && tb && tb[MDBA_MDB_EATTR_TIMER]) {
		struct timeval tv;

		__jiffies_to_tv(&tv, rta_getattr_u32(tb[MDBA_MDB_EATTR_TIMER]));
		fprintf(f, "%4i.%.2i", (int)tv.tv_sec, (int)tv.tv_usec/10000);
	}
	fprintf(f, "\n");
}

static void br_print_mdb_entry(FILE *f, int ifindex, struct rtattr *attr,
			       struct nlmsghdr *n)
{
	struct rtattr *etb[MDBA_MDB_EATTR_MAX + 1];
	struct br_mdb_entry *e;
	struct rtattr *i;
	int rem;

	rem = RTA_PAYLOAD(attr);
	for (i = RTA_DATA(attr); RTA_OK(i, rem); i = RTA_NEXT(i, rem)) {
		e = RTA_DATA(i);
		parse_rtattr(etb, MDBA_MDB_EATTR_MAX, MDB_RTA(RTA_DATA(i)),
			     RTA_PAYLOAD(i) - RTA_ALIGN(sizeof(*e)));
		print_mdb_entry(f, ifindex, e, n, etb);
	}
}

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], *i;

	if (n->nlmsg_type != RTM_GETMDB && n->nlmsg_type != RTM_NEWMDB && n->nlmsg_type != RTM_DELMDB) {
		fprintf(stderr, "Not RTM_GETMDB, RTM_NEWMDB or RTM_DELMDB: %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;

	parse_rtattr(tb, MDBA_MAX, MDBA_RTA(r), n->nlmsg_len - NLMSG_LENGTH(sizeof(*r)));

	if (tb[MDBA_MDB]) {
		int rem = RTA_PAYLOAD(tb[MDBA_MDB]);

		for (i = RTA_DATA(tb[MDBA_MDB]); RTA_OK(i, rem); i = RTA_NEXT(i, rem))
			br_print_mdb_entry(fp, r->ifindex, i, n);
	}

	if (tb[MDBA_ROUTER]) {
		if (n->nlmsg_type == RTM_GETMDB) {
			if (show_details) {
				fprintf(fp, "router ports on %s: ",
					ll_index_to_name(r->ifindex));
				br_print_router_ports(fp, tb[MDBA_ROUTER]);
			}
		} else {
			uint32_t *port_ifindex;

			i = RTA_DATA(tb[MDBA_ROUTER]);
			port_ifindex = RTA_DATA(i);
			if (n->nlmsg_type == RTM_DELMDB)
				fprintf(fp, "Deleted ");
			fprintf(fp, "router port dev %s master %s\n",
				ll_index_to_name(*port_ifindex),
				ll_index_to_name(r->ifindex));
		}
	}

	fflush(fp);

	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");
		return -1;
	}

	if (rtnl_dump_filter(&rth, print_mdb, stdout) < 0) {
		fprintf(stderr, "Dump terminated\n");
		return -1;
	}

	return 0;
}

static int mdb_modify(int cmd, int flags, int argc, char **argv)
{
	struct {
		struct nlmsghdr 	n;
		struct br_port_msg	bpm;
		char   			buf[1024];
	} req;
	struct br_mdb_entry entry;
	char *d = NULL, *p = NULL, *grp = NULL;
	short vid = 0;

	memset(&req, 0, sizeof(req));
	memset(&entry, 0, sizeof(entry));

	req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct br_port_msg));
	req.n.nlmsg_flags = NLM_F_REQUEST|flags;
	req.n.nlmsg_type = cmd;
	req.bpm.family = PF_BRIDGE;

	while (argc > 0) {
		if (strcmp(*argv, "dev") == 0) {
			NEXT_ARG();
			d = *argv;
		} else if (strcmp(*argv, "grp") == 0) {
			NEXT_ARG();
			grp = *argv;
		} else if (strcmp(*argv, "port") == 0) {
			NEXT_ARG();
			p = *argv;
		} else if (strcmp(*argv, "permanent") == 0) {
			if (cmd == RTM_NEWMDB)
				entry.state |= MDB_PERMANENT;
		} else if (strcmp(*argv, "temp") == 0) {
			;/* nothing */
		} else if (strcmp(*argv, "vid") == 0) {
			NEXT_ARG();
			vid = atoi(*argv);
		} else {
			if (matches(*argv, "help") == 0)
				usage();
		}
		argc--; argv++;
	}

	if (d == NULL || grp == NULL || p == NULL) {
		fprintf(stderr, "Device, group address and port name are required arguments.\n");
		return -1;
	}

	req.bpm.ifindex = ll_name_to_index(d);
	if (req.bpm.ifindex == 0) {
		fprintf(stderr, "Cannot find device \"%s\"\n", d);
		return -1;
	}

	entry.ifindex = ll_name_to_index(p);
	if (entry.ifindex == 0) {
		fprintf(stderr, "Cannot find device \"%s\"\n", p);
		return -1;
	}

	if (!inet_pton(AF_INET, grp, &entry.addr.u.ip4)) {
		if (!inet_pton(AF_INET6, grp, &entry.addr.u.ip6)) {
			fprintf(stderr, "Invalid address \"%s\"\n", grp);
			return -1;
		} else
			entry.addr.proto = htons(ETH_P_IPV6);
	} else
		entry.addr.proto = htons(ETH_P_IP);

	entry.vid = vid;
	addattr_l(&req.n, sizeof(req), MDBA_SET_ENTRY, &entry, sizeof(entry));

	if (rtnl_talk(&rth, &req.n, NULL, 0) < 0)
		return -1;

	return 0;
}

int do_mdb(int argc, char **argv)
{
	ll_init_map(&rth);

	if (argc > 0) {
		if (matches(*argv, "add") == 0)
			return mdb_modify(RTM_NEWMDB, NLM_F_CREATE|NLM_F_EXCL, argc-1, argv+1);
		if (matches(*argv, "delete") == 0)
			return mdb_modify(RTM_DELMDB, 0, argc-1, argv+1);

		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);
}
Commit	Line	Data
e06c7f7e CW	1	/*
	2	* Get mdb table with netlink
	3	*/
	4
	5	#include <stdio.h>
	6	#include <stdlib.h>
	7	#include <unistd.h>
	8	#include <fcntl.h>
	9	#include <sys/socket.h>
	10	#include <net/if.h>
	11	#include <netinet/in.h>
	12	#include <linux/if_bridge.h>
	13	#include <linux/if_ether.h>
	14	#include <string.h>
	15	#include <arpa/inet.h>
	16
	17	#include "libnetlink.h"
	18	#include "br_common.h"
	19	#include "rt_names.h"
	20	#include "utils.h"
	21
	22	#ifndef MDBA_RTA
	23	#define MDBA_RTA(r) \
	24	((struct rtattr)(((char)(r)) + NLMSG_ALIGN(sizeof(struct br_port_msg))))
	25	#endif
	26
9dca899b	27	static unsigned int filter_index;
e06c7f7e CW	28
	29	static void usage(void)
	30	{
6aac8617	31	fprintf(stderr, "Usage: bridge mdb { add \| del } dev DEV port PORT grp GROUP [permanent \| temp] [vid VID]\n");
e06c7f7e CW	32	fprintf(stderr, " bridge mdb {show} [ dev DEV ]\n");
	33	exit(-1);
	34	}
	35
	36	static void br_print_router_ports(FILE f, struct rtattr attr)
	37	{
	38	uint32_t *port_ifindex;
	39	struct rtattr *i;
	40	int rem;
	41
	42	rem = RTA_PAYLOAD(attr);
	43	for (i = RTA_DATA(attr); RTA_OK(i, rem); i = RTA_NEXT(i, rem)) {
	44	port_ifindex = RTA_DATA(i);
	45	fprintf(f, "%s ", ll_index_to_name(*port_ifindex));
	46	}
	47
	48	fprintf(f, "\n");
	49	}
	50
90d73159	51	static void print_mdb_entry(FILE f, int ifindex, struct br_mdb_entry e,
05d4f64d	52	struct nlmsghdr n, struct rtattr *tb)
e06c7f7e CW	53	{
e06c7f7e CW	54	SPRINT_BUF(abuf);
6aac8617 NA	55	const void *src;
	56	int af;
	57
	58	af = e->addr.proto == htons(ETH_P_IP) ? AF_INET : AF_INET6;
	59	src = af == AF_INET ? (const void *)&e->addr.u.ip4 :
	60	(const void *)&e->addr.u.ip6;
90d73159 NA	61	if (n->nlmsg_type == RTM_DELMDB)
90d73159 NA	62	fprintf(f, "Deleted ");
6aac8617 NA	63	fprintf(f, "dev %s port %s grp %s %s", ll_index_to_name(ifindex),
	64	ll_index_to_name(e->ifindex),
	65	inet_ntop(af, src, abuf, sizeof(abuf)),
	66	(e->state & MDB_PERMANENT) ? "permanent" : "temp");
	67	if (e->vid)
	68	fprintf(f, " vid %hu", e->vid);
05d4f64d NA	69	if (show_stats && tb && tb[MDBA_MDB_EATTR_TIMER]) {
	70	struct timeval tv;
	71
	72	__jiffies_to_tv(&tv, rta_getattr_u32(tb[MDBA_MDB_EATTR_TIMER]));
	73	fprintf(f, "%4i.%.2i", (int)tv.tv_sec, (int)tv.tv_usec/10000);
	74	}
6aac8617	75	fprintf(f, "\n");
e06c7f7e CW	76	}
e06c7f7e CW	77
90d73159 NA	78	static void br_print_mdb_entry(FILE f, int ifindex, struct rtattr attr,
90d73159 NA	79	struct nlmsghdr *n)
e06c7f7e	80	{
05d4f64d NA	81	struct rtattr *etb[MDBA_MDB_EATTR_MAX + 1];
05d4f64d NA	82	struct br_mdb_entry *e;
e06c7f7e CW	83	struct rtattr *i;
e06c7f7e CW	84	int rem;
e06c7f7e CW	85
	86	rem = RTA_PAYLOAD(attr);
	87	for (i = RTA_DATA(attr); RTA_OK(i, rem); i = RTA_NEXT(i, rem)) {
	88	e = RTA_DATA(i);
05d4f64d NA	89	parse_rtattr(etb, MDBA_MDB_EATTR_MAX, MDB_RTA(RTA_DATA(i)),
	90	RTA_PAYLOAD(i) - RTA_ALIGN(sizeof(*e)));
	91	print_mdb_entry(f, ifindex, e, n, etb);
e06c7f7e CW	92	}
	93	}
	94
	95	int print_mdb(const struct sockaddr_nl who, struct nlmsghdr n, void *arg)
	96	{
	97	FILE *fp = arg;
	98	struct br_port_msg *r = NLMSG_DATA(n);
	99	int len = n->nlmsg_len;
6b4867e6	100	struct rtattr tb[MDBA_MAX+1], i;
e06c7f7e	101
4a4ee616 CW	102	if (n->nlmsg_type != RTM_GETMDB && n->nlmsg_type != RTM_NEWMDB && n->nlmsg_type != RTM_DELMDB) {
4a4ee616 CW	103	fprintf(stderr, "Not RTM_GETMDB, RTM_NEWMDB or RTM_DELMDB: %08x %08x %08x\n",
e06c7f7e CW	104	n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);
	105
	106	return 0;
	107	}
	108
	109	len -= NLMSG_LENGTH(sizeof(*r));
	110	if (len < 0) {
	111	fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
	112	return -1;
	113	}
	114
	115	if (filter_index && filter_index != r->ifindex)
	116	return 0;
	117
	118	parse_rtattr(tb, MDBA_MAX, MDBA_RTA(r), n->nlmsg_len - NLMSG_LENGTH(sizeof(*r)));
	119
	120	if (tb[MDBA_MDB]) {
e06c7f7e CW	121	int rem = RTA_PAYLOAD(tb[MDBA_MDB]);
	122
	123	for (i = RTA_DATA(tb[MDBA_MDB]); RTA_OK(i, rem); i = RTA_NEXT(i, rem))
90d73159	124	br_print_mdb_entry(fp, r->ifindex, i, n);
e06c7f7e CW	125	}
	126
	127	if (tb[MDBA_ROUTER]) {
6b4867e6 NA	128	if (n->nlmsg_type == RTM_GETMDB) {
	129	if (show_details) {
	130	fprintf(fp, "router ports on %s: ",
	131	ll_index_to_name(r->ifindex));
	132	br_print_router_ports(fp, tb[MDBA_ROUTER]);
	133	}
	134	} else {
	135	uint32_t *port_ifindex;
	136
	137	i = RTA_DATA(tb[MDBA_ROUTER]);
	138	port_ifindex = RTA_DATA(i);
	139	if (n->nlmsg_type == RTM_DELMDB)
	140	fprintf(fp, "Deleted ");
	141	fprintf(fp, "router port dev %s master %s\n",
	142	ll_index_to_name(*port_ifindex),
	143	ll_index_to_name(r->ifindex));
e06c7f7e CW	144	}
	145	}
	146
4d45bf3b WK	147	fflush(fp);
4d45bf3b WK	148
e06c7f7e CW	149	return 0;
	150	}
	151
	152	static int mdb_show(int argc, char **argv)
	153	{
	154	char *filter_dev = NULL;
	155
	156	while (argc > 0) {
	157	if (strcmp(*argv, "dev") == 0) {
	158	NEXT_ARG();
	159	if (filter_dev)
	160	duparg("dev", *argv);
	161	filter_dev = *argv;
	162	}
	163	argc--; argv++;
	164	}
	165
	166	if (filter_dev) {
	167	filter_index = if_nametoindex(filter_dev);
	168	if (filter_index == 0) {
	169	fprintf(stderr, "Cannot find device \"%s\"\n",
	170	filter_dev);
	171	return -1;
	172	}
	173	}
	174
	175	if (rtnl_wilddump_request(&rth, PF_BRIDGE, RTM_GETMDB) < 0) {
	176	perror("Cannot send dump request");
42ecedd4	177	return -1;
e06c7f7e CW	178	}
	179
	180	if (rtnl_dump_filter(&rth, print_mdb, stdout) < 0) {
	181	fprintf(stderr, "Dump terminated\n");
42ecedd4	182	return -1;
e06c7f7e CW	183	}
	184
	185	return 0;
	186	}
	187
9dca6767 CW	188	static int mdb_modify(int cmd, int flags, int argc, char **argv)
	189	{
	190	struct {
	191	struct nlmsghdr n;
	192	struct br_port_msg bpm;
	193	char buf[1024];
	194	} req;
	195	struct br_mdb_entry entry;
	196	char d = NULL, p = NULL, *grp = NULL;
6aac8617	197	short vid = 0;
9dca6767 CW	198
	199	memset(&req, 0, sizeof(req));
	200	memset(&entry, 0, sizeof(entry));
	201
	202	req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct br_port_msg));
	203	req.n.nlmsg_flags = NLM_F_REQUEST\|flags;
	204	req.n.nlmsg_type = cmd;
	205	req.bpm.family = PF_BRIDGE;
	206
	207	while (argc > 0) {
	208	if (strcmp(*argv, "dev") == 0) {
	209	NEXT_ARG();
	210	d = *argv;
	211	} else if (strcmp(*argv, "grp") == 0) {
	212	NEXT_ARG();
	213	grp = *argv;
d8b75d1a CW	214	} else if (strcmp(*argv, "port") == 0) {
	215	NEXT_ARG();
	216	p = *argv;
	217	} else if (strcmp(*argv, "permanent") == 0) {
	218	if (cmd == RTM_NEWMDB)
	219	entry.state \|= MDB_PERMANENT;
	220	} else if (strcmp(*argv, "temp") == 0) {
	221	;/* nothing */
6aac8617 NA	222	} else if (strcmp(*argv, "vid") == 0) {
	223	NEXT_ARG();
	224	vid = atoi(*argv);
9dca6767	225	} else {
9dca6767 CW	226	if (matches(*argv, "help") == 0)
	227	usage();
	228	}
	229	argc--; argv++;
	230	}
	231
	232	if (d == NULL \|\| grp == NULL \|\| p == NULL) {
	233	fprintf(stderr, "Device, group address and port name are required arguments.\n");
42ecedd4	234	return -1;
9dca6767 CW	235	}
	236
	237	req.bpm.ifindex = ll_name_to_index(d);
	238	if (req.bpm.ifindex == 0) {
	239	fprintf(stderr, "Cannot find device \"%s\"\n", d);
	240	return -1;
	241	}
	242
	243	entry.ifindex = ll_name_to_index(p);
	244	if (entry.ifindex == 0) {
	245	fprintf(stderr, "Cannot find device \"%s\"\n", p);
	246	return -1;
	247	}
	248
	249	if (!inet_pton(AF_INET, grp, &entry.addr.u.ip4)) {
	250	if (!inet_pton(AF_INET6, grp, &entry.addr.u.ip6)) {
	251	fprintf(stderr, "Invalid address \"%s\"\n", grp);
	252	return -1;
	253	} else
	254	entry.addr.proto = htons(ETH_P_IPV6);
	255	} else
	256	entry.addr.proto = htons(ETH_P_IP);
	257
6aac8617	258	entry.vid = vid;
9dca6767 CW	259	addattr_l(&req.n, sizeof(req), MDBA_SET_ENTRY, &entry, sizeof(entry));
9dca6767 CW	260
c079e121	261	if (rtnl_talk(&rth, &req.n, NULL, 0) < 0)
42ecedd4	262	return -1;
9dca6767 CW	263
	264	return 0;
	265	}
	266
e06c7f7e CW	267	int do_mdb(int argc, char **argv)
	268	{
	269	ll_init_map(&rth);
	270
	271	if (argc > 0) {
9dca6767 CW	272	if (matches(*argv, "add") == 0)
	273	return mdb_modify(RTM_NEWMDB, NLM_F_CREATE\|NLM_F_EXCL, argc-1, argv+1);
	274	if (matches(*argv, "delete") == 0)
	275	return mdb_modify(RTM_DELMDB, 0, argc-1, argv+1);
	276
e06c7f7e CW	277	if (matches(*argv, "show") == 0 \|\|
	278	matches(*argv, "lst") == 0 \|\|
	279	matches(*argv, "list") == 0)
	280	return mdb_show(argc-1, argv+1);
	281	if (matches(*argv, "help") == 0)
	282	usage();
	283	} else
	284	return mdb_show(0, NULL);
	285
	286	fprintf(stderr, "Command \"%s\" is unknown, try \"bridge mdb help\".\n", *argv);
	287	exit(-1);
	288	}