348 	struct worker		*rescuer;	/* MD: rescue worker */  member
2992 	if (!wq->rescuer)  in send_mayday()
3004 		wake_up_process(wq->rescuer->task);  in send_mayday()
3442 	struct worker *rescuer = __rescuer;  in rescuer_thread()  local
3443 	struct workqueue_struct *wq = rescuer->rescue_wq;  in rescuer_thread()
3480 		worker_attach_to_pool(rescuer, pool);  in rescuer_thread()
3488 		WARN_ON_ONCE(!list_empty(&rescuer->scheduled));  in rescuer_thread()
3491 			    assign_work(work, rescuer, &n))  in rescuer_thread()
3495 		if (!list_empty(&rescuer->scheduled)) {  in rescuer_thread()
3496 			process_scheduled_works(rescuer);  in rescuer_thread()
3513 				if (wq->rescuer && list_empty(&pwq->mayday_node)) {  in rescuer_thread()
3529 		worker_detach_from_pool(rescuer);  in rescuer_thread()
3549 	WARN_ON_ONCE(!(rescuer->flags & WORKER_NOT_RUNNING));  in rescuer_thread()
4187 	if (!from_cancel && (wq->saved_max_active == 1 || wq->rescuer))  in start_flush_work()
5348 	if (ctx->wq->rescuer)  in apply_wqattrs_commit()
5349 		set_cpus_allowed_ptr(ctx->wq->rescuer->task,  in apply_wqattrs_commit()
5556 	struct worker *rescuer;  in init_rescuer()  local
5565 	rescuer = alloc_worker(NUMA_NO_NODE);  in init_rescuer()
5566 	if (!rescuer) {  in init_rescuer()
5572 	rescuer->rescue_wq = wq;  in init_rescuer()
5573 	format_worker_id(id_buf, sizeof(id_buf), rescuer, NULL);  in init_rescuer()
5575 	rescuer->task = kthread_create(rescuer_thread, rescuer, "%s", id_buf);  in init_rescuer()
5576 	if (IS_ERR(rescuer->task)) {  in init_rescuer()
5577 		ret = PTR_ERR(rescuer->task);  in init_rescuer()
5580 		kfree(rescuer);  in init_rescuer()
5584 	wq->rescuer = rescuer;  in init_rescuer()
5586 		kthread_bind_mask(rescuer->task, unbound_effective_cpumask(wq));  in init_rescuer()
5588 		kthread_bind_mask(rescuer->task, cpu_possible_mask);  in init_rescuer()
5589 	wake_up_process(rescuer->task);  in init_rescuer()
5861 	if (wq->rescuer) {  in destroy_workqueue()
5862 		struct worker *rescuer = wq->rescuer;  in destroy_workqueue()  local
5866 		wq->rescuer = NULL;  in destroy_workqueue()
5870 		kthread_stop(rescuer->task);  in destroy_workqueue()
5871 		kfree(rescuer);  in destroy_workqueue()