Home
last modified time | relevance | path

Searched refs:wq (Results 1 – 4 of 4) sorted by relevance

/io_uring/
Dio-wq.c101 struct io_wq *wq; member
138 static bool create_io_worker(struct io_wq *wq, struct io_wqe *wqe, int index);
144 static void io_wq_cancel_tw_create(struct io_wq *wq);
173 static void io_worker_ref_put(struct io_wq *wq) in io_worker_ref_put() argument
175 if (atomic_dec_and_test(&wq->worker_refs)) in io_worker_ref_put()
176 complete(&wq->worker_done); in io_worker_ref_put()
186 return test_bit(IO_WQ_BIT_EXIT, &worker->wqe->wq->state); in io_wq_worker_stopped()
193 struct io_wq *wq = wqe->wq; in io_worker_cancel_cb() local
199 io_worker_ref_put(wq); in io_worker_cancel_cb()
217 struct io_wq *wq = wqe->wq; in io_worker_exit() local
[all …]
Dio-wq.h135 void io_wq_exit_start(struct io_wq *wq);
136 void io_wq_put_and_exit(struct io_wq *wq);
138 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work);
141 int io_wq_cpu_affinity(struct io_wq *wq, cpumask_var_t mask);
142 int io_wq_max_workers(struct io_wq *wq, int *new_count);
152 enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel,
DMakefile6 obj-$(CONFIG_IO_WQ) += io-wq.o
Dio_uring.c7611 struct wait_queue_entry wq; member
7634 wq); in io_wake_function()
7737 init_waitqueue_func_entry(&iowq.wq, io_wake_function); in io_cqring_wait()
7738 iowq.wq.private = current; in io_cqring_wait()
7739 INIT_LIST_HEAD(&iowq.wq.entry); in io_cqring_wait()
7751 prepare_to_wait_exclusive(&ctx->cq_wait, &iowq.wq, in io_cqring_wait()
7754 finish_wait(&ctx->cq_wait, &iowq.wq); in io_cqring_wait()
9850 struct io_wq *wq = tctx->io_wq; in io_uring_clean_tctx() local
9858 if (wq) { in io_uring_clean_tctx()
9863 io_wq_put_and_exit(wq); in io_uring_clean_tctx()