Lines Matching refs:io_wq
295 struct io_wq *io_wq; member
1432 io_wq_enqueue(ctx->io_wq, &req->work); in __io_queue_async_work()
2083 tsk = io_wq_get_task(req->ctx->io_wq); in io_req_task_queue()
2204 tsk = io_wq_get_task(req->ctx->io_wq); in io_free_req_deferred()
3314 tsk = io_wq_get_task(req->ctx->io_wq); in io_async_buf_func()
4896 tsk = io_wq_get_task(req->ctx->io_wq); in __io_async_wake()
5603 cancel_ret = io_wq_cancel_cb(ctx->io_wq, io_cancel_cb, sqe_addr, false); in io_async_cancel_one()
7117 if (ctx->io_wq) { in io_finish_async()
7118 io_wq_destroy(ctx->io_wq); in io_finish_async()
7119 ctx->io_wq = NULL; in io_finish_async()
7708 ctx->io_wq = io_wq_create(concurrency, &data); in io_init_wq_offload()
7709 if (IS_ERR(ctx->io_wq)) { in io_init_wq_offload()
7710 ret = PTR_ERR(ctx->io_wq); in io_init_wq_offload()
7711 ctx->io_wq = NULL; in io_init_wq_offload()
7727 if (!io_wq_get(ctx_attach->io_wq, &data)) { in io_init_wq_offload()
7732 ctx->io_wq = ctx_attach->io_wq; in io_init_wq_offload()
8388 if (ctx->io_wq) in io_ring_ctx_wait_and_kill()
8389 io_wq_cancel_all(ctx->io_wq); in io_ring_ctx_wait_and_kill()
8521 cret = io_wq_cancel_work(ctx->io_wq, &req->work); in io_attempt_cancel()
8526 cret = io_wq_cancel_cb(ctx->io_wq, io_cancel_link_cb, req, true); in io_attempt_cancel()
8575 io_wq_cancel_cb(ctx->io_wq, io_wq_files_match, files, true); in io_uring_cancel_files()
8630 cret = io_wq_cancel_cb(ctx->io_wq, io_cancel_task_cb, task, true); in __io_uring_cancel_task_requests()