Lines Matching refs:worker
350 struct kthread_worker *worker; in erofs_destroy_percpu_workers() local
354 worker = rcu_dereference_protected( in erofs_destroy_percpu_workers()
357 if (worker) in erofs_destroy_percpu_workers()
358 kthread_destroy_worker(worker); in erofs_destroy_percpu_workers()
365 struct kthread_worker *worker = in erofs_init_percpu_worker() local
368 if (IS_ERR(worker)) in erofs_init_percpu_worker()
369 return worker; in erofs_init_percpu_worker()
371 sched_set_fifo_low(worker->task); in erofs_init_percpu_worker()
373 sched_set_normal(worker->task, 0); in erofs_init_percpu_worker()
374 return worker; in erofs_init_percpu_worker()
379 struct kthread_worker *worker; in erofs_init_percpu_workers() local
388 worker = erofs_init_percpu_worker(cpu); in erofs_init_percpu_workers()
389 if (!IS_ERR(worker)) in erofs_init_percpu_workers()
390 rcu_assign_pointer(z_erofs_pcpu_workers[cpu], worker); in erofs_init_percpu_workers()
405 struct kthread_worker *worker, *old; in erofs_cpu_online() local
407 worker = erofs_init_percpu_worker(cpu); in erofs_cpu_online()
408 if (IS_ERR(worker)) in erofs_cpu_online()
409 return PTR_ERR(worker); in erofs_cpu_online()
415 rcu_assign_pointer(z_erofs_pcpu_workers[cpu], worker); in erofs_cpu_online()
418 kthread_destroy_worker(worker); in erofs_cpu_online()
424 struct kthread_worker *worker; in erofs_cpu_offline() local
427 worker = rcu_dereference_protected(z_erofs_pcpu_workers[cpu], in erofs_cpu_offline()
433 if (worker) in erofs_cpu_offline()
434 kthread_destroy_worker(worker); in erofs_cpu_offline()
1462 struct kthread_worker *worker; in z_erofs_decompress_kickoff() local
1465 worker = rcu_dereference( in z_erofs_decompress_kickoff()
1467 if (!worker) { in z_erofs_decompress_kickoff()
1471 kthread_queue_work(worker, &io->u.kthread_work); in z_erofs_decompress_kickoff()