linux-master/io_uring/cancel.c

35  * Returns true if the request matches the criteria outlined by 'cd'.
37 bool io_cancel_req_match(struct io_kiocb *req, struct io_cancel_data *cd)
39 	bool match_user_data = cd->flags & IORING_ASYNC_CANCEL_USERDATA;
41 	if (req->ctx != cd->ctx)
44 	if (!(cd->flags & (IORING_ASYNC_CANCEL_FD | IORING_ASYNC_CANCEL_OP)))
47 	if (cd->flags & IORING_ASYNC_CANCEL_ANY)
49 	if (cd->flags & IORING_ASYNC_CANCEL_FD) {
50 		if (req->file != cd->file)
53 	if (cd->flags & IORING_ASYNC_CANCEL_OP) {
54 		if (req->opcode != cd->opcode)
57 	if (match_user_data && req->cqe.user_data != cd->data)
59 	if (cd->flags & IORING_ASYNC_CANCEL_ALL) {
61 		if (io_cancel_match_sequence(req, cd->seq))
71 	struct io_cancel_data *cd = data;
73 	return io_cancel_req_match(req, cd);
77 			       struct io_cancel_data *cd)
86 	all = cd->flags & (IORING_ASYNC_CANCEL_ALL|IORING_ASYNC_CANCEL_ANY);
87 	cancel_ret = io_wq_cancel_cb(tctx->io_wq, io_cancel_cb, cd, all);
103 int io_try_cancel(struct io_uring_task *tctx, struct io_cancel_data *cd,
106 	struct io_ring_ctx *ctx = cd->ctx;
111 	ret = io_async_cancel_one(tctx, cd);
119 	ret = io_poll_cancel(ctx, cd, issue_flags);
123 	ret = io_waitid_cancel(ctx, cd, issue_flags);
127 	ret = io_futex_cancel(ctx, cd, issue_flags);
132 	if (!(cd->flags & IORING_ASYNC_CANCEL_FD))
133 		ret = io_timeout_cancel(ctx, cd);
165 static int __io_async_cancel(struct io_cancel_data *cd,
169 	bool all = cd->flags & (IORING_ASYNC_CANCEL_ALL|IORING_ASYNC_CANCEL_ANY);
170 	struct io_ring_ctx *ctx = cd->ctx;
175 		ret = io_try_cancel(tctx, cd, issue_flags);
189 		ret = io_async_cancel_one(tctx, cd);
203 	struct io_cancel_data cd = {
213 	if (cd.flags & IORING_ASYNC_CANCEL_FD) {
215 		    cd.flags & IORING_ASYNC_CANCEL_FD_FIXED) {
226 		cd.file = req->file;
229 	ret = __io_async_cancel(&cd, tctx, issue_flags);
248 			    struct io_cancel_data *cd, int fd)
250 	struct io_ring_ctx *ctx = cd->ctx;
253 	if ((cd->flags & IORING_ASYNC_CANCEL_FD) &&
254 	    (cd->flags & IORING_ASYNC_CANCEL_FD_FIXED)) {
258 		cd->file = io_file_from_index(&ctx->file_table, fd);
259 		if (!cd->file)
263 	return __io_async_cancel(cd, tctx, 0);
269 	struct io_cancel_data cd = {
290 	cd.data = sc.addr;
291 	cd.flags = sc.flags;
292 	cd.opcode = sc.opcode;
295 	if ((cd.flags & IORING_ASYNC_CANCEL_FD) &&
296 	   !(cd.flags & IORING_ASYNC_CANCEL_FD_FIXED)) {
300 		cd.file = file;
303 	ret = __io_sync_cancel(current->io_uring, &cd, sc.fd);
323 		cd.seq = atomic_inc_return(&ctx->cancel_seq);
327 		ret = __io_sync_cancel(current->io_uring, &cd, sc.fd);