Function vhost_clear_queue_thread_unsafe

dpdk/examples/vhost/main.c:1530–1548

}

static void
vhost_clear_queue_thread_unsafe(struct vhost_dev *vdev, uint16_t queue_id)
{
	uint16_t n_pkt = 0;
	int pkts_inflight;

	int16_t dma_id = dma_bind[vid2socketid[vdev->vid]].dmas[queue_id].dev_id;
	pkts_inflight = rte_vhost_async_get_inflight_thread_unsafe(vdev->vid, queue_id);

	struct rte_mbuf *m_cpl[pkts_inflight];

	while (pkts_inflight) {
		n_pkt = rte_vhost_clear_queue_thread_unsafe(vdev->vid, queue_id, m_cpl,
							pkts_inflight, dma_id, 0);
		free_pkts(m_cpl, n_pkt);
		pkts_inflight = rte_vhost_async_get_inflight_thread_unsafe(vdev->vid,
									queue_id);
	}
}

static void
vhost_clear_queue(struct vhost_dev *vdev, uint16_t queue_id)