Lines Matching refs:cq
56 struct io_uring_cq cq; member
69 struct io_uring_sq *sq, struct io_uring_cq *cq) in io_uring_mmap() argument
98 cq->ring_sz = p->cq_off.cqes + p->cq_entries * sizeof(struct io_uring_cqe); in io_uring_mmap()
99 ptr = mmap(0, cq->ring_sz, PROT_READ | PROT_WRITE, in io_uring_mmap()
106 cq->khead = ptr + p->cq_off.head; in io_uring_mmap()
107 cq->ktail = ptr + p->cq_off.tail; in io_uring_mmap()
108 cq->kring_mask = ptr + p->cq_off.ring_mask; in io_uring_mmap()
109 cq->kring_entries = ptr + p->cq_off.ring_entries; in io_uring_mmap()
110 cq->koverflow = ptr + p->cq_off.overflow; in io_uring_mmap()
111 cq->cqes = ptr + p->cq_off.cqes; in io_uring_mmap()
143 ret = io_uring_mmap(fd, &p, &ring->sq, &ring->cq); in io_uring_queue_init()
164 struct io_uring_cq *cq = &ring->cq; in io_uring_wait_cqe() local
165 const unsigned int mask = *cq->kring_mask; in io_uring_wait_cqe()
166 unsigned int head = *cq->khead; in io_uring_wait_cqe()
172 if (head != *cq->ktail) { in io_uring_wait_cqe()
173 *cqe_ptr = &cq->cqes[head & mask]; in io_uring_wait_cqe()
280 *(&ring->cq)->khead += 1; in io_uring_cqe_seen()