[mirror_ubuntu-artful-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, *port_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)
			continue;
		port_nest = nla_nest_start(skb, MDBA_ROUTER_PORT);
		if (!port_nest)
			goto fail;
		if (nla_put_nohdr(skb, sizeof(u32), &p->dev->ifindex) ||
		    nla_put_u32(skb, MDBA_ROUTER_PATTR_TIMER,
				br_timer_value(&p->multicast_router_timer)) ||
		    nla_put_u8(skb, MDBA_ROUTER_PATTR_TYPE,
			       p->multicast_router)) {
			nla_nest_cancel(skb, port_nest);
			goto fail;
		}
		nla_nest_end(skb, port_nest);
	}

	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 void __mdb_entry_to_br_ip(struct br_mdb_entry *entry, struct br_ip *ip)
{
	memset(ip, 0, sizeof(struct br_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
}

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 nlattr *nest_ent;
				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;
				nest_ent = nla_nest_start(skb,
							  MDBA_MDB_ENTRY_INFO);
				if (!nest_ent) {
					nla_nest_cancel(skb, nest2);
					err = -EMSGSIZE;
					goto out;
				}
				if (nla_put_nohdr(skb, sizeof(e), &e) ||
				    nla_put_u32(skb,
						MDBA_MDB_EATTR_TIMER,
						br_timer_value(&p->timer))) {
					nla_nest_cancel(skb, nest_ent);
					nla_nest_cancel(skb, nest2);
					err = -EMSGSIZE;
					goto out;
				}
				nla_nest_end(skb, nest_ent);
			}
			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));
}

struct br_mdb_complete_info {
	struct net_bridge_port *port;
	struct br_ip ip;
};

static void br_mdb_complete(struct net_device *dev, int err, void *priv)
{
	struct br_mdb_complete_info *data = priv;
	struct net_bridge_port_group __rcu **pp;
	struct net_bridge_port_group *p;
	struct net_bridge_mdb_htable *mdb;
	struct net_bridge_mdb_entry *mp;
	struct net_bridge_port *port = data->port;
	struct net_bridge *br = port->br;

	if (err)
		goto err;

	spin_lock_bh(&br->multicast_lock);
	mdb = mlock_dereference(br->mdb, br);
	mp = br_mdb_ip_get(mdb, &data->ip);
	if (!mp)
		goto out;
	for (pp = &mp->ports; (p = mlock_dereference(*pp, br)) != NULL;
	     pp = &p->next) {
		if (p->port != port)
			continue;
		p->flags |= MDB_PG_FLAGS_OFFLOAD;
	}
out:
	spin_unlock_bh(&br->multicast_lock);
err:
	kfree(priv);
}

static void __br_mdb_notify(struct net_device *dev, struct net_bridge_port *p,
			    struct br_mdb_entry *entry, int type)
{
	struct br_mdb_complete_info *complete_info;
	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) {
		complete_info = kmalloc(sizeof(*complete_info), GFP_ATOMIC);
		if (complete_info) {
			complete_info->port = p;
			__mdb_entry_to_br_ip(entry, &complete_info->ip);
			mdb.obj.complete_priv = complete_info;
			mdb.obj.complete = br_mdb_complete;
			if (switchdev_port_obj_add(port_dev, &mdb.obj))
				kfree(complete_info);
		}
	} 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 *port,
		   struct br_ip *group, int type, u8 flags)
{
	struct br_mdb_entry entry;

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

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,
			  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_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_OR_ZERO(mp);
		if (err)
			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, NULL);
	if (unlikely(!p))
		return -ENOMEM;
	rcu_assign_pointer(*pp, 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 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;

	__mdb_entry_to_br_ip(entry, &ip);

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

static int br_mdb_add(struct sk_buff *skb, struct nlmsghdr *nlh,
		      struct netlink_ext_ack *extack)
{
	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
	 * 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->dev) && vg && entry->vid == 0) {
		list_for_each_entry(v, &vg->vlan_list, vlist) {
			entry->vid = v->vid;
			err = __br_mdb_add(net, br, entry);
			if (err)
				break;
			__br_mdb_notify(dev, p, entry, RTM_NEWMDB);
		}
	} else {
		err = __br_mdb_add(net, br, entry);
		if (!err)
			__br_mdb_notify(dev, p, entry, RTM_NEWMDB);
	}

	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;

	__mdb_entry_to_br_ip(entry, &ip);

	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 netlink_ext_ack *extack)
{
	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->dev) && 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, p, entry, RTM_DELMDB);
		}
	} else {
		err = __br_mdb_del(br, entry);
		if (!err)
			__br_mdb_notify(dev, p, entry, RTM_DELMDB);
	}

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