Lines Matching full:cqe
97 struct io_uring_cqe *cqe; in do_tx() local
157 ret = io_uring_wait_cqe(&ring, &cqe); in do_tx()
159 error(1, ret, "wait cqe"); in do_tx()
161 if (cqe->user_data != NONZC_TAG && in do_tx()
162 cqe->user_data != ZC_TAG) in do_tx()
163 error(1, -EINVAL, "invalid cqe->user_data"); in do_tx()
165 if (cqe->flags & IORING_CQE_F_NOTIF) { in do_tx()
166 if (cqe->flags & IORING_CQE_F_MORE) in do_tx()
175 if (cqe->flags & IORING_CQE_F_MORE) { in do_tx()
176 if (cqe->user_data != ZC_TAG) in do_tx()
177 error(1, cqe->res, "unexpected F_MORE"); in do_tx()
180 if (cqe->res >= 0) { in do_tx()
182 bytes += cqe->res; in do_tx()
183 } else if (cqe->res != -EAGAIN) { in do_tx()
184 error(1, cqe->res, "send failed"); in do_tx()
191 ret = io_uring_wait_cqe(&ring, &cqe); in do_tx()
193 error(1, ret, "wait cqe"); in do_tx()
194 if (cqe->flags & IORING_CQE_F_MORE) in do_tx()
196 if (!(cqe->flags & IORING_CQE_F_NOTIF)) in do_tx()