Lines Matching defs:qpair
40 static void vmci_qpair_get_queue_headers(const struct vmci_qpair *qpair,
115 vmci_qpair_get_queue_headers(const struct vmci_qpair *qpair,
120 ASSERT((qpair->produce_q != NULL) && (qpair->consume_q != NULL));
121 *produce_q_header = qpair->produce_q->q_header;
122 *consume_q_header = qpair->consume_q->q_header;
146 vmci_qpair_alloc(struct vmci_qpair **qpair, struct vmci_handle *handle,
198 *qpair = my_qpair;
223 vmci_qpair_detach(struct vmci_qpair **qpair)
228 if (!qpair || !(*qpair))
231 old_qpair = *qpair;
237 * the qpair struct here; there isn't much the caller can do, and we
245 *qpair = NULL;
256 * qpair from the point of the view of the caller as the producer.
269 vmci_qpair_get_produce_indexes(const struct vmci_qpair *qpair,
275 if (!qpair)
278 vmci_qpair_get_queue_headers(qpair, &produce_q_header,
283 if ((producer_tail && *producer_tail >= qpair->produce_q_size) ||
284 (consumer_head && *consumer_head >= qpair->produce_q_size))
309 vmci_qpair_get_consume_indexes(const struct vmci_qpair *qpair,
315 if (!qpair)
318 vmci_qpair_get_queue_headers(qpair, &produce_q_header,
323 if ((consumer_tail && *consumer_tail >= qpair->consume_q_size) ||
324 (producer_head && *producer_head >= qpair->consume_q_size))
351 vmci_qpair_produce_free_space(const struct vmci_qpair *qpair)
357 if (!qpair)
360 vmci_qpair_get_queue_headers(qpair, &produce_q_header,
363 qpair->produce_q_size);
389 vmci_qpair_consume_free_space(const struct vmci_qpair *qpair)
395 if (!qpair)
398 vmci_qpair_get_queue_headers(qpair, &produce_q_header,
401 qpair->consume_q_size);
427 vmci_qpair_produce_buf_ready(const struct vmci_qpair *qpair)
433 if (!qpair)
436 vmci_qpair_get_queue_headers(qpair, &produce_q_header,
439 qpair->produce_q_size);
465 vmci_qpair_consume_buf_ready(const struct vmci_qpair *qpair)
471 if (!qpair)
474 vmci_qpair_get_queue_headers(qpair, &produce_q_header,
477 qpair->consume_q_size);
645 vmci_qpair_enqueue(struct vmci_qpair *qpair, const void *buf, size_t buf_size,
650 if (!qpair || !buf)
653 result = enqueue(qpair->produce_q, qpair->consume_q,
654 qpair->produce_q_size, buf, buf_size, buf_type,
655 qpair->flags & VMCI_QPFLAG_LOCAL?
657 !(qpair->flags & VMCI_QPFLAG_NONBLOCK));
680 vmci_qpair_dequeue(struct vmci_qpair *qpair, void *buf, size_t buf_size,
685 if (!qpair || !buf)
688 result = dequeue(qpair->produce_q, qpair->consume_q,
689 qpair->consume_q_size, buf, buf_size, buf_type,
690 qpair->flags & VMCI_QPFLAG_LOCAL?
692 !(qpair->flags & VMCI_QPFLAG_NONBLOCK));
716 vmci_qpair_peek(struct vmci_qpair *qpair, void *buf, size_t buf_size,
721 if (!qpair || !buf)
724 result = dequeue(qpair->produce_q, qpair->consume_q,
725 qpair->consume_q_size, buf, buf_size, buf_type,
726 qpair->flags & VMCI_QPFLAG_LOCAL?
728 !(qpair->flags & VMCI_QPFLAG_NONBLOCK));
751 vmci_qpair_enquev(struct vmci_qpair *qpair, void *iov, size_t iov_size,
756 if (!qpair || !iov)
759 result = enqueue(qpair->produce_q, qpair->consume_q,
760 qpair->produce_q_size, iov, iov_size, buf_type,
761 qpair->flags & VMCI_QPFLAG_LOCAL?
763 !(qpair->flags & VMCI_QPFLAG_NONBLOCK));
786 vmci_qpair_dequev(struct vmci_qpair *qpair, void *iov, size_t iov_size,
791 if (!qpair || !iov)
794 result = dequeue(qpair->produce_q, qpair->consume_q,
795 qpair->consume_q_size, iov, iov_size, buf_type,
796 qpair->flags & VMCI_QPFLAG_LOCAL?
798 !(qpair->flags & VMCI_QPFLAG_NONBLOCK));
822 vmci_qpair_peekv(struct vmci_qpair *qpair, void *iov, size_t iov_size,
827 if (!qpair || !iov)
830 result = dequeue(qpair->produce_q, qpair->consume_q,
831 qpair->consume_q_size, iov, iov_size, buf_type,
832 qpair->flags & VMCI_QPFLAG_LOCAL?
834 !(qpair->flags & VMCI_QPFLAG_NONBLOCK));