131 	struct vhost_net_buf rxq;  member
154 static void *vhost_net_buf_get_ptr(struct vhost_net_buf *rxq)  in vhost_net_buf_get_ptr()  argument
156 	if (rxq->tail != rxq->head)  in vhost_net_buf_get_ptr()
157 		return rxq->queue[rxq->head];  in vhost_net_buf_get_ptr()
162 static int vhost_net_buf_get_size(struct vhost_net_buf *rxq)  in vhost_net_buf_get_size()  argument
164 	return rxq->tail - rxq->head;  in vhost_net_buf_get_size()
167 static int vhost_net_buf_is_empty(struct vhost_net_buf *rxq)  in vhost_net_buf_is_empty()  argument
169 	return rxq->tail == rxq->head;  in vhost_net_buf_is_empty()
172 static void *vhost_net_buf_consume(struct vhost_net_buf *rxq)  in vhost_net_buf_consume()  argument
174 	void *ret = vhost_net_buf_get_ptr(rxq);  in vhost_net_buf_consume()
175 	++rxq->head;  in vhost_net_buf_consume()
181 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_produce()  local
183 	rxq->head = 0;  in vhost_net_buf_produce()
184 	rxq->tail = ptr_ring_consume_batched(nvq->rx_ring, rxq->queue,  in vhost_net_buf_produce()
186 	return rxq->tail;  in vhost_net_buf_produce()
191 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_unproduce()  local
193 	if (nvq->rx_ring && !vhost_net_buf_is_empty(rxq)) {  in vhost_net_buf_unproduce()
194 		ptr_ring_unconsume(nvq->rx_ring, rxq->queue + rxq->head,  in vhost_net_buf_unproduce()
195 				   vhost_net_buf_get_size(rxq),  in vhost_net_buf_unproduce()
197 		rxq->head = rxq->tail = 0;  in vhost_net_buf_unproduce()
214 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_peek()  local
216 	if (!vhost_net_buf_is_empty(rxq))  in vhost_net_buf_peek()
223 	return vhost_net_buf_peek_len(vhost_net_buf_get_ptr(rxq));  in vhost_net_buf_peek()
226 static void vhost_net_buf_init(struct vhost_net_buf *rxq)  in vhost_net_buf_init()  argument
228 	rxq->head = rxq->tail = 0;  in vhost_net_buf_init()
319 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_vq_reset()
1214 			msg.msg_control = vhost_net_buf_consume(&nvq->rxq);  in handle_rx()
1345 	n->vqs[VHOST_NET_VQ_RX].rxq.queue = queue;  in vhost_net_open()
1370 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_open()
1448 	kfree(n->vqs[VHOST_NET_VQ_RX].rxq.queue);  in vhost_net_release()