38 static void	vmci_qpair_get_queue_headers(const struct vmci_qpair *qpair,
113 vmci_qpair_get_queue_headers(const struct vmci_qpair *qpair,  in vmci_qpair_get_queue_headers()  argument
118 	ASSERT((qpair->produce_q != NULL) && (qpair->consume_q != NULL));  in vmci_qpair_get_queue_headers()
119 	*produce_q_header = qpair->produce_q->q_header;  in vmci_qpair_get_queue_headers()
120 	*consume_q_header = qpair->consume_q->q_header;  in vmci_qpair_get_queue_headers()
144 vmci_qpair_alloc(struct vmci_qpair **qpair, struct vmci_handle *handle,  in vmci_qpair_alloc()  argument
191 	*qpair = my_qpair;  in vmci_qpair_alloc()
216 vmci_qpair_detach(struct vmci_qpair **qpair)  in vmci_qpair_detach()  argument
221 	if (!qpair || !(*qpair))  in vmci_qpair_detach()
224 	old_qpair = *qpair;  in vmci_qpair_detach()
238 	*qpair = NULL;  in vmci_qpair_detach()
262 vmci_qpair_get_produce_indexes(const struct vmci_qpair *qpair,  in vmci_qpair_get_produce_indexes()  argument
268 	if (!qpair)  in vmci_qpair_get_produce_indexes()
271 	vmci_qpair_get_queue_headers(qpair, &produce_q_header,  in vmci_qpair_get_produce_indexes()
276 	if ((producer_tail && *producer_tail >= qpair->produce_q_size) ||  in vmci_qpair_get_produce_indexes()
277 	    (consumer_head && *consumer_head >= qpair->produce_q_size))  in vmci_qpair_get_produce_indexes()
302 vmci_qpair_get_consume_indexes(const struct vmci_qpair *qpair,  in vmci_qpair_get_consume_indexes()  argument
308 	if (!qpair)  in vmci_qpair_get_consume_indexes()
311 	vmci_qpair_get_queue_headers(qpair, &produce_q_header,  in vmci_qpair_get_consume_indexes()
316 	if ((consumer_tail && *consumer_tail >= qpair->consume_q_size) ||  in vmci_qpair_get_consume_indexes()
317 	    (producer_head && *producer_head >= qpair->consume_q_size))  in vmci_qpair_get_consume_indexes()
344 vmci_qpair_produce_free_space(const struct vmci_qpair *qpair)  in vmci_qpair_produce_free_space()  argument
350 	if (!qpair)  in vmci_qpair_produce_free_space()
353 	vmci_qpair_get_queue_headers(qpair, &produce_q_header,  in vmci_qpair_produce_free_space()
356 	    qpair->produce_q_size);  in vmci_qpair_produce_free_space()
382 vmci_qpair_consume_free_space(const struct vmci_qpair *qpair)  in vmci_qpair_consume_free_space()  argument
388 	if (!qpair)  in vmci_qpair_consume_free_space()
391 	vmci_qpair_get_queue_headers(qpair, &produce_q_header,  in vmci_qpair_consume_free_space()
394 	    qpair->consume_q_size);  in vmci_qpair_consume_free_space()
420 vmci_qpair_produce_buf_ready(const struct vmci_qpair *qpair)  in vmci_qpair_produce_buf_ready()  argument
426 	if (!qpair)  in vmci_qpair_produce_buf_ready()
429 	vmci_qpair_get_queue_headers(qpair, &produce_q_header,  in vmci_qpair_produce_buf_ready()
432 	    qpair->produce_q_size);  in vmci_qpair_produce_buf_ready()
458 vmci_qpair_consume_buf_ready(const struct vmci_qpair *qpair)  in vmci_qpair_consume_buf_ready()  argument
464 	if (!qpair)  in vmci_qpair_consume_buf_ready()
467 	vmci_qpair_get_queue_headers(qpair, &produce_q_header,  in vmci_qpair_consume_buf_ready()
470 	    qpair->consume_q_size);  in vmci_qpair_consume_buf_ready()
638 vmci_qpair_enqueue(struct vmci_qpair *qpair, const void *buf, size_t buf_size,  in vmci_qpair_enqueue()  argument
643 	if (!qpair || !buf)  in vmci_qpair_enqueue()
646 	result = enqueue(qpair->produce_q, qpair->consume_q,  in vmci_qpair_enqueue()
647 	    qpair->produce_q_size, buf, buf_size, buf_type,  in vmci_qpair_enqueue()
648 	    qpair->flags & VMCI_QPFLAG_LOCAL?  in vmci_qpair_enqueue()
650 	    !(qpair->flags & VMCI_QPFLAG_NONBLOCK));  in vmci_qpair_enqueue()
673 vmci_qpair_dequeue(struct vmci_qpair *qpair, void *buf, size_t buf_size,  in vmci_qpair_dequeue()  argument
678 	if (!qpair || !buf)  in vmci_qpair_dequeue()
681 	result = dequeue(qpair->produce_q, qpair->consume_q,  in vmci_qpair_dequeue()
682 	    qpair->consume_q_size, buf, buf_size, buf_type,  in vmci_qpair_dequeue()
683 	    qpair->flags & VMCI_QPFLAG_LOCAL?  in vmci_qpair_dequeue()
685 	    !(qpair->flags & VMCI_QPFLAG_NONBLOCK));  in vmci_qpair_dequeue()
709 vmci_qpair_peek(struct vmci_qpair *qpair, void *buf, size_t buf_size,  in vmci_qpair_peek()  argument
714 	if (!qpair || !buf)  in vmci_qpair_peek()
717 	result = dequeue(qpair->produce_q, qpair->consume_q,  in vmci_qpair_peek()
718 	    qpair->consume_q_size, buf, buf_size, buf_type,  in vmci_qpair_peek()
719 	    qpair->flags & VMCI_QPFLAG_LOCAL?  in vmci_qpair_peek()
721 	    !(qpair->flags & VMCI_QPFLAG_NONBLOCK));  in vmci_qpair_peek()
744 vmci_qpair_enquev(struct vmci_qpair *qpair, void *iov, size_t iov_size,  in vmci_qpair_enquev()  argument
749 	if (!qpair || !iov)  in vmci_qpair_enquev()
752 	result = enqueue(qpair->produce_q, qpair->consume_q,  in vmci_qpair_enquev()
753 	    qpair->produce_q_size, iov, iov_size, buf_type,  in vmci_qpair_enquev()
754 	    qpair->flags & VMCI_QPFLAG_LOCAL?  in vmci_qpair_enquev()
756 	    !(qpair->flags & VMCI_QPFLAG_NONBLOCK));  in vmci_qpair_enquev()
779 vmci_qpair_dequev(struct vmci_qpair *qpair, void *iov, size_t iov_size,  in vmci_qpair_dequev()  argument
784 	if (!qpair || !iov)  in vmci_qpair_dequev()
787 	result = dequeue(qpair->produce_q, qpair->consume_q,  in vmci_qpair_dequev()
788 	    qpair->consume_q_size, iov, iov_size, buf_type,  in vmci_qpair_dequev()
789 	    qpair->flags & VMCI_QPFLAG_LOCAL?  in vmci_qpair_dequev()
791 	    !(qpair->flags & VMCI_QPFLAG_NONBLOCK));  in vmci_qpair_dequev()
815 vmci_qpair_peekv(struct vmci_qpair *qpair, void *iov, size_t iov_size,  in vmci_qpair_peekv()  argument
820 	if (!qpair || !iov)  in vmci_qpair_peekv()
823 	result = dequeue(qpair->produce_q, qpair->consume_q,  in vmci_qpair_peekv()
824 	    qpair->consume_q_size, iov, iov_size, buf_type,  in vmci_qpair_peekv()
825 	    qpair->flags & VMCI_QPFLAG_LOCAL?  in vmci_qpair_peekv()
827 	    !(qpair->flags & VMCI_QPFLAG_NONBLOCK));  in vmci_qpair_peekv()