Lines Matching refs:rescuer
251 struct worker *rescuer; /* I: rescue worker */ member
2018 if (!wq->rescuer) in send_mayday()
2030 wake_up_process(wq->rescuer->task); in send_mayday()
2463 struct worker *rescuer = __rescuer; in rescuer_thread() local
2464 struct workqueue_struct *wq = rescuer->rescue_wq; in rescuer_thread()
2465 struct list_head *scheduled = &rescuer->scheduled; in rescuer_thread()
2503 worker_attach_to_pool(rescuer, pool); in rescuer_thread()
2522 process_scheduled_works(rescuer); in rescuer_thread()
2557 worker_detach_from_pool(rescuer); in rescuer_thread()
2571 WARN_ON_ONCE(!(rescuer->flags & WORKER_NOT_RUNNING)); in rescuer_thread()
3012 (pwq->wq->saved_max_active == 1 || pwq->wq->rescuer)) { in start_flush_work()
3489 kfree(wq->rescuer); in rcu_free_wq()
4194 struct worker *rescuer; in init_rescuer() local
4200 rescuer = alloc_worker(NUMA_NO_NODE); in init_rescuer()
4201 if (!rescuer) in init_rescuer()
4204 rescuer->rescue_wq = wq; in init_rescuer()
4205 rescuer->task = kthread_create(rescuer_thread, rescuer, "%s", wq->name); in init_rescuer()
4206 ret = PTR_ERR_OR_ZERO(rescuer->task); in init_rescuer()
4208 kfree(rescuer); in init_rescuer()
4212 wq->rescuer = rescuer; in init_rescuer()
4213 kthread_bind_mask(rescuer->task, cpu_possible_mask); in init_rescuer()
4214 wake_up_process(rescuer->task); in init_rescuer()
4364 if (wq->rescuer) in destroy_workqueue()
4365 kthread_stop(wq->rescuer->task); in destroy_workqueue()
4660 worker == pwq->wq->rescuer ? "(RESCUER)" : "", in show_pwq()