Lines Matching refs:enqueue_count
1362 uint16_t enqueue_count; in async_enqueue_pkts() local
1366 enqueue_count = rte_vhost_submit_enqueue_burst(dev->vid, queue_id, in async_enqueue_pkts()
1369 return enqueue_count; in async_enqueue_pkts()
1382 uint16_t rx_count, enqueue_count; in drain_eth_rx() local
1391 enqueue_count = vdev_queue_ops[vdev->vid].enqueue_pkt_burst(vdev, in drain_eth_rx()
1395 if (enable_retry && unlikely(enqueue_count < rx_count)) { in drain_eth_rx()
1398 while (enqueue_count < rx_count && retry++ < burst_rx_retry_num) { in drain_eth_rx()
1400 enqueue_count += vdev_queue_ops[vdev->vid].enqueue_pkt_burst(vdev, in drain_eth_rx()
1401 VIRTIO_RXQ, &pkts[enqueue_count], in drain_eth_rx()
1402 rx_count - enqueue_count); in drain_eth_rx()
1409 rte_atomic_fetch_add_explicit(&vdev->stats.rx_atomic, enqueue_count, in drain_eth_rx()
1416 uint16_t enqueue_fail = rx_count - enqueue_count; in drain_eth_rx()
1418 free_pkts(&pkts[enqueue_count], enqueue_fail); in drain_eth_rx()