[mirror_ubuntu-zesty-kernel.git] / net / bridge / br_mdb.c

#include <linux/err.h>
#include <linux/igmp.h>
#include <linux/kernel.h>
#include <linux/netdevice.h>
#include <linux/rculist.h>
#include <linux/skbuff.h>
#include <linux/if_ether.h>
#include <net/ip.h>
#include <net/netlink.h>
#include <net/switchdev.h>
#if IS_ENABLED(CONFIG_IPV6)
#include <net/ipv6.h>
#include <net/addrconf.h>
#endif

#include "br_private.h"

static int br_rports_fill_info(struct sk_buff *skb, struct netlink_callback *cb,
			       struct net_device *dev)
{
	struct net_bridge *br = netdev_priv(dev);
	struct net_bridge_port *p;
	struct nlattr *nest;

	if (!br->multicast_router || hlist_empty(&br->router_list))
		return 0;

	nest = nla_nest_start(skb, MDBA_ROUTER);
	if (nest == NULL)
		return -EMSGSIZE;

	hlist_for_each_entry_rcu(p, &br->router_list, rlist) {
		if (p && nla_put_u32(skb, MDBA_ROUTER_PORT, p->dev->ifindex))
			goto fail;
	}

	nla_nest_end(skb, nest);
	return 0;
fail:
	nla_nest_cancel(skb, nest);
	return -EMSGSIZE;
}

static void __mdb_entry_fill_flags(struct br_mdb_entry *e, unsigned char flags)
{
	e->state = flags & MDB_PG_FLAGS_PERMANENT;
	e->flags = 0;
	if (flags & MDB_PG_FLAGS_OFFLOAD)
		e->flags |= MDB_FLAGS_OFFLOAD;
}

static int br_mdb_fill_info(struct sk_buff *skb, struct netlink_callback *cb,
			    struct net_device *dev)
{
	struct net_bridge *br = netdev_priv(dev);
	struct net_bridge_mdb_htable *mdb;
	struct nlattr *nest, *nest2;
	int i, err = 0;
	int idx = 0, s_idx = cb->args[1];

	if (br->multicast_disabled)
		return 0;

	mdb = rcu_dereference(br->mdb);
	if (!mdb)
		return 0;

	nest = nla_nest_start(skb, MDBA_MDB);
	if (nest == NULL)
		return -EMSGSIZE;

	for (i = 0; i < mdb->max; i++) {
		struct net_bridge_mdb_entry *mp;
		struct net_bridge_port_group *p;
		struct net_bridge_port_group __rcu **pp;
		struct net_bridge_port *port;

		hlist_for_each_entry_rcu(mp, &mdb->mhash[i], hlist[mdb->ver]) {
			if (idx < s_idx)
				goto skip;

			nest2 = nla_nest_start(skb, MDBA_MDB_ENTRY);
			if (nest2 == NULL) {
				err = -EMSGSIZE;
				goto out;
			}

			for (pp = &mp->ports;
			     (p = rcu_dereference(*pp)) != NULL;
			      pp = &p->next) {
				struct br_mdb_entry e;

				port = p->port;
				if (!port)
					continue;
				memset(&e, 0, sizeof(e));
				e.ifindex = port->dev->ifindex;
				e.vid = p->addr.vid;
				__mdb_entry_fill_flags(&e, p->flags);
				if (p->addr.proto == htons(ETH_P_IP))
					e.addr.u.ip4 = p->addr.u.ip4;
#if IS_ENABLED(CONFIG_IPV6)
				if (p->addr.proto == htons(ETH_P_IPV6))
					e.addr.u.ip6 = p->addr.u.ip6;
#endif
				e.addr.proto = p->addr.proto;
				if (nla_put(skb, MDBA_MDB_ENTRY_INFO, sizeof(e), &e)) {
					nla_nest_cancel(skb, nest2);
					err = -EMSGSIZE;
					goto out;
				}
			}
			nla_nest_end(skb, nest2);
		skip:
			idx++;
		}
	}

out:
	cb->args[1] = idx;
	nla_nest_end(skb, nest);
	return err;
}

static int br_mdb_dump(struct sk_buff *skb, struct netlink_callback *cb)
{
	struct net_device *dev;
	struct net *net = sock_net(skb->sk);
	struct nlmsghdr *nlh = NULL;
	int idx = 0, s_idx;

	s_idx = cb->args[0];

	rcu_read_lock();

	/* In theory this could be wrapped to 0... */
	cb->seq = net->dev_base_seq + br_mdb_rehash_seq;

	for_each_netdev_rcu(net, dev) {
		if (dev->priv_flags & IFF_EBRIDGE) {
			struct br_port_msg *bpm;

			if (idx < s_idx)
				goto skip;

			nlh = nlmsg_put(skb, NETLINK_CB(cb->skb).portid,
					cb->nlh->nlmsg_seq, RTM_GETMDB,
					sizeof(*bpm), NLM_F_MULTI);
			if (nlh == NULL)
				break;

			bpm = nlmsg_data(nlh);
			memset(bpm, 0, sizeof(*bpm));
			bpm->ifindex = dev->ifindex;
			if (br_mdb_fill_info(skb, cb, dev) < 0)
				goto out;
			if (br_rports_fill_info(skb, cb, dev) < 0)
				goto out;

			cb->args[1] = 0;
			nlmsg_end(skb, nlh);
		skip:
			idx++;
		}
	}

out:
	if (nlh)
		nlmsg_end(skb, nlh);
	rcu_read_unlock();
	cb->args[0] = idx;
	return skb->len;
}

static int nlmsg_populate_mdb_fill(struct sk_buff *skb,
				   struct net_device *dev,
				   struct br_mdb_entry *entry, u32 pid,
				   u32 seq, int type, unsigned int flags)
{
	struct nlmsghdr *nlh;
	struct br_port_msg *bpm;
	struct nlattr *nest, *nest2;

	nlh = nlmsg_put(skb, pid, seq, type, sizeof(*bpm), 0);
	if (!nlh)
		return -EMSGSIZE;

	bpm = nlmsg_data(nlh);
	memset(bpm, 0, sizeof(*bpm));
	bpm->family  = AF_BRIDGE;
	bpm->ifindex = dev->ifindex;
	nest = nla_nest_start(skb, MDBA_MDB);
	if (nest == NULL)
		goto cancel;
	nest2 = nla_nest_start(skb, MDBA_MDB_ENTRY);
	if (nest2 == NULL)
		goto end;

	if (nla_put(skb, MDBA_MDB_ENTRY_INFO, sizeof(*entry), entry))
		goto end;

	nla_nest_end(skb, nest2);
	nla_nest_end(skb, nest);
	nlmsg_end(skb, nlh);
	return 0;

end:
	nla_nest_end(skb, nest);
cancel:
	nlmsg_cancel(skb, nlh);
	return -EMSGSIZE;
}

