| /kernel/linux/linux-5.10/io_uring/ |
| D | io-wq.c | 139 static void io_wqe_dec_running(struct io_worker *worker);
146 static bool io_worker_get(struct io_worker *worker) in io_worker_get() argument
148 return refcount_inc_not_zero(&worker->ref); in io_worker_get()
151 static void io_worker_release(struct io_worker *worker) in io_worker_release() argument
153 if (refcount_dec_and_test(&worker->ref)) in io_worker_release()
154 complete(&worker->ref_done); in io_worker_release()
168 static inline struct io_wqe_acct *io_wqe_get_acct(struct io_worker *worker) in io_wqe_get_acct() argument
170 return io_get_acct(worker->wqe, worker->flags & IO_WORKER_F_BOUND); in io_wqe_get_acct()
179 static void io_worker_cancel_cb(struct io_worker *worker) in io_worker_cancel_cb() argument
181 struct io_wqe_acct *acct = io_wqe_get_acct(worker); in io_worker_cancel_cb()
[all …]
|
| /kernel/linux/linux-5.10/kernel/ |
| D | kthread.c | 689 void __kthread_init_worker(struct kthread_worker *worker, in __kthread_init_worker() argument
693 memset(worker, 0, sizeof(struct kthread_worker)); in __kthread_init_worker()
694 raw_spin_lock_init(&worker->lock); in __kthread_init_worker()
695 lockdep_set_class_and_name(&worker->lock, key, name); in __kthread_init_worker()
696 INIT_LIST_HEAD(&worker->work_list); in __kthread_init_worker()
697 INIT_LIST_HEAD(&worker->delayed_work_list); in __kthread_init_worker()
718 struct kthread_worker *worker = worker_ptr; in kthread_worker_fn() local
725 WARN_ON(worker->task && worker->task != current); in kthread_worker_fn()
726 worker->task = current; in kthread_worker_fn()
728 if (worker->flags & KTW_FREEZABLE) in kthread_worker_fn()
[all …]
|
| D | workqueue.c | 170 struct worker *manager; /* L: purely informational */
252 struct worker *rescuer; /* MD: rescue worker */
408 #define for_each_pool_worker(worker, pool) \ argument
409 list_for_each_entry((worker), &(pool)->workers, node) \
816 static struct worker *first_idle_worker(struct worker_pool *pool) in first_idle_worker()
821 return list_first_entry(&pool->idle_list, struct worker, entry); in first_idle_worker()
835 struct worker *worker = first_idle_worker(pool); in wake_up_worker() local
837 if (likely(worker)) in wake_up_worker()
838 wake_up_process(worker->task); in wake_up_worker()
849 struct worker *worker = kthread_data(task); in wq_worker_running() local
[all …]
|
| D | workqueue_internal.h | 24 struct worker { struct
65 static inline struct worker *current_wq_worker(void) in current_wq_worker()
|
| D | async.c | 327 struct worker *worker = current_wq_worker(); in current_is_async() local
329 return worker && worker->current_func == async_run_entry_fn; in current_is_async()
|
| /kernel/linux/linux-5.10/include/linux/ |
| D | kthread.h | 104 struct kthread_worker *worker; member
114 #define KTHREAD_WORKER_INIT(worker) { \ argument
115 .lock = __RAW_SPIN_LOCK_UNLOCKED((worker).lock), \
116 .work_list = LIST_HEAD_INIT((worker).work_list), \
117 .delayed_work_list = LIST_HEAD_INIT((worker).delayed_work_list),\
131 #define DEFINE_KTHREAD_WORKER(worker) \ argument
132 struct kthread_worker worker = KTHREAD_WORKER_INIT(worker)
146 # define KTHREAD_WORKER_INIT_ONSTACK(worker) \ argument
147 ({ kthread_init_worker(&worker); worker; })
148 # define DEFINE_KTHREAD_WORKER_ONSTACK(worker) \ argument
[all …]
|
| /kernel/linux/linux-5.10/tools/perf/bench/ |
| D | futex-hash.c | 46 struct worker { struct
70 struct worker *w = (struct worker *) arg; in workerfn() argument
127 struct worker *worker = NULL; in bench_futex_hash() local
148 worker = calloc(nthreads, sizeof(*worker)); in bench_futex_hash()
149 if (!worker) in bench_futex_hash()
167 worker[i].tid = i; in bench_futex_hash()
168 worker[i].futex = calloc(nfutexes, sizeof(*worker[i].futex)); in bench_futex_hash()
169 if (!worker[i].futex) in bench_futex_hash()
179 ret = pthread_create(&worker[i].thread, &thread_attr, workerfn, in bench_futex_hash()
180 (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
311 struct worker *w = &worker[i]; in do_threads()
356 (void *)(struct worker *) w); in do_threads()
369 struct worker *worker = p; in writerfn() local
381 shuffle((void *)worker, nthreads, sizeof(*worker)); in writerfn()
385 struct worker *w = &worker[i]; in writerfn()
408 struct worker *w1 = (struct worker *) p1; in cmpworker()
[all …]
|
| D | futex-lock-pi.c | 26 struct worker { struct
34 static struct worker *worker; variable
81 struct worker *w = (struct worker *) arg; in workerfn()
118 static void create_threads(struct worker *w, pthread_attr_t thread_attr, in create_threads()
127 worker[i].tid = i; in create_threads()
130 worker[i].futex = calloc(1, sizeof(u_int32_t)); in create_threads()
131 if (!worker[i].futex) in create_threads()
134 worker[i].futex = &global_futex; in create_threads()
142 if (pthread_create(&w[i].thread, &thread_attr, workerfn, &worker[i])) in create_threads()
171 worker = calloc(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
234 struct worker *w = &worker[i]; in do_threads()
267 (void *)(struct worker *) w); in do_threads()
304 struct worker *worker = NULL; in bench_epoll_ctl() local
339 worker = calloc(nthreads, sizeof(*worker)); in bench_epoll_ctl()
[all …]
|
| D | futex-wake.c | 41 pthread_t *worker; variable
147 worker = calloc(nthreads, sizeof(*worker)); in bench_futex_wake()
148 if (!worker) in bench_futex_wake()
170 block_threads(worker, thread_attr, cpu); in bench_futex_wake()
197 ret = pthread_join(worker[i], NULL); in bench_futex_wake()
212 free(worker); in bench_futex_wake()
|
| D | futex-requeue.c | 40 static pthread_t *worker; variable
139 worker = calloc(nthreads, sizeof(*worker)); in bench_futex_requeue()
140 if (!worker) in bench_futex_requeue()
165 block_threads(worker, thread_attr, cpu); in bench_futex_requeue()
204 ret = pthread_join(worker[i], NULL); in bench_futex_requeue()
218 free(worker); in bench_futex_requeue()
|
| /kernel/linux/linux-5.10/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()
34 queue->worker = wg_packet_percpu_multicore_worker_alloc(function, queue); in wg_packet_queue_init()
35 if (!queue->worker) { in wg_packet_queue_init()
44 free_percpu(queue->worker); in wg_packet_queue_free()
|
| /kernel/linux/linux-5.10/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()
|
| /kernel/linux/linux-5.10/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 …]
|
| /kernel/linux/linux-5.10/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()
|
| /kernel/linux/linux-5.10/drivers/thermal/intel/ |
| D | intel_powerclamp.c | 75 struct kthread_worker *worker; member
406 kthread_queue_delayed_work(w_data->worker, in clamp_balancing_func()
438 kthread_queue_work(w_data->worker, &w_data->balancing_work); in clamp_idle_injection_func()
481 struct kthread_worker *worker; in start_power_clamp_worker() local
483 worker = kthread_create_worker_on_cpu(cpu, 0, "kidle_inj/%ld", cpu); in start_power_clamp_worker()
484 if (IS_ERR(worker)) in start_power_clamp_worker()
487 w_data->worker = worker; in start_power_clamp_worker()
492 sched_set_fifo(worker->task); in start_power_clamp_worker()
496 kthread_queue_work(w_data->worker, &w_data->balancing_work); in start_power_clamp_worker()
503 if (!w_data->worker) in stop_power_clamp_worker()
[all …]
|
| /kernel/linux/linux-5.10/drivers/i2c/ |
| D | i2c-slave-testunit.c | 42 struct delayed_work worker; member
47 struct testunit_data *tu = container_of(work, struct testunit_data, worker.work); in i2c_slave_testunit_work()
115 queue_delayed_work(system_long_wq, &tu->worker, in i2c_slave_testunit_slave_cb()
143 INIT_DELAYED_WORK(&tu->worker, i2c_slave_testunit_work); in i2c_slave_testunit_probe()
152 cancel_delayed_work_sync(&tu->worker); in i2c_slave_testunit_remove()
|
| /kernel/linux/linux-5.10/drivers/crypto/caam/ |
| D | caamrng.c | 41 struct work_struct worker; member
141 worker); in caam_rng_worker()
159 schedule_work(&ctx->worker); in caam_read()
168 flush_work(&ctx->worker); in caam_cleanup()
192 INIT_WORK(&ctx->worker, caam_rng_worker); in caam_init()
|
| /kernel/linux/linux-5.10/tools/testing/selftests/bpf/prog_tests/ |
| D | send_signal_sched_switch.c | 18 static void *worker(void *p) in worker() function
49 err = pthread_create(threads + i, NULL, worker, NULL); in test_send_signal_sched_switch()
|
| /kernel/linux/linux-5.10/tools/testing/selftests/powerpc/tm/ |
| D | tm-vmx-unavail.c | 27 void *worker(void *unused) in worker() function
104 pthread_create(&thread[i], NULL, &worker, NULL); in tm_vmx_unavail_test()
|
| /kernel/linux/linux-5.10/drivers/hid/ |
| D | hid-bigbenff.c | 185 struct work_struct worker; member
194 schedule_work(&bigben->worker); in bigben_schedule_work()
201 struct bigben_device, worker); in bigben_worker()
365 cancel_work_sync(&bigben->worker); in bigben_remove()
414 INIT_WORK(&bigben->worker, bigben_worker); in bigben_probe()
|
| /kernel/linux/linux-5.10/drivers/platform/olpc/ |
| D | olpc-ec.c | 36 struct work_struct worker; member
80 struct olpc_ec_priv *ec = container_of(w, struct olpc_ec_priv, worker); in olpc_ec_worker()
106 schedule_work(&ec->worker); in olpc_ec_worker()
124 schedule_work(&ec->worker); in queue_ec_descriptor()
418 INIT_WORK(&ec->worker, olpc_ec_worker); in olpc_ec_probe()
|
| /kernel/linux/linux-5.10/drivers/macintosh/ams/ |
| D | ams-core.c | 65 schedule_work(&ams_info.worker); in ams_handle_irq()
185 INIT_WORK(&ams_info.worker, ams_worker); in ams_init()
216 flush_work(&ams_info.worker); in ams_sensor_detach()
|