diff options
Diffstat (limited to 'kernel/workqueue.c')
-rw-r--r-- | kernel/workqueue.c | 20 |
1 files changed, 11 insertions, 9 deletions
diff --git a/kernel/workqueue.c b/kernel/workqueue.c index 85bd3409b9f5..b394df8beaee 100644 --- a/kernel/workqueue.c +++ b/kernel/workqueue.c | |||
@@ -1048,16 +1048,14 @@ static void cwq_dec_nr_in_flight(struct cpu_workqueue_struct *cwq, int color, | |||
1048 | * for arbitrarily long | 1048 | * for arbitrarily long |
1049 | * | 1049 | * |
1050 | * On >= 0 return, the caller owns @work's PENDING bit. To avoid getting | 1050 | * On >= 0 return, the caller owns @work's PENDING bit. To avoid getting |
1051 | * preempted while holding PENDING and @work off queue, preemption must be | 1051 | * interrupted while holding PENDING and @work off queue, irq must be |
1052 | * disabled on entry. This ensures that we don't return -EAGAIN while | 1052 | * disabled on entry. This, combined with delayed_work->timer being |
1053 | * another task is preempted in this function. | 1053 | * irqsafe, ensures that we return -EAGAIN for finite short period of time. |
1054 | * | 1054 | * |
1055 | * On successful return, >= 0, irq is disabled and the caller is | 1055 | * On successful return, >= 0, irq is disabled and the caller is |
1056 | * responsible for releasing it using local_irq_restore(*@flags). | 1056 | * responsible for releasing it using local_irq_restore(*@flags). |
1057 | * | 1057 | * |
1058 | * This function is safe to call from any context other than IRQ handler. | 1058 | * This function is safe to call from any context including IRQ handler. |
1059 | * An IRQ handler may run on top of delayed_work_timer_fn() which can make | ||
1060 | * this function return -EAGAIN perpetually. | ||
1061 | */ | 1059 | */ |
1062 | static int try_to_grab_pending(struct work_struct *work, bool is_dwork, | 1060 | static int try_to_grab_pending(struct work_struct *work, bool is_dwork, |
1063 | unsigned long *flags) | 1061 | unsigned long *flags) |
@@ -1072,6 +1070,11 @@ static int try_to_grab_pending(struct work_struct *work, bool is_dwork, | |||
1072 | if (is_dwork) { | 1070 | if (is_dwork) { |
1073 | struct delayed_work *dwork = to_delayed_work(work); | 1071 | struct delayed_work *dwork = to_delayed_work(work); |
1074 | 1072 | ||
1073 | /* | ||
1074 | * dwork->timer is irqsafe. If del_timer() fails, it's | ||
1075 | * guaranteed that the timer is not queued anywhere and not | ||
1076 | * running on the local CPU. | ||
1077 | */ | ||
1075 | if (likely(del_timer(&dwork->timer))) | 1078 | if (likely(del_timer(&dwork->timer))) |
1076 | return 1; | 1079 | return 1; |
1077 | } | 1080 | } |
@@ -1327,9 +1330,8 @@ void delayed_work_timer_fn(unsigned long __data) | |||
1327 | struct delayed_work *dwork = (struct delayed_work *)__data; | 1330 | struct delayed_work *dwork = (struct delayed_work *)__data; |
1328 | struct cpu_workqueue_struct *cwq = get_work_cwq(&dwork->work); | 1331 | struct cpu_workqueue_struct *cwq = get_work_cwq(&dwork->work); |
1329 | 1332 | ||
1330 | local_irq_disable(); | 1333 | /* should have been called from irqsafe timer with irq already off */ |
1331 | __queue_work(dwork->cpu, cwq->wq, &dwork->work); | 1334 | __queue_work(dwork->cpu, cwq->wq, &dwork->work); |
1332 | local_irq_enable(); | ||
1333 | } | 1335 | } |
1334 | EXPORT_SYMBOL_GPL(delayed_work_timer_fn); | 1336 | EXPORT_SYMBOL_GPL(delayed_work_timer_fn); |
1335 | 1337 | ||
@@ -1444,7 +1446,7 @@ EXPORT_SYMBOL_GPL(queue_delayed_work); | |||
1444 | * Returns %false if @dwork was idle and queued, %true if @dwork was | 1446 | * Returns %false if @dwork was idle and queued, %true if @dwork was |
1445 | * pending and its timer was modified. | 1447 | * pending and its timer was modified. |
1446 | * | 1448 | * |
1447 | * This function is safe to call from any context other than IRQ handler. | 1449 | * This function is safe to call from any context including IRQ handler. |
1448 | * See try_to_grab_pending() for details. | 1450 | * See try_to_grab_pending() for details. |
1449 | */ | 1451 | */ |
1450 | bool mod_delayed_work_on(int cpu, struct workqueue_struct *wq, | 1452 | bool mod_delayed_work_on(int cpu, struct workqueue_struct *wq, |