static inline size_t rtnl_mdb_nlmsg_size(void)
{
	return NLMSG_ALIGN(sizeof(struct br_port_msg))
		+ nla_total_size(sizeof(struct br_mdb_entry));
}

static void __br_mdb_notify(struct net_device *dev, struct br_mdb_entry *entry,
			    int type, struct net_bridge_port_group *pg)
{
	struct switchdev_obj_port_mdb mdb = {
		.obj = {
			.id = SWITCHDEV_OBJ_ID_PORT_MDB,
			.flags = SWITCHDEV_F_DEFER,
		},
		.vid = entry->vid,
	};
	struct net_device *port_dev;
	struct net *net = dev_net(dev);
	struct sk_buff *skb;
	int err = -ENOBUFS;

	port_dev = __dev_get_by_index(net, entry->ifindex);
	if (entry->addr.proto == htons(ETH_P_IP))
		ip_eth_mc_map(entry->addr.u.ip4, mdb.addr);
#if IS_ENABLED(CONFIG_IPV6)
	else
		ipv6_eth_mc_map(&entry->addr.u.ip6, mdb.addr);
#endif

	mdb.obj.orig_dev = port_dev;
	if (port_dev && type == RTM_NEWMDB) {
		err = switchdev_port_obj_add(port_dev, &mdb.obj);
		if (!err && pg)
			pg->flags |= MDB_PG_FLAGS_OFFLOAD;
	} else if (port_dev && type == RTM_DELMDB) {
		switchdev_port_obj_del(port_dev, &mdb.obj);
	}

	skb = nlmsg_new(rtnl_mdb_nlmsg_size(), GFP_ATOMIC);
	if (!skb)
		goto errout;

	err = nlmsg_populate_mdb_fill(skb, dev, entry, 0, 0, type, NTF_SELF);
	if (err < 0) {
		kfree_skb(skb);
		goto errout;
	}

	rtnl_notify(skb, net, 0, RTNLGRP_MDB, NULL, GFP_ATOMIC);
	return;
errout:
	rtnl_set_sk_err(net, RTNLGRP_MDB, err);
}

void br_mdb_notify(struct net_device *dev, struct net_bridge_port_group *pg,
		   int type)
{
	struct br_mdb_entry entry;

	memset(&entry, 0, sizeof(entry));
	entry.ifindex = pg->port->dev->ifindex;
	entry.addr.proto = pg->addr.proto;
	entry.addr.u.ip4 = pg->addr.u.ip4;
#if IS_ENABLED(CONFIG_IPV6)
	entry.addr.u.ip6 = pg->addr.u.ip6;
#endif
	entry.vid = pg->addr.vid;
	__mdb_entry_fill_flags(&entry, pg->flags);
	__br_mdb_notify(dev, &entry, type, pg);
}

static int nlmsg_populate_rtr_fill(struct sk_buff *skb,
				   struct net_device *dev,
				   int ifindex, u32 pid,
				   u32 seq, int type, unsigned int flags)
{
	struct br_port_msg *bpm;
	struct nlmsghdr *nlh;
	struct nlattr *nest;

	nlh = nlmsg_put(skb, pid, seq, type, sizeof(*bpm), NLM_F_MULTI);
	if (!nlh)
		return -EMSGSIZE;

	bpm = nlmsg_data(nlh);
	memset(bpm, 0, sizeof(*bpm));
	bpm->family = AF_BRIDGE;
	bpm->ifindex = dev->ifindex;
	nest = nla_nest_start(skb, MDBA_ROUTER);
	if (!nest)
		goto cancel;

	if (nla_put_u32(skb, MDBA_ROUTER_PORT, ifindex))
		goto end;

	nla_nest_end(skb, nest);
	nlmsg_end(skb, nlh);
	return 0;

end:
	nla_nest_end(skb, nest);
cancel:
	nlmsg_cancel(skb, nlh);
	return -EMSGSIZE;
}

static inline size_t rtnl_rtr_nlmsg_size(void)
{
	return NLMSG_ALIGN(sizeof(struct br_port_msg))
		+ nla_total_size(sizeof(__u32));
}

void br_rtr_notify(struct net_device *dev, struct net_bridge_port *port,
		   int type)
{
	struct net *net = dev_net(dev);
	struct sk_buff *skb;
	int err = -ENOBUFS;
	int ifindex;

	ifindex = port ? port->dev->ifindex : 0;
	skb = nlmsg_new(rtnl_rtr_nlmsg_size(), GFP_ATOMIC);
	if (!skb)
		goto errout;

	err = nlmsg_populate_rtr_fill(skb, dev, ifindex, 0, 0, type, NTF_SELF);
	if (err < 0) {
		kfree_skb(skb);
		goto errout;
	}

	rtnl_notify(skb, net, 0, RTNLGRP_MDB, NULL, GFP_ATOMIC);
	return;

errout:
	rtnl_set_sk_err(net, RTNLGRP_MDB, err);
}

static bool is_valid_mdb_entry(struct br_mdb_entry *entry)
{
	if (entry->ifindex == 0)
		return false;

	if (entry->addr.proto == htons(ETH_P_IP)) {
		if (!ipv4_is_multicast(entry->addr.u.ip4))
			return false;
		if (ipv4_is_local_multicast(entry->addr.u.ip4))
			return false;
#if IS_ENABLED(CONFIG_IPV6)
	} else if (entry->addr.proto == htons(ETH_P_IPV6)) {
		if (ipv6_addr_is_ll_all_nodes(&entry->addr.u.ip6))
			return false;
#endif
	} else
		return false;
	if (entry->state != MDB_PERMANENT && entry->state != MDB_TEMPORARY)
		return false;
	if (entry->vid >= VLAN_VID_MASK)
		return false;

	return true;
}

static int br_mdb_parse(struct sk_buff *skb, struct nlmsghdr *nlh,
			struct net_device **pdev, struct br_mdb_entry **pentry)
{
	struct net *net = sock_net(skb->sk);
	struct br_mdb_entry *entry;
	struct br_port_msg *bpm;
	struct nlattr *tb[MDBA_SET_ENTRY_MAX+1];
	struct net_device *dev;
	int err;

