127 	struct vhost_net_buf rxq;  member
152 static void *vhost_net_buf_get_ptr(struct vhost_net_buf *rxq)  in vhost_net_buf_get_ptr()  argument
154 	if (rxq->tail != rxq->head)  in vhost_net_buf_get_ptr()
155 		return rxq->queue[rxq->head];  in vhost_net_buf_get_ptr()
160 static int vhost_net_buf_get_size(struct vhost_net_buf *rxq)  in vhost_net_buf_get_size()  argument
162 	return rxq->tail - rxq->head;  in vhost_net_buf_get_size()
165 static int vhost_net_buf_is_empty(struct vhost_net_buf *rxq)  in vhost_net_buf_is_empty()  argument
167 	return rxq->tail == rxq->head;  in vhost_net_buf_is_empty()
170 static void *vhost_net_buf_consume(struct vhost_net_buf *rxq)  in vhost_net_buf_consume()  argument
172 	void *ret = vhost_net_buf_get_ptr(rxq);  in vhost_net_buf_consume()
173 	++rxq->head;  in vhost_net_buf_consume()
179 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_produce()  local
181 	rxq->head = 0;  in vhost_net_buf_produce()
182 	rxq->tail = ptr_ring_consume_batched(nvq->rx_ring, rxq->queue,  in vhost_net_buf_produce()
184 	return rxq->tail;  in vhost_net_buf_produce()
189 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_unproduce()  local
191 	if (nvq->rx_ring && !vhost_net_buf_is_empty(rxq)) {  in vhost_net_buf_unproduce()
192 		ptr_ring_unconsume(nvq->rx_ring, rxq->queue + rxq->head,  in vhost_net_buf_unproduce()
193 				   vhost_net_buf_get_size(rxq),  in vhost_net_buf_unproduce()
195 		rxq->head = rxq->tail = 0;  in vhost_net_buf_unproduce()
212 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_peek()  local
214 	if (!vhost_net_buf_is_empty(rxq))  in vhost_net_buf_peek()
221 	return vhost_net_buf_peek_len(vhost_net_buf_get_ptr(rxq));  in vhost_net_buf_peek()
224 static void vhost_net_buf_init(struct vhost_net_buf *rxq)  in vhost_net_buf_init()  argument
226 	rxq->head = rxq->tail = 0;  in vhost_net_buf_init()
315 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_vq_reset()
1190 			msg.msg_control = vhost_net_buf_consume(&nvq->rxq);  in handle_rx()
1318 	n->vqs[VHOST_NET_VQ_RX].rxq.queue = queue;  in vhost_net_open()
1343 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_open()
1422 	kfree(n->vqs[VHOST_NET_VQ_RX].rxq.queue);  in vhost_net_release()