Lines Matching refs:io_wq
501 BUG_ON(!tctx->io_wq);
517 io_wq_enqueue(tctx->io_wq, &req->work);
3094 if (tsk && tsk->io_uring && tsk->io_uring->io_wq)
3095 io_wq_cancel_cb(tsk->io_uring->io_wq,
3247 * io_wq will stay alive while we hold uring_lock, because it's
3250 if (!tctx || !tctx->io_wq)
3252 cret = io_wq_cancel_cb(tctx->io_wq, io_cancel_ctx_cb, ctx, true);
3281 } else if (tctx && tctx->io_wq) {
3286 cret = io_wq_cancel_cb(tctx->io_wq, io_cancel_task_cb,
3338 if (tctx->io_wq)
3339 io_wq_exit_start(tctx->io_wq);
4323 if (tctx && tctx->io_wq) {
4324 ret = io_wq_max_workers(tctx->io_wq, new_count);
4347 if (WARN_ON_ONCE(!tctx->io_wq))
4353 (void)io_wq_max_workers(tctx->io_wq, new_count);