	err = nlmsg_parse(nlh, sizeof(*bpm), tb, MDBA_SET_ENTRY_MAX, NULL);
	if (err < 0)
		return err;

	bpm = nlmsg_data(nlh);
	if (bpm->ifindex == 0) {
		pr_info("PF_BRIDGE: br_mdb_parse() with invalid ifindex\n");
		return -EINVAL;
	}

	dev = __dev_get_by_index(net, bpm->ifindex);
	if (dev == NULL) {
		pr_info("PF_BRIDGE: br_mdb_parse() with unknown ifindex\n");
		return -ENODEV;
	}

	if (!(dev->priv_flags & IFF_EBRIDGE)) {
		pr_info("PF_BRIDGE: br_mdb_parse() with non-bridge\n");
		return -EOPNOTSUPP;
	}

	*pdev = dev;

	if (!tb[MDBA_SET_ENTRY] ||
	    nla_len(tb[MDBA_SET_ENTRY]) != sizeof(struct br_mdb_entry)) {
		pr_info("PF_BRIDGE: br_mdb_parse() with invalid attr\n");
		return -EINVAL;
	}

	entry = nla_data(tb[MDBA_SET_ENTRY]);
	if (!is_valid_mdb_entry(entry)) {
		pr_info("PF_BRIDGE: br_mdb_parse() with invalid entry\n");
		return -EINVAL;
	}

	*pentry = entry;
	return 0;
}

static int br_mdb_add_group(struct net_bridge *br, struct net_bridge_port *port,
			    struct br_ip *group, unsigned char state,
			    struct net_bridge_port_group **pg)
{
	struct net_bridge_mdb_entry *mp;
	struct net_bridge_port_group *p;
	struct net_bridge_port_group __rcu **pp;
	struct net_bridge_mdb_htable *mdb;
	unsigned long now = jiffies;
	int err;

	mdb = mlock_dereference(br->mdb, br);
	mp = br_mdb_ip_get(mdb, group);
	if (!mp) {
		mp = br_multicast_new_group(br, port, group);
		err = PTR_ERR(mp);
		if (IS_ERR(mp))
			return err;
	}

	for (pp = &mp->ports;
	     (p = mlock_dereference(*pp, br)) != NULL;
	     pp = &p->next) {
		if (p->port == port)
			return -EEXIST;
		if ((unsigned long)p->port < (unsigned long)port)
			break;
	}

	p = br_multicast_new_port_group(port, group, *pp, state);
	if (unlikely(!p))
		return -ENOMEM;
	rcu_assign_pointer(*pp, p);
	*pg = p;
	if (state == MDB_TEMPORARY)
		mod_timer(&p->timer, now + br->multicast_membership_interval);

	return 0;
}

static int __br_mdb_add(struct net *net, struct net_bridge *br,
			struct br_mdb_entry *entry,
			struct net_bridge_port_group **pg)
{
	struct br_ip ip;
	struct net_device *dev;
	struct net_bridge_port *p;
	int ret;

	if (!netif_running(br->dev) || br->multicast_disabled)
		return -EINVAL;

	dev = __dev_get_by_index(net, entry->ifindex);
	if (!dev)
		return -ENODEV;

	p = br_port_get_rtnl(dev);
	if (!p || p->br != br || p->state == BR_STATE_DISABLED)
		return -EINVAL;

	memset(&ip, 0, sizeof(ip));
	ip.vid = entry->vid;
	ip.proto = entry->addr.proto;
	if (ip.proto == htons(ETH_P_IP))
		ip.u.ip4 = entry->addr.u.ip4;
#if IS_ENABLED(CONFIG_IPV6)
	else
		ip.u.ip6 = entry->addr.u.ip6;
#endif

	spin_lock_bh(&br->multicast_lock);
	ret = br_mdb_add_group(br, p, &ip, entry->state, pg);
	spin_unlock_bh(&br->multicast_lock);
	return ret;
}

static int br_mdb_add(struct sk_buff *skb, struct nlmsghdr *nlh)
{
	struct net *net = sock_net(skb->sk);
	struct net_bridge_port_group *pg;
	struct net_bridge_vlan_group *vg;
	struct net_device *dev, *pdev;
	struct br_mdb_entry *entry;
	struct net_bridge_port *p;
	struct net_bridge_vlan *v;
	struct net_bridge *br;
	int err;

	err = br_mdb_parse(skb, nlh, &dev, &entry);
	if (err < 0)
		return err;

	br = netdev_priv(dev);

	/* If vlan filtering is enabled and VLAN is not specified
	 * install mdb entry on all vlans configured on the port.
	 */
	pdev = __dev_get_by_index(net, entry->ifindex);
	if (!pdev)
		return -ENODEV;

	p = br_port_get_rtnl(pdev);
	if (!p || p->br != br || p->state == BR_STATE_DISABLED)
		return -EINVAL;

	vg = nbp_vlan_group(p);
	if (br_vlan_enabled(br) && vg && entry->vid == 0) {
		list_for_each_entry(v, &vg->vlan_list, vlist) {
			entry->vid = v->vid;
			err = __br_mdb_add(net, br, entry, &pg);
			if (err)
				break;
			__br_mdb_notify(dev, entry, RTM_NEWMDB, pg);
		}
	} else {
		err = __br_mdb_add(net, br, entry, &pg);
		if (!err)
			__br_mdb_notify(dev, entry, RTM_NEWMDB, pg);
	}

	return err;
}

