798 	struct kthread_work *work;  in kthread_worker_fn()  local
821 	work = NULL;  in kthread_worker_fn()
824 		work = list_first_entry(&worker->work_list,  in kthread_worker_fn()
826 		list_del_init(&work->node);  in kthread_worker_fn()
828 	worker->current_work = work;  in kthread_worker_fn()
831 	if (work) {  in kthread_worker_fn()
832 		kthread_work_func_t func = work->func;  in kthread_worker_fn()
834 		trace_sched_kthread_work_execute_start(work);  in kthread_worker_fn()
835 		work->func(work);  in kthread_worker_fn()
840 		trace_sched_kthread_work_execute_end(work, func);  in kthread_worker_fn()
964 				   struct kthread_work *work)  in queuing_blocked()  argument
968 	return !list_empty(&work->node) || work->canceling;  in queuing_blocked()
972 					     struct kthread_work *work)  in kthread_insert_work_sanity_check()  argument
975 	WARN_ON_ONCE(!list_empty(&work->node));  in kthread_insert_work_sanity_check()
977 	WARN_ON_ONCE(work->worker && work->worker != worker);  in kthread_insert_work_sanity_check()
982 				struct kthread_work *work,  in kthread_insert_work()  argument
985 	kthread_insert_work_sanity_check(worker, work);  in kthread_insert_work()
987 	trace_sched_kthread_work_queue_work(worker, work);  in kthread_insert_work()
989 	list_add_tail(&work->node, pos);  in kthread_insert_work()
990 	work->worker = worker;  in kthread_insert_work()
1008 			struct kthread_work *work)  in kthread_queue_work()  argument
1014 	if (!queuing_blocked(worker, work)) {  in kthread_queue_work()
1015 		kthread_insert_work(worker, work, &worker->work_list);  in kthread_queue_work()
1034 	struct kthread_work *work = &dwork->work;  in kthread_delayed_work_timer_fn()  local
1035 	struct kthread_worker *worker = work->worker;  in kthread_delayed_work_timer_fn()
1047 	WARN_ON_ONCE(work->worker != worker);  in kthread_delayed_work_timer_fn()
1050 	WARN_ON_ONCE(list_empty(&work->node));  in kthread_delayed_work_timer_fn()
1051 	list_del_init(&work->node);  in kthread_delayed_work_timer_fn()
1052 	if (!work->canceling)  in kthread_delayed_work_timer_fn()
1053 		kthread_insert_work(worker, work, &worker->work_list);  in kthread_delayed_work_timer_fn()
1064 	struct kthread_work *work = &dwork->work;  in __kthread_queue_delayed_work()  local
1075 		kthread_insert_work(worker, work, &worker->work_list);  in __kthread_queue_delayed_work()
1080 	kthread_insert_work_sanity_check(worker, work);  in __kthread_queue_delayed_work()
1082 	list_add(&work->node, &worker->delayed_work_list);  in __kthread_queue_delayed_work()
1083 	work->worker = worker;  in __kthread_queue_delayed_work()
1107 	struct kthread_work *work = &dwork->work;  in kthread_queue_delayed_work()  local
1113 	if (!queuing_blocked(worker, work)) {  in kthread_queue_delayed_work()
1124 	struct kthread_work	work;  member
1128 static void kthread_flush_work_fn(struct kthread_work *work)  in kthread_flush_work_fn()  argument
1131 		container_of(work, struct kthread_flush_work, work);  in kthread_flush_work_fn()
1141 void kthread_flush_work(struct kthread_work *work)  in kthread_flush_work()  argument
1144 		KTHREAD_WORK_INIT(fwork.work, kthread_flush_work_fn),  in kthread_flush_work()
1150 	worker = work->worker;  in kthread_flush_work()
1156 	WARN_ON_ONCE(work->worker != worker);  in kthread_flush_work()
1158 	if (!list_empty(&work->node))  in kthread_flush_work()
1159 		kthread_insert_work(worker, &fwork.work, work->node.next);  in kthread_flush_work()
1160 	else if (worker->current_work == work)  in kthread_flush_work()
1161 		kthread_insert_work(worker, &fwork.work,  in kthread_flush_work()
1180 static void kthread_cancel_delayed_work_timer(struct kthread_work *work,  in kthread_cancel_delayed_work_timer()  argument
1184 		container_of(work, struct kthread_delayed_work, work);  in kthread_cancel_delayed_work_timer()
1185 	struct kthread_worker *worker = work->worker;  in kthread_cancel_delayed_work_timer()
1193 	work->canceling++;  in kthread_cancel_delayed_work_timer()
1197 	work->canceling--;  in kthread_cancel_delayed_work_timer()
1213 static bool __kthread_cancel_work(struct kthread_work *work)  in __kthread_cancel_work()  argument
1219 	if (!list_empty(&work->node)) {  in __kthread_cancel_work()
1220 		list_del_init(&work->node);  in __kthread_cancel_work()
1254 	struct kthread_work *work = &dwork->work;  in kthread_mod_delayed_work()  local
1261 	if (!work->worker) {  in kthread_mod_delayed_work()
1267 	WARN_ON_ONCE(work->worker != worker);  in kthread_mod_delayed_work()
1281 	kthread_cancel_delayed_work_timer(work, &flags);  in kthread_mod_delayed_work()
1282 	if (work->canceling) {  in kthread_mod_delayed_work()
1287 	ret = __kthread_cancel_work(work);  in kthread_mod_delayed_work()
1297 static bool __kthread_cancel_work_sync(struct kthread_work *work, bool is_dwork)  in __kthread_cancel_work_sync()  argument
1299 	struct kthread_worker *worker = work->worker;  in __kthread_cancel_work_sync()
1308 	WARN_ON_ONCE(work->worker != worker);  in __kthread_cancel_work_sync()
1311 		kthread_cancel_delayed_work_timer(work, &flags);  in __kthread_cancel_work_sync()
1313 	ret = __kthread_cancel_work(work);  in __kthread_cancel_work_sync()
1315 	if (worker->current_work != work)  in __kthread_cancel_work_sync()
1322 	work->canceling++;  in __kthread_cancel_work_sync()
1324 	kthread_flush_work(work);  in __kthread_cancel_work_sync()
1326 	work->canceling--;  in __kthread_cancel_work_sync()
1350 bool kthread_cancel_work_sync(struct kthread_work *work)  in kthread_cancel_work_sync()  argument
1352 	return __kthread_cancel_work_sync(work, false);  in kthread_cancel_work_sync()
1367 	return __kthread_cancel_work_sync(&dwork->work, true);  in kthread_cancel_delayed_work_sync()
1381 		KTHREAD_WORK_INIT(fwork.work, kthread_flush_work_fn),  in kthread_flush_worker()
1385 	kthread_queue_work(worker, &fwork.work);  in kthread_flush_worker()