Home
last modified time | relevance | path

Searched refs:wait (Results 1 – 3 of 3) sorted by relevance

/io_uring/
Dio-wq.c99 struct wait_queue_entry wait; member
454 spin_lock_irq(&wq->hash->wait.lock); in io_wait_on_hash()
455 if (list_empty(&wqe->wait.entry)) { in io_wait_on_hash()
456 __add_wait_queue(&wq->hash->wait, &wqe->wait); in io_wait_on_hash()
459 list_del_init(&wqe->wait.entry); in io_wait_on_hash()
463 spin_unlock_irq(&wq->hash->wait.lock); in io_wait_on_hash()
516 if (wq_has_sleeper(&wqe->wq->hash->wait)) in io_get_next_work()
517 wake_up(&wqe->wq->hash->wait); in io_get_next_work()
601 spin_lock_irq(&wq->hash->wait.lock); in io_worker_handle_work()
604 spin_unlock_irq(&wq->hash->wait.lock); in io_worker_handle_work()
[all …]
Dio_uring.c287 struct wait_queue_head wait; member
477 struct wait_queue_head wait; member
500 struct wait_queue_entry wait; member
1660 if (ctx->sq_data && waitqueue_active(&ctx->sq_data->wait)) in io_cqring_ev_posted()
1661 wake_up(&ctx->sq_data->wait); in io_cqring_ev_posted()
1755 wake_up(&tctx->wait); in io_put_task()
2909 wq_has_sleeper(&ctx->sq_data->wait)) in io_iopoll_req_issued()
2910 wake_up(&ctx->sq_data->wait); in io_iopoll_req_issued()
3530 static int io_async_buf_func(struct wait_queue_entry *wait, unsigned mode, in io_async_buf_func() argument
3534 struct io_kiocb *req = wait->private; in io_async_buf_func()
[all …]
Dio-wq.h118 struct wait_queue_head wait; member