Lines Matching refs:cq
57 struct io_uring_cq cq; member
71 struct io_uring_sq *sq, struct io_uring_cq *cq) in io_uring_mmap() argument
108 cq->ring_sz = p->cq_off.cqes + p->cq_entries * sizeof(struct io_uring_cqe); in io_uring_mmap()
109 ptr = mmap(0, cq->ring_sz, PROT_READ | PROT_WRITE, in io_uring_mmap()
116 cq->khead = ptr + p->cq_off.head; in io_uring_mmap()
117 cq->ktail = ptr + p->cq_off.tail; in io_uring_mmap()
118 cq->kring_mask = ptr + p->cq_off.ring_mask; in io_uring_mmap()
119 cq->kring_entries = ptr + p->cq_off.ring_entries; in io_uring_mmap()
120 cq->koverflow = ptr + p->cq_off.overflow; in io_uring_mmap()
121 cq->cqes = ptr + p->cq_off.cqes; in io_uring_mmap()
150 ret = io_uring_mmap(fd, p, &ring->sq, &ring->cq); in io_uring_queue_init_params()
185 struct io_uring_cq *cq = &ring->cq; in io_uring_wait_cqe() local
186 const unsigned int mask = *cq->kring_mask; in io_uring_wait_cqe()
187 unsigned int head = *cq->khead; in io_uring_wait_cqe()
193 if (head != *cq->ktail) { in io_uring_wait_cqe()
194 *cqe_ptr = &cq->cqes[head & mask]; in io_uring_wait_cqe()
309 *(&ring->cq)->khead += 1; in io_uring_cqe_seen()