Lines Matching full:cqe
319 const struct io_uring_cqe *cqe) in ublk_compl_batch_fetch() argument
321 unsigned short buf_idx = user_data_to_tag(cqe->user_data); in ublk_compl_batch_fetch()
323 unsigned end = start + cqe->res; in ublk_compl_batch_fetch()
327 if (cqe->res < 0) in ublk_compl_batch_fetch()
331 ublk_err("%s: fetch duplicated ios offset %u count %u\n", __func__, start, cqe->res); in ublk_compl_batch_fetch()
408 const struct io_uring_cqe *cqe, in ublk_batch_compl_commit_cmd() argument
411 unsigned short buf_idx = user_data_to_tag(cqe->user_data); in ublk_batch_compl_commit_cmd()
414 ublk_assert(cqe->res == 0); in ublk_batch_compl_commit_cmd()
416 int nr_elem = user_data_to_tgt_data(cqe->user_data); in ublk_batch_compl_commit_cmd()
418 ublk_assert(cqe->res == t->commit_buf_elem_size * nr_elem); in ublk_batch_compl_commit_cmd()
426 const struct io_uring_cqe *cqe) in ublk_batch_compl_cmd() argument
428 unsigned op = user_data_to_op(cqe->user_data); in ublk_batch_compl_cmd()
436 ublk_batch_compl_commit_cmd(t, cqe, op); in ublk_batch_compl_cmd()
441 q_id = user_data_to_q_id(cqe->user_data); in ublk_batch_compl_cmd()
443 buf_idx = ublk_compl_batch_fetch(t, q, cqe); in ublk_batch_compl_cmd()
445 if (cqe->res < 0 && cqe->res != -ENOBUFS) { in ublk_batch_compl_cmd()
448 } else if (!(cqe->flags & IORING_CQE_F_MORE) || cqe->res == -ENOBUFS) { in ublk_batch_compl_cmd()