| /linux/kernel/ |
| H A D | workqueue_internal.h | 24 struct worker { struct
45 struct task_struct *task; /* I: worker task */ argument
37 sleepingworker global() argument
44 taskworker global() argument
47 nodeworker global() argument
52 idworker global() argument
65 rescue_wqworker global() 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 | 584 for_each_pool_worker(worker,pool) global() argument
975 worker_set_flags(struct worker * worker,unsigned int flags) worker_set_flags() argument
997 worker_clr_flags(struct worker * worker,unsigned int flags) worker_clr_flags() argument
1035 worker_enter_idle(struct worker * worker) worker_enter_idle() argument
1068 worker_leave_idle(struct worker * worker) worker_leave_idle() argument
1115 struct worker *worker; find_worker_executing_work() local
1186 assign_work(struct work_struct * work,struct worker * worker,struct work_struct ** nextp) assign_work() argument
1254 struct worker *worker = first_idle_worker(pool); kick_pool() local
1406 struct worker *worker = kthread_data(task); wq_worker_running() local
1440 struct worker *worker = kthread_data(task); wq_worker_sleeping() local
1486 struct worker *worker = kthread_data(task); wq_worker_tick() local
1553 struct worker *worker = kthread_data(task); wq_worker_last_func() local
2213 struct worker *worker; is_chained_work() local
2298 struct worker *worker; __queue_work() local
2658 struct worker *worker; alloc_worker() local
2688 worker_attach_to_pool(struct worker * worker,struct worker_pool * pool) worker_attach_to_pool() argument
2714 unbind_worker(struct worker * worker) unbind_worker() argument
2726 detach_worker(struct worker * worker) detach_worker() argument
2742 worker_detach_from_pool(struct worker * worker) worker_detach_from_pool() argument
2758 format_worker_id(char * buf,size_t size,struct worker * worker,struct worker_pool * pool) format_worker_id() argument
2792 struct worker *worker; create_worker() local
2861 struct worker *worker; detach_dying_workers() local
2869 struct worker *worker, *tmp; reap_dying_workers() local
2889 set_worker_dying(struct worker * worker,struct list_head * list) set_worker_dying() argument
2934 struct worker *worker; idle_worker_timeout() local
2977 struct worker *worker; idle_cull_fn() local
3142 manage_workers(struct worker * worker) manage_workers() argument
3174 process_one_work(struct worker * worker,struct work_struct * work) process_one_work() argument
3347 process_scheduled_works(struct worker * worker) process_scheduled_works() argument
3386 struct worker *worker = __worker; worker_thread() local
3635 bh_worker(struct worker * worker) bh_worker() argument
3789 struct worker *worker; check_flush_dependency() local
3845 insert_wq_barrier(struct pool_workqueue * pwq,struct wq_barrier * barr,struct work_struct * target,struct worker * worker) insert_wq_barrier() argument
4228 struct worker *worker = NULL; start_flush_work() local
5015 struct worker *worker; put_unbound_pool() local
6095 struct worker *worker = current_wq_worker(); current_work() local
6111 struct worker *worker = current_wq_worker(); current_is_workqueue_rescuer() local
6200 struct worker *worker = current_wq_worker(); set_worker_desc() local
6231 struct worker *worker; print_worker_info() local
6273 pr_cont_worker_id(struct worker * worker) pr_cont_worker_id() argument
6334 struct worker *worker; show_pwq() local
6454 struct worker *worker; show_one_worker_pool() local
6551 struct worker *worker = kthread_data(task); wq_worker_comm() local
6601 struct worker *worker; unbind_workers() local
6654 struct worker *worker; rebind_workers() local
6715 struct worker *worker; restore_unbound_workers_cpumask() local
7001 struct worker *worker; workqueue_apply_unbound_cpumask() local
7589 struct worker *worker; show_cpu_pool_hog() local
[all...] |
| /linux/io_uring/ |
| H A D | io-wq.c | 165 static bool io_worker_get(struct io_worker *worker) in io_worker_get()
170 static void io_worker_release(struct io_worker *worker) in io_worker_release()
187 static inline struct io_wq_acct *io_wq_get_acct(struct io_worker *worker) in io_wq_get_acct()
200 struct io_worker *worker = current->worker_private; in io_wq_worker_stopped() local
208 static void io_worker_cancel_cb(struct io_worker *worker) in io_worker_cancel_cb()
224 struct io_worker *worker; in io_task_worker_match() local
232 static void io_worker_exit(struct io_worker *worker) in io_worker_exit()
296 struct io_worker *worker; in io_acct_activate_free_worker() local
344 static void io_wq_inc_running(struct io_worker *worker) in io_wq_inc_running()
353 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()
171 static void create_process_worker(union messaging_worker *worker, in create_process_worker()
185 static void create_worker(union messaging_worker *worker, in create_worker()
194 static void reap_worker(union messaging_worker *worker) in reap_worker()
210 static unsigned int group(union messaging_worker *worker, in group()
|
| 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
402 struct vhost_worker *worker = data; in vhost_run_work_kthread_list() local
440 struct vhost_worker *worker = data; in vhost_run_work_list() local
465 struct vhost_worker *worker = data; in vhost_worker_killed() local
647 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/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/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/fs/erofs/ |
| H A D | zdata.c | 296 struct kthread_worker *worker; in erofs_destroy_percpu_workers() local
311 struct kthread_worker *worker = in erofs_init_percpu_worker() local
323 struct kthread_worker *worker; in erofs_init_percpu_workers() local
345 struct kthread_worker *worker, *old; in erofs_cpu_online() local
364 struct kthread_worker *worker; in erofs_cpu_offline() local
1460 struct kthread_worker *worker; in z_erofs_decompress_kickoff() local
|
| /linux/drivers/gpio/ |
| H A D | gpio-mpsse.c | 370 struct mpsse_worker *worker, *worker_tmp; in gpio_mpsse_stop_all_except() local
493 struct mpsse_worker *worker; in gpio_mpsse_irq_disable() local
511 struct mpsse_worker *worker; in gpio_mpsse_irq_enable() 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_gt_sriov_vf_types.h | 50 struct work_struct worker; member
|
| /linux/drivers/i2c/ |
| H A D | i2c-slave-testunit.c | 50 struct delayed_work worker; member
|
| /linux/arch/x86/kvm/ |
| H A D | i8254.h | 51 struct kthread_worker *worker; member
|