Lines Matching defs:cqe
74 struct io_uring_cqe *cqe;
91 ret = io_uring_wait_cqe(&dev->ring, &cqe);
93 ublk_err("wait cqe: %s\n", strerror(-ret));
96 io_uring_cqe_seen(&dev->ring, cqe);
98 return cqe->res;
726 struct io_uring_cqe *cqe)
728 if (cqe->res < 0 && cqe->res != -EAGAIN)
730 __func__, cqe->res, q->q_id,
731 user_data_to_tag(cqe->user_data),
732 user_data_to_op(cqe->user_data));
735 q->tgt_ops->tgt_io_done(t, q, cqe);
740 const struct io_uring_cqe *cqe)
742 int fetch = (cqe->res != UBLK_IO_RES_ABORT) &&
744 unsigned tag = user_data_to_tag(cqe->user_data);
752 if (cqe->res == UBLK_IO_RES_OK) {
756 } else if (cqe->res == UBLK_IO_RES_NEED_GET_DATA) {
773 struct io_uring_cqe *cqe, void *data)
776 unsigned q_id = user_data_to_q_id(cqe->user_data);
778 unsigned cmd_op = user_data_to_op(cqe->user_data);
780 if (cqe->res < 0 && cqe->res != -ENODEV)
782 cqe->res, cqe->user_data, q->flags);
785 __func__, cqe->res, q->q_id, user_data_to_tag(cqe->user_data),
786 cmd_op, is_target_io(cqe->user_data),
787 user_data_to_tgt_data(cqe->user_data),
791 if (is_target_io(cqe->user_data)) {
792 ublksrv_handle_tgt_cqe(t, q, cqe);
798 ublk_handle_uring_cmd(t, q, cqe);
803 struct io_uring_cqe *cqe;
807 io_uring_for_each_cqe(&t->ring, head, cqe) {
808 ublk_handle_cqe(t, cqe, NULL);