static int __br_mdb_del(struct net_bridge *br, struct br_mdb_entry *entry)
{
	struct net_bridge_mdb_htable *mdb;
	struct net_bridge_mdb_entry *mp;
	struct net_bridge_port_group *p;
	struct net_bridge_port_group __rcu **pp;
	struct br_ip ip;
	int err = -EINVAL;

	if (!netif_running(br->dev) || br->multicast_disabled)
		return -EINVAL;

	memset(&ip, 0, sizeof(ip));
	ip.vid = entry->vid;
	ip.proto = entry->addr.proto;
	if (ip.proto == htons(ETH_P_IP))
		ip.u.ip4 = entry->addr.u.ip4;
#if IS_ENABLED(CONFIG_IPV6)
	else
		ip.u.ip6 = entry->addr.u.ip6;
#endif

	spin_lock_bh(&br->multicast_lock);
	mdb = mlock_dereference(br->mdb, br);

	mp = br_mdb_ip_get(mdb, &ip);
	if (!mp)
		goto unlock;

	for (pp = &mp->ports;
	     (p = mlock_dereference(*pp, br)) != NULL;
	     pp = &p->next) {
		if (!p->port || p->port->dev->ifindex != entry->ifindex)
			continue;

		if (p->port->state == BR_STATE_DISABLED)
			goto unlock;

		__mdb_entry_fill_flags(entry, p->flags);
		rcu_assign_pointer(*pp, p->next);
		hlist_del_init(&p->mglist);
		del_timer(&p->timer);
		call_rcu_bh(&p->rcu, br_multicast_free_pg);
		err = 0;

		if (!mp->ports && !mp->mglist &&
		    netif_running(br->dev))
			mod_timer(&mp->timer, jiffies);
		break;
	}

unlock:
	spin_unlock_bh(&br->multicast_lock);
	return err;
}

static int br_mdb_del(struct sk_buff *skb, struct nlmsghdr *nlh)
{
	struct net *net = sock_net(skb->sk);
	struct net_bridge_vlan_group *vg;
	struct net_device *dev, *pdev;
	struct br_mdb_entry *entry;
	struct net_bridge_port *p;
	struct net_bridge_vlan *v;
	struct net_bridge *br;
	int err;

	err = br_mdb_parse(skb, nlh, &dev, &entry);
	if (err < 0)
		return err;

	br = netdev_priv(dev);

	/* If vlan filtering is enabled and VLAN is not specified
	 * delete mdb entry on all vlans configured on the port.
	 */
	pdev = __dev_get_by_index(net, entry->ifindex);
	if (!pdev)
		return -ENODEV;

	p = br_port_get_rtnl(pdev);
	if (!p || p->br != br || p->state == BR_STATE_DISABLED)
		return -EINVAL;

	vg = nbp_vlan_group(p);
	if (br_vlan_enabled(br) && vg && entry->vid == 0) {
		list_for_each_entry(v, &vg->vlan_list, vlist) {
			entry->vid = v->vid;
			err = __br_mdb_del(br, entry);
			if (!err)
				__br_mdb_notify(dev, entry, RTM_DELMDB, NULL);
		}
	} else {
		err = __br_mdb_del(br, entry);
		if (!err)
			__br_mdb_notify(dev, entry, RTM_DELMDB, NULL);
	}

	return err;
}

void br_mdb_init(void)
{
	rtnl_register(PF_BRIDGE, RTM_GETMDB, NULL, br_mdb_dump, NULL);
	rtnl_register(PF_BRIDGE, RTM_NEWMDB, br_mdb_add, NULL, NULL);
	rtnl_register(PF_BRIDGE, RTM_DELMDB, br_mdb_del, NULL, NULL);
}

void br_mdb_uninit(void)
{
	rtnl_unregister(PF_BRIDGE, RTM_GETMDB);
	rtnl_unregister(PF_BRIDGE, RTM_NEWMDB);
	rtnl_unregister(PF_BRIDGE, RTM_DELMDB);
}
Commit	Line	Data
ee07c6e7 CW	1	#include <linux/err.h>
	2	#include <linux/igmp.h>
	3	#include <linux/kernel.h>
	4	#include <linux/netdevice.h>
	5	#include <linux/rculist.h>
	6	#include <linux/skbuff.h>
cfd56754	7	#include <linux/if_ether.h>
ee07c6e7 CW	8	#include <net/ip.h>
ee07c6e7 CW	9	#include <net/netlink.h>
f1fecb1d	10	#include <net/switchdev.h>
ee07c6e7 CW	11	#if IS_ENABLED(CONFIG_IPV6)
ee07c6e7 CW	12	#include <net/ipv6.h>
3c3769e6	13	#include <net/addrconf.h>
ee07c6e7 CW	14	#endif
	15
	16	#include "br_private.h"
	17
	18	static int br_rports_fill_info(struct sk_buff skb, struct netlink_callback cb,
	19	struct net_device *dev)
	20	{
	21	struct net_bridge *br = netdev_priv(dev);
	22	struct net_bridge_port *p;
ee07c6e7 CW	23	struct nlattr *nest;
	24
	25	if (!br->multicast_router \|\| hlist_empty(&br->router_list))
	26	return 0;
	27
	28	nest = nla_nest_start(skb, MDBA_ROUTER);
	29	if (nest == NULL)
	30	return -EMSGSIZE;
	31
b67bfe0d	32	hlist_for_each_entry_rcu(p, &br->router_list, rlist) {
ee07c6e7 CW	33	if (p && nla_put_u32(skb, MDBA_ROUTER_PORT, p->dev->ifindex))
	34	goto fail;
	35	}
	36
	37	nla_nest_end(skb, nest);
	38	return 0;
	39	fail:
	40	nla_nest_cancel(skb, nest);
	41	return -EMSGSIZE;
	42	}
	43
9d06b6d8 ER	44	static void __mdb_entry_fill_flags(struct br_mdb_entry *e, unsigned char flags)
	45	{
	46	e->state = flags & MDB_PG_FLAGS_PERMANENT;
	47	e->flags = 0;
	48	if (flags & MDB_PG_FLAGS_OFFLOAD)
	49	e->flags \|= MDB_FLAGS_OFFLOAD;
	50	}
	51
