|
@@ -829,21 +829,25 @@ void bond_change_active_slave(struct bonding *bond, struct slave *new_active)
|
|
|
if (bond_is_lb(bond)) {
|
|
|
bond_alb_handle_active_change(bond, new_active);
|
|
|
if (old_active)
|
|
|
- bond_set_slave_inactive_flags(old_active);
|
|
|
+ bond_set_slave_inactive_flags(old_active,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
if (new_active)
|
|
|
- bond_set_slave_active_flags(new_active);
|
|
|
+ bond_set_slave_active_flags(new_active,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
} else {
|
|
|
rcu_assign_pointer(bond->curr_active_slave, new_active);
|
|
|
}
|
|
|
|
|
|
if (bond->params.mode == BOND_MODE_ACTIVEBACKUP) {
|
|
|
if (old_active)
|
|
|
- bond_set_slave_inactive_flags(old_active);
|
|
|
+ bond_set_slave_inactive_flags(old_active,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
|
|
|
if (new_active) {
|
|
|
bool should_notify_peers = false;
|
|
|
|
|
|
- bond_set_slave_active_flags(new_active);
|
|
|
+ bond_set_slave_active_flags(new_active,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
|
|
|
if (bond->params.fail_over_mac)
|
|
|
bond_do_fail_over_mac(bond, new_active,
|
|
@@ -1193,6 +1197,11 @@ int bond_enslave(struct net_device *bond_dev, struct net_device *slave_dev)
|
|
|
return -EBUSY;
|
|
|
}
|
|
|
|
|
|
+ if (bond_dev == slave_dev) {
|
|
|
+ pr_err("%s: cannot enslave bond to itself.\n", bond_dev->name);
|
|
|
+ return -EPERM;
|
|
|
+ }
|
|
|
+
|
|
|
/* vlan challenged mutual exclusion */
|
|
|
/* no need to lock since we're protected by rtnl_lock */
|
|
|
if (slave_dev->features & NETIF_F_VLAN_CHALLENGED) {
|
|
@@ -1463,14 +1472,15 @@ int bond_enslave(struct net_device *bond_dev, struct net_device *slave_dev)
|
|
|
|
|
|
switch (bond->params.mode) {
|
|
|
case BOND_MODE_ACTIVEBACKUP:
|
|
|
- bond_set_slave_inactive_flags(new_slave);
|
|
|
+ bond_set_slave_inactive_flags(new_slave,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
break;
|
|
|
case BOND_MODE_8023AD:
|
|
|
/* in 802.3ad mode, the internal mechanism
|
|
|
* will activate the slaves in the selected
|
|
|
* aggregator
|
|
|
*/
|
|
|
- bond_set_slave_inactive_flags(new_slave);
|
|
|
+ bond_set_slave_inactive_flags(new_slave, BOND_SLAVE_NOTIFY_NOW);
|
|
|
/* if this is the first slave */
|
|
|
if (!prev_slave) {
|
|
|
SLAVE_AD_INFO(new_slave).id = 1;
|
|
@@ -1488,7 +1498,7 @@ int bond_enslave(struct net_device *bond_dev, struct net_device *slave_dev)
|
|
|
case BOND_MODE_TLB:
|
|
|
case BOND_MODE_ALB:
|
|
|
bond_set_active_slave(new_slave);
|
|
|
- bond_set_slave_inactive_flags(new_slave);
|
|
|
+ bond_set_slave_inactive_flags(new_slave, BOND_SLAVE_NOTIFY_NOW);
|
|
|
break;
|
|
|
default:
|
|
|
pr_debug("This slave is always active in trunk mode\n");
|
|
@@ -1654,9 +1664,6 @@ static int __bond_release_one(struct net_device *bond_dev,
|
|
|
return -EINVAL;
|
|
|
}
|
|
|
|
|
|
- /* release the slave from its bond */
|
|
|
- bond->slave_cnt--;
|
|
|
-
|
|
|
bond_sysfs_slave_del(slave);
|
|
|
|
|
|
bond_upper_dev_unlink(bond_dev, slave_dev);
|
|
@@ -1738,6 +1745,7 @@ static int __bond_release_one(struct net_device *bond_dev,
|
|
|
|
|
|
unblock_netpoll_tx();
|
|
|
synchronize_rcu();
|
|
|
+ bond->slave_cnt--;
|
|
|
|
|
|
if (!bond_has_slaves(bond)) {
|
|
|
call_netdevice_notifiers(NETDEV_CHANGEADDR, bond->dev);
|
|
@@ -2015,7 +2023,8 @@ static void bond_miimon_commit(struct bonding *bond)
|
|
|
|
|
|
if (bond->params.mode == BOND_MODE_ACTIVEBACKUP ||
|
|
|
bond->params.mode == BOND_MODE_8023AD)
|
|
|
- bond_set_slave_inactive_flags(slave);
|
|
|
+ bond_set_slave_inactive_flags(slave,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
|
|
|
pr_info("%s: link status definitely down for interface %s, disabling it\n",
|
|
|
bond->dev->name, slave->dev->name);
|
|
@@ -2562,7 +2571,8 @@ static void bond_ab_arp_commit(struct bonding *bond)
|
|
|
slave->link = BOND_LINK_UP;
|
|
|
if (bond->current_arp_slave) {
|
|
|
bond_set_slave_inactive_flags(
|
|
|
- bond->current_arp_slave);
|
|
|
+ bond->current_arp_slave,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
bond->current_arp_slave = NULL;
|
|
|
}
|
|
|
|
|
@@ -2582,7 +2592,8 @@ static void bond_ab_arp_commit(struct bonding *bond)
|
|
|
slave->link_failure_count++;
|
|
|
|
|
|
slave->link = BOND_LINK_DOWN;
|
|
|
- bond_set_slave_inactive_flags(slave);
|
|
|
+ bond_set_slave_inactive_flags(slave,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
|
|
|
pr_info("%s: link status definitely down for interface %s, disabling it\n",
|
|
|
bond->dev->name, slave->dev->name);
|
|
@@ -2615,17 +2626,17 @@ do_failover:
|
|
|
|
|
|
/*
|
|
|
* Send ARP probes for active-backup mode ARP monitor.
|
|
|
+ *
|
|
|
+ * Called with rcu_read_lock hold.
|
|
|
*/
|
|
|
static bool bond_ab_arp_probe(struct bonding *bond)
|
|
|
{
|
|
|
struct slave *slave, *before = NULL, *new_slave = NULL,
|
|
|
- *curr_arp_slave, *curr_active_slave;
|
|
|
+ *curr_arp_slave = rcu_dereference(bond->current_arp_slave),
|
|
|
+ *curr_active_slave = rcu_dereference(bond->curr_active_slave);
|
|
|
struct list_head *iter;
|
|
|
bool found = false;
|
|
|
-
|
|
|
- rcu_read_lock();
|
|
|
- curr_arp_slave = rcu_dereference(bond->current_arp_slave);
|
|
|
- curr_active_slave = rcu_dereference(bond->curr_active_slave);
|
|
|
+ bool should_notify_rtnl = BOND_SLAVE_NOTIFY_LATER;
|
|
|
|
|
|
if (curr_arp_slave && curr_active_slave)
|
|
|
pr_info("PROBE: c_arp %s && cas %s BAD\n",
|
|
@@ -2634,32 +2645,23 @@ static bool bond_ab_arp_probe(struct bonding *bond)
|
|
|
|
|
|
if (curr_active_slave) {
|
|
|
bond_arp_send_all(bond, curr_active_slave);
|
|
|
- rcu_read_unlock();
|
|
|
- return true;
|
|
|
+ return should_notify_rtnl;
|
|
|
}
|
|
|
- rcu_read_unlock();
|
|
|
|
|
|
/* if we don't have a curr_active_slave, search for the next available
|
|
|
* backup slave from the current_arp_slave and make it the candidate
|
|
|
* for becoming the curr_active_slave
|
|
|
*/
|
|
|
|
|
|
- if (!rtnl_trylock())
|
|
|
- return false;
|
|
|
- /* curr_arp_slave might have gone away */
|
|
|
- curr_arp_slave = ACCESS_ONCE(bond->current_arp_slave);
|
|
|
-
|
|
|
if (!curr_arp_slave) {
|
|
|
- curr_arp_slave = bond_first_slave(bond);
|
|
|
- if (!curr_arp_slave) {
|
|
|
- rtnl_unlock();
|
|
|
- return true;
|
|
|
- }
|
|
|
+ curr_arp_slave = bond_first_slave_rcu(bond);
|
|
|
+ if (!curr_arp_slave)
|
|
|
+ return should_notify_rtnl;
|
|
|
}
|
|
|
|
|
|
- bond_set_slave_inactive_flags(curr_arp_slave);
|
|
|
+ bond_set_slave_inactive_flags(curr_arp_slave, BOND_SLAVE_NOTIFY_LATER);
|
|
|
|
|
|
- bond_for_each_slave(bond, slave, iter) {
|
|
|
+ bond_for_each_slave_rcu(bond, slave, iter) {
|
|
|
if (!found && !before && IS_UP(slave->dev))
|
|
|
before = slave;
|
|
|
|
|
@@ -2677,7 +2679,8 @@ static bool bond_ab_arp_probe(struct bonding *bond)
|
|
|
if (slave->link_failure_count < UINT_MAX)
|
|
|
slave->link_failure_count++;
|
|
|
|
|
|
- bond_set_slave_inactive_flags(slave);
|
|
|
+ bond_set_slave_inactive_flags(slave,
|
|
|
+ BOND_SLAVE_NOTIFY_LATER);
|
|
|
|
|
|
pr_info("%s: backup interface %s is now down.\n",
|
|
|
bond->dev->name, slave->dev->name);
|
|
@@ -2689,26 +2692,31 @@ static bool bond_ab_arp_probe(struct bonding *bond)
|
|
|
if (!new_slave && before)
|
|
|
new_slave = before;
|
|
|
|
|
|
- if (!new_slave) {
|
|
|
- rtnl_unlock();
|
|
|
- return true;
|
|
|
- }
|
|
|
+ if (!new_slave)
|
|
|
+ goto check_state;
|
|
|
|
|
|
new_slave->link = BOND_LINK_BACK;
|
|
|
- bond_set_slave_active_flags(new_slave);
|
|
|
+ bond_set_slave_active_flags(new_slave, BOND_SLAVE_NOTIFY_LATER);
|
|
|
bond_arp_send_all(bond, new_slave);
|
|
|
new_slave->jiffies = jiffies;
|
|
|
rcu_assign_pointer(bond->current_arp_slave, new_slave);
|
|
|
- rtnl_unlock();
|
|
|
|
|
|
- return true;
|
|
|
+check_state:
|
|
|
+ bond_for_each_slave_rcu(bond, slave, iter) {
|
|
|
+ if (slave->should_notify) {
|
|
|
+ should_notify_rtnl = BOND_SLAVE_NOTIFY_NOW;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return should_notify_rtnl;
|
|
|
}
|
|
|
|
|
|
static void bond_activebackup_arp_mon(struct work_struct *work)
|
|
|
{
|
|
|
struct bonding *bond = container_of(work, struct bonding,
|
|
|
arp_work.work);
|
|
|
- bool should_notify_peers = false, should_commit = false;
|
|
|
+ bool should_notify_peers = false;
|
|
|
+ bool should_notify_rtnl = false;
|
|
|
int delta_in_ticks;
|
|
|
|
|
|
delta_in_ticks = msecs_to_jiffies(bond->params.arp_interval);
|
|
@@ -2717,11 +2725,12 @@ static void bond_activebackup_arp_mon(struct work_struct *work)
|
|
|
goto re_arm;
|
|
|
|
|
|
rcu_read_lock();
|
|
|
+
|
|
|
should_notify_peers = bond_should_notify_peers(bond);
|
|
|
- should_commit = bond_ab_arp_inspect(bond);
|
|
|
- rcu_read_unlock();
|
|
|
|
|
|
- if (should_commit) {
|
|
|
+ if (bond_ab_arp_inspect(bond)) {
|
|
|
+ rcu_read_unlock();
|
|
|
+
|
|
|
/* Race avoidance with bond_close flush of workqueue */
|
|
|
if (!rtnl_trylock()) {
|
|
|
delta_in_ticks = 1;
|
|
@@ -2730,23 +2739,28 @@ static void bond_activebackup_arp_mon(struct work_struct *work)
|
|
|
}
|
|
|
|
|
|
bond_ab_arp_commit(bond);
|
|
|
+
|
|
|
rtnl_unlock();
|
|
|
+ rcu_read_lock();
|
|
|
}
|
|
|
|
|
|
- if (!bond_ab_arp_probe(bond)) {
|
|
|
- /* rtnl locking failed, re-arm */
|
|
|
- delta_in_ticks = 1;
|
|
|
- should_notify_peers = false;
|
|
|
- }
|
|
|
+ should_notify_rtnl = bond_ab_arp_probe(bond);
|
|
|
+ rcu_read_unlock();
|
|
|
|
|
|
re_arm:
|
|
|
if (bond->params.arp_interval)
|
|
|
queue_delayed_work(bond->wq, &bond->arp_work, delta_in_ticks);
|
|
|
|
|
|
- if (should_notify_peers) {
|
|
|
+ if (should_notify_peers || should_notify_rtnl) {
|
|
|
if (!rtnl_trylock())
|
|
|
return;
|
|
|
- call_netdevice_notifiers(NETDEV_NOTIFY_PEERS, bond->dev);
|
|
|
+
|
|
|
+ if (should_notify_peers)
|
|
|
+ call_netdevice_notifiers(NETDEV_NOTIFY_PEERS,
|
|
|
+ bond->dev);
|
|
|
+ if (should_notify_rtnl)
|
|
|
+ bond_slave_state_notify(bond);
|
|
|
+
|
|
|
rtnl_unlock();
|
|
|
}
|
|
|
}
|
|
@@ -3046,9 +3060,11 @@ static int bond_open(struct net_device *bond_dev)
|
|
|
bond_for_each_slave(bond, slave, iter) {
|
|
|
if ((bond->params.mode == BOND_MODE_ACTIVEBACKUP)
|
|
|
&& (slave != bond->curr_active_slave)) {
|
|
|
- bond_set_slave_inactive_flags(slave);
|
|
|
+ bond_set_slave_inactive_flags(slave,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
} else {
|
|
|
- bond_set_slave_active_flags(slave);
|
|
|
+ bond_set_slave_active_flags(slave,
|
|
|
+ BOND_SLAVE_NOTIFY_NOW);
|
|
|
}
|
|
|
}
|
|
|
read_unlock(&bond->curr_slave_lock);
|