bonding: use flush_delayed_work_sync in bond_close
Subsystems (3)
PATCH 1/1 bonding: use flush_delayed_work_sync in bond_close
The bond_close() calls cancel_delayed_work() to cancel delayed works. It, however, cannot cancel works that were already queued in workqueue. The bond_open() initializes work->data, and proccess_one_work() refers get_work_cwq(work)->wq->flags. The get_work_cwq() returns NULL when work->data has been initialized. Thus, a panic occurs.
This patch uses flush_delayed_work_sync() instead of cancel_delayed_work() in bond_close(). It cancels delayed timer and waits for work to finish execution. So, it can avoid the null pointer dereference due to the parallel executions of proccess_one_work() and initializing proccess of bond_open().
---
drivers/net/bonding/bond_main.c | 10 +++++----- 1 files changed, 5 insertions(+), 5 deletions(-)
drivers/net/bonding/bond_main.c +5 -5
@@ -3504,27 +3504,27 @@ static int bond_close(struct net_device *bond_dev)write_unlock_bh (&bond->lock);if (bond->params.miimon) {/* link check interval, in milliseconds. */ -cancel_delayed_work (&bond->mii_work); +flush_delayed_work_sync (&bond->mii_work); }if (bond->params.arp_interval) {/* arp interval, in milliseconds. */ -cancel_delayed_work (&bond->arp_work); +flush_delayed_work_sync (&bond->arp_work); }switch (bond->params.mode) {case BOND_MODE_8023AD : -cancel_delayed_work (&bond->ad_work); +flush_delayed_work_sync (&bond->ad_work);break ;case BOND_MODE_TLB :case BOND_MODE_ALB : -cancel_delayed_work (&bond->alb_work); +flush_delayed_work_sync (&bond->alb_work);break ;default :break ; }if (delayed_work_pending (&bond->mcast_work)) -cancel_delayed_work (&bond->mcast_work); +flush_delayed_work_sync (&bond->mcast_work);if (bond_is_lb (bond)) {/* Must be called only after all
Quoted 11 lines · Mitsuo Hayasaka
The
bond_close()callscancel_delayed_work()to cancel delayed works. It, however, cannot cancel works that were already queued in workqueue. Thebond_open()initializeswork->data, andproccess_one_work()refers get_work_cwq(work)->wq->flags. Theget_work_cwq()returns NULL whenwork->datahas been initialized. Thus, a panic occurs.This patch uses
flush_delayed_work_sync()instead ofcancel_delayed_work()inbond_close(). It cancels delayed timer and waits for work to finish execution. So, it can avoid the null pointer dereference due to the parallel executions ofproccess_one_work()and initializing proccess ofbond_open().
I'm setting up to test this. I have a dim recollection that we
tried this some years ago, and there was a different deadlock that manifested through the flush path. Perhaps changes since then have removed that problem.
-J
Quoted 38 lines
Signed-off-by Mitsuo Hayasaka <[email protected]>Reviewed-by WANG Cong <[email protected]>Cc Jay Vosburgh <[email protected]>Cc Andy Gospodarek <[email protected]>Cc WANG Cong <[email protected]>---
drivers/net/bonding/bond_main.c| 10 +++++-----1 files changed, 5 insertions(+), 5 deletions(-)drivers/net/bonding/bond_main.c +4
-4@@ -3504,27 +3504,27 @@ static int bond_close(struct net_device *bond_dev)write_unlock_bh (&bond->lock);if (bond->params.miimon) {/* link check interval, in milliseconds. */ -cancel_delayed_work (&bond->mii_work); +flush_delayed_work_sync (&bond->mii_work); }if (bond->params.arp_interval) {/* arp interval, in milliseconds. */ -cancel_delayed_work (&bond->arp_work); +flush_delayed_work_sync (&bond->arp_work); }switch (bond->params.mode) {case BOND_MODE_8023AD : -cancel_delayed_work (&bond->ad_work); +flush_delayed_work_sync (&bond->ad_work);break ;case BOND_MODE_TLB :case BOND_MODE_ALB : -cancel_delayed_work (&bond->alb_work); +flush_delayed_work_sync (&bond->alb_work);break ;
drivers/net/bonding/bond_main.c static int bond_close(struct net_device *bond_dev) · line 3530
Quoted 10 lines
drivers/net/bonding/bond_main.c +1
-1default :break ; }if (delayed_work_pending (&bond->mcast_work)) -cancel_delayed_work (&bond->mcast_work); +flush_delayed_work_sync (&bond->mcast_work);if (bond_is_lb (bond)) {/* Must be called only after all
---
-Jay Vosburgh, IBM Linux Technology Center, [email protected]
Quoted 14 lines · On Wed, 19 Oct 2011 11:01:02 -0700 Jay Vosburgh <[email protected]> wrote:
Quoted 11 lines · Mitsuo Hayasaka
The
bond_close()callscancel_delayed_work()to cancel delayed works. It, however, cannot cancel works that were already queued in workqueue. Thebond_open()initializeswork->data, andproccess_one_work()refers get_work_cwq(work)->wq->flags. Theget_work_cwq()returns NULL whenwork->datahas been initialized. Thus, a panic occurs.This patch uses
flush_delayed_work_sync()instead ofcancel_delayed_work()inbond_close(). It cancels delayed timer and waits for work to finish execution. So, it can avoid the null pointer dereference due to the parallel executions ofproccess_one_work()and initializing proccess ofbond_open().
Quoted 6 lines
I'm setting up to test this. I have a dim recollection that we
tried this some years ago, and there was a different deadlock that manifested through the flush path. Perhaps changes since then have removed that problem.-J
Won't this deadlock on RTNL. The problem is that:
CPU0 CPU1
rtnl_lock
bond_close
delayed_work
mii_work
read_lock(bond->lock);
read_unlock(bond->lock);
rtnl_lock... waiting for CPU0
flush_delayed_work_sync
waiting for delayed_work to finish...Quoted 26 lines · Stephen Hemminger
Quoted 14 lines · On Wed, 19 Oct 2011 11:01:02 -0700 Jay Vosburgh <[email protected]> wrote:
Quoted 11 lines · Mitsuo Hayasaka
The
bond_close()callscancel_delayed_work()to cancel delayed works. It, however, cannot cancel works that were already queued in workqueue. Thebond_open()initializeswork->data, andproccess_one_work()refers get_work_cwq(work)->wq->flags. Theget_work_cwq()returns NULL whenwork->datahas been initialized. Thus, a panic occurs.This patch uses
flush_delayed_work_sync()instead ofcancel_delayed_work()inbond_close(). It cancels delayed timer and waits for work to finish execution. So, it can avoid the null pointer dereference due to the parallel executions ofproccess_one_work()and initializing proccess ofbond_open().Quoted 6 lines
I'm setting up to test this. I have a dim recollection that we
tried this some years ago, and there was a different deadlock that manifested through the flush path. Perhaps changes since then have removed that problem.-JWon't this deadlock on RTNL. The problem is that:
Quoted 10 lines
CPU0 CPU1
rtnl_lock
bond_close
delayed_work
mii_work
read_lock(bond->lock);read_unlock(bond->lock);rtnl_lock... waiting for CPU0
flush_delayed_work_sync
waiting fordelayed_workto finish...
Yah, that was it. We discussed this a couple of years ago in
regards to a similar patch:
http://lists.openwall.net/netdev/2009/12/17/3
The short version is that we could rework the rtnl_lock inside
the montiors to be conditional and retry on failure (where "retry" means "reschedule the work and try again later," not "spin retrying on rtnl"). That should permit the use of flush or cancel to terminate the work items.
I'll fiddle with it some later today and see if that seems
viable.
-J
---
-Jay Vosburgh, IBM Linux Technology Center, [email protected]
Quoted 42 lines · Jay Vosburgh
Quoted 26 lines · Stephen Hemminger
Quoted 14 lines · On Wed, 19 Oct 2011 11:01:02 -0700 Jay Vosburgh <[email protected]> wrote:
Quoted 11 lines · Mitsuo Hayasaka
The
bond_close()callscancel_delayed_work()to cancel delayed works. It, however, cannot cancel works that were already queued in workqueue. Thebond_open()initializeswork->data, andproccess_one_work()refers get_work_cwq(work)->wq->flags. Theget_work_cwq()returns NULL whenwork->datahas been initialized. Thus, a panic occurs.This patch uses
flush_delayed_work_sync()instead ofcancel_delayed_work()inbond_close(). It cancels delayed timer and waits for work to finish execution. So, it can avoid the null pointer dereference due to the parallel executions ofproccess_one_work()and initializing proccess ofbond_open().Quoted 6 lines
I'm setting up to test this. I have a dim recollection that we tried this some years ago, and there was a different deadlock that manifested through the flush path. Perhaps changes since then have removed that problem.
-J
Won't this deadlock on RTNL. The problem is that:
Quoted 10 lines
CPU0 CPU1
rtnl_lock
bond_close
delayed_work
mii_workread_lock(bond->lock);read_unlock(bond->lock);rtnl_lock... waiting for CPU0flush_delayed_work_sync
waiting fordelayed_workto finish...Yah, that was it. We discussed this a couple of years ago in regards to a similar patch:
Quoted 7 lines
http://lists.openwall.net/netdev/2009/12/17/3
The short version is that we could rework the
rtnl_lockinside the montiors to be conditional and retry on failure (where "retry" means "reschedule the work and try again later," not "spin retrying on rtnl"). That should permit the use of flush or cancel to terminate the work items.
Yes? Even if we use rtnl_trylock(), doesn't flush_delayed_work_sync() still queue the pending delayed work and wait for it to be finished?
Maybe I am too blind, why do we need rtnl_lock for cancel_delayed_work() inside bond_close()?
Thanks.
Quoted 45 lines · Américo Wang
Quoted 44 lines · Jay Vosburgh
Quoted 26 lines · Stephen Hemminger
Quoted 14 lines · On Wed, 19 Oct 2011 11:01:02 -0700 Jay Vosburgh <[email protected]> wrote:
Quoted 11 lines · Mitsuo Hayasaka
The
bond_close()callscancel_delayed_work()to cancel delayed works. It, however, cannot cancel works that were already queued in workqueue. Thebond_open()initializeswork->data, andproccess_one_work()refers get_work_cwq(work)->wq->flags. Theget_work_cwq()returns NULL whenwork->datahas been initialized. Thus, a panic occurs.This patch uses
flush_delayed_work_sync()instead ofcancel_delayed_work()inbond_close(). It cancels delayed timer and waits for work to finish execution. So, it can avoid the null pointer dereference due to the parallel executions ofproccess_one_work()and initializing proccess ofbond_open().Quoted 6 lines
I'm setting up to test this. I have a dim recollection that we tried this some years ago, and there was a different deadlock that manifested through the flush path. Perhaps changes since then have removed that problem.
-J
Won't this deadlock on RTNL. The problem is that:
Quoted 10 lines
CPU0 CPU1
rtnl_lock
bond_close
delayed_work
mii_workread_lock(bond->lock);read_unlock(bond->lock);rtnl_lock... waiting for CPU0flush_delayed_work_sync
waiting fordelayed_workto finish...Yah, that was it. We discussed this a couple of years ago in regards to a similar patch:
Quoted 8 lines
Quoted 5 lines
The short version is that we could rework the
rtnl_lockinside the montiors to be conditional and retry on failure (where "retry" means "reschedule the work and try again later," not "spin retrying on rtnl"). That should permit the use of flush or cancel to terminate the work items.Yes? Even if we use
rtnl_trylock(), doesn'tflush_delayed_work_sync()still queue the pending delayed work and wait for it to be finished?
Yes, it does. The original patch wants to use flush instead of
cancel to wait for the work to finish, because there's evidently a possibility of getting back into bond_open before the work item executes, and bond_open would reinitialize the work queue and corrupt the queued work item.
The original patch series, and recipe for destruction, is here:
http://www.spinics.net/lists/netdev/msg176382.html
I've been unable to reproduce the work queue panic locally,
although it sounds plausible.
Mitsuo: can you provide the precise bonding configuration you're
using to induce the problem? Driver options, number and type of slaves, etc.
Quoted 2 lines
Maybe I am too blind, why do we need
rtnl_lockforcancel_delayed_work()insidebond_close()?
We don't need RTNL for cancel/flush. However, bond_close is anndo_stop operation, and is called in the dev_close path, which always occurs under RTNL. The mii / arp monitor work functions separately acquire RTNL if they need to perform various failover related operations.
I'm working on a patch that should resolve the mii / arp monitor
RTNL problem as I described above (if rtnl_trylock fails, punt and reschedule the work). I need to rearrange the netdev_bonding_change stuff a bit as well, since it acquires RTNL separately.
Once these changes are made to mii / arp monitor, thenbond_close can call flush instead of cancel, which should eliminate the original problem described at the top.
-J
---
-Jay Vosburgh, IBM Linux Technology Center, [email protected]
Quoted 82 lines · Jay Vosburgh
Quoted 45 lines · Américo Wang
Quoted 44 lines · Jay Vosburgh
Quoted 26 lines · Stephen Hemminger
Quoted 14 lines · On Wed, 19 Oct 2011 11:01:02 -0700 Jay Vosburgh <[email protected]> wrote:
Quoted 11 lines · Mitsuo Hayasaka
The
bond_close()callscancel_delayed_work()to cancel delayed works. It, however, cannot cancel works that were already queued in workqueue. Thebond_open()initializeswork->data, andproccess_one_work()refers get_work_cwq(work)->wq->flags. Theget_work_cwq()returns NULL whenwork->datahas been initialized. Thus, a panic occurs.This patch uses
flush_delayed_work_sync()instead ofcancel_delayed_work()inbond_close(). It cancels delayed timer and waits for work to finish execution. So, it can avoid the null pointer dereference due to the parallel executions ofproccess_one_work()and initializing proccess ofbond_open().Quoted 6 lines
I'm setting up to test this. I have a dim recollection that we tried this some years ago, and there was a different deadlock that manifested through the flush path. Perhaps changes since then have removed that problem.
-J
Won't this deadlock on RTNL. The problem is that:
Quoted 10 lines
CPU0 CPU1
rtnl_lock
bond_close
delayed_work
mii_workread_lock(bond->lock);read_unlock(bond->lock);rtnl_lock... waiting for CPU0flush_delayed_work_sync
waiting fordelayed_workto finish...Yah, that was it. We discussed this a couple of years ago in regards to a similar patch:
Quoted 8 lines
Quoted 5 lines
The short version is that we could rework the
rtnl_lockinside the montiors to be conditional and retry on failure (where "retry" means "reschedule the work and try again later," not "spin retrying on rtnl"). That should permit the use of flush or cancel to terminate the work items.Yes? Even if we use
rtnl_trylock(), doesn'tflush_delayed_work_sync()still queue the pending delayed work and wait for it to be finished?Yes, it does. The original patch wants to use flush instead of
cancel to wait for the work to finish, because there's evidently a possibility of getting back intobond_openbefore the work item executes, andbond_openwould reinitialize the work queue and corrupt the queued work item.The original patch series, and recipe for destruction, is here:
http://www.spinics.net/lists/netdev/msg176382.html
I've been unable to reproduce the work queue panic locally,
although it sounds plausible.Mitsuo: can you provide the precise bonding configuration you're
using to induce the problem? Driver options, number and type of slaves, etc.Quoted 2 lines
Maybe I am too blind, why do we need
rtnl_lockforcancel_delayed_work()insidebond_close()?We don't need RTNL for cancel/flush. However,
bond_closeis anndo_stopoperation, and is called in thedev_closepath, which always occurs under RTNL. The mii / arp monitor work functions separately acquire RTNL if they need to perform various failover related operations.
Quoted 8 lines
I'm working on a patch that should resolve the mii / arp monitor
RTNL problem as I described above (ifrtnl_trylockfails, punt and reschedule the work). I need to rearrange thenetdev_bonding_changestuff a bit as well, since it acquires RTNL separately.Once these changes are made to mii / arp monitor, then
bond_closecan call flush instead of cancel, which should eliminate the original problem described at the top.
Just an update: there are three functions that may deadlock if
the cancel work calls are changed to flush_sync. There are two rtnl_lock calls in each of the bond_mii_monitor and bond_activebackup_arp_mon functions, and one more in the bond_alb_monitor.
Still testing to make sure I haven't missed anything, and I
still haven't been able to reproduce Mitsuo's original failure.
-J
---
-Jay Vosburgh, IBM Linux Technology Center, [email protected]
Quoted 93 lines · Jay Vosburgh
Quoted 82 lines · Jay Vosburgh
Quoted 45 lines · Américo Wang
Quoted 44 lines · Jay Vosburgh
Quoted 26 lines · Stephen Hemminger
Quoted 14 lines · On Wed, 19 Oct 2011 11:01:02 -0700 Jay Vosburgh <[email protected]> wrote:
Quoted 11 lines · Mitsuo Hayasaka
The
bond_close()callscancel_delayed_work()to cancel delayed works. It, however, cannot cancel works that were already queued in workqueue. Thebond_open()initializeswork->data, andproccess_one_work()refers get_work_cwq(work)->wq->flags. Theget_work_cwq()returns NULL whenwork->datahas been initialized. Thus, a panic occurs.This patch uses
flush_delayed_work_sync()instead ofcancel_delayed_work()inbond_close(). It cancels delayed timer and waits for work to finish execution. So, it can avoid the null pointer dereference due to the parallel executions ofproccess_one_work()and initializing proccess ofbond_open().Quoted 6 lines
I'm setting up to test this. I have a dim recollection that we
tried this some years ago, and there was a different deadlock that manifested through the flush path. Perhaps changes since then have removed that problem.-JWon't this deadlock on RTNL. The problem is that:
Quoted 10 lines
CPU0 CPU1
rtnl_lock
bond_close
delayed_work
mii_work
read_lock(bond->lock);read_unlock(bond->lock);rtnl_lock... waiting for CPU0
flush_delayed_work_sync
waiting fordelayed_workto finish...Yah, that was it. We discussed this a couple of years ago in
regards to a similar patch:Quoted 8 lines
Quoted 5 lines
The short version is that we could rework the
rtnl_lockinside
the montiors to be conditional and retry on failure (where "retry" means "reschedule the work and try again later," not "spin retrying on rtnl"). That should permit the use of flush or cancel to terminate the work items.Yes? Even if we use
rtnl_trylock(), doesn'tflush_delayed_work_sync()still queue the pending delayed work and wait for it to be finished?Yes, it does. The original patch wants to use flush instead of
cancel to wait for the work to finish, because there's evidently a possibility of getting back intobond_openbefore the work item executes, andbond_openwould reinitialize the work queue and corrupt the queued work item.The original patch series, and recipe for destruction, is here:
http://www.spinics.net/lists/netdev/msg176382.html
I've been unable to reproduce the work queue panic locally,
although it sounds plausible.Mitsuo: can you provide the precise bonding configuration you're
using to induce the problem? Driver options, number and type of slaves, etc.Quoted 2 lines
Maybe I am too blind, why do we need
rtnl_lockforcancel_delayed_work()insidebond_close()?We don't need RTNL for cancel/flush. However,
bond_closeis anndo_stopoperation, and is called in thedev_closepath, which always occurs under RTNL. The mii / arp monitor work functions separately acquire RTNL if they need to perform various failover related operations.Quoted 8 lines
I'm working on a patch that should resolve the mii / arp monitor
RTNL problem as I described above (ifrtnl_trylockfails, punt and reschedule the work). I need to rearrange thenetdev_bonding_changestuff a bit as well, since it acquires RTNL separately.Once these changes are made to mii / arp monitor, then
bond_closecan call flush instead of cancel, which should eliminate the original problem described at the top.
Quoted 8 lines
Just an update: there are three functions that may deadlock if
the cancel work calls are changed toflush_sync. There are twortnl_lockcalls in each of thebond_mii_monitorandbond_activebackup_arp_monfunctions, and one more in thebond_alb_monitor.Still testing to make sure I haven't missed anything, and I
still haven't been able to reproduce Mitsuo's original failure.
The interval of mii_mon was set to 1 to reproduce this bug easily and the 802.3ad mode was used. Then, I executed the following command.
# while true; do ifconfig bond0 down; done & # while true; do ifconfig bond0 up; done &
This bug rarely occurs since it is the severe timing problem. I found that it is more easily to reproduce this bug when using guest OS.
For example, it took one to three days for me to reproduce it on host OS, but some hours on guest OS.
Thanks.
Quoted 7 lines
-J---
-Jay Vosburgh, IBM Linux Technology Center, [email protected]
HAYASAKA Mitsuo <[email protected]> wrote:
[...]
Quoted 11 lines
The interval of
mii_monwas set to 1 to reproduce this bug easily and the 802.3ad mode was used. Then, I executed the following command.# while true; do ifconfig bond0 down; done & # while true; do ifconfig bond0 up; done &This bug rarely occurs since it is the severe timing problem. I found that it is more easily to reproduce this bug when using guest OS.
For example, it took one to three days for me to reproduce it on host OS, but some hours on guest OS.
Could you test this patch and see if it resolves the problem?
This patch does a few things:
All of the monitor functions that run on work queues are
modified to never unconditionally acquire RTNL; all will reschedule the work and return if rtnl_trylock fails. This covers bond_mii_monitor, bond_activebackup_arp_mon, and bond_alb_monitor.
The "clear out the work queues" calls in bond_close andbond_uninit now call cancel_delayed_work_sync, which should either delete a pending work item, or wait for an executing item to complete. I chose cancel_ over the original patch's flush_ because we just want the work queue stopped. We don't need to have any pending items execute if they're not already running.
Also in reference to the previous, I'm not sure if we still need
to check for delayed_work_pending, but I've left those checks in place.
Remove the "kill_timers" field and all references to it. Ifcancel_delayed_work_sync is safe to use, we do not need an extra sentinel.
Lastly, for testing purposes only, the bond_alb_monitor in this
patch includes an unconditional call to rtnl_trylock(); this is an artifical way to make the race in that function easier to test for, because the real race is very difficult to hit.
This patch is against net-next as of yesterday. Comments? -J
drivers/net/bonding/bond_3ad.c +2 -6
@@ -2110,9 +2110,6 @@ void bond_3ad_state_machine_handler(struct work_struct *work)read_lock (&bond->lock); -if (bond->kill_timers) - goto out; -//check if there are any slaves if (bond->slave_cnt ==0 ) goto re_arm;
@@ -2161,9 +2158,8 @@ void bond_3ad_state_machine_handler(struct work_struct *work) } re_arm: -if (!bond->kill_timers) -queue_delayed_work (bond->wq, &bond->ad_work, ad_delta_in_ticks); -out: +queue_delayed_work (bond->wq, &bond->ad_work, ad_delta_in_ticks); +read_unlock (&bond->lock); }
drivers/net/bonding/bond_alb.c +14 -8
@@ -1343,10 +1343,6 @@ void bond_alb_monitor(struct work_struct *work)read_lock (&bond->lock); -if (bond->kill_timers) { - goto out; - } -if (bond->slave_cnt ==0 ) { bond_info->tx_rebalance_counter =0 ; bond_info->lp_counter =0 ;
@@ -1394,6 +1390,14 @@ void bond_alb_monitor(struct work_struct *work) bond_info->tx_rebalance_counter =0 ; } +/* XXX - unconditional attempt at RTNL for testing purposes, as +* normal case, below, is difficult to induce. +*/ +read_unlock (&bond->lock); +if (rtnl_trylock ()) +rtnl_unlock (); +read_lock (&bond->lock); +/* handle rlb stuff */ if (bond_info->rlb_enabled) { if (bond_info->primary_is_promisc &&
@@ -1404,7 +1408,10 @@ void bond_alb_monitor(struct work_struct *work)* nothing else. */ read_unlock (&bond->lock); -rtnl_lock (); +if (!rtnl_trylock ()) { +read_lock (&bond->lock); + goto re_arm; + } bond_info->rlb_promisc_timeout_counter =0 ;
@@ -1440,9 +1447,8 @@ void bond_alb_monitor(struct work_struct *work) } re_arm: -if (!bond->kill_timers) -queue_delayed_work (bond->wq, &bond->alb_work, alb_delta_in_ticks); -out: +queue_delayed_work (bond->wq, &bond->alb_work, alb_delta_in_ticks); +read_unlock (&bond->lock); }
drivers/net/bonding/bond_main.c +54 -46
220 lines not on this page · raw message
drivers/net/bonding/bonding.h +0 -1
@@ -222,7 +222,6 @@ struct bonding { struct slave *);rwlock_t lock;rwlock_t curr_slave_lock; -s8 kill_timers;u8 send_peer_notif;s8 setup_by_slave;s8 igmp_retrans;
---
-Jay Vosburgh, IBM Linux Technology Center, [email protected]
HAYASAKA Mitsuo
Tested-byHi Joy,
I checked your patch, and any problems have not been observed for almost one day although I could reproduce the BUG in the latest net-next without it.
I think this patch works well.
Quoted 382 lines · Jay Vosburgh
HAYASAKA Mitsuo <[email protected]> wrote:
[...]Quoted 11 lines
The interval of
mii_monwas set to 1 to reproduce this bug easily and the 802.3ad mode was used. Then, I executed the following command.# while true; do ifconfig bond0 down; done & # while true; do ifconfig bond0 up; done &This bug rarely occurs since it is the severe timing problem. I found that it is more easily to reproduce this bug when using guest OS.
For example, it took one to three days for me to reproduce it on host OS, but some hours on guest OS.
Could you test this patch and see if it resolves the problem?
This patch does a few things:
All of the monitor functions that run on work queues are
modified to never unconditionally acquire RTNL; all will reschedule the work and return ifrtnl_trylockfails. This coversbond_mii_monitor,bond_activebackup_arp_mon, andbond_alb_monitor.The "clear out the work queues" calls in
bond_closeandbond_uninitnow callcancel_delayed_work_sync, which should either delete a pending work item, or wait for an executing item to complete. I chosecancel_over the original patch'sflush_because we just want the work queue stopped. We don't need to have any pending items execute if they're not already running.Also in reference to the previous, I'm not sure if we still need
to check fordelayed_work_pending, but I've left those checks in place.Remove the "
kill_timers" field and all references to it. Ifcancel_delayed_work_syncis safe to use, we do not need an extra sentinel.Lastly, for testing purposes only, the
bond_alb_monitorin this
patch includes an unconditional call tortnl_trylock(); this is an artifical way to make the race in that function easier to test for, because the real race is very difficult to hit.This patch is against net-next as of yesterday. Comments? -Jdrivers/net/bonding/bond_3ad.c +2
-6@@ -2110,9 +2110,6 @@ void bond_3ad_state_machine_handler(struct work_struct *work)read_lock (&bond->lock); -if (bond->kill_timers) - goto out; -//check if there are any slaves if (bond->slave_cnt ==0 ) goto re_arm;@@ -2161,9 +2158,8 @@ void bond_3ad_state_machine_handler(struct work_struct *work) } re_arm: -if (!bond->kill_timers) -queue_delayed_work (bond->wq, &bond->ad_work, ad_delta_in_ticks); -out: +queue_delayed_work (bond->wq, &bond->ad_work, ad_delta_in_ticks); +read_unlock (&bond->lock); }drivers/net/bonding/bond_alb.c +14
-8@@ -1343,10 +1343,6 @@ void bond_alb_monitor(struct work_struct *work)read_lock (&bond->lock); -if (bond->kill_timers) { - goto out; - } -if (bond->slave_cnt ==0 ) { bond_info->tx_rebalance_counter =0 ; bond_info->lp_counter =0 ;@@ -1394,6 +1390,14 @@ void bond_alb_monitor(struct work_struct *work) bond_info->tx_rebalance_counter =0 ; } +/* XXX - unconditional attempt at RTNL for testing purposes, as +* normal case, below, is difficult to induce. +*/ +read_unlock (&bond->lock); +if (rtnl_trylock ()) +rtnl_unlock (); +read_lock (&bond->lock); +/* handle rlb stuff */ if (bond_info->rlb_enabled) { if (bond_info->primary_is_promisc &&@@ -1404,7 +1408,10 @@ void bond_alb_monitor(struct work_struct *work)* nothing else. */ read_unlock (&bond->lock); -rtnl_lock (); +if (!rtnl_trylock ()) { +read_lock (&bond->lock); + goto re_arm; + } bond_info->rlb_promisc_timeout_counter =0 ;@@ -1440,9 +1447,8 @@ void bond_alb_monitor(struct work_struct *work) } re_arm: -if (!bond->kill_timers) -queue_delayed_work (bond->wq, &bond->alb_work, alb_delta_in_ticks); -out: +queue_delayed_work (bond->wq, &bond->alb_work, alb_delta_in_ticks); +read_unlock (&bond->lock); }drivers/net/bonding/bond_main.c +54
-46@@ -774,9 +774,6 @@ static void bond_resend_igmp_join_requests(struct bonding *bond)read_lock (&bond->lock); -if (bond->kill_timers) - goto out; -/* rejoin all groups on bond device */ __bond_resend_igmp_join_requests (bond->dev);@@ -790,9 +787,9 @@ static void bond_resend_igmp_join_requests(struct bonding *bond)__bond_resend_igmp_join_requests (vlan_dev); } -if ((--bond->igmp_retrans >0 ) && !bond->kill_timers) +if (--bond->igmp_retrans >0 )queue_delayed_work (bond->wq, &bond->mcast_work,HZ /5 ); -out: +read_unlock (&bond->lock); }@@ -2518,19 +2515,26 @@ void bond_mii_monitor(struct work_struct *work) struct bonding *bond = container_of(work, struct bonding, mii_work.work);bool should_notify_peers = false; +unsigned long delay;read_lock (&bond->lock); -if (bond->kill_timers) - goto out; + + delay =msecs_to_jiffies (bond->params.miimon);if (bond->slave_cnt ==0 ) goto re_arm; - should_notify_peers =bond_should_notify_peers (bond); -if (bond_miimon_inspect (bond)) {read_unlock (&bond->lock); -rtnl_lock (); + +/* Race avoidance with bond_close flush of workqueue */ +if (!rtnl_trylock ()) { +read_lock (&bond->lock); + delay =1 ; + should_notify_peers = false; + goto re_arm; + } +read_lock (&bond->lock);bond_miimon_commit (bond);@@ -2540,15 +2544,21 @@ void bond_mii_monitor(struct work_struct *work)read_lock (&bond->lock); } + should_notify_peers =bond_should_notify_peers (bond); + re_arm: -if (bond->params.miimon && !bond->kill_timers) -queue_delayed_work (bond->wq, &bond->mii_work, -msecs_to_jiffies (bond->params.miimon)); -out: +if (bond->params.miimon) +queue_delayed_work (bond->wq, &bond->mii_work, delay); +read_unlock (&bond->lock);if (should_notify_peers) { -rtnl_lock (); +if (!rtnl_trylock ()) { +read_lock (&bond->lock); + bond->send_peer_notif++; +read_unlock (&bond->lock); +return ; + }netdev_bonding_change (bond->dev,NETDEV_NOTIFY_PEERS );rtnl_unlock (); }@@ -2790,9 +2800,6 @@ void bond_loadbalance_arp_mon(struct work_struct *work) delta_in_ticks =msecs_to_jiffies (bond->params.arp_interval); -if (bond->kill_timers) - goto out; -if (bond->slave_cnt ==0 ) goto re_arm;@@ -2889,9 +2896,9 @@ void bond_loadbalance_arp_mon(struct work_struct *work) } re_arm: -if (bond->params.arp_interval && !bond->kill_timers) +if (bond->params.arp_interval)queue_delayed_work (bond->wq, &bond->arp_work, delta_in_ticks); -out: +read_unlock (&bond->lock); }@@ -3132,9 +3139,6 @@ void bond_activebackup_arp_mon(struct work_struct *work)read_lock (&bond->lock); -if (bond->kill_timers) - goto out; - delta_in_ticks =msecs_to_jiffies (bond->params.arp_interval);if (bond->slave_cnt ==0 )@@ -3144,7 +3148,15 @@ void bond_activebackup_arp_mon(struct work_struct *work)if (bond_ab_arp_inspect (bond, delta_in_ticks)) {read_unlock (&bond->lock); -rtnl_lock (); + +/* Race avoidance with bond_close flush of workqueue */ +if (!rtnl_trylock ()) { +read_lock (&bond->lock); + delta_in_ticks =1 ; + should_notify_peers = false; + goto re_arm; + } +read_lock (&bond->lock);bond_ab_arp_commit (bond, delta_in_ticks);@@ -3157,13 +3169,18 @@ void bond_activebackup_arp_mon(struct work_struct *work)bond_ab_arp_probe (bond); re_arm: -if (bond->params.arp_interval && !bond->kill_timers) +if (bond->params.arp_interval)queue_delayed_work (bond->wq, &bond->arp_work, delta_in_ticks); -out: +read_unlock (&bond->lock);if (should_notify_peers) { -rtnl_lock (); +if (!rtnl_trylock ()) { +read_lock (&bond->lock); + bond->send_peer_notif++; +read_unlock (&bond->lock); +return ; + }netdev_bonding_change (bond->dev,NETDEV_NOTIFY_PEERS );rtnl_unlock (); }@@ -3425,8 +3442,6 @@ static int bond_open(struct net_device *bond_dev)struct slave *slave;int i; - bond->kill_timers =0 ; -/* reset slave->backup and slave->inactive */ read_lock (&bond->lock);if (bond->slave_cnt >0 ) {@@ -3495,33 +3510,30 @@ static int bond_close(struct net_device *bond_dev) bond->send_peer_notif =0 ; -/* signal timers not to re-arm */ - bond->kill_timers =1 ; -write_unlock_bh (&bond->lock);if (bond->params.miimon) {/* link check interval, in milliseconds. */ -cancel_delayed_work (&bond->mii_work); +cancel_delayed_work_sync (&bond->mii_work); }if (bond->params.arp_interval) {/* arp interval, in milliseconds. */ -cancel_delayed_work (&bond->arp_work); +cancel_delayed_work_sync (&bond->arp_work); }switch (bond->params.mode) {case BOND_MODE_8023AD : -cancel_delayed_work (&bond->ad_work); +cancel_delayed_work_sync (&bond->ad_work);break ;case BOND_MODE_TLB :case BOND_MODE_ALB : -cancel_delayed_work (&bond->alb_work); +cancel_delayed_work_sync (&bond->alb_work);break ;default :break ; }if (delayed_work_pending (&bond->mcast_work)) -cancel_delayed_work (&bond->mcast_work); +cancel_delayed_work_sync (&bond->mcast_work);if (bond_is_lb (bond)) {/* Must be called only after all @@ -4368,26 +4380,22 @@ static void bond_setup(struct net_device *bond_dev)static void bond_work_cancel_all (struct bonding *bond) { -write_lock_bh (&bond->lock); - bond->kill_timers =1 ; -write_unlock_bh (&bond->lock); -if (bond->params.miimon &&delayed_work_pending (&bond->mii_work)) -cancel_delayed_work (&bond->mii_work); +cancel_delayed_work_sync (&bond->mii_work);if (bond->params.arp_interval &&delayed_work_pending (&bond->arp_work)) -cancel_delayed_work (&bond->arp_work); +cancel_delayed_work_sync (&bond->arp_work);if (bond->params.mode ==BOND_MODE_ALB &&delayed_work_pending (&bond->alb_work)) -cancel_delayed_work (&bond->alb_work); +cancel_delayed_work_sync (&bond->alb_work);if (bond->params.mode ==BOND_MODE_8023AD &&delayed_work_pending (&bond->ad_work)) -cancel_delayed_work (&bond->ad_work); +cancel_delayed_work_sync (&bond->ad_work);if (delayed_work_pending (&bond->mcast_work)) -cancel_delayed_work (&bond->mcast_work); +cancel_delayed_work_sync (&bond->mcast_work); }/* drivers/net/bonding/bonding.h +0
-2@@ -222,7 +222,6 @@ struct bonding { struct slave *);rwlock_t lock;rwlock_t curr_slave_lock; -s8 kill_timers;u8 send_peer_notif;s8 setup_by_slave;s8 igmp_retrans; ----Jay Vosburgh, IBM Linux Technology Center, [email protected]
David Miller
maintainerFrom: HAYASAKA Mitsuo <[email protected]>
Date: Fri, 28 Oct 2011 10:52:31 +0900
Quoted 7 lines
I checked your patch, and any problems have not been observed for almost one day although I could reproduce the BUG in the latest net-next without it.
I think this patch works well.
Tested-by Mitsuo Hayasaka <[email protected]>
Jay, please formally submit this patch with proper signoffs etc.
Thanks!
PATCH 1/1 bonding: eliminate bond_close race conditions
This patch resolves two sets of race conditions.
Mitsuo Hayasaka <[email protected]> reported the
first, as follows:
The bond_close() calls cancel_delayed_work() to cancel delayed works. It, however, cannot cancel works that were already queued in workqueue. The bond_open() initializes work->data, and proccess_one_work() refers get_work_cwq(work)->wq->flags. The get_work_cwq() returns NULL when work->data has been initialized. Thus, a panic occurs.
He included a patch that converted the cancel_delayed_work calls
in bond_close to flush_delayed_work_sync, which eliminated the above problem.
His patch is incorporated, at least in principle, into this
patch. In this patch, we use cancel_delayed_work_sync in place of flush_delayed_work_sync, and also convert bond_uninit in addition to bond_close.
This conversion to _sync, however, opens new races betweenbond_close and three periodically executing workqueue functions:bond_mii_monitor, bond_alb_monitor and bond_activebackup_arp_mon.
The race occurs because bond_close and bond_uninit are always
called with RTNL held, and these workqueue functions may acquire RTNL to perform failover-related activities. If bond_close or bond_uninit is waiting in cancel_delayed_work_sync, deadlock occurs.
These deadlocks are resolved by having the workqueue functions
acquire RTNL conditionally. If the rtnl_trylock() fails, the functions reschedule and return immediately. For the cases that are attempting to perform link failover, a delay of 1 is used; for the other cases, the normal interval is used (as those activities are not as time critical).
Additionally, the bond_mii_monitor function now stores the delay
in a variable (mimicing the structure of activebackup_arp_mon).
Lastly, all of the above renders the kill_timers sentinel moot,
and therefore it has been removed.
--- drivers/net/bonding/bond_3ad.c | 8 +--- drivers/net/bonding/bond_alb.c | 16 +++---- drivers/net/bonding/bond_main.c | 96 +++++++++++++++++++++------------------ drivers/net/bonding/bonding.h | 1 - 4 files changed, 61 insertions(+), 60 deletions(-)
drivers/net/bonding/bond_3ad.c +2 -6
@@ -2110,9 +2110,6 @@ void bond_3ad_state_machine_handler(struct work_struct *work)read_lock (&bond->lock); -if (bond->kill_timers) - goto out; -//check if there are any slaves if (bond->slave_cnt ==0 ) goto re_arm;
@@ -2161,9 +2158,8 @@ void bond_3ad_state_machine_handler(struct work_struct *work) } re_arm: -if (!bond->kill_timers) -queue_delayed_work (bond->wq, &bond->ad_work, ad_delta_in_ticks); -out: +queue_delayed_work (bond->wq, &bond->ad_work, ad_delta_in_ticks); +read_unlock (&bond->lock); }
drivers/net/bonding/bond_alb.c +7 -9
@@ -1343,10 +1343,6 @@ void bond_alb_monitor(struct work_struct *work)read_lock (&bond->lock); -if (bond->kill_timers) { - goto out; - } -if (bond->slave_cnt ==0 ) { bond_info->tx_rebalance_counter =0 ; bond_info->lp_counter =0 ;
@@ -1401,10 +1397,13 @@ void bond_alb_monitor(struct work_struct *work)/* * dev_set_promiscuity requires rtnl and -* nothing else. +* nothing else. Avoid race with bond_close. */ read_unlock (&bond->lock); -rtnl_lock (); +if (!rtnl_trylock ()) { +read_lock (&bond->lock); + goto re_arm; + } bond_info->rlb_promisc_timeout_counter =0 ;
@@ -1440,9 +1439,8 @@ void bond_alb_monitor(struct work_struct *work) } re_arm: -if (!bond->kill_timers) -queue_delayed_work (bond->wq, &bond->alb_work, alb_delta_in_ticks); -out: +queue_delayed_work (bond->wq, &bond->alb_work, alb_delta_in_ticks); +read_unlock (&bond->lock); }
drivers/net/bonding/bond_main.c +52 -44
215 lines not on this page · raw message
drivers/net/bonding/bonding.h +0 -1
@@ -222,7 +222,6 @@ struct bonding { struct slave *);rwlock_t lock;rwlock_t curr_slave_lock; -s8 kill_timers;u8 send_peer_notif;s8 setup_by_slave;s8 igmp_retrans;
Signature · 1 line
1.7.1
Re: [PATCH net-next] bonding: eliminate bond_close race conditions
From: Jay Vosburgh <[email protected]>
Date: Fri, 28 Oct 2011 18:42:50 -0700
Quoted 2 lines
This patch resolves two sets of race conditions.
...
Quoted 2 lines
Tested-by Mitsuo Hayasaka <[email protected]>Signed-off-by Jay Vosburgh <[email protected]>
Applied, thanks a lot Jay.