Lines Matching refs:cqe
361 struct io_uring_cqe *cqe; in do_tx() local
421 ret = io_uring_wait_cqe(&ring, &cqe); in do_tx()
425 if (cqe->user_data != NONZC_TAG && in do_tx()
426 cqe->user_data != ZC_TAG) in do_tx()
429 if (cqe->flags & IORING_CQE_F_NOTIF) { in do_tx()
430 if (cqe->flags & IORING_CQE_F_MORE) in do_tx()
439 if (cqe->flags & IORING_CQE_F_MORE) { in do_tx()
440 if (cqe->user_data != ZC_TAG) in do_tx()
441 error(1, cqe->res, "unexpected F_MORE"); in do_tx()
444 if (cqe->res >= 0) { in do_tx()
446 bytes += cqe->res; in do_tx()
447 } else if (cqe->res != -EAGAIN) { in do_tx()
448 error(1, cqe->res, "send failed"); in do_tx()
455 ret = io_uring_wait_cqe(&ring, &cqe); in do_tx()
458 if (cqe->flags & IORING_CQE_F_MORE) in do_tx()
460 if (!(cqe->flags & IORING_CQE_F_NOTIF)) in do_tx()