127 	struct vhost_net_buf rxq;  member
150 static void *vhost_net_buf_get_ptr(struct vhost_net_buf *rxq)  in vhost_net_buf_get_ptr()  argument
152 	if (rxq->tail != rxq->head)  in vhost_net_buf_get_ptr()
153 		return rxq->queue[rxq->head];  in vhost_net_buf_get_ptr()
158 static int vhost_net_buf_get_size(struct vhost_net_buf *rxq)  in vhost_net_buf_get_size()  argument
160 	return rxq->tail - rxq->head;  in vhost_net_buf_get_size()
163 static int vhost_net_buf_is_empty(struct vhost_net_buf *rxq)  in vhost_net_buf_is_empty()  argument
165 	return rxq->tail == rxq->head;  in vhost_net_buf_is_empty()
168 static void *vhost_net_buf_consume(struct vhost_net_buf *rxq)  in vhost_net_buf_consume()  argument
170 	void *ret = vhost_net_buf_get_ptr(rxq);  in vhost_net_buf_consume()
171 	++rxq->head;  in vhost_net_buf_consume()
177 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_produce()  local
179 	rxq->head = 0;  in vhost_net_buf_produce()
180 	rxq->tail = ptr_ring_consume_batched(nvq->rx_ring, rxq->queue,  in vhost_net_buf_produce()
182 	return rxq->tail;  in vhost_net_buf_produce()
187 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_unproduce()  local
189 	if (nvq->rx_ring && !vhost_net_buf_is_empty(rxq)) {  in vhost_net_buf_unproduce()
190 		ptr_ring_unconsume(nvq->rx_ring, rxq->queue + rxq->head,  in vhost_net_buf_unproduce()
191 				   vhost_net_buf_get_size(rxq),  in vhost_net_buf_unproduce()
193 		rxq->head = rxq->tail = 0;  in vhost_net_buf_unproduce()
210 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_peek()  local
212 	if (!vhost_net_buf_is_empty(rxq))  in vhost_net_buf_peek()
219 	return vhost_net_buf_peek_len(vhost_net_buf_get_ptr(rxq));  in vhost_net_buf_peek()
222 static void vhost_net_buf_init(struct vhost_net_buf *rxq)  in vhost_net_buf_init()  argument
224 	rxq->head = rxq->tail = 0;  in vhost_net_buf_init()
313 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_vq_reset()
1165 			msg.msg_control = vhost_net_buf_consume(&nvq->rxq);  in handle_rx()
1293 	n->vqs[VHOST_NET_VQ_RX].rxq.queue = queue;  in vhost_net_open()
1318 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_open()
1396 	kfree(n->vqs[VHOST_NET_VQ_RX].rxq.queue);  in vhost_net_release()