Lines Matching refs:rescuer
250 struct worker *rescuer; /* I: rescue worker */ member
1839 if (!wq->rescuer) in send_mayday()
1851 wake_up_process(wq->rescuer->task); in send_mayday()
2249 struct worker *rescuer = __rescuer; in rescuer_thread() local
2250 struct workqueue_struct *wq = rescuer->rescue_wq; in rescuer_thread()
2251 struct list_head *scheduled = &rescuer->scheduled; in rescuer_thread()
2260 rescuer->task->flags |= PF_WQ_WORKER; in rescuer_thread()
2288 worker_attach_to_pool(rescuer, pool); in rescuer_thread()
2291 rescuer->pool = pool; in rescuer_thread()
2303 process_scheduled_works(rescuer); in rescuer_thread()
2336 rescuer->pool = NULL; in rescuer_thread()
2339 worker_detach_from_pool(rescuer, pool); in rescuer_thread()
2348 rescuer->task->flags &= ~PF_WQ_WORKER; in rescuer_thread()
2353 WARN_ON_ONCE(!(rescuer->flags & WORKER_NOT_RUNNING)); in rescuer_thread()
2748 if (pwq->wq->saved_max_active == 1 || pwq->wq->rescuer) in start_flush_work()
3147 kfree(wq->rescuer); in rcu_free_wq()
3883 struct worker *rescuer; in __alloc_workqueue_key() local
3885 rescuer = alloc_worker(NUMA_NO_NODE); in __alloc_workqueue_key()
3886 if (!rescuer) in __alloc_workqueue_key()
3889 rescuer->rescue_wq = wq; in __alloc_workqueue_key()
3890 rescuer->task = kthread_create(rescuer_thread, rescuer, "%s", in __alloc_workqueue_key()
3892 if (IS_ERR(rescuer->task)) { in __alloc_workqueue_key()
3893 kfree(rescuer); in __alloc_workqueue_key()
3897 wq->rescuer = rescuer; in __alloc_workqueue_key()
3898 kthread_bind_mask(rescuer->task, cpu_possible_mask); in __alloc_workqueue_key()
3899 wake_up_process(rescuer->task); in __alloc_workqueue_key()
3978 if (wq->rescuer) in destroy_workqueue()
3979 kthread_stop(wq->rescuer->task); in destroy_workqueue()
4259 worker == pwq->wq->rescuer ? "(RESCUER)" : "", in show_pwq()