Searched refs:cd (Results 1 – 10 of 10) sorted by relevance
| /io_uring/ |
| A D | cancel.c | 41 if (req->ctx != cd->ctx) in io_cancel_req_match()
50 if (req->file != cd->file) in io_cancel_req_match()
54 if (req->opcode != cd->opcode) in io_cancel_req_match()
201 struct io_cancel_data cd = { in io_async_cancel() local
224 cd.file = req->file; in io_async_cancel()
249 if (!cd->file) in __io_sync_cancel()
259 struct io_cancel_data cd = { in io_sync_cancel() local
280 cd.data = sc.addr; in io_sync_cancel()
281 cd.flags = sc.flags; in io_sync_cancel()
282 cd.opcode = sc.opcode; in io_sync_cancel()
[all …]
|
| A D | cancel.h | 21 int io_try_cancel(struct io_uring_task *tctx, struct io_cancel_data *cd,
25 bool io_cancel_req_match(struct io_kiocb *req, struct io_cancel_data *cd);
31 int io_cancel_remove(struct io_ring_ctx *ctx, struct io_cancel_data *cd,
|
| A D | poll.c | 752 struct io_cancel_data *cd) in io_poll_find() argument
755 u32 index = hash_long(cd->data, ctx->cancel_table.hash_bits); in io_poll_find()
759 if (cd->data != req->cqe.user_data) in io_poll_find()
763 if (cd->flags & IORING_ASYNC_CANCEL_ALL) { in io_poll_find()
764 if (io_cancel_match_sequence(req, cd->seq)) in io_poll_find()
773 struct io_cancel_data *cd) in io_poll_file_find() argument
783 if (io_cancel_req_match(req, cd)) in io_poll_file_find()
807 req = io_poll_file_find(ctx, cd); in __io_poll_cancel()
809 req = io_poll_find(ctx, false, cd); in __io_poll_cancel()
824 ret = __io_poll_cancel(ctx, cd); in io_poll_cancel()
[all …]
|
| A D | futex.h | 12 int io_futex_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd,
20 struct io_cancel_data *cd, in io_futex_cancel() argument
|
| A D | timeout.c | 279 struct io_cancel_data *cd) in io_timeout_extract() argument
289 if (io_cancel_req_match(tmp, cd)) { in io_timeout_extract()
305 int io_timeout_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd) in io_timeout_cancel() argument
311 req = io_timeout_extract(ctx, cd); in io_timeout_cancel()
328 struct io_cancel_data cd = { in io_req_task_link_timeout() local
333 ret = io_try_cancel(req->tctx, &cd, 0); in io_req_task_link_timeout()
424 struct io_cancel_data cd = { .ctx = ctx, .data = user_data, }; in io_timeout_update() local
425 struct io_kiocb *req = io_timeout_extract(ctx, &cd); in io_timeout_update()
489 struct io_cancel_data cd = { .ctx = ctx, .data = tr->addr, }; in io_timeout_remove() local
492 ret = io_timeout_cancel(ctx, &cd); in io_timeout_remove()
|
| A D | waitid.h | 12 int io_waitid_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd,
|
| A D | timeout.h | 13 int io_timeout_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd);
|
| A D | poll.h | 42 int io_poll_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd,
|
| A D | waitid.c | 154 int io_waitid_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd, in io_waitid_cancel() argument
157 return io_cancel_remove(ctx, cd, issue_flags, &ctx->waitid_list, __io_waitid_cancel); in io_waitid_cancel()
|
| A D | futex.c | 111 int io_futex_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd, in io_futex_cancel() argument
114 return io_cancel_remove(ctx, cd, issue_flags, &ctx->futex_list, __io_futex_cancel); in io_futex_cancel()
|
Completed in 12 milliseconds