| /linux/kernel/ |
| H A D | workqueue_internal.h | 24 struct worker { struct
38 int sleeping; /* S: is worker sleeping? */ argument
45 struct task_struct *task; /* I: worker task */ argument
46 struct worker_pool *pool; /* A: the associated pool */ argument
48 struct list_head node; /* A: anchored at pool->workers */ argument
53 int id; /* I: worker id */ argument
66 * current_wq_worker - return struct worker if %current is a workqueue worker argument
|
| H A D | kthread.c | 958 void __kthread_init_worker(struct kthread_worker *worker, in __kthread_init_worker()
987 struct kthread_worker *worker = worker_ptr; in kthread_worker_fn() local
1052 struct kthread_worker *worker; in __kthread_create_worker_on_node() local
1089 struct kthread_worker *worker; in kthread_create_worker_on_node() local
1140 struct kthread_worker *worker; in kthread_create_worker_on_cpu() local
1155 static inline bool queuing_blocked(struct kthread_worker *worker, in queuing_blocked()
1163 static void kthread_insert_work_sanity_check(struct kthread_worker *worker, in kthread_insert_work_sanity_check()
1173 static void kthread_insert_work(struct kthread_worker *worker, in kthread_insert_work()
1199 bool kthread_queue_work(struct kthread_worker *worker, in kthread_queue_work()
1228 struct kthread_worker *worker = work->worker; in kthread_delayed_work_timer_fn() local
[all …]
|
| H A D | workqueue.c | 601 for_each_pool_worker(worker,pool) global() argument
992 worker_set_flags(struct worker * worker,unsigned int flags) worker_set_flags() argument
1014 worker_clr_flags(struct worker * worker,unsigned int flags) worker_clr_flags() argument
1052 worker_enter_idle(struct worker * worker) worker_enter_idle() argument
1085 worker_leave_idle(struct worker * worker) worker_leave_idle() argument
1132 struct worker *worker; find_worker_executing_work() local
1203 assign_work(struct work_struct * work,struct worker * worker,struct work_struct ** nextp) assign_work() argument
1277 struct worker *worker = first_idle_worker(pool); kick_pool_pick() local
1452 struct worker *worker = kthread_data(task); wq_worker_running() local
1486 struct worker *worker = kthread_data(task); wq_worker_sleeping() local
1532 struct worker *worker = kthread_data(task); wq_worker_tick() local
1603 struct worker *worker = kthread_data(task); wq_worker_last_func() local
2286 struct worker *worker; is_chained_work() local
2392 struct worker *worker; __queue_work() local
2753 struct worker *worker; alloc_worker() local
2783 worker_attach_to_pool(struct worker * worker,struct worker_pool * pool) worker_attach_to_pool() argument
2809 unbind_worker(struct worker * worker) unbind_worker() argument
2821 detach_worker(struct worker * worker) detach_worker() argument
2837 worker_detach_from_pool(struct worker * worker) worker_detach_from_pool() argument
2853 format_worker_id(char * buf,size_t size,struct worker * worker,struct worker_pool * pool) format_worker_id() argument
2887 struct worker *worker; create_worker() local
2956 struct worker *worker; detach_dying_workers() local
2964 struct worker *worker, *tmp; reap_dying_workers() local
2984 set_worker_dying(struct worker * worker,struct list_head * list) set_worker_dying() argument
3036 struct worker *worker; idle_worker_timeout() local
3079 struct worker *worker; idle_cull_fn() local
3253 manage_workers(struct worker * worker) manage_workers() argument
3285 process_one_work(struct worker * worker,struct work_struct * work) process_one_work() argument
3468 process_scheduled_works(struct worker * worker) process_scheduled_works() argument
3507 struct worker *worker = __worker; worker_thread() local
3756 bh_worker(struct worker * worker) bh_worker() argument
3910 struct worker *worker; check_flush_dependency() local
3966 insert_wq_barrier(struct pool_workqueue * pwq,struct wq_barrier * barr,struct work_struct * target,struct worker * worker) insert_wq_barrier() argument
4349 struct worker *worker = NULL; start_flush_work() local
5136 struct worker *worker; put_unbound_pool() local
6284 struct worker *worker = current_wq_worker(); current_work() local
6300 struct worker *worker = current_wq_worker(); current_is_workqueue_rescuer() local
6321 struct worker *worker = current_wq_worker(); current_is_workqueue_mem_reclaim() local
6413 struct worker *worker = current_wq_worker(); set_worker_desc() local
6444 struct worker *worker; print_worker_info() local
6486 pr_cont_worker_id(struct worker * worker) pr_cont_worker_id() argument
6547 struct worker *worker; show_pwq() local
6669 struct worker *worker; show_one_worker_pool() local
6766 struct worker *worker = kthread_data(task); wq_worker_comm() local
6816 struct worker *worker; unbind_workers() local
6869 struct worker *worker; rebind_workers() local
6930 struct worker *worker; restore_unbound_workers_cpumask() local
7216 struct worker *worker; workqueue_apply_unbound_cpumask() local
7840 struct worker *worker; show_cpu_pool_busy_workers() local
[all...] |
| /linux/io_uring/ |
| H A D | io-wq.c | 166 static bool io_worker_get(struct io_worker *worker) in io_worker_get()
171 static void io_worker_release(struct io_worker *worker) in io_worker_release()
188 static inline struct io_wq_acct *io_wq_get_acct(struct io_worker *worker) in io_wq_get_acct()
201 struct io_worker *worker = current->worker_private; in io_wq_worker_stopped() local
209 static void io_worker_cancel_cb(struct io_worker *worker) in io_worker_cancel_cb()
228 struct io_worker *worker; in io_task_worker_match() local
236 static void io_worker_exit(struct io_worker *worker) in io_worker_exit()
300 struct io_worker *worker; in io_acct_activate_free_worker() local
348 static void io_wq_inc_running(struct io_worker *worker) in io_wq_inc_running()
357 struct io_worker *worker; in create_worker_cb() local
[all …]
|
| /linux/tools/perf/bench/ |
| H A D | futex-hash.c | 44 struct worker { struct
45 int tid;
46 u_int32_t *futex;
47 pthread_t thread;
48 unsigned long ops;
134 struct worker *worker = NULL; in bench_futex_hash() local
|
| H A D | futex-lock-pi.c | 27 struct worker { struct
35 static struct worker *worker; argument
|
| H A D | epoll-ctl.c | 67 struct worker { struct
68 int tid;
69 pthread_t thread;
70 unsigned long ops[EPOLL_NR_OPS];
71 int *fdmap;
223 static int do_threads(struct worker *worker, struct perf_cpu_map *cpu) in do_threads()
317 struct worker *worker = NULL; in bench_epoll_ctl() local
|
| H A D | sched-messaging.c | 150 static void create_thread_worker(union messaging_worker *worker, in create_thread_worker() argument
171 static void create_process_worker(union messaging_worker *worker, in create_process_worker() argument
185 static void create_worker(union messaging_worker *worker, in create_worker() argument
194 static void reap_worker(union messaging_worker *worker) in reap_worker() argument
210 group(union messaging_worker * worker,unsigned int num_fds,int ready_out,int wakefd) group() argument
[all...] |
| H A D | futex-wake.c | 36 static pthread_t *worker; variable
|
| H A D | futex-requeue.c | 36 static pthread_t *worker; variable
|
| /linux/drivers/vhost/ |
| H A D | vhost.c | 244 static void vhost_worker_queue(struct vhost_worker *worker, in vhost_worker_queue()
259 struct vhost_worker *worker; in vhost_vq_work_queue() local
280 static void __vhost_worker_flush(struct vhost_worker *worker) in __vhost_worker_flush()
300 static void vhost_worker_flush(struct vhost_worker *worker) in vhost_worker_flush()
309 struct vhost_worker *worker; in vhost_dev_flush() local
320 struct vhost_worker *worker; in vhost_vq_has_work() local
414 struct vhost_worker *worker = data; in vhost_run_work_kthread_list() local
452 struct vhost_worker *worker = data; in vhost_run_work_list() local
477 struct vhost_worker *worker = data; in vhost_worker_killed() local
659 static int vhost_attach_task_to_cgroups(struct vhost_worker *worker) in vhost_attach_task_to_cgroups()
[all …]
|
| /linux/include/linux/ |
| H A D | devm-helpers.h | 48 work_func_t worker) in devm_delayed_work_autocancel()
73 work_func_t worker) in devm_work_autocancel()
|
| H A D | kthread.h | 156 struct kthread_worker *worker; member
187 #define kthread_init_worker(worker) \ argument
|
| /linux/tools/testing/selftests/sched_ext/ |
| H A D | cyclic_kick_wait.c | 45 struct worker_ctx *worker = arg; in worker_fn() local
62 static int join_worker(struct worker_ctx *worker) in join_worker()
|
| /linux/tools/testing/selftests/powerpc/tm/ |
| H A D | tm-vmx-unavail.c | 26 void *worker(void *unused) in worker() function
|
| /linux/tools/testing/selftests/bpf/prog_tests/ |
| H A D | send_signal_sched_switch.c | 18 static void *worker(void *p) in worker() function
|
| /linux/include/drm/ |
| H A D | drm_flip_work.h | 65 struct work_struct worker; member
|
| /linux/drivers/hid/ |
| H A D | hid-asus.c | 162 struct asus_worker *worker; member
393 static void asus_worker_schedule(struct asus_worker *worker, struct asus_work_action *action) in asus_worker_schedule()
743 struct asus_worker *worker = drvdata->worker; in asus_kbd_backlight_set() local
764 struct asus_worker *worker = container_of(work, struct asus_worker, work); in asus_work() local
820 static void asus_worker_stop(struct asus_worker *worker) in asus_worker_stop()
|
| /linux/drivers/gpu/drm/i915/selftests/ |
| H A D | i915_request.c | 304 struct kthread_worker *worker; member
494 struct kthread_worker *worker; in mock_breadcrumbs_smoketest() local
1459 struct kthread_worker *worker; member
1647 struct kthread_worker *worker; in live_parallel_engines() local
1806 struct kthread_worker *worker; in live_breadcrumbs_smoketest() local
2957 struct kthread_worker *worker; member
3215 struct kthread_worker *worker; in perf_parallel_engines() local
|
| /linux/drivers/net/wireguard/ |
| H A D | queueing.c | 13 struct multicore_worker __percpu *worker = alloc_percpu(struct multicore_worker); in wg_packet_percpu_multicore_worker_alloc() local
|
| /linux/drivers/gpio/ |
| H A D | gpio-mpsse.c | 370 struct mpsse_worker *worker, *worker_tmp; gpio_mpsse_stop_all_except() local
493 struct mpsse_worker *worker; gpio_mpsse_irq_disable() local
511 struct mpsse_worker *worker; gpio_mpsse_irq_enable() local
[all...] |
| /linux/fs/erofs/ |
| H A D | zdata.c | 306 struct kthread_worker *worker; in erofs_destroy_percpu_workers() local
321 struct kthread_worker *worker = in erofs_init_percpu_worker() local
333 struct kthread_worker *worker; in erofs_init_percpu_workers() local
355 struct kthread_worker *worker, *old; in erofs_cpu_online() local
374 struct kthread_worker *worker; in erofs_cpu_offline() local
1445 struct kthread_worker *worker; in z_erofs_decompress_kickoff() local
|
| /linux/drivers/macintosh/ams/ |
| H A D | ams.h | 37 struct work_struct worker; member
|
| /linux/samples/seccomp/ |
| H A D | user-trap.c | 208 pid_t worker = 0 , tracer = 0; in main() local
|
| /linux/drivers/gpu/drm/xe/ |
| H A D | xe_pagefault_types.h | 138 struct work_struct worker; member
|