net/virtio: vring init for packed queues

Add and initialize descriptor data structures.

Signed-off-by: Jens Freimann <jfreimann@redhat.com>
Signed-off-by: Tiwei Bie <tiwei.bie@intel.com>
Reviewed-by: Maxime Coquelin <maxime.coquelin@redhat.com>
This commit is contained in:
Jens Freimann 2018-12-17 22:31:32 +01:00 committed by Ferruh Yigit
parent e9f4feb7e6
commit f803734b0f
3 changed files with 46 additions and 16 deletions

View File

@ -299,20 +299,22 @@ virtio_init_vring(struct virtqueue *vq)
PMD_INIT_FUNC_TRACE(); PMD_INIT_FUNC_TRACE();
/*
* Reinitialise since virtio port might have been stopped and restarted
*/
memset(ring_mem, 0, vq->vq_ring_size); memset(ring_mem, 0, vq->vq_ring_size);
vring_init(vr, size, ring_mem, VIRTIO_PCI_VRING_ALIGN);
vq->vq_used_cons_idx = 0; vq->vq_used_cons_idx = 0;
vq->vq_desc_head_idx = 0; vq->vq_desc_head_idx = 0;
vq->vq_avail_idx = 0; vq->vq_avail_idx = 0;
vq->vq_desc_tail_idx = (uint16_t)(vq->vq_nentries - 1); vq->vq_desc_tail_idx = (uint16_t)(vq->vq_nentries - 1);
vq->vq_free_cnt = vq->vq_nentries; vq->vq_free_cnt = vq->vq_nentries;
memset(vq->vq_descx, 0, sizeof(struct vq_desc_extra) * vq->vq_nentries); memset(vq->vq_descx, 0, sizeof(struct vq_desc_extra) * vq->vq_nentries);
if (vtpci_packed_queue(vq->hw)) {
vring_desc_init(vr->desc, size); vring_init_packed(&vq->ring_packed, ring_mem,
VIRTIO_PCI_VRING_ALIGN, size);
vring_desc_init_packed(vq, size);
} else {
vring_init_split(vr, ring_mem, VIRTIO_PCI_VRING_ALIGN, size);
vring_desc_init_split(vr->desc, size);
}
/* /*
* Disable device(host) interrupting guest * Disable device(host) interrupting guest
*/ */
@ -384,11 +386,16 @@ virtio_init_queue(struct rte_eth_dev *dev, uint16_t vtpci_queue_idx)
vq->hw = hw; vq->hw = hw;
vq->vq_queue_index = vtpci_queue_idx; vq->vq_queue_index = vtpci_queue_idx;
vq->vq_nentries = vq_size; vq->vq_nentries = vq_size;
vq->event_flags_shadow = 0;
if (vtpci_packed_queue(hw)) {
vq->avail_wrap_counter = 1;
vq->used_wrap_counter = 1;
}
/* /*
* Reserve a memzone for vring elements * Reserve a memzone for vring elements
*/ */
size = vring_size(vq_size, VIRTIO_PCI_VRING_ALIGN); size = vring_size(hw, vq_size, VIRTIO_PCI_VRING_ALIGN);
vq->vq_ring_size = RTE_ALIGN_CEIL(size, VIRTIO_PCI_VRING_ALIGN); vq->vq_ring_size = RTE_ALIGN_CEIL(size, VIRTIO_PCI_VRING_ALIGN);
PMD_INIT_LOG(DEBUG, "vring_size: %d, rounded_vring_size: %d", PMD_INIT_LOG(DEBUG, "vring_size: %d, rounded_vring_size: %d",
size, vq->vq_ring_size); size, vq->vq_ring_size);
@ -491,7 +498,8 @@ virtio_init_queue(struct rte_eth_dev *dev, uint16_t vtpci_queue_idx)
for (i = 0; i < vq_size; i++) { for (i = 0; i < vq_size; i++) {
struct vring_desc *start_dp = txr[i].tx_indir; struct vring_desc *start_dp = txr[i].tx_indir;
vring_desc_init(start_dp, RTE_DIM(txr[i].tx_indir)); vring_desc_init_split(start_dp,
RTE_DIM(txr[i].tx_indir));
/* first indirect descriptor is always the tx header */ /* first indirect descriptor is always the tx header */
start_dp->addr = txvq->virtio_net_hdr_mem start_dp->addr = txvq->virtio_net_hdr_mem
@ -1488,7 +1496,8 @@ virtio_init_device(struct rte_eth_dev *eth_dev, uint64_t req_features)
/* Setting up rx_header size for the device */ /* Setting up rx_header size for the device */
if (vtpci_with_feature(hw, VIRTIO_NET_F_MRG_RXBUF) || if (vtpci_with_feature(hw, VIRTIO_NET_F_MRG_RXBUF) ||
vtpci_with_feature(hw, VIRTIO_F_VERSION_1)) vtpci_with_feature(hw, VIRTIO_F_VERSION_1) ||
vtpci_with_feature(hw, VIRTIO_F_RING_PACKED))
hw->vtnet_hdr_size = sizeof(struct virtio_net_hdr_mrg_rxbuf); hw->vtnet_hdr_size = sizeof(struct virtio_net_hdr_mrg_rxbuf);
else else
hw->vtnet_hdr_size = sizeof(struct virtio_net_hdr); hw->vtnet_hdr_size = sizeof(struct virtio_net_hdr);
@ -1908,7 +1917,8 @@ virtio_dev_configure(struct rte_eth_dev *dev)
if (vtpci_with_feature(hw, VIRTIO_F_IN_ORDER)) { if (vtpci_with_feature(hw, VIRTIO_F_IN_ORDER)) {
hw->use_inorder_tx = 1; hw->use_inorder_tx = 1;
if (vtpci_with_feature(hw, VIRTIO_NET_F_MRG_RXBUF)) { if (vtpci_with_feature(hw, VIRTIO_NET_F_MRG_RXBUF) &&
!vtpci_packed_queue(hw)) {
hw->use_inorder_rx = 1; hw->use_inorder_rx = 1;
hw->use_simple_rx = 0; hw->use_simple_rx = 0;
} else { } else {

View File

@ -125,10 +125,18 @@ struct vring {
#define vring_avail_event(vr) (*(uint16_t *)&(vr)->used->ring[(vr)->num]) #define vring_avail_event(vr) (*(uint16_t *)&(vr)->used->ring[(vr)->num])
static inline size_t static inline size_t
vring_size(unsigned int num, unsigned long align) vring_size(struct virtio_hw *hw, unsigned int num, unsigned long align)
{ {
size_t size; size_t size;
if (vtpci_packed_queue(hw)) {
size = num * sizeof(struct vring_packed_desc);
size += sizeof(struct vring_packed_desc_event);
size = RTE_ALIGN_CEIL(size, align);
size += sizeof(struct vring_packed_desc_event);
return size;
}
size = num * sizeof(struct vring_desc); size = num * sizeof(struct vring_desc);
size += sizeof(struct vring_avail) + (num * sizeof(uint16_t)); size += sizeof(struct vring_avail) + (num * sizeof(uint16_t));
size = RTE_ALIGN_CEIL(size, align); size = RTE_ALIGN_CEIL(size, align);
@ -136,10 +144,9 @@ vring_size(unsigned int num, unsigned long align)
(num * sizeof(struct vring_used_elem)); (num * sizeof(struct vring_used_elem));
return size; return size;
} }
static inline void static inline void
vring_init(struct vring *vr, unsigned int num, uint8_t *p, vring_init_split(struct vring *vr, uint8_t *p, unsigned long align,
unsigned long align) unsigned int num)
{ {
vr->num = num; vr->num = num;
vr->desc = (struct vring_desc *) p; vr->desc = (struct vring_desc *) p;
@ -149,6 +156,19 @@ vring_init(struct vring *vr, unsigned int num, uint8_t *p,
RTE_ALIGN_CEIL((uintptr_t)(&vr->avail->ring[num]), align); RTE_ALIGN_CEIL((uintptr_t)(&vr->avail->ring[num]), align);
} }
static inline void
vring_init_packed(struct vring_packed *vr, uint8_t *p, unsigned long align,
unsigned int num)
{
vr->num = num;
vr->desc_packed = (struct vring_packed_desc *)p;
vr->driver_event = (struct vring_packed_desc_event *)(p +
vr->num * sizeof(struct vring_packed_desc));
vr->device_event = (struct vring_packed_desc_event *)
RTE_ALIGN_CEIL((uintptr_t)(vr->driver_event +
sizeof(struct vring_packed_desc_event)), align);
}
/* /*
* The following is used with VIRTIO_RING_F_EVENT_IDX. * The following is used with VIRTIO_RING_F_EVENT_IDX.
* Assuming a given event_idx value from the other size, if we have * Assuming a given event_idx value from the other size, if we have

View File

@ -278,7 +278,7 @@ vring_desc_init_packed(struct virtqueue *vq, int n)
/* Chain all the descriptors in the ring with an END */ /* Chain all the descriptors in the ring with an END */
static inline void static inline void
vring_desc_init(struct vring_desc *dp, uint16_t n) vring_desc_init_split(struct vring_desc *dp, uint16_t n)
{ {
uint16_t i; uint16_t i;