misc/vmw_vmci/vmci_queue_pair.c

148 	struct vmci_queue *consume_q;
204 	struct vmci_queue *consume_q;
217 	void *consume_q;
435 	struct vmci_queue *consume_q = cons_q;
438 	if (!produce_q || !num_produce_pages || !consume_q ||
465 			consume_q->kernel_if->u.g.pas[i] >> PAGE_SHIFT;
579 				struct vmci_queue *consume_q)
588 		consume_q->kernel_if->mutex = &produce_q->kernel_if->__mutex;
597 				   struct vmci_queue *consume_q)
601 		consume_q->kernel_if->mutex = NULL;
607  * the consume_q share a mutex.  So, only one of the two need to
618  * the consume_q share a mutex.  So, only one of the two need to
653 				   struct vmci_queue *consume_q)
673 				     consume_q->kernel_if->num_pages,
675 				     consume_q->kernel_if->u.h.header_page);
676 	if (retval < (int)consume_q->kernel_if->num_pages) {
680 			qp_release_pages(consume_q->kernel_if->u.h.header_page,
698 					struct vmci_queue *consume_q)
712 				       consume_q);
721 					   struct vmci_queue *consume_q)
728 	qp_release_pages(consume_q->kernel_if->u.h.header_page,
729 			 consume_q->kernel_if->num_pages, true);
730 	memset(consume_q->kernel_if->u.h.header_page, 0,
731 	       sizeof(*consume_q->kernel_if->u.h.header_page) *
732 	       consume_q->kernel_if->num_pages);
744 			      struct vmci_queue *consume_q)
748 	if (!produce_q->q_header || !consume_q->q_header) {
751 		if (produce_q->q_header != consume_q->q_header)
759 		headers[1] = *consume_q->kernel_if->u.h.header_page;
763 			consume_q->q_header =
785 				struct vmci_queue *consume_q)
788 		if (produce_q->q_header < consume_q->q_header)
791 			vunmap(consume_q->q_header);
794 		consume_q->q_header = NULL;
884 			 void *consume_q)
907 		entry->consume_q = consume_q;
932 	qp_cleanup_queue_mutex(entry->produce_q, entry->consume_q);
934 	qp_free_queue(entry->consume_q, entry->qp.consume_size);
1096 			       struct vmci_queue **consume_q,
1145 			my_produce_q = queue_pair_entry->consume_q;
1230 	*consume_q = (struct vmci_queue *)my_consume_q;
1240 		vmci_q_header_init((*consume_q)->q_header, *handle);
1362 	entry->consume_q = qp_host_alloc_queue(guest_consume_size);
1363 	if (entry->consume_q == NULL) {
1368 	qp_init_queue_mutex(entry->produce_q, entry->consume_q);
1385 		entry->consume_q->q_header = (struct vmci_queue_header *)tmp;
1393 						      entry->consume_q);
1427 		vmci_q_header_init(entry->consume_q->q_header,
1438 		qp_host_free_queue(entry->consume_q, guest_consume_size);
1640 							      entry->consume_q);
1773 			      struct vmci_queue **consume_q,
1807 			*produce_q = entry->consume_q;
1808 			*consume_q = entry->produce_q;
1811 			*consume_q = entry->consume_q;
1832 		  struct vmci_queue **consume_q,
1841 	if (!handle || !produce_q || !consume_q ||
1847 					   produce_size, consume_q,
1852 					  produce_size, consume_q,
2019 					 entry->produce_q, entry->consume_q);
2023 	result = qp_host_map_queues(entry->produce_q, entry->consume_q);
2026 					       entry->consume_q);
2061 	entry->consume_q->saved_header = NULL;
2141 		    entry->consume_q->q_header;
2146 						 entry->consume_q);
2153 						       entry->consume_q);
2178 		qp_cleanup_queue_mutex(entry->produce_q, entry->consume_q);
2180 		qp_host_free_queue(entry->consume_q, entry->qp.consume_size);
2260 						 entry->consume_q);
2289 	    entry->consume_q->saved_header != NULL) {
2300 	    NULL == entry->consume_q->q_header) {
2301 		result = qp_host_map_queues(entry->produce_q, entry->consume_q);
2309 	memcpy(&entry->saved_consume_q, entry->consume_q->q_header,
2311 	entry->consume_q->saved_header = &entry->saved_consume_q;
2364 		qp_host_unmap_queues(gid, entry->produce_q, entry->consume_q);
2374 					       entry->consume_q);
2448 				struct vmci_queue *consume_q)
2452 	if (NULL == produce_q->q_header || NULL == consume_q->q_header) {
2453 		result = qp_host_map_queues(produce_q, consume_q);
2456 				consume_q->saved_header) ?
2476 	result = qp_map_queue_headers(qpair->produce_q, qpair->consume_q);
2479 		*consume_q_header = qpair->consume_q->q_header;
2481 		   qpair->consume_q->saved_header) {
2483 		*consume_q_header = qpair->consume_q->saved_header;
2541 				 struct vmci_queue *consume_q,
2551 	result = qp_map_queue_headers(produce_q, consume_q);
2556 					      consume_q->q_header,
2607 				 struct vmci_queue *consume_q,
2618 	result = qp_map_queue_headers(produce_q, consume_q);
2622 	buf_ready = vmci_q_header_buf_ready(consume_q->q_header,
2640 		result = qp_memcpy_from_queue_iter(to, consume_q, head, read);
2646 		result = qp_memcpy_from_queue_iter(to, consume_q, head, tmp);
2648 			result = qp_memcpy_from_queue_iter(to, consume_q, 0,
2754 			       &my_qpair->consume_q,
3053 					   qpair->consume_q,
3097 					   qpair->consume_q,
3142 					   qpair->consume_q,
3183 					   qpair->consume_q,
3224 					   qpair->consume_q,
3266 					   qpair->consume_q,