diff options
Diffstat (limited to 'kernel/workqueue.c')
-rw-r--r-- | kernel/workqueue.c | 30 |
1 files changed, 24 insertions, 6 deletions
diff --git a/kernel/workqueue.c b/kernel/workqueue.c index 09b685daee3d..6202b08f1933 100644 --- a/kernel/workqueue.c +++ b/kernel/workqueue.c | |||
@@ -1804,8 +1804,8 @@ static void pool_mayday_timeout(unsigned long __pool) | |||
1804 | struct worker_pool *pool = (void *)__pool; | 1804 | struct worker_pool *pool = (void *)__pool; |
1805 | struct work_struct *work; | 1805 | struct work_struct *work; |
1806 | 1806 | ||
1807 | spin_lock_irq(&wq_mayday_lock); /* for wq->maydays */ | 1807 | spin_lock_irq(&pool->lock); |
1808 | spin_lock(&pool->lock); | 1808 | spin_lock(&wq_mayday_lock); /* for wq->maydays */ |
1809 | 1809 | ||
1810 | if (need_to_create_worker(pool)) { | 1810 | if (need_to_create_worker(pool)) { |
1811 | /* | 1811 | /* |
@@ -1818,8 +1818,8 @@ static void pool_mayday_timeout(unsigned long __pool) | |||
1818 | send_mayday(work); | 1818 | send_mayday(work); |
1819 | } | 1819 | } |
1820 | 1820 | ||
1821 | spin_unlock(&pool->lock); | 1821 | spin_unlock(&wq_mayday_lock); |
1822 | spin_unlock_irq(&wq_mayday_lock); | 1822 | spin_unlock_irq(&pool->lock); |
1823 | 1823 | ||
1824 | mod_timer(&pool->mayday_timer, jiffies + MAYDAY_INTERVAL); | 1824 | mod_timer(&pool->mayday_timer, jiffies + MAYDAY_INTERVAL); |
1825 | } | 1825 | } |
@@ -2248,12 +2248,30 @@ repeat: | |||
2248 | * Slurp in all works issued via this workqueue and | 2248 | * Slurp in all works issued via this workqueue and |
2249 | * process'em. | 2249 | * process'em. |
2250 | */ | 2250 | */ |
2251 | WARN_ON_ONCE(!list_empty(&rescuer->scheduled)); | 2251 | WARN_ON_ONCE(!list_empty(scheduled)); |
2252 | list_for_each_entry_safe(work, n, &pool->worklist, entry) | 2252 | list_for_each_entry_safe(work, n, &pool->worklist, entry) |
2253 | if (get_work_pwq(work) == pwq) | 2253 | if (get_work_pwq(work) == pwq) |
2254 | move_linked_works(work, scheduled, &n); | 2254 | move_linked_works(work, scheduled, &n); |
2255 | 2255 | ||
2256 | process_scheduled_works(rescuer); | 2256 | if (!list_empty(scheduled)) { |
2257 | process_scheduled_works(rescuer); | ||
2258 | |||
2259 | /* | ||
2260 | * The above execution of rescued work items could | ||
2261 | * have created more to rescue through | ||
2262 | * pwq_activate_first_delayed() or chained | ||
2263 | * queueing. Let's put @pwq back on mayday list so | ||
2264 | * that such back-to-back work items, which may be | ||
2265 | * being used to relieve memory pressure, don't | ||
2266 | * incur MAYDAY_INTERVAL delay inbetween. | ||
2267 | */ | ||
2268 | if (need_to_create_worker(pool)) { | ||
2269 | spin_lock(&wq_mayday_lock); | ||
2270 | get_pwq(pwq); | ||
2271 | list_move_tail(&pwq->mayday_node, &wq->maydays); | ||
2272 | spin_unlock(&wq_mayday_lock); | ||
2273 | } | ||
2274 | } | ||
2257 | 2275 | ||
2258 | /* | 2276 | /* |
2259 | * Put the reference grabbed by send_mayday(). @pool won't | 2277 | * Put the reference grabbed by send_mayday(). @pool won't |