295 	struct kthread_worker *worker;  in erofs_destroy_percpu_workers()  local
299 		worker = rcu_dereference_protected(  in erofs_destroy_percpu_workers()
302 		if (worker)  in erofs_destroy_percpu_workers()
303 			kthread_destroy_worker(worker);  in erofs_destroy_percpu_workers()
310 	struct kthread_worker *worker =  in erofs_init_percpu_worker()  local
313 	if (IS_ERR(worker))  in erofs_init_percpu_worker()
314 		return worker;  in erofs_init_percpu_worker()
316 		sched_set_fifo_low(worker->task);  in erofs_init_percpu_worker()
317 	return worker;  in erofs_init_percpu_worker()
322 	struct kthread_worker *worker;  in erofs_init_percpu_workers()  local
331 		worker = erofs_init_percpu_worker(cpu);  in erofs_init_percpu_workers()
332 		if (!IS_ERR(worker))  in erofs_init_percpu_workers()
333 			rcu_assign_pointer(z_erofs_pcpu_workers[cpu], worker);  in erofs_init_percpu_workers()
344 	struct kthread_worker *worker, *old;  in erofs_cpu_online()  local
346 	worker = erofs_init_percpu_worker(cpu);  in erofs_cpu_online()
347 	if (IS_ERR(worker))  in erofs_cpu_online()
348 		return PTR_ERR(worker);  in erofs_cpu_online()
354 		rcu_assign_pointer(z_erofs_pcpu_workers[cpu], worker);  in erofs_cpu_online()
357 		kthread_destroy_worker(worker);  in erofs_cpu_online()
363 	struct kthread_worker *worker;  in erofs_cpu_offline()  local
366 	worker = rcu_dereference_protected(z_erofs_pcpu_workers[cpu],  in erofs_cpu_offline()
372 	if (worker)  in erofs_cpu_offline()
373 		kthread_destroy_worker(worker);  in erofs_cpu_offline()
1471 		struct kthread_worker *worker;  in z_erofs_decompress_kickoff()  local
1474 		worker = rcu_dereference(  in z_erofs_decompress_kickoff()
1476 		if (!worker) {  in z_erofs_decompress_kickoff()
1480 			kthread_queue_work(worker, &io->u.kthread_work);  in z_erofs_decompress_kickoff()