[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <20171009124009.o2b6s2et6itquwyd@tardis>
Date: Mon, 9 Oct 2017 20:40:09 +0800
From: Boqun Feng <boqun.feng@...il.com>
To: Lai Jiangshan <jiangshanlai@...il.com>
Cc: LKML <linux-kernel@...r.kernel.org>,
Josef Bacik <josef@...icpanda.com>,
Peter Zijlstra <peterz@...radead.org>,
Tejun Heo <tj@...nel.org>
Subject: Re: [RFC] workqueue: Fix irq inversion deadlock in manage_workers()
On Mon, Oct 09, 2017 at 09:40:43AM +0000, Lai Jiangshan wrote:
[...]
> > Reported-by: Josef Bacik <josef@...icpanda.com>
> > Signed-off-by: Boqun Feng <boqun.feng@...il.com>
> > Cc: Peter Zijlstra <peterz@...radead.org>
> > ---
> > kernel/workqueue.c | 35 ++++++++++++++++++++++++++++++++++-
> > 1 file changed, 34 insertions(+), 1 deletion(-)
> >
> > diff --git a/kernel/workqueue.c b/kernel/workqueue.c
> > index 64d0edf428f8..2ea7b04cc48b 100644
> > --- a/kernel/workqueue.c
> > +++ b/kernel/workqueue.c
> > @@ -1997,7 +1997,40 @@ static bool manage_workers(struct worker *worker)
> > maybe_create_worker(pool);
> >
> > pool->manager = NULL;
> > +
> > + /*
> > + * Put the manager back to ->idle_list, this allows us to drop the
> > + * pool->lock safely without racing with put_unbound_pool()
> > + *
> > + * <in "manager worker" thread>
> > + * worker_thread():
> > + * spin_lock_irq(&pool->lock);
> > + * worker_leave_idle();
> > + * manage_workers(): // return true
> > + * mutex_trylock(&pool->manager_arb);
> > + * <without entering idle here>
> > + * spin_unlock_irq(&pool->lock);
> > + * mutex_unlock(&pool->manager_arb);
> > + *
> > + * put_unbound_pool():
> > + * mutex_lock(&pool->manager_arb);
> > + * spin_lock_irq(&pool->lock);
> > + * <set ILDE worker to DIE>
> > + * <the manager worker is not set to be DIE, because it's not IDLE>
> > + * ...
> > + * wait_for_completion(&pool->detach_completion);
> > + * <no one will complete() because pool->workers is not empty>
> > + *
> > + * spin_lock_irq(&pool->lock);
> > + * <pool->worklist is empty, go to sleep>
> > + *
> > + * No one is going to wake up the manager worker, even so, it won't
> > + * complete(->detach_completion), since it's not a DIE worker.
> > + */
> > + worker_enter_idle(worker);
> > + spin_unlock_irq(&pool->lock);
> > mutex_unlock(&pool->manager_arb);
> > + spin_lock_irq(&pool->lock);
> > return true;
> > }
> >
> > @@ -2202,6 +2235,7 @@ static int worker_thread(void *__worker)
> > woke_up:
> > spin_lock_irq(&pool->lock);
> >
> > +recheck:
> > /* am I supposed to die? */
> > if (unlikely(worker->flags & WORKER_DIE)) {
> > spin_unlock_irq(&pool->lock);
> > @@ -2216,7 +2250,6 @@ static int worker_thread(void *__worker)
> > }
> >
> > worker_leave_idle(worker);
>
> I think worker_leave_idle() might be called multiple times,
"Multiple times" is not a problem, the problem is unbalanced
enter/leave, right?
> which might cause bugs, since recheck is moved up.
>
And that's impossible, as we only goto recheck if manage_workers()
return true, and that means the worker got the manager_arb and set
itself idle again. So it's fine.
Regards,
Boqun
> > -recheck:
> > /* no more worker necessary? */
> > if (!need_more_worker(pool))
> > goto sleep;
> > --
> > 2.14.1
> >
Download attachment "signature.asc" of type "application/pgp-signature" (489 bytes)
Powered by blists - more mailing lists