lkml.org 
[lkml]   [2014]   [May]   [7]   [last100]   RSS Feed
Views: [wrap][no wrap]   [headers]  [forward] 
 
Messages in this thread
/
Date
From
SubjectRe: [PATCH 04/10] workqueue: destroy worker directly in the idle timeout handler
Hello, Lai.

On Wed, May 07, 2014 at 03:10:20PM +0800, Lai Jiangshan wrote:
> 1) complete() can't be called inside attach_mutex due to the worker
> shouldn't access to the pool after complete().

Sure, complete it after releasing the lock. Shutdown can't complete
before the completion gets completed, right?

> 2) put_unbound_pool() may called from get_unbound_pool(), we need to add
> an additional check and avoid the wait_for_completion() if so.
>
> +static void worker_detach_from_pool(struct worker *worker, struct worker_pool *pool)
> +{
> + bool is_last;
> +
> + mutex_lock(&pool->bind_mutex);
> + list_del(&worker->bind_entry);
> + is_last = list_empty(&worker->bind_entry);
> + mutex_unlock(&pool->bind_mutex);
> +
> + /* need some comments here */
> + if (is_last)
> + complete(&pool->workers_detached);
> +}
>
>
> @@ -3588,6 +3587,7 @@ static void put_unbound_pool(struct worker_pool *pool)
> mutex_lock(&pool->manager_mutex);
> spin_lock_irq(&pool->lock);
>
> + need_to_wait = pool->nr_workers != 0; /* it may be called from get_unbound_pool() */
> while ((worker = first_worker(pool)))
> destroy_worker(worker);
> WARN_ON(pool->nr_workers || pool->nr_idle);
> @@ -3596,6 +3596,8 @@ static void put_unbound_pool(struct worker_pool *pool)
> mutex_unlock(&pool->manager_mutex);
> mutex_unlock(&pool->manager_arb);
>
> + if (need_to_wait)
> + wait_for_completion(&pool->workers_detached);

Shouldn't it be able to wait whenever it's about to destroy non-empty
pool?

DECLARE_COMPLETION_ONSTACK(completion);

...

while ((worker = first_worker(pool))) {
destroy_worker(worker);
pool->detach_completion = &completion;
}

...
unlock;

if (pool->detach_completion)
wait_for_completion();
...

And the worker side can simply do,

struct completion *completion;

if (I'm the last worker exiting)
completion = pool->detach_completion;
unlock;

complete(completion);

Thanks.

--
tejun


\
 
 \ /
  Last update: 2014-05-07 15:41    [W:0.079 / U:1.232 seconds]
©2003-2020 Jasper Spaans|hosted at Digital Ocean and TransIP|Read the blog|Advertise on this site