Lines Matching refs:worker
345 struct kthread_worker *worker; in erofs_destroy_percpu_workers() local
349 worker = rcu_dereference_protected( in erofs_destroy_percpu_workers()
352 if (worker) in erofs_destroy_percpu_workers()
353 kthread_destroy_worker(worker); in erofs_destroy_percpu_workers()
360 struct kthread_worker *worker = in erofs_init_percpu_worker() local
363 if (IS_ERR(worker)) in erofs_init_percpu_worker()
364 return worker; in erofs_init_percpu_worker()
366 sched_set_fifo_low(worker->task); in erofs_init_percpu_worker()
367 return worker; in erofs_init_percpu_worker()
372 struct kthread_worker *worker; in erofs_init_percpu_workers() local
381 worker = erofs_init_percpu_worker(cpu); in erofs_init_percpu_workers()
382 if (!IS_ERR(worker)) in erofs_init_percpu_workers()
383 rcu_assign_pointer(z_erofs_pcpu_workers[cpu], worker); in erofs_init_percpu_workers()
398 struct kthread_worker *worker, *old; in erofs_cpu_online() local
400 worker = erofs_init_percpu_worker(cpu); in erofs_cpu_online()
401 if (IS_ERR(worker)) in erofs_cpu_online()
402 return PTR_ERR(worker); in erofs_cpu_online()
408 rcu_assign_pointer(z_erofs_pcpu_workers[cpu], worker); in erofs_cpu_online()
411 kthread_destroy_worker(worker); in erofs_cpu_online()
417 struct kthread_worker *worker; in erofs_cpu_offline() local
420 worker = rcu_dereference_protected(z_erofs_pcpu_workers[cpu], in erofs_cpu_offline()
426 if (worker) in erofs_cpu_offline()
427 kthread_destroy_worker(worker); in erofs_cpu_offline()
1415 struct kthread_worker *worker; in z_erofs_decompress_kickoff() local
1418 worker = rcu_dereference( in z_erofs_decompress_kickoff()
1420 if (!worker) { in z_erofs_decompress_kickoff()
1424 kthread_queue_work(worker, &io->u.kthread_work); in z_erofs_decompress_kickoff()