ee07c6e7 CW	52	static int br_mdb_fill_info(struct sk_buff skb, struct netlink_callback cb,
	53	struct net_device *dev)
	54	{
	55	struct net_bridge *br = netdev_priv(dev);
	56	struct net_bridge_mdb_htable *mdb;
	57	struct nlattr nest, nest2;
	58	int i, err = 0;
	59	int idx = 0, s_idx = cb->args[1];
	60
	61	if (br->multicast_disabled)
	62	return 0;
	63
	64	mdb = rcu_dereference(br->mdb);
	65	if (!mdb)
	66	return 0;
	67
	68	nest = nla_nest_start(skb, MDBA_MDB);
	69	if (nest == NULL)
	70	return -EMSGSIZE;
	71
	72	for (i = 0; i < mdb->max; i++) {
ee07c6e7	73	struct net_bridge_mdb_entry *mp;
762a3d89	74	struct net_bridge_port_group *p;
762a3d89	75	struct net_bridge_port_group __rcu **pp;
ee07c6e7 CW	76	struct net_bridge_port *port;
ee07c6e7 CW	77
b67bfe0d	78	hlist_for_each_entry_rcu(mp, &mdb->mhash[i], hlist[mdb->ver]) {
ee07c6e7 CW	79	if (idx < s_idx)
	80	goto skip;
	81
	82	nest2 = nla_nest_start(skb, MDBA_MDB_ENTRY);
	83	if (nest2 == NULL) {
	84	err = -EMSGSIZE;
	85	goto out;
	86	}
	87
	88	for (pp = &mp->ports;
	89	(p = rcu_dereference(*pp)) != NULL;
	90	pp = &p->next) {
76cc173d NA	91	struct br_mdb_entry e;
76cc173d NA	92
ee07c6e7	93	port = p->port;
76cc173d NA	94	if (!port)
	95	continue;
	96	memset(&e, 0, sizeof(e));
	97	e.ifindex = port->dev->ifindex;
	98	e.vid = p->addr.vid;
	99	__mdb_entry_fill_flags(&e, p->flags);
	100	if (p->addr.proto == htons(ETH_P_IP))
	101	e.addr.u.ip4 = p->addr.u.ip4;
ee07c6e7	102	#if IS_ENABLED(CONFIG_IPV6)
76cc173d NA	103	if (p->addr.proto == htons(ETH_P_IPV6))
76cc173d NA	104	e.addr.u.ip6 = p->addr.u.ip6;
ee07c6e7	105	#endif
76cc173d NA	106	e.addr.proto = p->addr.proto;
	107	if (nla_put(skb, MDBA_MDB_ENTRY_INFO, sizeof(e), &e)) {
	108	nla_nest_cancel(skb, nest2);
	109	err = -EMSGSIZE;
	110	goto out;
ee07c6e7 CW	111	}
	112	}
	113	nla_nest_end(skb, nest2);
	114	skip:
	115	idx++;
	116	}
	117	}
	118
	119	out:
	120	cb->args[1] = idx;
	121	nla_nest_end(skb, nest);
	122	return err;
	123	}
	124
	125	static int br_mdb_dump(struct sk_buff skb, struct netlink_callback cb)
	126	{
	127	struct net_device *dev;
	128	struct net *net = sock_net(skb->sk);
	129	struct nlmsghdr *nlh = NULL;
	130	int idx = 0, s_idx;
	131
	132	s_idx = cb->args[0];
	133
	134	rcu_read_lock();
	135
2ce297fc CW	136	/* In theory this could be wrapped to 0... */
2ce297fc CW	137	cb->seq = net->dev_base_seq + br_mdb_rehash_seq;
ee07c6e7 CW	138
	139	for_each_netdev_rcu(net, dev) {
	140	if (dev->priv_flags & IFF_EBRIDGE) {
	141	struct br_port_msg *bpm;
	142
	143	if (idx < s_idx)
	144	goto skip;
	145
	146	nlh = nlmsg_put(skb, NETLINK_CB(cb->skb).portid,
	147	cb->nlh->nlmsg_seq, RTM_GETMDB,
	148	sizeof(*bpm), NLM_F_MULTI);
	149	if (nlh == NULL)
	150	break;
	151
	152	bpm = nlmsg_data(nlh);
c085c499	153	memset(bpm, 0, sizeof(*bpm));
ee07c6e7 CW	154	bpm->ifindex = dev->ifindex;
	155	if (br_mdb_fill_info(skb, cb, dev) < 0)
	156	goto out;
	157	if (br_rports_fill_info(skb, cb, dev) < 0)
	158	goto out;
	159
	160	cb->args[1] = 0;
	161	nlmsg_end(skb, nlh);
	162	skip:
	163	idx++;
	164	}
	165	}
	166
	167	out:
	168	if (nlh)
	169	nlmsg_end(skb, nlh);
	170	rcu_read_unlock();
	171	cb->args[0] = idx;
	172	return skb->len;
	173	}
	174
37a393bc CW	175	static int nlmsg_populate_mdb_fill(struct sk_buff *skb,
	176	struct net_device *dev,
	177	struct br_mdb_entry *entry, u32 pid,
	178	u32 seq, int type, unsigned int flags)
	179	{
	180	struct nlmsghdr *nlh;
	181	struct br_port_msg *bpm;
	182	struct nlattr nest, nest2;
	183
82199679	184	nlh = nlmsg_put(skb, pid, seq, type, sizeof(*bpm), 0);
37a393bc CW	185	if (!nlh)
	186	return -EMSGSIZE;
	187
	188	bpm = nlmsg_data(nlh);
c085c499	189	memset(bpm, 0, sizeof(*bpm));
37a393bc CW	190	bpm->family = AF_BRIDGE;
	191	bpm->ifindex = dev->ifindex;
	192	nest = nla_nest_start(skb, MDBA_MDB);
	193	if (nest == NULL)
	194	goto cancel;
	195	nest2 = nla_nest_start(skb, MDBA_MDB_ENTRY);
	196	if (nest2 == NULL)
	197	goto end;
	198
	199	if (nla_put(skb, MDBA_MDB_ENTRY_INFO, sizeof(*entry), entry))
	200	goto end;
	201
	202	nla_nest_end(skb, nest2);
	203	nla_nest_end(skb, nest);
053c095a JB	204	nlmsg_end(skb, nlh);
053c095a JB	205	return 0;
37a393bc CW	206
	207	end:
	208	nla_nest_end(skb, nest);
	209	cancel:
	210	nlmsg_cancel(skb, nlh);
	211	return -EMSGSIZE;
	212	}
	213
	214	static inline size_t rtnl_mdb_nlmsg_size(void)
	215	{
	216	return NLMSG_ALIGN(sizeof(struct br_port_msg))
	217	+ nla_total_size(sizeof(struct br_mdb_entry));
	218	}
	219
	220	static void __br_mdb_notify(struct net_device dev, struct br_mdb_entry entry,
9e8430f8	221	int type, struct net_bridge_port_group *pg)
37a393bc	222	{
f1fecb1d ER	223	struct switchdev_obj_port_mdb mdb = {
	224	.obj = {
	225	.id = SWITCHDEV_OBJ_ID_PORT_MDB,
	226	.flags = SWITCHDEV_F_DEFER,
	227	},
	228	.vid = entry->vid,
	229	};
	230	struct net_device *port_dev;
37a393bc CW	231	struct net *net = dev_net(dev);
	232	struct sk_buff *skb;
	233	int err = -ENOBUFS;
	234
f1fecb1d ER	235	port_dev = __dev_get_by_index(net, entry->ifindex);
	236	if (entry->addr.proto == htons(ETH_P_IP))
	237	ip_eth_mc_map(entry->addr.u.ip4, mdb.addr);
	238	#if IS_ENABLED(CONFIG_IPV6)
	239	else
	240	ipv6_eth_mc_map(&entry->addr.u.ip6, mdb.addr);
	241	#endif
	242
	243	mdb.obj.orig_dev = port_dev;
9e8430f8 ER	244	if (port_dev && type == RTM_NEWMDB) {
	245	err = switchdev_port_obj_add(port_dev, &mdb.obj);
	246	if (!err && pg)
	247	pg->flags \|= MDB_PG_FLAGS_OFFLOAD;
	248	} else if (port_dev && type == RTM_DELMDB) {
f1fecb1d	249	switchdev_port_obj_del(port_dev, &mdb.obj);
9e8430f8	250	}
f1fecb1d	251
37a393bc CW	252	skb = nlmsg_new(rtnl_mdb_nlmsg_size(), GFP_ATOMIC);
	253	if (!skb)
	254	goto errout;
	255
	256	err = nlmsg_populate_mdb_fill(skb, dev, entry, 0, 0, type, NTF_SELF);
	257	if (err < 0) {
	258	kfree_skb(skb);
	259	goto errout;
	260	}
	261
	262	rtnl_notify(skb, net, 0, RTNLGRP_MDB, NULL, GFP_ATOMIC);
	263	return;
	264	errout:
	265	rtnl_set_sk_err(net, RTNLGRP_MDB, err);
	266	}
	267
