diff options
| -rw-r--r-- | include/linux/workqueue.h | 2 | ||||
| -rw-r--r-- | kernel/workqueue.c | 7 |
2 files changed, 8 insertions, 1 deletions
diff --git a/include/linux/workqueue.h b/include/linux/workqueue.h index 4f9d277bcd9a..c959666eafca 100644 --- a/include/linux/workqueue.h +++ b/include/linux/workqueue.h | |||
| @@ -241,6 +241,8 @@ enum { | |||
| 241 | WQ_HIGHPRI = 1 << 4, /* high priority */ | 241 | WQ_HIGHPRI = 1 << 4, /* high priority */ |
| 242 | WQ_CPU_INTENSIVE = 1 << 5, /* cpu instensive workqueue */ | 242 | WQ_CPU_INTENSIVE = 1 << 5, /* cpu instensive workqueue */ |
| 243 | 243 | ||
| 244 | WQ_DYING = 1 << 6, /* internal: workqueue is dying */ | ||
| 245 | |||
| 244 | WQ_MAX_ACTIVE = 512, /* I like 512, better ideas? */ | 246 | WQ_MAX_ACTIVE = 512, /* I like 512, better ideas? */ |
| 245 | WQ_MAX_UNBOUND_PER_CPU = 4, /* 4 * #cpus for unbound wq */ | 247 | WQ_MAX_UNBOUND_PER_CPU = 4, /* 4 * #cpus for unbound wq */ |
| 246 | WQ_DFL_ACTIVE = WQ_MAX_ACTIVE / 2, | 248 | WQ_DFL_ACTIVE = WQ_MAX_ACTIVE / 2, |
diff --git a/kernel/workqueue.c b/kernel/workqueue.c index cc3456f96c56..362b50d092e2 100644 --- a/kernel/workqueue.c +++ b/kernel/workqueue.c | |||
| @@ -87,7 +87,8 @@ enum { | |||
| 87 | /* | 87 | /* |
| 88 | * Structure fields follow one of the following exclusion rules. | 88 | * Structure fields follow one of the following exclusion rules. |
| 89 | * | 89 | * |
| 90 | * I: Set during initialization and read-only afterwards. | 90 | * I: Modifiable by initialization/destruction paths and read-only for |
| 91 | * everyone else. | ||
| 91 | * | 92 | * |
| 92 | * P: Preemption protected. Disabling preemption is enough and should | 93 | * P: Preemption protected. Disabling preemption is enough and should |
| 93 | * only be modified and accessed from the local cpu. | 94 | * only be modified and accessed from the local cpu. |
| @@ -944,6 +945,9 @@ static void __queue_work(unsigned int cpu, struct workqueue_struct *wq, | |||
| 944 | 945 | ||
| 945 | debug_work_activate(work); | 946 | debug_work_activate(work); |
| 946 | 947 | ||
| 948 | if (WARN_ON_ONCE(wq->flags & WQ_DYING)) | ||
| 949 | return; | ||
| 950 | |||
| 947 | /* determine gcwq to use */ | 951 | /* determine gcwq to use */ |
| 948 | if (!(wq->flags & WQ_UNBOUND)) { | 952 | if (!(wq->flags & WQ_UNBOUND)) { |
| 949 | struct global_cwq *last_gcwq; | 953 | struct global_cwq *last_gcwq; |
| @@ -2828,6 +2832,7 @@ void destroy_workqueue(struct workqueue_struct *wq) | |||
| 2828 | { | 2832 | { |
| 2829 | unsigned int cpu; | 2833 | unsigned int cpu; |
| 2830 | 2834 | ||
| 2835 | wq->flags |= WQ_DYING; | ||
| 2831 | flush_workqueue(wq); | 2836 | flush_workqueue(wq); |
| 2832 | 2837 | ||
| 2833 | /* | 2838 | /* |
