Searched refs:wq (Results 1 – 6 of 6) sorted by relevance
/io_uring/ |
A D | io-wq.c | 209 struct io_wq *wq = worker->wq; in io_worker_cancel_cb() local 232 struct io_wq *wq = worker->wq; in io_worker_exit() local 358 wq = worker->wq; in create_worker_cb() 389 struct io_wq *wq = worker->wq; in io_queue_worker_create() local 457 struct io_wq *wq = worker->wq; in io_wq_dec_running() local 511 __add_wait_queue(&wq->hash->wait, &wq->wait); in io_wait_on_hash() 600 struct io_wq *wq = worker->wq; in io_worker_handle_work() local 684 struct io_wq *wq = worker->wq; in io_wq_worker() local 843 wq = worker->wq; in create_worker_cont() 905 worker->wq = wq; in create_io_worker() [all …]
|
A D | io-wq.h | 42 void io_wq_exit_start(struct io_wq *wq); 43 void io_wq_put_and_exit(struct io_wq *wq); 45 void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work); 49 int io_wq_max_workers(struct io_wq *wq, int *new_count); 64 enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel,
|
A D | io_uring.h | 43 struct wait_queue_entry wq; member 297 static inline void __io_wq_wake(struct wait_queue_head *wq) in __io_wq_wake() argument 306 if (wq_has_sleeper(wq)) in __io_wq_wake() 307 __wake_up(wq, TASK_NORMAL, 0, poll_to_key(EPOLL_URING_WAKE | EPOLLIN)); in __io_wq_wake()
|
A D | tctx.c | 190 struct io_wq *wq = tctx->io_wq; in io_uring_clean_tctx() local 198 if (wq) { in io_uring_clean_tctx() 203 io_wq_put_and_exit(wq); in io_uring_clean_tctx()
|
A D | Makefile | 18 obj-$(CONFIG_IO_WQ) += io-wq.o
|
A D | io_uring.c | 2421 struct io_wait_queue *iowq = container_of(curr, struct io_wait_queue, wq); in io_wake_function() 2461 wake_up_process(iowq->wq.private); in io_cqring_timer_wakeup() 2614 init_waitqueue_func_entry(&iowq.wq, io_wake_function); in io_cqring_wait() 2615 iowq.wq.private = current; in io_cqring_wait() 2616 INIT_LIST_HEAD(&iowq.wq.entry); in io_cqring_wait() 2663 prepare_to_wait_exclusive(&ctx->cq_wait, &iowq.wq, in io_cqring_wait() 2711 finish_wait(&ctx->cq_wait, &iowq.wq); in io_cqring_wait()
|
Completed in 16 milliseconds