Searched refs:cd (Results 1 – 6 of 6) sorted by relevance
/io_uring/ |
D | cancel.c | 33 struct io_cancel_data *cd = data; in io_cancel_cb() local 35 if (req->ctx != cd->ctx) in io_cancel_cb() 37 if (cd->flags & IORING_ASYNC_CANCEL_ANY) { in io_cancel_cb() 39 } else if (cd->flags & IORING_ASYNC_CANCEL_FD) { in io_cancel_cb() 40 if (req->file != cd->file) in io_cancel_cb() 43 if (req->cqe.user_data != cd->data) in io_cancel_cb() 46 if (cd->flags & (IORING_ASYNC_CANCEL_ALL|IORING_ASYNC_CANCEL_ANY)) { in io_cancel_cb() 47 if (cd->seq == req->work.cancel_seq) in io_cancel_cb() 49 req->work.cancel_seq = cd->seq; in io_cancel_cb() 55 struct io_cancel_data *cd) in io_async_cancel_one() argument [all …]
|
D | poll.c | 800 struct io_cancel_data *cd, in io_poll_find() argument 805 u32 index = hash_long(cd->data, table->hash_bits); in io_poll_find() 812 if (cd->data != req->cqe.user_data) in io_poll_find() 816 if (cd->flags & IORING_ASYNC_CANCEL_ALL) { in io_poll_find() 817 if (cd->seq == req->work.cancel_seq) in io_poll_find() 819 req->work.cancel_seq = cd->seq; in io_poll_find() 829 struct io_cancel_data *cd, in io_poll_file_find() argument 844 if (!(cd->flags & IORING_ASYNC_CANCEL_ANY) && in io_poll_file_find() 845 req->file != cd->file) in io_poll_file_find() 847 if (cd->seq == req->work.cancel_seq) in io_poll_file_find() [all …]
|
D | timeout.c | 223 struct io_cancel_data *cd) in io_timeout_extract() argument 233 if (!(cd->flags & IORING_ASYNC_CANCEL_ANY) && in io_timeout_extract() 234 cd->data != tmp->cqe.user_data) in io_timeout_extract() 236 if (cd->flags & (IORING_ASYNC_CANCEL_ALL|IORING_ASYNC_CANCEL_ANY)) { in io_timeout_extract() 237 if (cd->seq == tmp->work.cancel_seq) in io_timeout_extract() 239 tmp->work.cancel_seq = cd->seq; in io_timeout_extract() 255 int io_timeout_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd) in io_timeout_cancel() argument 261 req = io_timeout_extract(ctx, cd); in io_timeout_cancel() 279 struct io_cancel_data cd = { in io_req_task_link_timeout() local 284 ret = io_try_cancel(req->task->io_uring, &cd, issue_flags); in io_req_task_link_timeout() [all …]
|
D | cancel.h | 19 int io_try_cancel(struct io_uring_task *tctx, struct io_cancel_data *cd,
|
D | poll.h | 34 int io_poll_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd,
|
D | timeout.h | 26 int io_timeout_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd);
|