2014-11-28 21:34:17 +08:00
|
|
|
/*
|
|
|
|
|
* net/switchdev/switchdev.c - Switch device API
|
|
|
|
|
* Copyright (c) 2014 Jiri Pirko <jiri@resnulli.us>
|
2015-03-10 04:59:09 +08:00
|
|
|
* Copyright (c) 2014-2015 Scott Feldman <sfeldma@gmail.com>
|
2014-11-28 21:34:17 +08:00
|
|
|
*
|
|
|
|
|
* This program is free software; you can redistribute it and/or modify
|
|
|
|
|
* it under the terms of the GNU General Public License as published by
|
|
|
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
|
|
|
* (at your option) any later version.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
#include <linux/kernel.h>
|
|
|
|
|
#include <linux/types.h>
|
|
|
|
|
#include <linux/init.h>
|
2015-01-16 06:49:36 +08:00
|
|
|
#include <linux/mutex.h>
|
|
|
|
|
#include <linux/notifier.h>
|
2014-11-28 21:34:17 +08:00
|
|
|
#include <linux/netdevice.h>
|
2015-05-11 00:47:56 +08:00
|
|
|
#include <linux/if_bridge.h>
|
2015-03-06 13:21:15 +08:00
|
|
|
#include <net/ip_fib.h>
|
2014-11-28 21:34:17 +08:00
|
|
|
#include <net/switchdev.h>
|
|
|
|
|
|
switchdev: introduce get/set attrs ops
Add two new swdev ops for get/set switch port attributes. Most swdev
interactions on a port are gets or sets on port attributes, so rather than
adding ops for each attribute, let's define clean get/set ops for all
attributes, and then we can have clear, consistent rules on how attributes
propagate on stacked devs.
Add the basic algorithms for get/set attr ops. Use the same recusive algo
to walk lower devs we've used for STP updates, for example. For get,
compare attr value for each lower dev and only return success if attr
values match across all lower devs. For sets, set the same attr value for
all lower devs. We'll use a two-phase prepare-commit transaction model for
sets. In the first phase, the driver(s) are asked if attr set is OK. If
all OK, the commit attr set in second phase. A driver would NACK the
prepare phase if it can't set the attr due to lack of resources or support,
within it's control. RTNL lock must be held across both phases because
we'll recurse all lower devs first in prepare phase, and then recurse all
lower devs again in commit phase. If any lower dev fails the prepare
phase, we need to abort the transaction for all lower devs.
If lower dev recusion isn't desired, allow a flag SWITCHDEV_F_NO_RECURSE to
indicate get/set only work on port (lowest) device.
Signed-off-by: Scott Feldman <sfeldma@gmail.com>
Acked-by: Jiri Pirko <jiri@resnulli.us>
Signed-off-by: David S. Miller <davem@davemloft.net>
2015-05-11 00:47:48 +08:00
|
|
|
/**
|
|
|
|
|
* switchdev_port_attr_get - Get port attribute
|
|
|
|
|
*
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @attr: attribute to get
|
|
|
|
|
*/
|
|
|
|
|
int switchdev_port_attr_get(struct net_device *dev, struct switchdev_attr *attr)
|
|
|
|
|
{
|
|
|
|
|
const struct switchdev_ops *ops = dev->switchdev_ops;
|
|
|
|
|
struct net_device *lower_dev;
|
|
|
|
|
struct list_head *iter;
|
|
|
|
|
struct switchdev_attr first = {
|
|
|
|
|
.id = SWITCHDEV_ATTR_UNDEFINED
|
|
|
|
|
};
|
|
|
|
|
int err = -EOPNOTSUPP;
|
|
|
|
|
|
|
|
|
|
if (ops && ops->switchdev_port_attr_get)
|
|
|
|
|
return ops->switchdev_port_attr_get(dev, attr);
|
|
|
|
|
|
|
|
|
|
if (attr->flags & SWITCHDEV_F_NO_RECURSE)
|
|
|
|
|
return err;
|
|
|
|
|
|
|
|
|
|
/* Switch device port(s) may be stacked under
|
|
|
|
|
* bond/team/vlan dev, so recurse down to get attr on
|
|
|
|
|
* each port. Return -ENODATA if attr values don't
|
|
|
|
|
* compare across ports.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
netdev_for_each_lower_dev(dev, lower_dev, iter) {
|
|
|
|
|
err = switchdev_port_attr_get(lower_dev, attr);
|
|
|
|
|
if (err)
|
|
|
|
|
break;
|
|
|
|
|
if (first.id == SWITCHDEV_ATTR_UNDEFINED)
|
|
|
|
|
first = *attr;
|
|
|
|
|
else if (memcmp(&first, attr, sizeof(*attr)))
|
|
|
|
|
return -ENODATA;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_attr_get);
|
|
|
|
|
|
|
|
|
|
static int __switchdev_port_attr_set(struct net_device *dev,
|
|
|
|
|
struct switchdev_attr *attr)
|
|
|
|
|
{
|
|
|
|
|
const struct switchdev_ops *ops = dev->switchdev_ops;
|
|
|
|
|
struct net_device *lower_dev;
|
|
|
|
|
struct list_head *iter;
|
|
|
|
|
int err = -EOPNOTSUPP;
|
|
|
|
|
|
|
|
|
|
if (ops && ops->switchdev_port_attr_set)
|
|
|
|
|
return ops->switchdev_port_attr_set(dev, attr);
|
|
|
|
|
|
|
|
|
|
if (attr->flags & SWITCHDEV_F_NO_RECURSE)
|
|
|
|
|
return err;
|
|
|
|
|
|
|
|
|
|
/* Switch device port(s) may be stacked under
|
|
|
|
|
* bond/team/vlan dev, so recurse down to set attr on
|
|
|
|
|
* each port.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
netdev_for_each_lower_dev(dev, lower_dev, iter) {
|
|
|
|
|
err = __switchdev_port_attr_set(lower_dev, attr);
|
|
|
|
|
if (err)
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
struct switchdev_attr_set_work {
|
|
|
|
|
struct work_struct work;
|
|
|
|
|
struct net_device *dev;
|
|
|
|
|
struct switchdev_attr attr;
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
static void switchdev_port_attr_set_work(struct work_struct *work)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_attr_set_work *asw =
|
|
|
|
|
container_of(work, struct switchdev_attr_set_work, work);
|
|
|
|
|
int err;
|
|
|
|
|
|
|
|
|
|
rtnl_lock();
|
|
|
|
|
err = switchdev_port_attr_set(asw->dev, &asw->attr);
|
2015-06-11 23:19:01 +08:00
|
|
|
if (err && err != -EOPNOTSUPP)
|
|
|
|
|
netdev_err(asw->dev, "failed (err=%d) to set attribute (id=%d)\n",
|
|
|
|
|
err, asw->attr.id);
|
switchdev: introduce get/set attrs ops
Add two new swdev ops for get/set switch port attributes. Most swdev
interactions on a port are gets or sets on port attributes, so rather than
adding ops for each attribute, let's define clean get/set ops for all
attributes, and then we can have clear, consistent rules on how attributes
propagate on stacked devs.
Add the basic algorithms for get/set attr ops. Use the same recusive algo
to walk lower devs we've used for STP updates, for example. For get,
compare attr value for each lower dev and only return success if attr
values match across all lower devs. For sets, set the same attr value for
all lower devs. We'll use a two-phase prepare-commit transaction model for
sets. In the first phase, the driver(s) are asked if attr set is OK. If
all OK, the commit attr set in second phase. A driver would NACK the
prepare phase if it can't set the attr due to lack of resources or support,
within it's control. RTNL lock must be held across both phases because
we'll recurse all lower devs first in prepare phase, and then recurse all
lower devs again in commit phase. If any lower dev fails the prepare
phase, we need to abort the transaction for all lower devs.
If lower dev recusion isn't desired, allow a flag SWITCHDEV_F_NO_RECURSE to
indicate get/set only work on port (lowest) device.
Signed-off-by: Scott Feldman <sfeldma@gmail.com>
Acked-by: Jiri Pirko <jiri@resnulli.us>
Signed-off-by: David S. Miller <davem@davemloft.net>
2015-05-11 00:47:48 +08:00
|
|
|
rtnl_unlock();
|
|
|
|
|
|
|
|
|
|
dev_put(asw->dev);
|
|
|
|
|
kfree(work);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static int switchdev_port_attr_set_defer(struct net_device *dev,
|
|
|
|
|
struct switchdev_attr *attr)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_attr_set_work *asw;
|
|
|
|
|
|
|
|
|
|
asw = kmalloc(sizeof(*asw), GFP_ATOMIC);
|
|
|
|
|
if (!asw)
|
|
|
|
|
return -ENOMEM;
|
|
|
|
|
|
|
|
|
|
INIT_WORK(&asw->work, switchdev_port_attr_set_work);
|
|
|
|
|
|
|
|
|
|
dev_hold(dev);
|
|
|
|
|
asw->dev = dev;
|
|
|
|
|
memcpy(&asw->attr, attr, sizeof(asw->attr));
|
|
|
|
|
|
|
|
|
|
schedule_work(&asw->work);
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* switchdev_port_attr_set - Set port attribute
|
|
|
|
|
*
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @attr: attribute to set
|
|
|
|
|
*
|
|
|
|
|
* Use a 2-phase prepare-commit transaction model to ensure
|
|
|
|
|
* system is not left in a partially updated state due to
|
|
|
|
|
* failure from driver/device.
|
|
|
|
|
*/
|
|
|
|
|
int switchdev_port_attr_set(struct net_device *dev, struct switchdev_attr *attr)
|
|
|
|
|
{
|
|
|
|
|
int err;
|
|
|
|
|
|
|
|
|
|
if (!rtnl_is_locked()) {
|
|
|
|
|
/* Running prepare-commit transaction across stacked
|
|
|
|
|
* devices requires nothing moves, so if rtnl_lock is
|
|
|
|
|
* not held, schedule a worker thread to hold rtnl_lock
|
|
|
|
|
* while setting attr.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
return switchdev_port_attr_set_defer(dev, attr);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Phase I: prepare for attr set. Driver/device should fail
|
|
|
|
|
* here if there are going to be issues in the commit phase,
|
|
|
|
|
* such as lack of resources or support. The driver/device
|
|
|
|
|
* should reserve resources needed for the commit phase here,
|
|
|
|
|
* but should not commit the attr.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
attr->trans = SWITCHDEV_TRANS_PREPARE;
|
|
|
|
|
err = __switchdev_port_attr_set(dev, attr);
|
|
|
|
|
if (err) {
|
|
|
|
|
/* Prepare phase failed: abort the transaction. Any
|
|
|
|
|
* resources reserved in the prepare phase are
|
|
|
|
|
* released.
|
|
|
|
|
*/
|
|
|
|
|
|
2015-07-11 07:48:58 +08:00
|
|
|
if (err != -EOPNOTSUPP) {
|
|
|
|
|
attr->trans = SWITCHDEV_TRANS_ABORT;
|
|
|
|
|
__switchdev_port_attr_set(dev, attr);
|
|
|
|
|
}
|
switchdev: introduce get/set attrs ops
Add two new swdev ops for get/set switch port attributes. Most swdev
interactions on a port are gets or sets on port attributes, so rather than
adding ops for each attribute, let's define clean get/set ops for all
attributes, and then we can have clear, consistent rules on how attributes
propagate on stacked devs.
Add the basic algorithms for get/set attr ops. Use the same recusive algo
to walk lower devs we've used for STP updates, for example. For get,
compare attr value for each lower dev and only return success if attr
values match across all lower devs. For sets, set the same attr value for
all lower devs. We'll use a two-phase prepare-commit transaction model for
sets. In the first phase, the driver(s) are asked if attr set is OK. If
all OK, the commit attr set in second phase. A driver would NACK the
prepare phase if it can't set the attr due to lack of resources or support,
within it's control. RTNL lock must be held across both phases because
we'll recurse all lower devs first in prepare phase, and then recurse all
lower devs again in commit phase. If any lower dev fails the prepare
phase, we need to abort the transaction for all lower devs.
If lower dev recusion isn't desired, allow a flag SWITCHDEV_F_NO_RECURSE to
indicate get/set only work on port (lowest) device.
Signed-off-by: Scott Feldman <sfeldma@gmail.com>
Acked-by: Jiri Pirko <jiri@resnulli.us>
Signed-off-by: David S. Miller <davem@davemloft.net>
2015-05-11 00:47:48 +08:00
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Phase II: commit attr set. This cannot fail as a fault
|
|
|
|
|
* of driver/device. If it does, it's a bug in the driver/device
|
|
|
|
|
* because the driver said everythings was OK in phase I.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
attr->trans = SWITCHDEV_TRANS_COMMIT;
|
|
|
|
|
err = __switchdev_port_attr_set(dev, attr);
|
2015-06-12 02:20:42 +08:00
|
|
|
WARN(err, "%s: Commit of attribute (id=%d) failed.\n",
|
|
|
|
|
dev->name, attr->id);
|
switchdev: introduce get/set attrs ops
Add two new swdev ops for get/set switch port attributes. Most swdev
interactions on a port are gets or sets on port attributes, so rather than
adding ops for each attribute, let's define clean get/set ops for all
attributes, and then we can have clear, consistent rules on how attributes
propagate on stacked devs.
Add the basic algorithms for get/set attr ops. Use the same recusive algo
to walk lower devs we've used for STP updates, for example. For get,
compare attr value for each lower dev and only return success if attr
values match across all lower devs. For sets, set the same attr value for
all lower devs. We'll use a two-phase prepare-commit transaction model for
sets. In the first phase, the driver(s) are asked if attr set is OK. If
all OK, the commit attr set in second phase. A driver would NACK the
prepare phase if it can't set the attr due to lack of resources or support,
within it's control. RTNL lock must be held across both phases because
we'll recurse all lower devs first in prepare phase, and then recurse all
lower devs again in commit phase. If any lower dev fails the prepare
phase, we need to abort the transaction for all lower devs.
If lower dev recusion isn't desired, allow a flag SWITCHDEV_F_NO_RECURSE to
indicate get/set only work on port (lowest) device.
Signed-off-by: Scott Feldman <sfeldma@gmail.com>
Acked-by: Jiri Pirko <jiri@resnulli.us>
Signed-off-by: David S. Miller <davem@davemloft.net>
2015-05-11 00:47:48 +08:00
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_attr_set);
|
|
|
|
|
|
2015-05-13 14:03:51 +08:00
|
|
|
static int __switchdev_port_obj_add(struct net_device *dev,
|
|
|
|
|
struct switchdev_obj *obj)
|
2015-05-11 00:47:52 +08:00
|
|
|
{
|
|
|
|
|
const struct switchdev_ops *ops = dev->switchdev_ops;
|
|
|
|
|
struct net_device *lower_dev;
|
|
|
|
|
struct list_head *iter;
|
|
|
|
|
int err = -EOPNOTSUPP;
|
|
|
|
|
|
|
|
|
|
if (ops && ops->switchdev_port_obj_add)
|
|
|
|
|
return ops->switchdev_port_obj_add(dev, obj);
|
|
|
|
|
|
|
|
|
|
/* Switch device port(s) may be stacked under
|
|
|
|
|
* bond/team/vlan dev, so recurse down to add object on
|
|
|
|
|
* each port.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
netdev_for_each_lower_dev(dev, lower_dev, iter) {
|
|
|
|
|
err = __switchdev_port_obj_add(lower_dev, obj);
|
|
|
|
|
if (err)
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* switchdev_port_obj_add - Add port object
|
|
|
|
|
*
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @obj: object to add
|
|
|
|
|
*
|
|
|
|
|
* Use a 2-phase prepare-commit transaction model to ensure
|
|
|
|
|
* system is not left in a partially updated state due to
|
|
|
|
|
* failure from driver/device.
|
|
|
|
|
*
|
|
|
|
|
* rtnl_lock must be held.
|
|
|
|
|
*/
|
|
|
|
|
int switchdev_port_obj_add(struct net_device *dev, struct switchdev_obj *obj)
|
|
|
|
|
{
|
|
|
|
|
int err;
|
|
|
|
|
|
|
|
|
|
ASSERT_RTNL();
|
|
|
|
|
|
|
|
|
|
/* Phase I: prepare for obj add. Driver/device should fail
|
|
|
|
|
* here if there are going to be issues in the commit phase,
|
|
|
|
|
* such as lack of resources or support. The driver/device
|
|
|
|
|
* should reserve resources needed for the commit phase here,
|
|
|
|
|
* but should not commit the obj.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
obj->trans = SWITCHDEV_TRANS_PREPARE;
|
|
|
|
|
err = __switchdev_port_obj_add(dev, obj);
|
|
|
|
|
if (err) {
|
|
|
|
|
/* Prepare phase failed: abort the transaction. Any
|
|
|
|
|
* resources reserved in the prepare phase are
|
|
|
|
|
* released.
|
|
|
|
|
*/
|
|
|
|
|
|
2015-07-11 07:48:58 +08:00
|
|
|
if (err != -EOPNOTSUPP) {
|
|
|
|
|
obj->trans = SWITCHDEV_TRANS_ABORT;
|
|
|
|
|
__switchdev_port_obj_add(dev, obj);
|
|
|
|
|
}
|
2015-05-11 00:47:52 +08:00
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Phase II: commit obj add. This cannot fail as a fault
|
|
|
|
|
* of driver/device. If it does, it's a bug in the driver/device
|
|
|
|
|
* because the driver said everythings was OK in phase I.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
obj->trans = SWITCHDEV_TRANS_COMMIT;
|
|
|
|
|
err = __switchdev_port_obj_add(dev, obj);
|
|
|
|
|
WARN(err, "%s: Commit of object (id=%d) failed.\n", dev->name, obj->id);
|
|
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_obj_add);
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* switchdev_port_obj_del - Delete port object
|
|
|
|
|
*
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @obj: object to delete
|
|
|
|
|
*/
|
|
|
|
|
int switchdev_port_obj_del(struct net_device *dev, struct switchdev_obj *obj)
|
|
|
|
|
{
|
|
|
|
|
const struct switchdev_ops *ops = dev->switchdev_ops;
|
|
|
|
|
struct net_device *lower_dev;
|
|
|
|
|
struct list_head *iter;
|
|
|
|
|
int err = -EOPNOTSUPP;
|
|
|
|
|
|
|
|
|
|
if (ops && ops->switchdev_port_obj_del)
|
|
|
|
|
return ops->switchdev_port_obj_del(dev, obj);
|
|
|
|
|
|
|
|
|
|
/* Switch device port(s) may be stacked under
|
|
|
|
|
* bond/team/vlan dev, so recurse down to delete object on
|
|
|
|
|
* each port.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
netdev_for_each_lower_dev(dev, lower_dev, iter) {
|
|
|
|
|
err = switchdev_port_obj_del(lower_dev, obj);
|
|
|
|
|
if (err)
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_obj_del);
|
|
|
|
|
|
2015-05-14 12:55:43 +08:00
|
|
|
/**
|
|
|
|
|
* switchdev_port_obj_dump - Dump port objects
|
|
|
|
|
*
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @obj: object to dump
|
|
|
|
|
*/
|
|
|
|
|
int switchdev_port_obj_dump(struct net_device *dev, struct switchdev_obj *obj)
|
|
|
|
|
{
|
|
|
|
|
const struct switchdev_ops *ops = dev->switchdev_ops;
|
|
|
|
|
struct net_device *lower_dev;
|
|
|
|
|
struct list_head *iter;
|
|
|
|
|
int err = -EOPNOTSUPP;
|
|
|
|
|
|
|
|
|
|
if (ops && ops->switchdev_port_obj_dump)
|
|
|
|
|
return ops->switchdev_port_obj_dump(dev, obj);
|
|
|
|
|
|
|
|
|
|
/* Switch device port(s) may be stacked under
|
|
|
|
|
* bond/team/vlan dev, so recurse down to dump objects on
|
|
|
|
|
* first port at bottom of stack.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
netdev_for_each_lower_dev(dev, lower_dev, iter) {
|
|
|
|
|
err = switchdev_port_obj_dump(lower_dev, obj);
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_obj_dump);
|
|
|
|
|
|
2015-05-11 00:47:46 +08:00
|
|
|
static DEFINE_MUTEX(switchdev_mutex);
|
|
|
|
|
static RAW_NOTIFIER_HEAD(switchdev_notif_chain);
|
2015-01-16 06:49:36 +08:00
|
|
|
|
|
|
|
|
/**
|
2015-05-11 00:47:46 +08:00
|
|
|
* register_switchdev_notifier - Register notifier
|
2015-01-16 06:49:36 +08:00
|
|
|
* @nb: notifier_block
|
|
|
|
|
*
|
|
|
|
|
* Register switch device notifier. This should be used by code
|
|
|
|
|
* which needs to monitor events happening in particular device.
|
|
|
|
|
* Return values are same as for atomic_notifier_chain_register().
|
|
|
|
|
*/
|
2015-05-11 00:47:46 +08:00
|
|
|
int register_switchdev_notifier(struct notifier_block *nb)
|
2015-01-16 06:49:36 +08:00
|
|
|
{
|
|
|
|
|
int err;
|
|
|
|
|
|
2015-05-11 00:47:46 +08:00
|
|
|
mutex_lock(&switchdev_mutex);
|
|
|
|
|
err = raw_notifier_chain_register(&switchdev_notif_chain, nb);
|
|
|
|
|
mutex_unlock(&switchdev_mutex);
|
2015-01-16 06:49:36 +08:00
|
|
|
return err;
|
|
|
|
|
}
|
2015-05-11 00:47:46 +08:00
|
|
|
EXPORT_SYMBOL_GPL(register_switchdev_notifier);
|
2015-01-16 06:49:36 +08:00
|
|
|
|
|
|
|
|
/**
|
2015-05-11 00:47:46 +08:00
|
|
|
* unregister_switchdev_notifier - Unregister notifier
|
2015-01-16 06:49:36 +08:00
|
|
|
* @nb: notifier_block
|
|
|
|
|
*
|
|
|
|
|
* Unregister switch device notifier.
|
|
|
|
|
* Return values are same as for atomic_notifier_chain_unregister().
|
|
|
|
|
*/
|
2015-05-11 00:47:46 +08:00
|
|
|
int unregister_switchdev_notifier(struct notifier_block *nb)
|
2015-01-16 06:49:36 +08:00
|
|
|
{
|
|
|
|
|
int err;
|
|
|
|
|
|
2015-05-11 00:47:46 +08:00
|
|
|
mutex_lock(&switchdev_mutex);
|
|
|
|
|
err = raw_notifier_chain_unregister(&switchdev_notif_chain, nb);
|
|
|
|
|
mutex_unlock(&switchdev_mutex);
|
2015-01-16 06:49:36 +08:00
|
|
|
return err;
|
|
|
|
|
}
|
2015-05-11 00:47:46 +08:00
|
|
|
EXPORT_SYMBOL_GPL(unregister_switchdev_notifier);
|
2015-01-16 06:49:36 +08:00
|
|
|
|
|
|
|
|
/**
|
2015-05-11 00:47:46 +08:00
|
|
|
* call_switchdev_notifiers - Call notifiers
|
2015-01-16 06:49:36 +08:00
|
|
|
* @val: value passed unmodified to notifier function
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @info: notifier information data
|
|
|
|
|
*
|
|
|
|
|
* Call all network notifier blocks. This should be called by driver
|
|
|
|
|
* when it needs to propagate hardware event.
|
|
|
|
|
* Return values are same as for atomic_notifier_call_chain().
|
|
|
|
|
*/
|
2015-05-11 00:47:46 +08:00
|
|
|
int call_switchdev_notifiers(unsigned long val, struct net_device *dev,
|
|
|
|
|
struct switchdev_notifier_info *info)
|
2015-01-16 06:49:36 +08:00
|
|
|
{
|
|
|
|
|
int err;
|
|
|
|
|
|
|
|
|
|
info->dev = dev;
|
2015-05-11 00:47:46 +08:00
|
|
|
mutex_lock(&switchdev_mutex);
|
|
|
|
|
err = raw_notifier_call_chain(&switchdev_notif_chain, val, info);
|
|
|
|
|
mutex_unlock(&switchdev_mutex);
|
2015-01-16 06:49:36 +08:00
|
|
|
return err;
|
|
|
|
|
}
|
2015-05-11 00:47:46 +08:00
|
|
|
EXPORT_SYMBOL_GPL(call_switchdev_notifiers);
|
2015-01-30 14:40:13 +08:00
|
|
|
|
2015-06-22 15:27:17 +08:00
|
|
|
struct switchdev_vlan_dump {
|
|
|
|
|
struct switchdev_obj obj;
|
|
|
|
|
struct sk_buff *skb;
|
|
|
|
|
u32 filter_mask;
|
|
|
|
|
u16 flags;
|
|
|
|
|
u16 begin;
|
|
|
|
|
u16 end;
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
static int switchdev_port_vlan_dump_put(struct net_device *dev,
|
|
|
|
|
struct switchdev_vlan_dump *dump)
|
|
|
|
|
{
|
|
|
|
|
struct bridge_vlan_info vinfo;
|
|
|
|
|
|
|
|
|
|
vinfo.flags = dump->flags;
|
|
|
|
|
|
|
|
|
|
if (dump->begin == 0 && dump->end == 0) {
|
|
|
|
|
return 0;
|
|
|
|
|
} else if (dump->begin == dump->end) {
|
|
|
|
|
vinfo.vid = dump->begin;
|
|
|
|
|
if (nla_put(dump->skb, IFLA_BRIDGE_VLAN_INFO,
|
|
|
|
|
sizeof(vinfo), &vinfo))
|
|
|
|
|
return -EMSGSIZE;
|
|
|
|
|
} else {
|
|
|
|
|
vinfo.vid = dump->begin;
|
|
|
|
|
vinfo.flags |= BRIDGE_VLAN_INFO_RANGE_BEGIN;
|
|
|
|
|
if (nla_put(dump->skb, IFLA_BRIDGE_VLAN_INFO,
|
|
|
|
|
sizeof(vinfo), &vinfo))
|
|
|
|
|
return -EMSGSIZE;
|
|
|
|
|
vinfo.vid = dump->end;
|
|
|
|
|
vinfo.flags &= ~BRIDGE_VLAN_INFO_RANGE_BEGIN;
|
|
|
|
|
vinfo.flags |= BRIDGE_VLAN_INFO_RANGE_END;
|
|
|
|
|
if (nla_put(dump->skb, IFLA_BRIDGE_VLAN_INFO,
|
|
|
|
|
sizeof(vinfo), &vinfo))
|
|
|
|
|
return -EMSGSIZE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static int switchdev_port_vlan_dump_cb(struct net_device *dev,
|
|
|
|
|
struct switchdev_obj *obj)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_vlan_dump *dump =
|
|
|
|
|
container_of(obj, struct switchdev_vlan_dump, obj);
|
|
|
|
|
struct switchdev_obj_vlan *vlan = &dump->obj.u.vlan;
|
|
|
|
|
int err = 0;
|
|
|
|
|
|
|
|
|
|
if (vlan->vid_begin > vlan->vid_end)
|
|
|
|
|
return -EINVAL;
|
|
|
|
|
|
|
|
|
|
if (dump->filter_mask & RTEXT_FILTER_BRVLAN) {
|
|
|
|
|
dump->flags = vlan->flags;
|
|
|
|
|
for (dump->begin = dump->end = vlan->vid_begin;
|
|
|
|
|
dump->begin <= vlan->vid_end;
|
|
|
|
|
dump->begin++, dump->end++) {
|
|
|
|
|
err = switchdev_port_vlan_dump_put(dev, dump);
|
|
|
|
|
if (err)
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
} else if (dump->filter_mask & RTEXT_FILTER_BRVLAN_COMPRESSED) {
|
|
|
|
|
if (dump->begin > vlan->vid_begin &&
|
|
|
|
|
dump->begin >= vlan->vid_end) {
|
|
|
|
|
if ((dump->begin - 1) == vlan->vid_end &&
|
|
|
|
|
dump->flags == vlan->flags) {
|
|
|
|
|
/* prepend */
|
|
|
|
|
dump->begin = vlan->vid_begin;
|
|
|
|
|
} else {
|
|
|
|
|
err = switchdev_port_vlan_dump_put(dev, dump);
|
|
|
|
|
dump->flags = vlan->flags;
|
|
|
|
|
dump->begin = vlan->vid_begin;
|
|
|
|
|
dump->end = vlan->vid_end;
|
|
|
|
|
}
|
|
|
|
|
} else if (dump->end <= vlan->vid_begin &&
|
|
|
|
|
dump->end < vlan->vid_end) {
|
|
|
|
|
if ((dump->end + 1) == vlan->vid_begin &&
|
|
|
|
|
dump->flags == vlan->flags) {
|
|
|
|
|
/* append */
|
|
|
|
|
dump->end = vlan->vid_end;
|
|
|
|
|
} else {
|
|
|
|
|
err = switchdev_port_vlan_dump_put(dev, dump);
|
|
|
|
|
dump->flags = vlan->flags;
|
|
|
|
|
dump->begin = vlan->vid_begin;
|
|
|
|
|
dump->end = vlan->vid_end;
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
err = -EINVAL;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static int switchdev_port_vlan_fill(struct sk_buff *skb, struct net_device *dev,
|
|
|
|
|
u32 filter_mask)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_vlan_dump dump = {
|
|
|
|
|
.obj = {
|
|
|
|
|
.id = SWITCHDEV_OBJ_PORT_VLAN,
|
|
|
|
|
.cb = switchdev_port_vlan_dump_cb,
|
|
|
|
|
},
|
|
|
|
|
.skb = skb,
|
|
|
|
|
.filter_mask = filter_mask,
|
|
|
|
|
};
|
|
|
|
|
int err = 0;
|
|
|
|
|
|
|
|
|
|
if ((filter_mask & RTEXT_FILTER_BRVLAN) ||
|
|
|
|
|
(filter_mask & RTEXT_FILTER_BRVLAN_COMPRESSED)) {
|
|
|
|
|
err = switchdev_port_obj_dump(dev, &dump.obj);
|
|
|
|
|
if (err)
|
|
|
|
|
goto err_out;
|
|
|
|
|
if (filter_mask & RTEXT_FILTER_BRVLAN_COMPRESSED)
|
|
|
|
|
/* last one */
|
|
|
|
|
err = switchdev_port_vlan_dump_put(dev, &dump);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
err_out:
|
|
|
|
|
return err == -EOPNOTSUPP ? 0 : err;
|
|
|
|
|
}
|
|
|
|
|
|
2015-05-11 00:48:04 +08:00
|
|
|
/**
|
|
|
|
|
* switchdev_port_bridge_getlink - Get bridge port attributes
|
|
|
|
|
*
|
|
|
|
|
* @dev: port device
|
|
|
|
|
*
|
|
|
|
|
* Called for SELF on rtnl_bridge_getlink to get bridge port
|
|
|
|
|
* attributes.
|
|
|
|
|
*/
|
|
|
|
|
int switchdev_port_bridge_getlink(struct sk_buff *skb, u32 pid, u32 seq,
|
|
|
|
|
struct net_device *dev, u32 filter_mask,
|
|
|
|
|
int nlflags)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_attr attr = {
|
|
|
|
|
.id = SWITCHDEV_ATTR_PORT_BRIDGE_FLAGS,
|
|
|
|
|
};
|
|
|
|
|
u16 mode = BRIDGE_MODE_UNDEF;
|
|
|
|
|
u32 mask = BR_LEARNING | BR_LEARNING_SYNC;
|
|
|
|
|
int err;
|
|
|
|
|
|
|
|
|
|
err = switchdev_port_attr_get(dev, &attr);
|
2015-06-23 22:26:04 +08:00
|
|
|
if (err && err != -EOPNOTSUPP)
|
2015-05-11 00:48:04 +08:00
|
|
|
return err;
|
|
|
|
|
|
|
|
|
|
return ndo_dflt_bridge_getlink(skb, pid, seq, dev, mode,
|
2015-06-22 15:27:17 +08:00
|
|
|
attr.u.brport_flags, mask, nlflags,
|
|
|
|
|
filter_mask, switchdev_port_vlan_fill);
|
2015-05-11 00:48:04 +08:00
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_bridge_getlink);
|
|
|
|
|
|
2015-05-11 00:47:56 +08:00
|
|
|
static int switchdev_port_br_setflag(struct net_device *dev,
|
|
|
|
|
struct nlattr *nlattr,
|
|
|
|
|
unsigned long brport_flag)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_attr attr = {
|
|
|
|
|
.id = SWITCHDEV_ATTR_PORT_BRIDGE_FLAGS,
|
|
|
|
|
};
|
|
|
|
|
u8 flag = nla_get_u8(nlattr);
|
|
|
|
|
int err;
|
|
|
|
|
|
|
|
|
|
err = switchdev_port_attr_get(dev, &attr);
|
|
|
|
|
if (err)
|
|
|
|
|
return err;
|
|
|
|
|
|
|
|
|
|
if (flag)
|
2015-05-14 02:16:50 +08:00
|
|
|
attr.u.brport_flags |= brport_flag;
|
2015-05-11 00:47:56 +08:00
|
|
|
else
|
2015-05-14 02:16:50 +08:00
|
|
|
attr.u.brport_flags &= ~brport_flag;
|
2015-05-11 00:47:56 +08:00
|
|
|
|
|
|
|
|
return switchdev_port_attr_set(dev, &attr);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static const struct nla_policy
|
|
|
|
|
switchdev_port_bridge_policy[IFLA_BRPORT_MAX + 1] = {
|
|
|
|
|
[IFLA_BRPORT_STATE] = { .type = NLA_U8 },
|
|
|
|
|
[IFLA_BRPORT_COST] = { .type = NLA_U32 },
|
|
|
|
|
[IFLA_BRPORT_PRIORITY] = { .type = NLA_U16 },
|
|
|
|
|
[IFLA_BRPORT_MODE] = { .type = NLA_U8 },
|
|
|
|
|
[IFLA_BRPORT_GUARD] = { .type = NLA_U8 },
|
|
|
|
|
[IFLA_BRPORT_PROTECT] = { .type = NLA_U8 },
|
|
|
|
|
[IFLA_BRPORT_FAST_LEAVE] = { .type = NLA_U8 },
|
|
|
|
|
[IFLA_BRPORT_LEARNING] = { .type = NLA_U8 },
|
|
|
|
|
[IFLA_BRPORT_LEARNING_SYNC] = { .type = NLA_U8 },
|
|
|
|
|
[IFLA_BRPORT_UNICAST_FLOOD] = { .type = NLA_U8 },
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
static int switchdev_port_br_setlink_protinfo(struct net_device *dev,
|
|
|
|
|
struct nlattr *protinfo)
|
|
|
|
|
{
|
|
|
|
|
struct nlattr *attr;
|
|
|
|
|
int rem;
|
|
|
|
|
int err;
|
|
|
|
|
|
|
|
|
|
err = nla_validate_nested(protinfo, IFLA_BRPORT_MAX,
|
|
|
|
|
switchdev_port_bridge_policy);
|
|
|
|
|
if (err)
|
|
|
|
|
return err;
|
|
|
|
|
|
|
|
|
|
nla_for_each_nested(attr, protinfo, rem) {
|
|
|
|
|
switch (nla_type(attr)) {
|
|
|
|
|
case IFLA_BRPORT_LEARNING:
|
|
|
|
|
err = switchdev_port_br_setflag(dev, attr,
|
|
|
|
|
BR_LEARNING);
|
|
|
|
|
break;
|
|
|
|
|
case IFLA_BRPORT_LEARNING_SYNC:
|
|
|
|
|
err = switchdev_port_br_setflag(dev, attr,
|
|
|
|
|
BR_LEARNING_SYNC);
|
|
|
|
|
break;
|
|
|
|
|
default:
|
|
|
|
|
err = -EOPNOTSUPP;
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
if (err)
|
|
|
|
|
return err;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static int switchdev_port_br_afspec(struct net_device *dev,
|
|
|
|
|
struct nlattr *afspec,
|
|
|
|
|
int (*f)(struct net_device *dev,
|
|
|
|
|
struct switchdev_obj *obj))
|
|
|
|
|
{
|
|
|
|
|
struct nlattr *attr;
|
|
|
|
|
struct bridge_vlan_info *vinfo;
|
|
|
|
|
struct switchdev_obj obj = {
|
|
|
|
|
.id = SWITCHDEV_OBJ_PORT_VLAN,
|
|
|
|
|
};
|
2015-05-14 02:16:50 +08:00
|
|
|
struct switchdev_obj_vlan *vlan = &obj.u.vlan;
|
2015-05-11 00:47:56 +08:00
|
|
|
int rem;
|
|
|
|
|
int err;
|
|
|
|
|
|
|
|
|
|
nla_for_each_nested(attr, afspec, rem) {
|
|
|
|
|
if (nla_type(attr) != IFLA_BRIDGE_VLAN_INFO)
|
|
|
|
|
continue;
|
|
|
|
|
if (nla_len(attr) != sizeof(struct bridge_vlan_info))
|
|
|
|
|
return -EINVAL;
|
|
|
|
|
vinfo = nla_data(attr);
|
2015-05-14 02:16:50 +08:00
|
|
|
vlan->flags = vinfo->flags;
|
2015-05-11 00:47:56 +08:00
|
|
|
if (vinfo->flags & BRIDGE_VLAN_INFO_RANGE_BEGIN) {
|
2015-06-22 15:27:16 +08:00
|
|
|
if (vlan->vid_begin)
|
2015-05-11 00:47:56 +08:00
|
|
|
return -EINVAL;
|
2015-06-22 15:27:16 +08:00
|
|
|
vlan->vid_begin = vinfo->vid;
|
2015-05-11 00:47:56 +08:00
|
|
|
} else if (vinfo->flags & BRIDGE_VLAN_INFO_RANGE_END) {
|
2015-06-22 15:27:16 +08:00
|
|
|
if (!vlan->vid_begin)
|
2015-05-11 00:47:56 +08:00
|
|
|
return -EINVAL;
|
2015-05-14 02:16:50 +08:00
|
|
|
vlan->vid_end = vinfo->vid;
|
2015-06-22 15:27:16 +08:00
|
|
|
if (vlan->vid_end <= vlan->vid_begin)
|
2015-05-11 00:47:56 +08:00
|
|
|
return -EINVAL;
|
|
|
|
|
err = f(dev, &obj);
|
|
|
|
|
if (err)
|
|
|
|
|
return err;
|
2015-05-14 02:16:50 +08:00
|
|
|
memset(vlan, 0, sizeof(*vlan));
|
2015-05-11 00:47:56 +08:00
|
|
|
} else {
|
2015-06-22 15:27:16 +08:00
|
|
|
if (vlan->vid_begin)
|
2015-05-11 00:47:56 +08:00
|
|
|
return -EINVAL;
|
2015-06-22 15:27:16 +08:00
|
|
|
vlan->vid_begin = vinfo->vid;
|
2015-05-14 02:16:50 +08:00
|
|
|
vlan->vid_end = vinfo->vid;
|
2015-05-11 00:47:56 +08:00
|
|
|
err = f(dev, &obj);
|
|
|
|
|
if (err)
|
|
|
|
|
return err;
|
2015-05-14 02:16:50 +08:00
|
|
|
memset(vlan, 0, sizeof(*vlan));
|
2015-05-11 00:47:56 +08:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
2015-01-30 14:40:13 +08:00
|
|
|
/**
|
2015-05-11 00:47:56 +08:00
|
|
|
* switchdev_port_bridge_setlink - Set bridge port attributes
|
2015-01-30 14:40:13 +08:00
|
|
|
*
|
|
|
|
|
* @dev: port device
|
2015-05-11 00:47:56 +08:00
|
|
|
* @nlh: netlink header
|
|
|
|
|
* @flags: netlink flags
|
2015-01-30 14:40:13 +08:00
|
|
|
*
|
2015-05-11 00:47:56 +08:00
|
|
|
* Called for SELF on rtnl_bridge_setlink to set bridge port
|
|
|
|
|
* attributes.
|
2015-01-30 14:40:13 +08:00
|
|
|
*/
|
2015-05-11 00:47:46 +08:00
|
|
|
int switchdev_port_bridge_setlink(struct net_device *dev,
|
|
|
|
|
struct nlmsghdr *nlh, u16 flags)
|
2015-01-30 14:40:13 +08:00
|
|
|
{
|
2015-05-11 00:47:56 +08:00
|
|
|
struct nlattr *protinfo;
|
|
|
|
|
struct nlattr *afspec;
|
|
|
|
|
int err = 0;
|
|
|
|
|
|
|
|
|
|
protinfo = nlmsg_find_attr(nlh, sizeof(struct ifinfomsg),
|
|
|
|
|
IFLA_PROTINFO);
|
|
|
|
|
if (protinfo) {
|
|
|
|
|
err = switchdev_port_br_setlink_protinfo(dev, protinfo);
|
|
|
|
|
if (err)
|
|
|
|
|
return err;
|
|
|
|
|
}
|
2015-01-30 14:40:13 +08:00
|
|
|
|
2015-05-11 00:47:56 +08:00
|
|
|
afspec = nlmsg_find_attr(nlh, sizeof(struct ifinfomsg),
|
|
|
|
|
IFLA_AF_SPEC);
|
|
|
|
|
if (afspec)
|
|
|
|
|
err = switchdev_port_br_afspec(dev, afspec,
|
|
|
|
|
switchdev_port_obj_add);
|
2015-01-30 14:40:13 +08:00
|
|
|
|
2015-05-11 00:47:56 +08:00
|
|
|
return err;
|
2015-01-30 14:40:13 +08:00
|
|
|
}
|
2015-05-11 00:47:46 +08:00
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_bridge_setlink);
|
2015-01-30 14:40:13 +08:00
|
|
|
|
|
|
|
|
/**
|
2015-05-11 00:48:00 +08:00
|
|
|
* switchdev_port_bridge_dellink - Set bridge port attributes
|
2015-01-30 14:40:13 +08:00
|
|
|
*
|
|
|
|
|
* @dev: port device
|
2015-05-11 00:48:00 +08:00
|
|
|
* @nlh: netlink header
|
|
|
|
|
* @flags: netlink flags
|
2015-01-30 14:40:13 +08:00
|
|
|
*
|
2015-05-11 00:48:00 +08:00
|
|
|
* Called for SELF on rtnl_bridge_dellink to set bridge port
|
|
|
|
|
* attributes.
|
2015-01-30 14:40:13 +08:00
|
|
|
*/
|
2015-05-11 00:47:46 +08:00
|
|
|
int switchdev_port_bridge_dellink(struct net_device *dev,
|
|
|
|
|
struct nlmsghdr *nlh, u16 flags)
|
2015-01-30 14:40:13 +08:00
|
|
|
{
|
2015-05-11 00:48:00 +08:00
|
|
|
struct nlattr *afspec;
|
2015-01-30 14:40:13 +08:00
|
|
|
|
2015-05-11 00:48:00 +08:00
|
|
|
afspec = nlmsg_find_attr(nlh, sizeof(struct ifinfomsg),
|
|
|
|
|
IFLA_AF_SPEC);
|
|
|
|
|
if (afspec)
|
|
|
|
|
return switchdev_port_br_afspec(dev, afspec,
|
|
|
|
|
switchdev_port_obj_del);
|
2015-01-30 14:40:13 +08:00
|
|
|
|
2015-05-11 00:48:00 +08:00
|
|
|
return 0;
|
2015-01-30 14:40:13 +08:00
|
|
|
}
|
2015-05-11 00:47:46 +08:00
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_bridge_dellink);
|
2015-01-30 14:40:13 +08:00
|
|
|
|
2015-05-14 12:55:43 +08:00
|
|
|
/**
|
|
|
|
|
* switchdev_port_fdb_add - Add FDB (MAC/VLAN) entry to port
|
|
|
|
|
*
|
|
|
|
|
* @ndmsg: netlink hdr
|
|
|
|
|
* @nlattr: netlink attributes
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @addr: MAC address to add
|
|
|
|
|
* @vid: VLAN to add
|
|
|
|
|
*
|
|
|
|
|
* Add FDB entry to switch device.
|
|
|
|
|
*/
|
|
|
|
|
int switchdev_port_fdb_add(struct ndmsg *ndm, struct nlattr *tb[],
|
|
|
|
|
struct net_device *dev, const unsigned char *addr,
|
|
|
|
|
u16 vid, u16 nlm_flags)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_obj obj = {
|
|
|
|
|
.id = SWITCHDEV_OBJ_PORT_FDB,
|
|
|
|
|
.u.fdb = {
|
2015-08-12 03:00:37 +08:00
|
|
|
.addr = addr,
|
2015-05-14 12:55:43 +08:00
|
|
|
.vid = vid,
|
|
|
|
|
},
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
return switchdev_port_obj_add(dev, &obj);
|
|
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_fdb_add);
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* switchdev_port_fdb_del - Delete FDB (MAC/VLAN) entry from port
|
|
|
|
|
*
|
|
|
|
|
* @ndmsg: netlink hdr
|
|
|
|
|
* @nlattr: netlink attributes
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @addr: MAC address to delete
|
|
|
|
|
* @vid: VLAN to delete
|
|
|
|
|
*
|
|
|
|
|
* Delete FDB entry from switch device.
|
|
|
|
|
*/
|
|
|
|
|
int switchdev_port_fdb_del(struct ndmsg *ndm, struct nlattr *tb[],
|
|
|
|
|
struct net_device *dev, const unsigned char *addr,
|
|
|
|
|
u16 vid)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_obj obj = {
|
|
|
|
|
.id = SWITCHDEV_OBJ_PORT_FDB,
|
|
|
|
|
.u.fdb = {
|
2015-08-12 03:00:37 +08:00
|
|
|
.addr = addr,
|
2015-05-14 12:55:43 +08:00
|
|
|
.vid = vid,
|
|
|
|
|
},
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
return switchdev_port_obj_del(dev, &obj);
|
|
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_fdb_del);
|
|
|
|
|
|
|
|
|
|
struct switchdev_fdb_dump {
|
|
|
|
|
struct switchdev_obj obj;
|
|
|
|
|
struct sk_buff *skb;
|
|
|
|
|
struct netlink_callback *cb;
|
|
|
|
|
int idx;
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
static int switchdev_port_fdb_dump_cb(struct net_device *dev,
|
|
|
|
|
struct switchdev_obj *obj)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_fdb_dump *dump =
|
|
|
|
|
container_of(obj, struct switchdev_fdb_dump, obj);
|
|
|
|
|
u32 portid = NETLINK_CB(dump->cb->skb).portid;
|
|
|
|
|
u32 seq = dump->cb->nlh->nlmsg_seq;
|
|
|
|
|
struct nlmsghdr *nlh;
|
|
|
|
|
struct ndmsg *ndm;
|
|
|
|
|
|
|
|
|
|
if (dump->idx < dump->cb->args[0])
|
|
|
|
|
goto skip;
|
|
|
|
|
|
|
|
|
|
nlh = nlmsg_put(dump->skb, portid, seq, RTM_NEWNEIGH,
|
|
|
|
|
sizeof(*ndm), NLM_F_MULTI);
|
|
|
|
|
if (!nlh)
|
|
|
|
|
return -EMSGSIZE;
|
|
|
|
|
|
|
|
|
|
ndm = nlmsg_data(nlh);
|
|
|
|
|
ndm->ndm_family = AF_BRIDGE;
|
|
|
|
|
ndm->ndm_pad1 = 0;
|
|
|
|
|
ndm->ndm_pad2 = 0;
|
|
|
|
|
ndm->ndm_flags = NTF_SELF;
|
|
|
|
|
ndm->ndm_type = 0;
|
|
|
|
|
ndm->ndm_ifindex = dev->ifindex;
|
2015-08-10 21:09:52 +08:00
|
|
|
ndm->ndm_state = obj->u.fdb.ndm_state;
|
2015-05-14 12:55:43 +08:00
|
|
|
|
|
|
|
|
if (nla_put(dump->skb, NDA_LLADDR, ETH_ALEN, obj->u.fdb.addr))
|
|
|
|
|
goto nla_put_failure;
|
|
|
|
|
|
|
|
|
|
if (obj->u.fdb.vid && nla_put_u16(dump->skb, NDA_VLAN, obj->u.fdb.vid))
|
|
|
|
|
goto nla_put_failure;
|
|
|
|
|
|
|
|
|
|
nlmsg_end(dump->skb, nlh);
|
|
|
|
|
|
|
|
|
|
skip:
|
|
|
|
|
dump->idx++;
|
|
|
|
|
return 0;
|
|
|
|
|
|
|
|
|
|
nla_put_failure:
|
|
|
|
|
nlmsg_cancel(dump->skb, nlh);
|
|
|
|
|
return -EMSGSIZE;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* switchdev_port_fdb_dump - Dump port FDB (MAC/VLAN) entries
|
|
|
|
|
*
|
|
|
|
|
* @skb: netlink skb
|
|
|
|
|
* @cb: netlink callback
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @filter_dev: filter device
|
|
|
|
|
* @idx:
|
|
|
|
|
*
|
|
|
|
|
* Delete FDB entry from switch device.
|
|
|
|
|
*/
|
|
|
|
|
int switchdev_port_fdb_dump(struct sk_buff *skb, struct netlink_callback *cb,
|
|
|
|
|
struct net_device *dev,
|
|
|
|
|
struct net_device *filter_dev, int idx)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_fdb_dump dump = {
|
|
|
|
|
.obj = {
|
|
|
|
|
.id = SWITCHDEV_OBJ_PORT_FDB,
|
|
|
|
|
.cb = switchdev_port_fdb_dump_cb,
|
|
|
|
|
},
|
|
|
|
|
.skb = skb,
|
|
|
|
|
.cb = cb,
|
|
|
|
|
.idx = idx,
|
|
|
|
|
};
|
|
|
|
|
|
2015-09-03 20:04:17 +08:00
|
|
|
switchdev_port_obj_dump(dev, &dump.obj);
|
2015-05-14 12:55:43 +08:00
|
|
|
return dump.idx;
|
|
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_fdb_dump);
|
|
|
|
|
|
2015-05-11 00:47:46 +08:00
|
|
|
static struct net_device *switchdev_get_lowest_dev(struct net_device *dev)
|
2015-03-06 13:21:17 +08:00
|
|
|
{
|
2015-05-11 00:47:47 +08:00
|
|
|
const struct switchdev_ops *ops = dev->switchdev_ops;
|
2015-03-06 13:21:17 +08:00
|
|
|
struct net_device *lower_dev;
|
|
|
|
|
struct net_device *port_dev;
|
|
|
|
|
struct list_head *iter;
|
|
|
|
|
|
|
|
|
|
/* Recusively search down until we find a sw port dev.
|
2015-05-11 00:47:49 +08:00
|
|
|
* (A sw port dev supports switchdev_port_attr_get).
|
2015-03-06 13:21:17 +08:00
|
|
|
*/
|
|
|
|
|
|
2015-05-11 00:47:49 +08:00
|
|
|
if (ops && ops->switchdev_port_attr_get)
|
2015-03-06 13:21:17 +08:00
|
|
|
return dev;
|
|
|
|
|
|
|
|
|
|
netdev_for_each_lower_dev(dev, lower_dev, iter) {
|
2015-05-11 00:47:46 +08:00
|
|
|
port_dev = switchdev_get_lowest_dev(lower_dev);
|
2015-03-06 13:21:17 +08:00
|
|
|
if (port_dev)
|
|
|
|
|
return port_dev;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return NULL;
|
|
|
|
|
}
|
|
|
|
|
|
2015-05-11 00:47:46 +08:00
|
|
|
static struct net_device *switchdev_get_dev_by_nhs(struct fib_info *fi)
|
2015-03-06 13:21:17 +08:00
|
|
|
{
|
2015-05-11 00:47:49 +08:00
|
|
|
struct switchdev_attr attr = {
|
|
|
|
|
.id = SWITCHDEV_ATTR_PORT_PARENT_ID,
|
|
|
|
|
};
|
|
|
|
|
struct switchdev_attr prev_attr;
|
2015-03-06 13:21:17 +08:00
|
|
|
struct net_device *dev = NULL;
|
|
|
|
|
int nhsel;
|
|
|
|
|
|
|
|
|
|
/* For this route, all nexthop devs must be on the same switch. */
|
|
|
|
|
|
|
|
|
|
for (nhsel = 0; nhsel < fi->fib_nhs; nhsel++) {
|
|
|
|
|
const struct fib_nh *nh = &fi->fib_nh[nhsel];
|
|
|
|
|
|
|
|
|
|
if (!nh->nh_dev)
|
|
|
|
|
return NULL;
|
|
|
|
|
|
2015-05-11 00:47:46 +08:00
|
|
|
dev = switchdev_get_lowest_dev(nh->nh_dev);
|
2015-03-06 13:21:17 +08:00
|
|
|
if (!dev)
|
|
|
|
|
return NULL;
|
|
|
|
|
|
2015-05-11 00:47:49 +08:00
|
|
|
if (switchdev_port_attr_get(dev, &attr))
|
2015-03-06 13:21:17 +08:00
|
|
|
return NULL;
|
|
|
|
|
|
2015-07-19 09:24:49 +08:00
|
|
|
if (nhsel > 0 &&
|
|
|
|
|
!netdev_phys_item_id_same(&prev_attr.u.ppid, &attr.u.ppid))
|
2015-03-06 13:21:17 +08:00
|
|
|
return NULL;
|
|
|
|
|
|
2015-05-11 00:47:49 +08:00
|
|
|
prev_attr = attr;
|
2015-03-06 13:21:17 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return dev;
|
|
|
|
|
}
|
|
|
|
|
|
2015-03-06 13:21:15 +08:00
|
|
|
/**
|
2015-06-04 11:43:43 +08:00
|
|
|
* switchdev_fib_ipv4_add - Add/modify switch IPv4 route entry
|
2015-03-06 13:21:15 +08:00
|
|
|
*
|
|
|
|
|
* @dst: route's IPv4 destination address
|
|
|
|
|
* @dst_len: destination address length (prefix length)
|
|
|
|
|
* @fi: route FIB info structure
|
|
|
|
|
* @tos: route TOS
|
|
|
|
|
* @type: route type
|
2015-03-10 04:59:09 +08:00
|
|
|
* @nlflags: netlink flags passed in (NLM_F_*)
|
2015-03-06 13:21:15 +08:00
|
|
|
* @tb_id: route table ID
|
|
|
|
|
*
|
2015-06-04 11:43:43 +08:00
|
|
|
* Add/modify switch IPv4 route entry.
|
2015-03-06 13:21:15 +08:00
|
|
|
*/
|
2015-05-11 00:47:46 +08:00
|
|
|
int switchdev_fib_ipv4_add(u32 dst, int dst_len, struct fib_info *fi,
|
|
|
|
|
u8 tos, u8 type, u32 nlflags, u32 tb_id)
|
2015-03-06 13:21:15 +08:00
|
|
|
{
|
2015-05-11 00:48:06 +08:00
|
|
|
struct switchdev_obj fib_obj = {
|
|
|
|
|
.id = SWITCHDEV_OBJ_IPV4_FIB,
|
2015-05-14 02:16:50 +08:00
|
|
|
.u.ipv4_fib = {
|
2015-05-13 14:03:52 +08:00
|
|
|
.dst = dst,
|
2015-05-11 00:48:06 +08:00
|
|
|
.dst_len = dst_len,
|
|
|
|
|
.fi = fi,
|
|
|
|
|
.tos = tos,
|
|
|
|
|
.type = type,
|
|
|
|
|
.nlflags = nlflags,
|
|
|
|
|
.tb_id = tb_id,
|
|
|
|
|
},
|
|
|
|
|
};
|
2015-03-06 13:21:17 +08:00
|
|
|
struct net_device *dev;
|
|
|
|
|
int err = 0;
|
|
|
|
|
|
2015-03-06 13:21:19 +08:00
|
|
|
/* Don't offload route if using custom ip rules or if
|
|
|
|
|
* IPv4 FIB offloading has been disabled completely.
|
|
|
|
|
*/
|
|
|
|
|
|
2015-03-06 17:14:36 +08:00
|
|
|
#ifdef CONFIG_IP_MULTIPLE_TABLES
|
|
|
|
|
if (fi->fib_net->ipv4.fib_has_custom_rules)
|
|
|
|
|
return 0;
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
if (fi->fib_net->ipv4.fib_offload_disabled)
|
2015-03-06 13:21:16 +08:00
|
|
|
return 0;
|
|
|
|
|
|
2015-05-11 00:47:46 +08:00
|
|
|
dev = switchdev_get_dev_by_nhs(fi);
|
2015-03-06 13:21:17 +08:00
|
|
|
if (!dev)
|
|
|
|
|
return 0;
|
2015-05-11 00:48:06 +08:00
|
|
|
|
|
|
|
|
err = switchdev_port_obj_add(dev, &fib_obj);
|
|
|
|
|
if (!err)
|
2015-05-23 13:22:35 +08:00
|
|
|
fi->fib_flags |= RTNH_F_OFFLOAD;
|
2015-03-06 13:21:17 +08:00
|
|
|
|
2015-06-11 08:04:49 +08:00
|
|
|
return err == -EOPNOTSUPP ? 0 : err;
|
2015-03-06 13:21:15 +08:00
|
|
|
}
|
2015-05-11 00:47:46 +08:00
|
|
|
EXPORT_SYMBOL_GPL(switchdev_fib_ipv4_add);
|
2015-03-06 13:21:15 +08:00
|
|
|
|
|
|
|
|
/**
|
2015-05-11 00:47:46 +08:00
|
|
|
* switchdev_fib_ipv4_del - Delete IPv4 route entry from switch
|
2015-03-06 13:21:15 +08:00
|
|
|
*
|
|
|
|
|
* @dst: route's IPv4 destination address
|
|
|
|
|
* @dst_len: destination address length (prefix length)
|
|
|
|
|
* @fi: route FIB info structure
|
|
|
|
|
* @tos: route TOS
|
|
|
|
|
* @type: route type
|
|
|
|
|
* @tb_id: route table ID
|
|
|
|
|
*
|
|
|
|
|
* Delete IPv4 route entry from switch device.
|
|
|
|
|
*/
|
2015-05-11 00:47:46 +08:00
|
|
|
int switchdev_fib_ipv4_del(u32 dst, int dst_len, struct fib_info *fi,
|
|
|
|
|
u8 tos, u8 type, u32 tb_id)
|
2015-03-06 13:21:15 +08:00
|
|
|
{
|
2015-05-11 00:48:06 +08:00
|
|
|
struct switchdev_obj fib_obj = {
|
|
|
|
|
.id = SWITCHDEV_OBJ_IPV4_FIB,
|
2015-05-14 02:16:50 +08:00
|
|
|
.u.ipv4_fib = {
|
2015-05-13 14:03:52 +08:00
|
|
|
.dst = dst,
|
2015-05-11 00:48:06 +08:00
|
|
|
.dst_len = dst_len,
|
|
|
|
|
.fi = fi,
|
|
|
|
|
.tos = tos,
|
|
|
|
|
.type = type,
|
|
|
|
|
.nlflags = 0,
|
|
|
|
|
.tb_id = tb_id,
|
|
|
|
|
},
|
|
|
|
|
};
|
2015-03-06 13:21:17 +08:00
|
|
|
struct net_device *dev;
|
|
|
|
|
int err = 0;
|
|
|
|
|
|
2015-05-14 12:17:41 +08:00
|
|
|
if (!(fi->fib_flags & RTNH_F_OFFLOAD))
|
2015-03-06 13:21:17 +08:00
|
|
|
return 0;
|
|
|
|
|
|
2015-05-11 00:47:46 +08:00
|
|
|
dev = switchdev_get_dev_by_nhs(fi);
|
2015-03-06 13:21:17 +08:00
|
|
|
if (!dev)
|
|
|
|
|
return 0;
|
|
|
|
|
|
2015-05-11 00:48:06 +08:00
|
|
|
err = switchdev_port_obj_del(dev, &fib_obj);
|
|
|
|
|
if (!err)
|
2015-05-23 13:22:35 +08:00
|
|
|
fi->fib_flags &= ~RTNH_F_OFFLOAD;
|
2015-03-06 13:21:17 +08:00
|
|
|
|
2015-06-11 08:04:49 +08:00
|
|
|
return err == -EOPNOTSUPP ? 0 : err;
|
2015-03-06 13:21:15 +08:00
|
|
|
}
|
2015-05-11 00:47:46 +08:00
|
|
|
EXPORT_SYMBOL_GPL(switchdev_fib_ipv4_del);
|
2015-03-06 13:21:19 +08:00
|
|
|
|
|
|
|
|
/**
|
2015-05-11 00:47:46 +08:00
|
|
|
* switchdev_fib_ipv4_abort - Abort an IPv4 FIB operation
|
2015-03-06 13:21:19 +08:00
|
|
|
*
|
|
|
|
|
* @fi: route FIB info structure
|
|
|
|
|
*/
|
2015-05-11 00:47:46 +08:00
|
|
|
void switchdev_fib_ipv4_abort(struct fib_info *fi)
|
2015-03-06 13:21:19 +08:00
|
|
|
{
|
|
|
|
|
/* There was a problem installing this route to the offload
|
|
|
|
|
* device. For now, until we come up with more refined
|
|
|
|
|
* policy handling, abruptly end IPv4 fib offloading for
|
|
|
|
|
* for entire net by flushing offload device(s) of all
|
|
|
|
|
* IPv4 routes, and mark IPv4 fib offloading broken from
|
|
|
|
|
* this point forward.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
fib_flush_external(fi->fib_net);
|
|
|
|
|
fi->fib_net->ipv4.fib_offload_disabled = true;
|
|
|
|
|
}
|
2015-05-11 00:47:46 +08:00
|
|
|
EXPORT_SYMBOL_GPL(switchdev_fib_ipv4_abort);
|
2015-07-19 09:24:50 +08:00
|
|
|
|
|
|
|
|
static bool switchdev_port_same_parent_id(struct net_device *a,
|
|
|
|
|
struct net_device *b)
|
|
|
|
|
{
|
|
|
|
|
struct switchdev_attr a_attr = {
|
|
|
|
|
.id = SWITCHDEV_ATTR_PORT_PARENT_ID,
|
|
|
|
|
.flags = SWITCHDEV_F_NO_RECURSE,
|
|
|
|
|
};
|
|
|
|
|
struct switchdev_attr b_attr = {
|
|
|
|
|
.id = SWITCHDEV_ATTR_PORT_PARENT_ID,
|
|
|
|
|
.flags = SWITCHDEV_F_NO_RECURSE,
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
if (switchdev_port_attr_get(a, &a_attr) ||
|
|
|
|
|
switchdev_port_attr_get(b, &b_attr))
|
|
|
|
|
return false;
|
|
|
|
|
|
|
|
|
|
return netdev_phys_item_id_same(&a_attr.u.ppid, &b_attr.u.ppid);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static u32 switchdev_port_fwd_mark_get(struct net_device *dev,
|
|
|
|
|
struct net_device *group_dev)
|
|
|
|
|
{
|
|
|
|
|
struct net_device *lower_dev;
|
|
|
|
|
struct list_head *iter;
|
|
|
|
|
|
|
|
|
|
netdev_for_each_lower_dev(group_dev, lower_dev, iter) {
|
|
|
|
|
if (lower_dev == dev)
|
|
|
|
|
continue;
|
|
|
|
|
if (switchdev_port_same_parent_id(dev, lower_dev))
|
|
|
|
|
return lower_dev->offload_fwd_mark;
|
|
|
|
|
return switchdev_port_fwd_mark_get(dev, lower_dev);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return dev->ifindex;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static void switchdev_port_fwd_mark_reset(struct net_device *group_dev,
|
|
|
|
|
u32 old_mark, u32 *reset_mark)
|
|
|
|
|
{
|
|
|
|
|
struct net_device *lower_dev;
|
|
|
|
|
struct list_head *iter;
|
|
|
|
|
|
|
|
|
|
netdev_for_each_lower_dev(group_dev, lower_dev, iter) {
|
|
|
|
|
if (lower_dev->offload_fwd_mark == old_mark) {
|
|
|
|
|
if (!*reset_mark)
|
|
|
|
|
*reset_mark = lower_dev->ifindex;
|
|
|
|
|
lower_dev->offload_fwd_mark = *reset_mark;
|
|
|
|
|
}
|
|
|
|
|
switchdev_port_fwd_mark_reset(lower_dev, old_mark, reset_mark);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* switchdev_port_fwd_mark_set - Set port offload forwarding mark
|
|
|
|
|
*
|
|
|
|
|
* @dev: port device
|
|
|
|
|
* @group_dev: containing device
|
|
|
|
|
* @joining: true if dev is joining group; false if leaving group
|
|
|
|
|
*
|
|
|
|
|
* An ungrouped port's offload mark is just its ifindex. A grouped
|
|
|
|
|
* port's (member of a bridge, for example) offload mark is the ifindex
|
|
|
|
|
* of one of the ports in the group with the same parent (switch) ID.
|
|
|
|
|
* Ports on the same device in the same group will have the same mark.
|
|
|
|
|
*
|
|
|
|
|
* Example:
|
|
|
|
|
*
|
|
|
|
|
* br0 ifindex=9
|
|
|
|
|
* sw1p1 ifindex=2 mark=2
|
|
|
|
|
* sw1p2 ifindex=3 mark=2
|
|
|
|
|
* sw2p1 ifindex=4 mark=5
|
|
|
|
|
* sw2p2 ifindex=5 mark=5
|
|
|
|
|
*
|
|
|
|
|
* If sw2p2 leaves the bridge, we'll have:
|
|
|
|
|
*
|
|
|
|
|
* br0 ifindex=9
|
|
|
|
|
* sw1p1 ifindex=2 mark=2
|
|
|
|
|
* sw1p2 ifindex=3 mark=2
|
|
|
|
|
* sw2p1 ifindex=4 mark=4
|
|
|
|
|
* sw2p2 ifindex=5 mark=5
|
|
|
|
|
*/
|
|
|
|
|
void switchdev_port_fwd_mark_set(struct net_device *dev,
|
|
|
|
|
struct net_device *group_dev,
|
|
|
|
|
bool joining)
|
|
|
|
|
{
|
|
|
|
|
u32 mark = dev->ifindex;
|
|
|
|
|
u32 reset_mark = 0;
|
|
|
|
|
|
|
|
|
|
if (group_dev && joining) {
|
|
|
|
|
mark = switchdev_port_fwd_mark_get(dev, group_dev);
|
|
|
|
|
} else if (group_dev && !joining) {
|
|
|
|
|
if (dev->offload_fwd_mark == mark)
|
|
|
|
|
/* Ohoh, this port was the mark reference port,
|
|
|
|
|
* but it's leaving the group, so reset the
|
|
|
|
|
* mark for the remaining ports in the group.
|
|
|
|
|
*/
|
|
|
|
|
switchdev_port_fwd_mark_reset(group_dev, mark,
|
|
|
|
|
&reset_mark);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
dev->offload_fwd_mark = mark;
|
|
|
|
|
}
|
|
|
|
|
EXPORT_SYMBOL_GPL(switchdev_port_fwd_mark_set);
|
