diff options
| author |   Zhihong Wang <zhihong.wang@intel.com> | 2016-06-21 20:33:59 -0400 |
|---|---|---|
| committer |   Damjan Marion <damarion@cisco.com> | 2016-06-25 17:34:30 +0000 |
| commit | 692581faf8d2eb876db5ab068ba4b477bc7ea174 (patch) | |
| tree | b3fbc1b90423bee14166dc2cdda1904b19d66f7d | |
| parent | 07515d7aaee6ab030501fc155bc8938f72f0da34 (diff) | |
vhost-dpdk: dequeue size fix
Burst size for DPDK is 32, which is different from VLIB_FRAME_SIZE.
A loop is needed to dequeue all packets.
Change-Id: Ie611c58c4e3434251a47fe6ad1f38abcb85180cb
Signed-off-by: Zhihong Wang <zhihong.wang@intel.com>
| -rw-r--r-- | vnet/vnet/devices/dpdk/dpdk_priv.h | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/vnet/vnet/devices/dpdk/dpdk_priv.h b/vnet/vnet/devices/dpdk/dpdk_priv.h index e5a67978a07..c202d85b590 100644 --- a/vnet/vnet/devices/dpdk/dpdk_priv.h +++ b/vnet/vnet/devices/dpdk/dpdk_priv.h @@ -92,12 +92,20 @@ dpdk_rx_burst ( dpdk_main_t * dm, dpdk_device_t * xd, u16 queue_id) return 0; #endif - n_buffers = rte_vhost_dequeue_burst(&xd->vu_vhost_dev, offset + VIRTIO_TXQ, - bm->pktmbuf_pools[socket_id], - xd->rx_vectors[queue_id], VLIB_FRAME_SIZE); + struct rte_mbuf **pkts = xd->rx_vectors[queue_id]; + while (n_left) { + n_this_chunk = rte_vhost_dequeue_burst(&xd->vu_vhost_dev, + offset + VIRTIO_TXQ, + bm->pktmbuf_pools[socket_id], + pkts + n_buffers, + n_left); + n_buffers += n_this_chunk; + n_left -= n_this_chunk; + if (n_this_chunk == 0) + break; + } int i; u32 bytes = 0; - struct rte_mbuf **pkts = xd->rx_vectors[queue_id]; for (i = 0; i < n_buffers; i++) { struct rte_mbuf *buff = pkts[i]; bytes += rte_pktmbuf_data_len(buff); |