126 	struct vhost_net_buf rxq;  member
151 static void *vhost_net_buf_get_ptr(struct vhost_net_buf *rxq)  in vhost_net_buf_get_ptr()  argument
153 	if (rxq->tail != rxq->head)  in vhost_net_buf_get_ptr()
154 		return rxq->queue[rxq->head];  in vhost_net_buf_get_ptr()
159 static int vhost_net_buf_get_size(struct vhost_net_buf *rxq)  in vhost_net_buf_get_size()  argument
161 	return rxq->tail - rxq->head;  in vhost_net_buf_get_size()
164 static int vhost_net_buf_is_empty(struct vhost_net_buf *rxq)  in vhost_net_buf_is_empty()  argument
166 	return rxq->tail == rxq->head;  in vhost_net_buf_is_empty()
169 static void *vhost_net_buf_consume(struct vhost_net_buf *rxq)  in vhost_net_buf_consume()  argument
171 	void *ret = vhost_net_buf_get_ptr(rxq);  in vhost_net_buf_consume()
172 	++rxq->head;  in vhost_net_buf_consume()
178 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_produce()  local
180 	rxq->head = 0;  in vhost_net_buf_produce()
181 	rxq->tail = ptr_ring_consume_batched(nvq->rx_ring, rxq->queue,  in vhost_net_buf_produce()
183 	return rxq->tail;  in vhost_net_buf_produce()
188 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_unproduce()  local
190 	if (nvq->rx_ring && !vhost_net_buf_is_empty(rxq)) {  in vhost_net_buf_unproduce()
191 		ptr_ring_unconsume(nvq->rx_ring, rxq->queue + rxq->head,  in vhost_net_buf_unproduce()
192 				   vhost_net_buf_get_size(rxq),  in vhost_net_buf_unproduce()
194 		rxq->head = rxq->tail = 0;  in vhost_net_buf_unproduce()
211 	struct vhost_net_buf *rxq = &nvq->rxq;  in vhost_net_buf_peek()  local
213 	if (!vhost_net_buf_is_empty(rxq))  in vhost_net_buf_peek()
220 	return vhost_net_buf_peek_len(vhost_net_buf_get_ptr(rxq));  in vhost_net_buf_peek()
223 static void vhost_net_buf_init(struct vhost_net_buf *rxq)  in vhost_net_buf_init()  argument
225 	rxq->head = rxq->tail = 0;  in vhost_net_buf_init()
314 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_vq_reset()
1183 			msg.msg_control = vhost_net_buf_consume(&nvq->rxq);  in handle_rx()
1311 	n->vqs[VHOST_NET_VQ_RX].rxq.queue = queue;  in vhost_net_open()
1336 		vhost_net_buf_init(&n->vqs[i].rxq);  in vhost_net_open()
1420 	kfree(n->vqs[VHOST_NET_VQ_RX].rxq.queue);  in vhost_net_release()