Function drain_eth_rx

dpdk/examples/vhost/main.c:1379–1420

}

static __rte_always_inline void
drain_eth_rx(struct vhost_dev *vdev)
{
	uint16_t rx_count, enqueue_count;
	struct rte_mbuf *pkts[MAX_PKT_BURST];

	rx_count = rte_eth_rx_burst(ports[0], vdev->vmdq_rx_q,
				    pkts, MAX_PKT_BURST);

	if (!rx_count)
		return;

	enqueue_count = vdev_queue_ops[vdev->vid].enqueue_pkt_burst(vdev,
						VIRTIO_RXQ, pkts, rx_count);

	/* Retry if necessary */
	if (enable_retry && unlikely(enqueue_count < rx_count)) {
		uint32_t retry = 0;

		while (enqueue_count < rx_count && retry++ < burst_rx_retry_num) {
			rte_delay_us(burst_rx_delay_time);
			enqueue_count += vdev_queue_ops[vdev->vid].enqueue_pkt_burst(vdev,
							VIRTIO_RXQ, &pkts[enqueue_count],
							rx_count - enqueue_count);
		}
	}

	if (enable_stats) {
		__atomic_fetch_add(&vdev->stats.rx_total_atomic, rx_count,
				__ATOMIC_SEQ_CST);
		__atomic_fetch_add(&vdev->stats.rx_atomic, enqueue_count,
				__ATOMIC_SEQ_CST);
	}

	if (!dma_bind[vid2socketid[vdev->vid]].dmas[VIRTIO_RXQ].async_enabled) {
		free_pkts(pkts, rx_count);
	} else {
		uint16_t enqueue_fail = rx_count - enqueue_count;
		if (enqueue_fail > 0)
			free_pkts(&pkts[enqueue_count], enqueue_fail);
	}
}

uint16_t async_dequeue_pkts(struct vhost_dev *dev, uint16_t queue_id,
			    struct rte_mempool *mbuf_pool,