Lines Matching refs:VIRTIO_RXQ

341 		(dma_info + vid)->dmas[VIRTIO_RXQ].dev_id = dev_id;  in open_dma()
993 int16_t dma_id = dma_bind[vdev->vid].dmas[VIRTIO_RXQ].dev_id; in complete_async_pkts()
996 VIRTIO_RXQ, p_cpl, MAX_PKT_BURST, dma_id, 0); in complete_async_pkts()
1009 ret = vs_enqueue_pkts(dst_vdev, VIRTIO_RXQ, &m, 1); in sync_virtio_xmit()
1011 ret = rte_vhost_enqueue_burst(dst_vdev->vid, VIRTIO_RXQ, &m, 1); in sync_virtio_xmit()
1033 ret = vs_enqueue_pkts(vdev, VIRTIO_RXQ, m, nr_xmit); in drain_vhost()
1034 } else if (dma_bind[vdev->vid].dmas[VIRTIO_RXQ].async_enabled) { in drain_vhost()
1036 int16_t dma_id = dma_bind[vdev->vid].dmas[VIRTIO_RXQ].dev_id; in drain_vhost()
1039 ret = rte_vhost_submit_enqueue_burst(vdev->vid, VIRTIO_RXQ, m, nr_xmit, dma_id, 0); in drain_vhost()
1045 ret = rte_vhost_enqueue_burst(vdev->vid, VIRTIO_RXQ, in drain_vhost()
1056 if (!dma_bind[vdev->vid].dmas[VIRTIO_RXQ].async_enabled) in drain_vhost()
1347 VIRTIO_RXQ))) { in drain_eth_rx()
1353 VIRTIO_RXQ)) in drain_eth_rx()
1359 enqueue_count = vs_enqueue_pkts(vdev, VIRTIO_RXQ, in drain_eth_rx()
1361 } else if (dma_bind[vdev->vid].dmas[VIRTIO_RXQ].async_enabled) { in drain_eth_rx()
1363 int16_t dma_id = dma_bind[vdev->vid].dmas[VIRTIO_RXQ].dev_id; in drain_eth_rx()
1367 VIRTIO_RXQ, pkts, rx_count, dma_id, 0); in drain_eth_rx()
1374 enqueue_count = rte_vhost_enqueue_burst(vdev->vid, VIRTIO_RXQ, in drain_eth_rx()
1385 if (!dma_bind[vdev->vid].dmas[VIRTIO_RXQ].async_enabled) in drain_eth_rx()
1537 if (dma_bind[vid].dmas[VIRTIO_RXQ].async_enabled) { in destroy_device()
1540 int16_t dma_id = dma_bind[vid].dmas[VIRTIO_RXQ].dev_id; in destroy_device()
1541 pkts_inflight = rte_vhost_async_get_inflight_thread_unsafe(vid, VIRTIO_RXQ); in destroy_device()
1545 n_pkt = rte_vhost_clear_queue_thread_unsafe(vid, VIRTIO_RXQ, in destroy_device()
1549 VIRTIO_RXQ); in destroy_device()
1552 rte_vhost_async_channel_unregister(vid, VIRTIO_RXQ); in destroy_device()
1553 dma_bind[vid].dmas[VIRTIO_RXQ].async_enabled = false; in destroy_device()
1616 rte_vhost_enable_guest_notification(vid, VIRTIO_RXQ, 0); in new_device()
1623 if (dma_bind[vid].dmas[VIRTIO_RXQ].dev_id != INVALID_DMA_ID) { in new_device()
1626 ret = rte_vhost_async_channel_register(vid, VIRTIO_RXQ); in new_device()
1628 dma_bind[vid].dmas[VIRTIO_RXQ].async_enabled = true; in new_device()
1647 if (queue_id != VIRTIO_RXQ) in vring_state_changed()
1655 int16_t dma_id = dma_bind[vid].dmas[VIRTIO_RXQ].dev_id; in vring_state_changed()