9e8430f8 ER	268	void br_mdb_notify(struct net_device dev, struct net_bridge_port_group pg,
9e8430f8 ER	269	int type)
37a393bc CW	270	{
	271	struct br_mdb_entry entry;
	272
c085c499	273	memset(&entry, 0, sizeof(entry));
9e8430f8 ER	274	entry.ifindex = pg->port->dev->ifindex;
	275	entry.addr.proto = pg->addr.proto;
	276	entry.addr.u.ip4 = pg->addr.u.ip4;
37a393bc	277	#if IS_ENABLED(CONFIG_IPV6)
9e8430f8	278	entry.addr.u.ip6 = pg->addr.u.ip6;
37a393bc	279	#endif
9e8430f8 ER	280	entry.vid = pg->addr.vid;
	281	__mdb_entry_fill_flags(&entry, pg->flags);
	282	__br_mdb_notify(dev, &entry, type, pg);
37a393bc CW	283	}
37a393bc CW	284
949f1e39 SA	285	static int nlmsg_populate_rtr_fill(struct sk_buff *skb,
	286	struct net_device *dev,
	287	int ifindex, u32 pid,
	288	u32 seq, int type, unsigned int flags)
	289	{
	290	struct br_port_msg *bpm;
	291	struct nlmsghdr *nlh;
	292	struct nlattr *nest;
	293
	294	nlh = nlmsg_put(skb, pid, seq, type, sizeof(*bpm), NLM_F_MULTI);
	295	if (!nlh)
	296	return -EMSGSIZE;
	297
	298	bpm = nlmsg_data(nlh);
	299	memset(bpm, 0, sizeof(*bpm));
	300	bpm->family = AF_BRIDGE;
	301	bpm->ifindex = dev->ifindex;
	302	nest = nla_nest_start(skb, MDBA_ROUTER);
	303	if (!nest)
	304	goto cancel;
	305
	306	if (nla_put_u32(skb, MDBA_ROUTER_PORT, ifindex))
	307	goto end;
	308
	309	nla_nest_end(skb, nest);
	310	nlmsg_end(skb, nlh);
	311	return 0;
	312
	313	end:
	314	nla_nest_end(skb, nest);
	315	cancel:
	316	nlmsg_cancel(skb, nlh);
	317	return -EMSGSIZE;
	318	}
	319
	320	static inline size_t rtnl_rtr_nlmsg_size(void)
	321	{
	322	return NLMSG_ALIGN(sizeof(struct br_port_msg))
	323	+ nla_total_size(sizeof(__u32));
	324	}
	325
	326	void br_rtr_notify(struct net_device dev, struct net_bridge_port port,
	327	int type)
	328	{
	329	struct net *net = dev_net(dev);
	330	struct sk_buff *skb;
	331	int err = -ENOBUFS;
	332	int ifindex;
	333
	334	ifindex = port ? port->dev->ifindex : 0;
	335	skb = nlmsg_new(rtnl_rtr_nlmsg_size(), GFP_ATOMIC);
	336	if (!skb)
	337	goto errout;
	338
	339	err = nlmsg_populate_rtr_fill(skb, dev, ifindex, 0, 0, type, NTF_SELF);
	340	if (err < 0) {
	341	kfree_skb(skb);
	342	goto errout;
	343	}
	344
	345	rtnl_notify(skb, net, 0, RTNLGRP_MDB, NULL, GFP_ATOMIC);
	346	return;
	347
	348	errout:
349	rtnl_set_sk_err(net, RTNLGRP_MDB, err);
350	}
351
cfd56754 CW	352	static bool is_valid_mdb_entry(struct br_mdb_entry *entry)
	353	{
	354	if (entry->ifindex == 0)
	355	return false;
	356
	357	if (entry->addr.proto == htons(ETH_P_IP)) {
	358	if (!ipv4_is_multicast(entry->addr.u.ip4))
	359	return false;
	360	if (ipv4_is_local_multicast(entry->addr.u.ip4))
	361	return false;
	362	#if IS_ENABLED(CONFIG_IPV6)
	363	} else if (entry->addr.proto == htons(ETH_P_IPV6)) {
3c3769e6	364	if (ipv6_addr_is_ll_all_nodes(&entry->addr.u.ip6))
cfd56754 CW	365	return false;
	366	#endif
	367	} else
	368	return false;
ccb1c31a AW	369	if (entry->state != MDB_PERMANENT && entry->state != MDB_TEMPORARY)
ccb1c31a AW	370	return false;
74fe61f1 NA	371	if (entry->vid >= VLAN_VID_MASK)
74fe61f1 NA	372	return false;
cfd56754 CW	373
	374	return true;
	375	}
	376
	377	static int br_mdb_parse(struct sk_buff skb, struct nlmsghdr nlh,
	378	struct net_device pdev, struct br_mdb_entry pentry)
	379	{
	380	struct net *net = sock_net(skb->sk);
	381	struct br_mdb_entry *entry;
	382	struct br_port_msg *bpm;
	383	struct nlattr *tb[MDBA_SET_ENTRY_MAX+1];
	384	struct net_device *dev;
	385	int err;
	386
12d87251	387	err = nlmsg_parse(nlh, sizeof(*bpm), tb, MDBA_SET_ENTRY_MAX, NULL);
cfd56754 CW	388	if (err < 0)
	389	return err;
	390
	391	bpm = nlmsg_data(nlh);
	392	if (bpm->ifindex == 0) {
	393	pr_info("PF_BRIDGE: br_mdb_parse() with invalid ifindex\n");
	394	return -EINVAL;
	395	}
	396
	397	dev = __dev_get_by_index(net, bpm->ifindex);
	398	if (dev == NULL) {
	399	pr_info("PF_BRIDGE: br_mdb_parse() with unknown ifindex\n");
	400	return -ENODEV;
	401	}
	402
	403	if (!(dev->priv_flags & IFF_EBRIDGE)) {
	404	pr_info("PF_BRIDGE: br_mdb_parse() with non-bridge\n");
	405	return -EOPNOTSUPP;
	406	}
	407
	408	*pdev = dev;
	409
	410	if (!tb[MDBA_SET_ENTRY] \|\|
	411	nla_len(tb[MDBA_SET_ENTRY]) != sizeof(struct br_mdb_entry)) {
	412	pr_info("PF_BRIDGE: br_mdb_parse() with invalid attr\n");
	413	return -EINVAL;
	414	}
	415
	416	entry = nla_data(tb[MDBA_SET_ENTRY]);
	417	if (!is_valid_mdb_entry(entry)) {
	418	pr_info("PF_BRIDGE: br_mdb_parse() with invalid entry\n");
	419	return -EINVAL;
	420	}
	421
	422	*pentry = entry;
	423	return 0;
	424	}
	425
	426	static int br_mdb_add_group(struct net_bridge br, struct net_bridge_port port,
9e8430f8 ER	427	struct br_ip *group, unsigned char state,
9e8430f8 ER	428	struct net_bridge_port_group **pg)
cfd56754 CW	429	{
	430	struct net_bridge_mdb_entry *mp;
	431	struct net_bridge_port_group *p;
	432	struct net_bridge_port_group __rcu **pp;
	433	struct net_bridge_mdb_htable *mdb;
f7e2965d	434	unsigned long now = jiffies;
cfd56754 CW	435	int err;
	436
	437	mdb = mlock_dereference(br->mdb, br);
	438	mp = br_mdb_ip_get(mdb, group);
	439	if (!mp) {
	440	mp = br_multicast_new_group(br, port, group);
	441	err = PTR_ERR(mp);
	442	if (IS_ERR(mp))
	443	return err;
	444	}
	445
	446	for (pp = &mp->ports;
	447	(p = mlock_dereference(*pp, br)) != NULL;
	448	pp = &p->next) {
	449	if (p->port == port)
	450	return -EEXIST;
	451	if ((unsigned long)p->port < (unsigned long)port)
	452	break;
	453	}
	454
ccb1c31a	455	p = br_multicast_new_port_group(port, group, *pp, state);
cfd56754 CW	456	if (unlikely(!p))
	457	return -ENOMEM;
	458	rcu_assign_pointer(*pp, p);
9e8430f8	459	*pg = p;
f7e2965d SA	460	if (state == MDB_TEMPORARY)
f7e2965d SA	461	mod_timer(&p->timer, now + br->multicast_membership_interval);
cfd56754	462
cfd56754 CW	463	return 0;
	464	}
	465
	466	static int __br_mdb_add(struct net net, struct net_bridge br,
9e8430f8 ER	467	struct br_mdb_entry *entry,
9e8430f8 ER	468	struct net_bridge_port_group **pg)
cfd56754 CW	469	{
	470	struct br_ip ip;
	471	struct net_device *dev;
	472	struct net_bridge_port *p;
	473	int ret;
	474
	475	if (!netif_running(br->dev) \|\| br->multicast_disabled)
	476	return -EINVAL;
	477
	478	dev = __dev_get_by_index(net, entry->ifindex);
	479	if (!dev)
	480	return -ENODEV;
	481
	482	p = br_port_get_rtnl(dev);
	483	if (!p \|\| p->br != br \|\| p->state == BR_STATE_DISABLED)
	484	return -EINVAL;
	485
f1158b74	486	memset(&ip, 0, sizeof(ip));
74fe61f1	487	ip.vid = entry->vid;
cfd56754 CW	488	ip.proto = entry->addr.proto;
	489	if (ip.proto == htons(ETH_P_IP))
	490	ip.u.ip4 = entry->addr.u.ip4;
	491	#if IS_ENABLED(CONFIG_IPV6)
	492	else
	493	ip.u.ip6 = entry->addr.u.ip6;
	494	#endif
	495
	496	spin_lock_bh(&br->multicast_lock);
9e8430f8	497	ret = br_mdb_add_group(br, p, &ip, entry->state, pg);
cfd56754 CW	498	spin_unlock_bh(&br->multicast_lock);
	499	return ret;
	500	}
	501
