Lines Matching refs:io_wq
456 BUG_ON(!tctx->io_wq); in io_queue_iowq()
472 io_wq_enqueue(tctx->io_wq, &req->work); in io_queue_iowq()
2753 if (tsk && tsk->io_uring && tsk->io_uring->io_wq) in io_ring_exit_work()
2754 io_wq_cancel_cb(tsk->io_uring->io_wq, in io_ring_exit_work()
2894 if (!tctx || !tctx->io_wq) in io_uring_try_cancel_iowq()
2896 cret = io_wq_cancel_cb(tctx->io_wq, io_cancel_ctx_cb, ctx, true); in io_uring_try_cancel_iowq()
2919 } else if (tctx && tctx->io_wq) { in io_uring_try_cancel_requests()
2924 cret = io_wq_cancel_cb(tctx->io_wq, io_cancel_task_cb, in io_uring_try_cancel_requests()
2972 if (tctx->io_wq) in io_uring_cancel_generic()
2973 io_wq_exit_start(tctx->io_wq); in io_uring_cancel_generic()
3761 if (!tctx || !tctx->io_wq) in io_register_iowq_aff()
3784 ret = io_wq_cpu_affinity(tctx->io_wq, new_mask); in io_register_iowq_aff()
3793 if (!tctx || !tctx->io_wq) in io_unregister_iowq_aff()
3796 return io_wq_cpu_affinity(tctx->io_wq, NULL); in io_unregister_iowq_aff()
3841 if (tctx && tctx->io_wq) { in io_register_iowq_max_workers()
3842 ret = io_wq_max_workers(tctx->io_wq, new_count); in io_register_iowq_max_workers()
3865 if (WARN_ON_ONCE(!tctx->io_wq)) in io_register_iowq_max_workers()
3871 (void)io_wq_max_workers(tctx->io_wq, new_count); in io_register_iowq_max_workers()