Home
last modified time | relevance | path

Searched refs:cd (Results 1 – 6 of 6) sorted by relevance

/io_uring/
Dcancel.c33 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 …]
Dpoll.c800 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 …]
Dtimeout.c223 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 …]
Dcancel.h19 int io_try_cancel(struct io_uring_task *tctx, struct io_cancel_data *cd,
Dpoll.h34 int io_poll_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd,
Dtimeout.h26 int io_timeout_cancel(struct io_ring_ctx *ctx, struct io_cancel_data *cd);