661d2967	502	static int br_mdb_add(struct sk_buff skb, struct nlmsghdr nlh)
cfd56754 CW	503	{
cfd56754 CW	504	struct net *net = sock_net(skb->sk);
9e8430f8	505	struct net_bridge_port_group *pg;
2594e906	506	struct net_bridge_vlan_group *vg;
e44deb2f	507	struct net_device dev, pdev;
cfd56754	508	struct br_mdb_entry *entry;
e44deb2f	509	struct net_bridge_port *p;
2594e906	510	struct net_bridge_vlan *v;
cfd56754 CW	511	struct net_bridge *br;
	512	int err;
	513
	514	err = br_mdb_parse(skb, nlh, &dev, &entry);
	515	if (err < 0)
	516	return err;
	517
	518	br = netdev_priv(dev);
	519
e44deb2f SA	520	/* If vlan filtering is enabled and VLAN is not specified
	521	* install mdb entry on all vlans configured on the port.
	522	*/
	523	pdev = __dev_get_by_index(net, entry->ifindex);
	524	if (!pdev)
	525	return -ENODEV;
	526
	527	p = br_port_get_rtnl(pdev);
	528	if (!p \|\| p->br != br \|\| p->state == BR_STATE_DISABLED)
	529	return -EINVAL;
	530
2594e906 NA	531	vg = nbp_vlan_group(p);
	532	if (br_vlan_enabled(br) && vg && entry->vid == 0) {
	533	list_for_each_entry(v, &vg->vlan_list, vlist) {
	534	entry->vid = v->vid;
9e8430f8	535	err = __br_mdb_add(net, br, entry, &pg);
e44deb2f SA	536	if (err)
e44deb2f SA	537	break;
9e8430f8	538	__br_mdb_notify(dev, entry, RTM_NEWMDB, pg);
e44deb2f SA	539	}
e44deb2f SA	540	} else {
9e8430f8	541	err = __br_mdb_add(net, br, entry, &pg);
e44deb2f	542	if (!err)
9e8430f8	543	__br_mdb_notify(dev, entry, RTM_NEWMDB, pg);
e44deb2f SA	544	}
e44deb2f SA	545
cfd56754 CW	546	return err;
	547	}
	548
	549	static int __br_mdb_del(struct net_bridge br, struct br_mdb_entry entry)
	550	{
	551	struct net_bridge_mdb_htable *mdb;
	552	struct net_bridge_mdb_entry *mp;
	553	struct net_bridge_port_group *p;
	554	struct net_bridge_port_group __rcu **pp;
	555	struct br_ip ip;
	556	int err = -EINVAL;
	557
	558	if (!netif_running(br->dev) \|\| br->multicast_disabled)
	559	return -EINVAL;
	560
f1158b74	561	memset(&ip, 0, sizeof(ip));
74fe61f1	562	ip.vid = entry->vid;
cfd56754	563	ip.proto = entry->addr.proto;
51ed7f3e	564	if (ip.proto == htons(ETH_P_IP))
cfd56754 CW	565	ip.u.ip4 = entry->addr.u.ip4;
cfd56754 CW	566	#if IS_ENABLED(CONFIG_IPV6)
51ed7f3e	567	else
cfd56754 CW	568	ip.u.ip6 = entry->addr.u.ip6;
	569	#endif
	570
	571	spin_lock_bh(&br->multicast_lock);
	572	mdb = mlock_dereference(br->mdb, br);
	573
	574	mp = br_mdb_ip_get(mdb, &ip);
	575	if (!mp)
	576	goto unlock;
	577
	578	for (pp = &mp->ports;
	579	(p = mlock_dereference(*pp, br)) != NULL;
	580	pp = &p->next) {
	581	if (!p->port \|\| p->port->dev->ifindex != entry->ifindex)
	582	continue;
	583
	584	if (p->port->state == BR_STATE_DISABLED)
	585	goto unlock;
	586
9d06b6d8	587	__mdb_entry_fill_flags(entry, p->flags);
cfd56754 CW	588	rcu_assign_pointer(*pp, p->next);
	589	hlist_del_init(&p->mglist);
	590	del_timer(&p->timer);
	591	call_rcu_bh(&p->rcu, br_multicast_free_pg);
	592	err = 0;
	593
454594f3	594	if (!mp->ports && !mp->mglist &&
cfd56754 CW	595	netif_running(br->dev))
	596	mod_timer(&mp->timer, jiffies);
	597	break;
	598	}
	599
	600	unlock:
	601	spin_unlock_bh(&br->multicast_lock);
	602	return err;
	603	}
	604
