| /linux-6.6.21/io_uring/ |
| D | io-wq.c | 137 static void io_wq_dec_running(struct io_worker *worker);
144 static bool io_worker_get(struct io_worker *worker) in io_worker_get() argument
146 return refcount_inc_not_zero(&worker->ref); in io_worker_get()
149 static void io_worker_release(struct io_worker *worker) in io_worker_release() argument
151 if (refcount_dec_and_test(&worker->ref)) in io_worker_release()
152 complete(&worker->ref_done); in io_worker_release()
166 static inline struct io_wq_acct *io_wq_get_acct(struct io_worker *worker) in io_wq_get_acct() argument
168 return io_get_acct(worker->wq, worker->flags & IO_WORKER_F_BOUND); in io_wq_get_acct()
179 struct io_worker *worker = current->worker_private; in io_wq_worker_stopped() local
184 return test_bit(IO_WQ_BIT_EXIT, &worker->wq->state); in io_wq_worker_stopped()
[all …]
|
| /linux-6.6.21/kernel/ |
| D | kthread.c | 756 void __kthread_init_worker(struct kthread_worker *worker, in __kthread_init_worker() argument
760 memset(worker, 0, sizeof(struct kthread_worker)); in __kthread_init_worker()
761 raw_spin_lock_init(&worker->lock); in __kthread_init_worker()
762 lockdep_set_class_and_name(&worker->lock, key, name); in __kthread_init_worker()
763 INIT_LIST_HEAD(&worker->work_list); in __kthread_init_worker()
764 INIT_LIST_HEAD(&worker->delayed_work_list); in __kthread_init_worker()
785 struct kthread_worker *worker = worker_ptr; in kthread_worker_fn() local
792 WARN_ON(worker->task && worker->task != current); in kthread_worker_fn()
793 worker->task = current; in kthread_worker_fn()
795 if (worker->flags & KTW_FREEZABLE) in kthread_worker_fn()
[all …]
|
| D | workqueue.c | 186 struct worker *manager; /* L: purely informational */
298 struct worker *rescuer; /* MD: rescue worker */
489 #define for_each_pool_worker(worker, pool) \ argument
490 list_for_each_entry((worker), &(pool)->workers, node) \
867 static inline void worker_set_flags(struct worker *worker, unsigned int flags) in worker_set_flags() argument
869 struct worker_pool *pool = worker->pool; in worker_set_flags()
875 !(worker->flags & WORKER_NOT_RUNNING)) { in worker_set_flags()
879 worker->flags |= flags; in worker_set_flags()
889 static inline void worker_clr_flags(struct worker *worker, unsigned int flags) in worker_clr_flags() argument
891 struct worker_pool *pool = worker->pool; in worker_clr_flags()
[all …]
|
| D | async.c | 342 struct worker *worker = current_wq_worker(); in current_is_async() local
344 return worker && worker->current_func == async_run_entry_fn; in current_is_async()
|
| /linux-6.6.21/tools/perf/bench/ |
| D | futex-hash.c | 43 struct worker { struct
73 struct worker *w = (struct worker *) arg; in workerfn()
130 struct worker *worker = NULL; in bench_futex_hash() local
158 worker = calloc(params.nthreads, sizeof(*worker)); in bench_futex_hash()
159 if (!worker) in bench_futex_hash()
183 worker[i].tid = i; in bench_futex_hash()
184 worker[i].futex = calloc(params.nfutexes, sizeof(*worker[i].futex)); in bench_futex_hash()
185 if (!worker[i].futex) in bench_futex_hash()
196 ret = pthread_create(&worker[i].thread, &thread_attr, workerfn, in bench_futex_hash()
197 (void *)(struct worker *) &worker[i]); in bench_futex_hash()
[all …]
|
| D | epoll-wait.c | 118 struct worker { struct
186 struct worker *w = (struct worker *) arg; in workerfn()
240 static void nest_epollfd(struct worker *w) in nest_epollfd()
292 static int do_threads(struct worker *worker, struct perf_cpu_map *cpu) in do_threads() argument
318 struct worker *w = &worker[i]; in do_threads()
366 (void *)(struct worker *) w); in do_threads()
382 struct worker *worker = p; in writerfn() local
394 shuffle((void *)worker, nthreads, sizeof(*worker)); in writerfn()
398 struct worker *w = &worker[i]; in writerfn()
421 struct worker *w1 = (struct worker *) p1; in cmpworker()
[all …]
|
| D | futex-lock-pi.c | 27 struct worker { struct
35 static struct worker *worker; variable
84 struct worker *w = (struct worker *) arg; in workerfn()
121 static void create_threads(struct worker *w, struct perf_cpu_map *cpu) in create_threads()
138 worker[i].tid = i; in create_threads()
141 worker[i].futex = calloc(1, sizeof(u_int32_t)); in create_threads()
142 if (!worker[i].futex) in create_threads()
145 worker[i].futex = &global_futex; in create_threads()
155 if (pthread_create(&w[i].thread, &thread_attr, workerfn, &worker[i])) { in create_threads()
192 worker = calloc(params.nthreads, sizeof(*worker)); in bench_futex_lock_pi()
[all …]
|
| D | epoll-ctl.c | 67 struct worker { struct
132 static inline void do_epoll_op(struct worker *w, int op, int fd) in do_epoll_op()
160 static inline void do_random_epoll_op(struct worker *w) in do_random_epoll_op()
174 struct worker *w = (struct worker *) arg; in workerfn()
204 static void init_fdmaps(struct worker *w, int pct) in init_fdmaps()
223 static int do_threads(struct worker *worker, struct perf_cpu_map *cpu) in do_threads() argument
241 struct worker *w = &worker[i]; in do_threads()
277 (void *)(struct worker *) w); in do_threads()
317 struct worker *worker = NULL; in bench_epoll_ctl() local
352 worker = calloc(nthreads, sizeof(*worker)); in bench_epoll_ctl()
[all …]
|
| D | futex-wake.c | 36 static pthread_t *worker; variable
169 worker = calloc(params.nthreads, sizeof(*worker)); in bench_futex_wake()
170 if (!worker) in bench_futex_wake()
192 block_threads(worker, cpu); in bench_futex_wake()
221 ret = pthread_join(worker[i], NULL); in bench_futex_wake()
235 free(worker); in bench_futex_wake()
|
| D | futex-requeue.c | 36 static pthread_t *worker; variable
194 worker = calloc(params.nthreads, sizeof(*worker)); in bench_futex_requeue()
195 if (!worker) in bench_futex_requeue()
223 block_threads(worker, cpu); in bench_futex_requeue()
295 ret = pthread_join(worker[i], NULL); in bench_futex_requeue()
308 free(worker); in bench_futex_requeue()
|
| /linux-6.6.21/include/linux/ |
| D | kthread.h | 134 struct kthread_worker *worker; member
162 extern void __kthread_init_worker(struct kthread_worker *worker,
165 #define kthread_init_worker(worker) \ argument
168 __kthread_init_worker((worker), "("#worker")->lock", &__key); \
196 bool kthread_queue_work(struct kthread_worker *worker,
199 bool kthread_queue_delayed_work(struct kthread_worker *worker,
203 bool kthread_mod_delayed_work(struct kthread_worker *worker,
208 void kthread_flush_worker(struct kthread_worker *worker);
213 void kthread_destroy_worker(struct kthread_worker *worker);
|
| D | devm-helpers.h | 48 work_func_t worker) in devm_delayed_work_autocancel() argument
50 INIT_DELAYED_WORK(w, worker); in devm_delayed_work_autocancel()
73 work_func_t worker) in devm_work_autocancel() argument
75 INIT_WORK(w, worker); in devm_work_autocancel()
|
| /linux-6.6.21/drivers/net/wireguard/ |
| D | queueing.c | 13 struct multicore_worker __percpu *worker = alloc_percpu(struct multicore_worker); in wg_packet_percpu_multicore_worker_alloc() local
15 if (!worker) in wg_packet_percpu_multicore_worker_alloc()
19 per_cpu_ptr(worker, cpu)->ptr = ptr; in wg_packet_percpu_multicore_worker_alloc()
20 INIT_WORK(&per_cpu_ptr(worker, cpu)->work, function); in wg_packet_percpu_multicore_worker_alloc()
22 return worker; in wg_packet_percpu_multicore_worker_alloc()
35 queue->worker = wg_packet_percpu_multicore_worker_alloc(function, queue); in wg_packet_queue_init()
36 if (!queue->worker) { in wg_packet_queue_init()
45 free_percpu(queue->worker); in wg_packet_queue_free()
|
| /linux-6.6.21/drivers/vhost/ |
| D | vhost.c | 236 static void vhost_worker_queue(struct vhost_worker *worker, in vhost_worker_queue() argument
244 llist_add(&work->node, &worker->work_list); in vhost_worker_queue()
245 vhost_task_wake(worker->vtsk); in vhost_worker_queue()
251 struct vhost_worker *worker; in vhost_vq_work_queue() local
255 worker = rcu_dereference(vq->worker); in vhost_vq_work_queue()
256 if (worker) { in vhost_vq_work_queue()
258 vhost_worker_queue(worker, work); in vhost_vq_work_queue()
285 static void vhost_worker_flush(struct vhost_worker *worker) in vhost_worker_flush() argument
292 vhost_worker_queue(worker, &flush.work); in vhost_worker_flush()
298 struct vhost_worker *worker; in vhost_dev_flush() local
[all …]
|
| /linux-6.6.21/drivers/gpu/drm/ |
| D | drm_vblank_work.c | 60 kthread_queue_work(vblank->worker, &work->base); in drm_handle_vblank_works()
147 ret = kthread_queue_work(vblank->worker, &work->base); in drm_vblank_work_schedule()
251 struct kthread_worker *worker; in drm_vblank_worker_init() local
255 worker = kthread_create_worker(0, "card%d-crtc%d", in drm_vblank_worker_init()
258 if (IS_ERR(worker)) in drm_vblank_worker_init()
259 return PTR_ERR(worker); in drm_vblank_worker_init()
261 vblank->worker = worker; in drm_vblank_worker_init()
263 sched_set_fifo(worker->task); in drm_vblank_worker_init()
|
| D | drm_flip_work.c | 110 queue_work(wq, &work->worker); in drm_flip_work_commit()
116 struct drm_flip_work *work = container_of(w, struct drm_flip_work, worker); in flip_worker()
156 INIT_WORK(&work->worker, flip_worker); in drm_flip_work_init()
|
| /linux-6.6.21/samples/seccomp/ |
| D | user-trap.c | 204 pid_t worker = 0 , tracer = 0; in main() local
211 worker = fork(); in main()
212 if (worker < 0) { in main()
217 if (worker == 0) { in main()
343 if (waitpid(worker, &status, 0) != worker) { in main()
368 if (worker > 0) in main()
369 kill(worker, SIGKILL); in main()
|
| /linux-6.6.21/drivers/gpu/drm/msm/ |
| D | msm_atomic.c | 118 timer->worker = kthread_create_worker(0, "atomic-worker-%d", crtc_idx); in msm_atomic_init_pending_timer()
119 if (IS_ERR(timer->worker)) { in msm_atomic_init_pending_timer()
120 int ret = PTR_ERR(timer->worker); in msm_atomic_init_pending_timer()
121 timer->worker = NULL; in msm_atomic_init_pending_timer()
124 sched_set_fifo(timer->worker->task); in msm_atomic_init_pending_timer()
126 msm_hrtimer_work_init(&timer->work, timer->worker, in msm_atomic_init_pending_timer()
135 if (timer->worker) in msm_atomic_destroy_pending_timer()
136 kthread_destroy_worker(timer->worker); in msm_atomic_destroy_pending_timer()
|
| D | msm_io_utils.c | 107 kthread_queue_work(work->worker, &work->work); in msm_hrtimer_worktimer()
120 struct kthread_worker *worker, in msm_hrtimer_work_init() argument
127 work->worker = worker; in msm_hrtimer_work_init()
|
| /linux-6.6.21/Documentation/core-api/ |
| D | workqueue.rst | 20 queue is called workqueue and the thread is called worker.
22 While there are work items on the workqueue the worker executes the
24 there is no work item left on the workqueue the worker becomes idle.
25 When a new work item gets queued, the worker begins executing again.
32 worker thread per CPU and a single threaded (ST) wq had one worker
42 worker pool. An MT wq could provide only one execution context per CPU
60 * Use per-CPU unified worker pools shared by all wq to provide
64 * Automatically regulate worker pool and level of concurrency so that
80 Special purpose threads, called worker threads, execute the functions
82 worker threads become idle. These worker threads are managed in so
[all …]
|
| /linux-6.6.21/drivers/i2c/ |
| D | i2c-slave-testunit.c | 43 struct delayed_work worker; member
48 struct testunit_data *tu = container_of(work, struct testunit_data, worker.work); in i2c_slave_testunit_work()
118 queue_delayed_work(system_long_wq, &tu->worker, in i2c_slave_testunit_slave_cb()
151 INIT_DELAYED_WORK(&tu->worker, i2c_slave_testunit_work); in i2c_slave_testunit_probe()
160 cancel_delayed_work_sync(&tu->worker); in i2c_slave_testunit_remove()
|
| /linux-6.6.21/drivers/block/ |
| D | loop.c | 832 struct loop_worker *cur_worker, *worker = NULL; in loop_queue_work() local
847 worker = cur_worker; in loop_queue_work()
855 if (worker) in loop_queue_work()
858 worker = kzalloc(sizeof(struct loop_worker), GFP_NOWAIT | __GFP_NOWARN); in loop_queue_work()
863 if (!worker) { in loop_queue_work()
871 worker->blkcg_css = cmd->blkcg_css; in loop_queue_work()
872 css_get(worker->blkcg_css); in loop_queue_work()
873 INIT_WORK(&worker->work, loop_workfn); in loop_queue_work()
874 INIT_LIST_HEAD(&worker->cmd_list); in loop_queue_work()
875 INIT_LIST_HEAD(&worker->idle_list); in loop_queue_work()
[all …]
|
| /linux-6.6.21/fs/erofs/ |
| D | zdata.c | 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
[all …]
|
| /linux-6.6.21/drivers/crypto/caam/ |
| D | caamrng.c | 43 struct work_struct worker; member
143 worker); in caam_rng_worker()
161 schedule_work(&ctx->worker); in caam_read()
170 flush_work(&ctx->worker); in caam_cleanup()
239 INIT_WORK(&ctx->worker, caam_rng_worker); in caam_init()
|
| /linux-6.6.21/drivers/gpu/drm/i915/gt/ |
| D | selftest_slpc.c | 20 struct kthread_worker *worker; member
491 threads[i].worker = kthread_create_worker(0, "igt/slpc_parallel:%d", gt->info.id); in live_slpc_tile_interaction()
493 if (IS_ERR(threads[i].worker)) { in live_slpc_tile_interaction()
494 ret = PTR_ERR(threads[i].worker); in live_slpc_tile_interaction()
500 kthread_queue_work(threads[i].worker, &threads[i].work); in live_slpc_tile_interaction()
506 if (IS_ERR_OR_NULL(threads[i].worker)) in live_slpc_tile_interaction()
515 kthread_destroy_worker(threads[i].worker); in live_slpc_tile_interaction()
|