Lines Matching refs:consume_q
28 struct vmci_queue *consume_q; member
118 ASSERT((qpair->produce_q != NULL) && (qpair->consume_q != NULL)); in vmci_qpair_get_queue_headers()
120 *consume_q_header = qpair->consume_q->q_header; in vmci_qpair_get_queue_headers()
182 my_qpair->produce_q_size, &my_qpair->consume_q, in vmci_qpair_alloc()
499 enqueue(struct vmci_queue *produce_q, struct vmci_queue *consume_q, in enqueue() argument
508 ASSERT((produce_q != NULL) && (consume_q != NULL)); in enqueue()
511 consume_q->q_header, in enqueue()
571 struct vmci_queue *consume_q, const uint64_t consume_q_size, void *buf, in dequeue() argument
581 ASSERT((produce_q != NULL) && (consume_q != NULL)); in dequeue()
583 buf_ready = vmci_queue_header_buf_ready(consume_q->q_header, in dequeue()
593 result = memcpy_from_queue(buf, 0, consume_q, head, read, in dequeue()
600 result = memcpy_from_queue(buf, 0, consume_q, head, tmp, in dequeue()
603 result = memcpy_from_queue(buf, tmp, consume_q, 0, in dequeue()
646 result = enqueue(qpair->produce_q, qpair->consume_q, in vmci_qpair_enqueue()
681 result = dequeue(qpair->produce_q, qpair->consume_q, in vmci_qpair_dequeue()
717 result = dequeue(qpair->produce_q, qpair->consume_q, in vmci_qpair_peek()
752 result = enqueue(qpair->produce_q, qpair->consume_q, in vmci_qpair_enquev()
787 result = dequeue(qpair->produce_q, qpair->consume_q, in vmci_qpair_dequev()
823 result = dequeue(qpair->produce_q, qpair->consume_q, in vmci_qpair_peekv()