Searched refs:cqe (Results 1 – 3 of 3) sorted by relevance
126 struct io_uring_cqe *cqe; in copy_file() local174 ret = io_uring_wait_cqe(ring, &cqe); in copy_file()177 ret = io_uring_peek_cqe(ring, &cqe); in copy_file()179 cqe = NULL; in copy_file()188 if (!cqe) in copy_file()191 data = io_uring_cqe_get_data(cqe); in copy_file()192 if (cqe->res < 0) { in copy_file()193 if (cqe->res == -EAGAIN) { in copy_file()195 io_uring_cqe_seen(ring, cqe); in copy_file()199 strerror(-cqe->res)); in copy_file()[all …]
81 struct io_uring_cqe *cqe) in io_uring_cqe_seen() argument83 if (cqe) { in io_uring_cqe_seen()103 static inline void *io_uring_cqe_get_data(struct io_uring_cqe *cqe) in io_uring_cqe_get_data() argument105 return (void *) (uintptr_t) cqe->user_data; in io_uring_cqe_get_data()
247 struct io_uring_cqe *cqe; in reap_events() local257 cqe = &ring->cqes[head & cq_ring_mask]; in reap_events()259 f = (struct file *) (uintptr_t) cqe->user_data; in reap_events()261 if (cqe->res != BS) { in reap_events()262 printf("io: unexpected ret=%d\n", cqe->res); in reap_events()263 if (polled && cqe->res == -EOPNOTSUPP) in reap_events()