|
@@ -2313,11 +2313,11 @@ repeat:
|
|
put_pwq(pwq);
|
|
put_pwq(pwq);
|
|
|
|
|
|
/*
|
|
/*
|
|
- * Leave this pool. If keep_working() is %true, notify a
|
|
|
|
|
|
+ * Leave this pool. If need_more_worker() is %true, notify a
|
|
* regular worker; otherwise, we end up with 0 concurrency
|
|
* regular worker; otherwise, we end up with 0 concurrency
|
|
* and stalling the execution.
|
|
* and stalling the execution.
|
|
*/
|
|
*/
|
|
- if (keep_working(pool))
|
|
|
|
|
|
+ if (need_more_worker(pool))
|
|
wake_up_worker(pool);
|
|
wake_up_worker(pool);
|
|
|
|
|
|
rescuer->pool = NULL;
|
|
rescuer->pool = NULL;
|