125 	struct vhost_net_buf rxq;  member
144 static void *vhost_net_buf_get_ptr(struct vhost_net_buf *rxq)  in vhost_net_buf_get_ptr()  argument
146 	if (rxq->tail != rxq->head)  in vhost_net_buf_get_ptr()
147 		return rxq->queue[rxq->head];  in vhost_net_buf_get_ptr()
152 static int vhost_net_buf_get_size(struct vhost_net_buf *rxq)  in vhost_net_buf_get_size()  argument
154 	return rxq->tail - rxq->head;  in vhost_net_buf_get_size()
157 static int vhost_net_buf_is_empty(struct vhost_net_buf *rxq)  in vhost_net_buf_is_empty()  argument
159 	return rxq->tail == rxq->head;  in vhost_net_buf_is_empty()
162 static void *vhost_net_buf_consume(struct vhost_net_buf *rxq)  in vhost_net_buf_consume()  argument
164 	void *ret = vhost_net_buf_get_ptr(rxq);  in vhost_net_buf_consume()
165 	++rxq->head;  in vhost_net_buf_consume()
171 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_produce()  local
173 	rxq->head = 0;  in vhost_net_buf_produce()
174 	rxq->tail = ptr_ring_consume_batched(nvq->rx_ring, rxq->queue,  in vhost_net_buf_produce()
176 	return rxq->tail;  in vhost_net_buf_produce()
181 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_unproduce()  local
183 	if (nvq->rx_ring && !vhost_net_buf_is_empty(rxq)) {  in vhost_net_buf_unproduce()
184 		ptr_ring_unconsume(nvq->rx_ring, rxq->queue + rxq->head,  in vhost_net_buf_unproduce()
185 				   vhost_net_buf_get_size(rxq),  in vhost_net_buf_unproduce()
187 		rxq->head = rxq->tail = 0;  in vhost_net_buf_unproduce()
204 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_peek()  local
206 	if (!vhost_net_buf_is_empty(rxq))  in vhost_net_buf_peek()
213 	return vhost_net_buf_peek_len(vhost_net_buf_get_ptr(rxq));  in vhost_net_buf_peek()
216 static void vhost_net_buf_init(struct vhost_net_buf *rxq)  in vhost_net_buf_init()  argument
218 	rxq->head = rxq->tail = 0;  in vhost_net_buf_init()
307 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_vq_reset()
970 			msg.msg_control = vhost_net_buf_consume(&nvq->rxq);  in handle_rx()
1099 	n->vqs[VHOST_NET_VQ_RX].rxq.queue = queue;  in vhost_net_open()
1114 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_open()
1193 	kfree(n->vqs[VHOST_NET_VQ_RX].rxq.queue);  in vhost_net_release()