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