Searched refs:cq_wait_nr (Results 1 – 5 of 5) sorted by relevance
15 atomic_set(&ctx->cq_wait_nr, nr_wait); in io_loop_wait_start()22 atomic_set(&ctx->cq_wait_nr, IO_CQ_WAKE_INIT); in io_loop_wait_finish()
183 nr_wait = atomic_read(&ctx->cq_wait_nr); in io_req_local_work_add()194 if (!atomic_dec_and_test(&ctx->cq_wait_nr)) in io_req_local_work_add()196 } else if (atomic_xchg(&ctx->cq_wait_nr, IO_CQ_WAKE_INIT) <= 0) { in io_req_local_work_add()
525 atomic_set(&ctx->cq_wait_nr, 1); in io_uring_try_cancel_requests()
254 atomic_set(&ctx->cq_wait_nr, IO_CQ_WAKE_INIT); in io_ring_ctx_alloc()
454 atomic_t cq_wait_nr; member