|
@@ -3744,8 +3744,12 @@ static int apply_workqueue_attrs_locked(struct workqueue_struct *wq,
|
|
|
return -EINVAL;
|
|
|
|
|
|
/* creating multiple pwqs breaks ordering guarantee */
|
|
|
- if (WARN_ON((wq->flags & __WQ_ORDERED) && !list_empty(&wq->pwqs)))
|
|
|
- return -EINVAL;
|
|
|
+ if (!list_empty(&wq->pwqs)) {
|
|
|
+ if (WARN_ON(wq->flags & __WQ_ORDERED_EXPLICIT))
|
|
|
+ return -EINVAL;
|
|
|
+
|
|
|
+ wq->flags &= ~__WQ_ORDERED;
|
|
|
+ }
|
|
|
|
|
|
ctx = apply_wqattrs_prepare(wq, attrs);
|
|
|
if (!ctx)
|
|
@@ -4129,13 +4133,14 @@ void workqueue_set_max_active(struct workqueue_struct *wq, int max_active)
|
|
|
struct pool_workqueue *pwq;
|
|
|
|
|
|
/* disallow meddling with max_active for ordered workqueues */
|
|
|
- if (WARN_ON(wq->flags & __WQ_ORDERED))
|
|
|
+ if (WARN_ON(wq->flags & __WQ_ORDERED_EXPLICIT))
|
|
|
return;
|
|
|
|
|
|
max_active = wq_clamp_max_active(max_active, wq->flags, wq->name);
|
|
|
|
|
|
mutex_lock(&wq->mutex);
|
|
|
|
|
|
+ wq->flags &= ~__WQ_ORDERED;
|
|
|
wq->saved_max_active = max_active;
|
|
|
|
|
|
for_each_pwq(pwq, wq)
|
|
@@ -5263,7 +5268,7 @@ int workqueue_sysfs_register(struct workqueue_struct *wq)
|
|
|
* attributes breaks ordering guarantee. Disallow exposing ordered
|
|
|
* workqueues.
|
|
|
*/
|
|
|
- if (WARN_ON(wq->flags & __WQ_ORDERED))
|
|
|
+ if (WARN_ON(wq->flags & __WQ_ORDERED_EXPLICIT))
|
|
|
return -EINVAL;
|
|
|
|
|
|
wq->wq_dev = wq_dev = kzalloc(sizeof(*wq_dev), GFP_KERNEL);
|