Home
last modified time | relevance | path

Searched defs:worker (Results 1 – 25 of 55) sorted by relevance

123

/Linux-v5.15/kernel/
Dworkqueue_internal.h24 struct worker { struct
39 struct task_struct *task; /* I: worker task */ argument
40 struct worker_pool *pool; /* A: the associated pool */ argument
42 struct list_head node; /* A: anchored at pool->workers */ argument
47 int id; /* I: worker id */ argument
59 /* used by the scheduler to determine a worker's last known identity */ argument
64 * current_wq_worker - return struct worker if %current is a workqueue worker argument
Dkthread.c695 void __kthread_init_worker(struct kthread_worker *worker, in __kthread_init_worker()
724 struct kthread_worker *worker = worker_ptr; in kthread_worker_fn() local
781 struct kthread_worker *worker; in __kthread_create_worker() local
824 struct kthread_worker *worker; in kthread_create_worker() local
874 struct kthread_worker *worker; in kthread_create_worker_on_cpu() local
890 static inline bool queuing_blocked(struct kthread_worker *worker, in queuing_blocked()
898 static void kthread_insert_work_sanity_check(struct kthread_worker *worker, in kthread_insert_work_sanity_check()
908 static void kthread_insert_work(struct kthread_worker *worker, in kthread_insert_work()
934 bool kthread_queue_work(struct kthread_worker *worker, in kthread_queue_work()
962 struct kthread_worker *worker = work->worker; in kthread_delayed_work_timer_fn() local
[all …]
Dworkqueue.c425 #define for_each_pool_worker(worker, pool) \ argument
852 struct worker *worker = first_idle_worker(pool); in wake_up_worker() local
866 struct worker *worker = kthread_data(task); in wq_worker_running() local
885 struct worker *next, *worker = kthread_data(task); in wq_worker_sleeping() local
951 struct worker *worker = kthread_data(task); in wq_worker_last_func() local
966 static inline void worker_set_flags(struct worker *worker, unsigned int flags) in worker_set_flags()
991 static inline void worker_clr_flags(struct worker *worker, unsigned int flags) in worker_clr_flags()
1046 struct worker *worker; in find_worker_executing_work() local
1377 struct worker *worker; in is_chained_work() local
1462 struct worker *worker; in __queue_work() local
[all …]
Dasync.c304 struct worker *worker = current_wq_worker(); in current_is_async() local
/Linux-v5.15/fs/
Dio-wq.c144 static bool io_worker_get(struct io_worker *worker) in io_worker_get()
149 static void io_worker_release(struct io_worker *worker) in io_worker_release()
166 static inline struct io_wqe_acct *io_wqe_get_acct(struct io_worker *worker) in io_wqe_get_acct()
177 static void io_worker_exit(struct io_worker *worker) in io_worker_exit()
218 struct io_worker *worker; in io_wqe_activate_free_worker() local
267 static void io_wqe_inc_running(struct io_worker *worker) in io_wqe_inc_running()
276 struct io_worker *worker; in create_worker_cb() local
302 static bool io_queue_worker_create(struct io_worker *worker, in io_queue_worker_create()
337 static void io_wqe_dec_running(struct io_worker *worker) in io_wqe_dec_running()
357 static void __io_worker_busy(struct io_wqe *wqe, struct io_worker *worker, in __io_worker_busy()
[all …]
/Linux-v5.15/tools/perf/bench/
Dfutex-hash.c42 struct worker { struct
43 int tid;
44 u_int32_t *futex;
45 pthread_t thread;
69 static void *workerfn(void *arg) in workerfn() argument
129 struct worker *worker = NULL; in bench_futex_hash() local
Dfutex-lock-pi.c26 struct worker { struct
34 static struct worker *worker; argument
Depoll-wait.c117 struct worker { struct
118 int tid;
119 int epollfd; /* for --multiq */
120 pthread_t thread;
121 unsigned long ops;
122 int *fdmap;
291 static int do_threads(struct worker *worker, struct perf_cpu_map *cpu) in do_threads()
368 struct worker *worker = p; in writerfn() local
417 struct worker *worker = NULL; in bench_epoll_wait() local
Depoll-ctl.c66 struct worker { struct
67 int tid;
68 pthread_t thread;
69 unsigned long ops[EPOLL_NR_OPS];
70 int *fdmap;
222 static int do_threads(struct worker *worker, struct perf_cpu_map *cpu) in do_threads()
303 struct worker *worker = NULL; in bench_epoll_ctl() local
Dfutex-wake.c35 static pthread_t *worker; variable
Dfutex-requeue.c35 static pthread_t *worker; variable
/Linux-v5.15/include/linux/
Dkthread.h106 struct kthread_worker *worker; member
116 #define KTHREAD_WORKER_INIT(worker) { \ argument
133 #define DEFINE_KTHREAD_WORKER(worker) \ argument
148 # define KTHREAD_WORKER_INIT_ONSTACK(worker) \ argument
150 # define DEFINE_KTHREAD_WORKER_ONSTACK(worker) \ argument
153 # define DEFINE_KTHREAD_WORKER_ONSTACK(worker) DEFINE_KTHREAD_WORKER(worker) argument
159 #define kthread_init_worker(worker) \ argument
Ddevm-helpers.h48 work_func_t worker) in devm_delayed_work_autocancel()
73 work_func_t worker) in devm_work_autocancel()
/Linux-v5.15/tools/testing/selftests/bpf/prog_tests/
Dsend_signal_sched_switch.c18 static void *worker(void *p) in worker() function
/Linux-v5.15/tools/testing/selftests/powerpc/tm/
Dtm-vmx-unavail.c26 void *worker(void *unused) in worker() function
/Linux-v5.15/include/drm/
Ddrm_flip_work.h76 struct work_struct worker; member
Ddrm_vblank.h212 struct kthread_worker *worker; member
/Linux-v5.15/drivers/net/wireguard/
Dqueueing.c12 struct multicore_worker __percpu *worker = alloc_percpu(struct multicore_worker); in wg_packet_percpu_multicore_worker_alloc() local
/Linux-v5.15/drivers/gpu/drm/
Ddrm_vblank_work.c251 struct kthread_worker *worker; in drm_vblank_worker_init() local
/Linux-v5.15/samples/seccomp/
Duser-trap.c204 pid_t worker = 0 , tracer = 0; in main() local
/Linux-v5.15/drivers/macintosh/ams/
Dams.h34 struct work_struct worker; member
/Linux-v5.15/drivers/i2c/
Di2c-slave-testunit.c43 struct delayed_work worker; member
/Linux-v5.15/drivers/thermal/intel/
Dintel_powerclamp.c74 struct kthread_worker *worker; member
477 struct kthread_worker *worker; in start_power_clamp_worker() local
/Linux-v5.15/drivers/gpu/drm/i915/gt/uc/
Dintel_guc_ct.h83 struct work_struct worker; /* handler for incoming requests */ member
/Linux-v5.15/drivers/block/
Dloop.c1002 struct loop_worker *cur_worker, *worker = NULL; in loop_queue_work() local
1336 struct loop_worker *pos, *worker; in __loop_clr_fd() local
2227 static void loop_process_work(struct loop_worker *worker, in loop_process_work()
2263 struct loop_worker *worker = in loop_workfn() local
2278 struct loop_worker *pos, *worker; in loop_free_idle_workers() local

123