661d2967	605	static int br_mdb_del(struct sk_buff skb, struct nlmsghdr nlh)
cfd56754	606	{
e44deb2f	607	struct net *net = sock_net(skb->sk);
2594e906	608	struct net_bridge_vlan_group *vg;
e44deb2f	609	struct net_device dev, pdev;
cfd56754	610	struct br_mdb_entry *entry;
e44deb2f	611	struct net_bridge_port *p;
2594e906	612	struct net_bridge_vlan *v;
cfd56754 CW	613	struct net_bridge *br;
	614	int err;
	615
	616	err = br_mdb_parse(skb, nlh, &dev, &entry);
	617	if (err < 0)
	618	return err;
	619
	620	br = netdev_priv(dev);
	621
e44deb2f SA	622	/* If vlan filtering is enabled and VLAN is not specified
	623	* delete mdb entry on all vlans configured on the port.
	624	*/
	625	pdev = __dev_get_by_index(net, entry->ifindex);
	626	if (!pdev)
	627	return -ENODEV;
	628
	629	p = br_port_get_rtnl(pdev);
	630	if (!p \|\| p->br != br \|\| p->state == BR_STATE_DISABLED)
	631	return -EINVAL;
	632
2594e906 NA	633	vg = nbp_vlan_group(p);
	634	if (br_vlan_enabled(br) && vg && entry->vid == 0) {
	635	list_for_each_entry(v, &vg->vlan_list, vlist) {
	636	entry->vid = v->vid;
e44deb2f SA	637	err = __br_mdb_del(br, entry);
e44deb2f SA	638	if (!err)
9e8430f8	639	__br_mdb_notify(dev, entry, RTM_DELMDB, NULL);
e44deb2f SA	640	}
	641	} else {
	642	err = __br_mdb_del(br, entry);
	643	if (!err)
9e8430f8	644	__br_mdb_notify(dev, entry, RTM_DELMDB, NULL);
e44deb2f SA	645	}
e44deb2f SA	646
cfd56754 CW	647	return err;
	648	}
	649
ee07c6e7 CW	650	void br_mdb_init(void)
	651	{
	652	rtnl_register(PF_BRIDGE, RTM_GETMDB, NULL, br_mdb_dump, NULL);
cfd56754 CW	653	rtnl_register(PF_BRIDGE, RTM_NEWMDB, br_mdb_add, NULL, NULL);
cfd56754 CW	654	rtnl_register(PF_BRIDGE, RTM_DELMDB, br_mdb_del, NULL, NULL);
ee07c6e7	655	}
63233159 VY	656
	657	void br_mdb_uninit(void)
	658	{
	659	rtnl_unregister(PF_BRIDGE, RTM_GETMDB);
	660	rtnl_unregister(PF_BRIDGE, RTM_NEWMDB);
	661	rtnl_unregister(PF_BRIDGE, RTM_DELMDB);
	662	}