Skip to content

Commit 6fde8f0

Browse files
dingtianhongdavem330
authored andcommitted
bonding: fix locking in bond_loadbalance_arp_mon()
The commit 1d3ee88 (bonding: add netlink attributes to slave link dev) has add rtmsg_ifinfo() in bond_set_active_slave() and bond_set_backup_slave(), so the two function need to called in RTNL lock, but bond_loadbalance_arp_mon() only calling these functions in RCU, warning message will occurs. fix this by add a new function bond_slave_state_change(), which will reset the slave's state after slave link check, so remove the bond_set_xxx_slave() from the cycle and only record the slave_state_changed, this will call the new function to set all slaves to new state in RTNL later. Cc: Jay Vosburgh <[email protected]> Cc: Veaceslav Falico <[email protected]> Cc: Andy Gospodarek <[email protected]> Signed-off-by: Ding Tianhong <[email protected]> Signed-off-by: David S. Miller <[email protected]>
1 parent 93e14b6 commit 6fde8f0

File tree

2 files changed

+30
-12
lines changed

2 files changed

+30
-12
lines changed

drivers/net/bonding/bond_main.c

+17-12
Original file line numberDiff line numberDiff line change
@@ -2346,7 +2346,7 @@ static void bond_loadbalance_arp_mon(struct work_struct *work)
23462346
arp_work.work);
23472347
struct slave *slave, *oldcurrent;
23482348
struct list_head *iter;
2349-
int do_failover = 0;
2349+
int do_failover = 0, slave_state_changed = 0;
23502350

23512351
if (!bond_has_slaves(bond))
23522352
goto re_arm;
@@ -2370,7 +2370,7 @@ static void bond_loadbalance_arp_mon(struct work_struct *work)
23702370
bond_time_in_interval(bond, slave->dev->last_rx, 1)) {
23712371

23722372
slave->link = BOND_LINK_UP;
2373-
bond_set_active_slave(slave);
2373+
slave_state_changed = 1;
23742374

23752375
/* primary_slave has no meaning in round-robin
23762376
* mode. the window of a slave being up and
@@ -2399,7 +2399,7 @@ static void bond_loadbalance_arp_mon(struct work_struct *work)
23992399
!bond_time_in_interval(bond, slave->dev->last_rx, 2)) {
24002400

24012401
slave->link = BOND_LINK_DOWN;
2402-
bond_set_backup_slave(slave);
2402+
slave_state_changed = 1;
24032403

24042404
if (slave->link_failure_count < UINT_MAX)
24052405
slave->link_failure_count++;
@@ -2426,19 +2426,24 @@ static void bond_loadbalance_arp_mon(struct work_struct *work)
24262426

24272427
rcu_read_unlock();
24282428

2429-
if (do_failover) {
2430-
/* the bond_select_active_slave must hold RTNL
2431-
* and curr_slave_lock for write.
2432-
*/
2429+
if (do_failover || slave_state_changed) {
24332430
if (!rtnl_trylock())
24342431
goto re_arm;
2435-
block_netpoll_tx();
2436-
write_lock_bh(&bond->curr_slave_lock);
24372432

2438-
bond_select_active_slave(bond);
2433+
if (slave_state_changed) {
2434+
bond_slave_state_change(bond);
2435+
} else if (do_failover) {
2436+
/* the bond_select_active_slave must hold RTNL
2437+
* and curr_slave_lock for write.
2438+
*/
2439+
block_netpoll_tx();
2440+
write_lock_bh(&bond->curr_slave_lock);
24392441

2440-
write_unlock_bh(&bond->curr_slave_lock);
2441-
unblock_netpoll_tx();
2442+
bond_select_active_slave(bond);
2443+
2444+
write_unlock_bh(&bond->curr_slave_lock);
2445+
unblock_netpoll_tx();
2446+
}
24422447
rtnl_unlock();
24432448
}
24442449

drivers/net/bonding/bonding.h

+13
Original file line numberDiff line numberDiff line change
@@ -303,6 +303,19 @@ static inline void bond_set_backup_slave(struct slave *slave)
303303
}
304304
}
305305

306+
static inline void bond_slave_state_change(struct bonding *bond)
307+
{
308+
struct list_head *iter;
309+
struct slave *tmp;
310+
311+
bond_for_each_slave(bond, tmp, iter) {
312+
if (tmp->link == BOND_LINK_UP)
313+
bond_set_active_slave(tmp);
314+
else if (tmp->link == BOND_LINK_DOWN)
315+
bond_set_backup_slave(tmp);
316+
}
317+
}
318+
306319
static inline int bond_slave_state(struct slave *slave)
307320
{
308321
return slave->backup;

0 commit comments

Comments
 (0)