76 static int io_async_cancel_one(struct io_uring_task *tctx,  in io_async_cancel_one()  argument
83 	if (!tctx || !tctx->io_wq)  in io_async_cancel_one()
87 	cancel_ret = io_wq_cancel_cb(tctx->io_wq, io_cancel_cb, cd, all);  in io_async_cancel_one()
103 int io_try_cancel(struct io_uring_task *tctx, struct io_cancel_data *cd,  in io_try_cancel()  argument
109 	WARN_ON_ONCE(!io_wq_current_is_worker() && tctx != current->io_uring);  in io_try_cancel()
111 	ret = io_async_cancel_one(tctx, cd);  in io_try_cancel()
166 			     struct io_uring_task *tctx,  in __io_async_cancel()  argument
175 		ret = io_try_cancel(tctx, cd, issue_flags);  in __io_async_cancel()
208 	struct io_uring_task *tctx = req->tctx;  in io_async_cancel()  local
227 	ret = __io_async_cancel(&cd, tctx, issue_flags);  in io_async_cancel()
235 static int __io_sync_cancel(struct io_uring_task *tctx,  in __io_sync_cancel()  argument
253 	return __io_async_cancel(cd, tctx, 0);  in __io_sync_cancel()
345 bool io_cancel_remove_all(struct io_ring_ctx *ctx, struct io_uring_task *tctx,  in io_cancel_remove_all()  argument
356 		if (!io_match_task_safe(req, tctx, cancel_all))  in io_cancel_remove_all()