Home
last modified time | relevance | path

Searched refs:rx_queues (Results 1 – 25 of 142) sorted by relevance

123456

/dpdk/drivers/net/bnxt/
H A Dbnxt_rxq.c268 rxq = bp->rx_queues[i]; in bnxt_free_rx_mbufs()
346 if (eth_dev->data->rx_queues) { in bnxt_rx_queue_setup_op()
347 rxq = eth_dev->data->rx_queues[queue_idx]; in bnxt_rx_queue_setup_op()
370 eth_dev->data->rx_queues[queue_idx] = rxq; in bnxt_rx_queue_setup_op()
428 if (eth_dev->data->rx_queues) { in bnxt_rx_queue_intr_enable_op()
429 rxq = eth_dev->data->rx_queues[queue_id]; in bnxt_rx_queue_intr_enable_op()
451 if (eth_dev->data->rx_queues) { in bnxt_rx_queue_intr_disable_op()
452 rxq = eth_dev->data->rx_queues[queue_id]; in bnxt_rx_queue_intr_disable_op()
552 rxq = bp->rx_queues[rx_queue_id]; in bnxt_rx_queue_stop()
579 if (bp->rx_queues[i]->rx_started) in bnxt_rx_queue_stop()
[all …]
H A Dbnxt_reps.c54 rep_rxq = vfr_bp->rx_queues[que]; in bnxt_vfr_recv()
424 rxq = rep_bp->rx_queues[i]; in bnxt_rep_free_rx_mbufs()
587 rep_bp->rx_queues = (void *)eth_dev->data->rx_queues; in bnxt_rep_dev_configure_op()
645 if (!parent_bp->rx_queues) { in bnxt_rep_rx_queue_setup_op()
650 parent_rxq = parent_bp->rx_queues[queue_idx]; in bnxt_rep_rx_queue_setup_op()
661 if (eth_dev->data->rx_queues) { in bnxt_rep_rx_queue_setup_op()
662 rxq = eth_dev->data->rx_queues[queue_idx]; in bnxt_rep_rx_queue_setup_op()
675 eth_dev->data->rx_queues[queue_idx] = rxq; in bnxt_rep_rx_queue_setup_op()
708 struct bnxt_rx_queue *rxq = dev->data->rx_queues[queue_idx]; in bnxt_rep_rx_queue_release_op()
/dpdk/lib/ethdev/
H A Dethdev_private.c280 fpo->rxq.data = dev->data->rx_queues; in eth_dev_fp_ops_setup()
353 void **rxq = dev->data->rx_queues; in eth_dev_rxq_release()
382 if (dev->data->rx_queues == NULL && nb_queues != 0) { /* first time configuration */ in eth_dev_rx_queue_config()
383 dev->data->rx_queues = rte_zmalloc("ethdev->rx_queues", in eth_dev_rx_queue_config()
384 sizeof(dev->data->rx_queues[0]) * in eth_dev_rx_queue_config()
387 if (dev->data->rx_queues == NULL) { in eth_dev_rx_queue_config()
391 } else if (dev->data->rx_queues != NULL && nb_queues != 0) { /* re-configure */ in eth_dev_rx_queue_config()
395 } else if (dev->data->rx_queues != NULL && nb_queues == 0) { in eth_dev_rx_queue_config()
399 rte_free(dev->data->rx_queues); in eth_dev_rx_queue_config()
400 dev->data->rx_queues = NULL; in eth_dev_rx_queue_config()
/dpdk/drivers/net/nfb/
H A Dnfb_rx.c18 struct ndp_rx_queue *rxq = dev->data->rx_queues[rxq_id]; in nfb_eth_rx_queue_start()
39 struct ndp_rx_queue *rxq = dev->data->rx_queues[rxq_id]; in nfb_eth_rx_queue_stop()
87 dev->data->rx_queues[rx_queue_id] = rxq; in nfb_eth_rx_queue_setup()
128 struct ndp_rx_queue *rxq = dev->data->rx_queues[qid]; in nfb_eth_rx_queue_release()
H A Dnfb_stats.c24 dev->data->rx_queues); in nfb_eth_stats_get()
63 dev->data->rx_queues); in nfb_eth_stats_reset()
/dpdk/drivers/net/ring/
H A Drte_eth_ring.c28 struct rte_ring * const *rx_queues; member
140 dev->data->rx_queues[rx_queue_id] = &internals->rx_ring_queues[rx_queue_id]; in eth_rx_queue_setup()
276 r = dev->data->rx_queues[i]; in eth_dev_close()
311 struct rte_ring * const rx_queues[], in do_eth_dev_ring_create() argument
366 data->rx_queues = rx_queues_local; in do_eth_dev_ring_create()
373 internals->rx_ring_queues[i].rng = rx_queues[i]; in do_eth_dev_ring_create()
374 data->rx_queues[i] = &internals->rx_ring_queues[i]; in do_eth_dev_ring_create()
411 rte_eth_from_rings(const char *name, struct rte_ring *const rx_queues[], in rte_eth_from_rings() argument
418 .rx_queues = rx_queues, in rte_eth_from_rings()
431 if (rx_queues == NULL && nb_rx_queues > 0) { in rte_eth_from_rings()
[all …]
/dpdk/drivers/net/hns3/
H A Dhns3_ethdev_dump.c233 void **rx_queues; in get_rx_queue() local
236 rx_queues = dev->data->rx_queues; in get_rx_queue()
237 if (rx_queues == NULL || rx_queues[queue_id] == NULL) { in get_rx_queue()
242 rxq = (struct hns3_rx_queue *)rx_queues[queue_id]; in get_rx_queue()
246 return rx_queues[queue_id]; in get_rx_queue()
284 void **rx_queues; in get_rxtx_fake_queue_info() local
291 rx_queues = hw->fkq_data.rx_queues; in get_rxtx_fake_queue_info()
292 if (rx_queues == NULL || rx_queues[queue_id] == NULL) { in get_rxtx_fake_queue_info()
296 rxq = (struct hns3_rx_queue *)rx_queues[queue_id]; in get_rxtx_fake_queue_info()
H A Dhns3_rxtx.c164 if (hw->fkq_data.rx_queues[idx]) { in hns3_fake_rx_queue_release()
173 hw->fkq_data.rx_queues = NULL; in hns3_fake_rx_queue_release()
215 if (dev->data->rx_queues[i]) { in hns3_free_rx_queues()
217 dev->data->rx_queues[i] = NULL; in hns3_free_rx_queues()
224 if (fkq_data->rx_queues[i]) in hns3_free_rx_queues()
356 rxq = hw->data->rx_queues[i]; in hns3_update_all_queues_pvid_proc_en()
509 rxq = hw->data->rx_queues[i]; in hns3_start_all_rxqs()
530 rxq = hw->data->rx_queues[j]; in hns3_start_all_rxqs()
544 rxq = hw->data->rx_queues[i]; in hns3_restore_tqp_enable_state()
1287 rxq = hw->data->rx_queues[i]; in hns3_start_tqps()
[all …]
/dpdk/drivers/net/ark/
H A Dark_ethdev_rx.c133 if (dev->data->rx_queues[queue_idx] != NULL) { in eth_ark_dev_rx_queue_setup()
134 eth_ark_dev_rx_queue_release(dev->data->rx_queues[queue_idx]); in eth_ark_dev_rx_queue_setup()
135 dev->data->rx_queues[queue_idx] = NULL; in eth_ark_dev_rx_queue_setup()
201 dev->data->rx_queues[queue_idx] = queue; in eth_ark_dev_rx_queue_setup()
412 queue = dev->data->rx_queues[queue_id]; in eth_ark_rx_start_queue()
435 queue = dev->data->rx_queues[queue_id]; in eth_ark_rx_stop_queue()
528 queue = dev->data->rx_queues[queue_id]; in eth_ark_rx_dump_queue()
608 queue = (struct ark_rx_queue *)dev->data->rx_queues[i]; in eth_ark_udm_force_close()
/dpdk/drivers/net/vhost/
H A Drte_eth_vhost.c237 vq = dev->data->rx_queues[i]; in vhost_dev_xstats_reset()
294 vq = dev->data->rx_queues[i]; in vhost_dev_xstats_get()
578 vq = dev->data->rx_queues[qid]; in eth_rxq_intr_enable()
615 vq = dev->data->rx_queues[qid]; in eth_rxq_intr_disable()
682 vq = dev->data->rx_queues[i]; in eth_vhost_install_intr()
738 vq = dev->data->rx_queues[i]; in update_queuing_status()
769 vq = eth_dev->data->rx_queues[i]; in queue_setup()
875 vq = eth_dev->data->rx_queues[i]; in destroy_device()
1208 if (dev->data->rx_queues) in eth_dev_close()
1310 vq = dev->data->rx_queues[i]; in eth_stats_get()
[all …]
/dpdk/drivers/net/mlx4/
H A Dmlx4_rxq.c193 rxq = dev->data->rx_queues[id]; in mlx4_rss_attach()
272 mlx4_rxq_detach(dev->data->rx_queues[rss->queue_id[i]]); in mlx4_rss_attach()
307 mlx4_rxq_detach(dev->data->rx_queues[rss->queue_id[i]]); in mlx4_rss_detach()
361 struct rxq *rxq = ETH_DEV(priv)->data->rx_queues[i]; in mlx4_rss_init()
436 struct rxq *rxq = ETH_DEV(priv)->data->rx_queues[i]; in mlx4_rss_init()
462 struct rxq *rxq = ETH_DEV(priv)->data->rx_queues[i]; in mlx4_rss_deinit()
768 rxq = dev->data->rx_queues[idx]; in mlx4_rx_queue_setup()
829 dev->data->rx_queues[idx] = rxq; in mlx4_rx_queue_setup()
916 struct rxq *rxq = dev->data->rx_queues[idx]; in mlx4_rx_queue_release()
920 dev->data->rx_queues[idx] = NULL; in mlx4_rx_queue_release()
H A Dmlx4_intr.c80 struct rxq *rxq = ETH_DEV(priv)->data->rx_queues[i]; in mlx4_rx_intr_vec_enable()
328 struct rxq *rxq = dev->data->rx_queues[idx]; in mlx4_rx_intr_disable()
373 struct rxq *rxq = dev->data->rx_queues[idx]; in mlx4_rx_intr_enable()
/dpdk/drivers/net/enetfec/
H A Denet_ethdev.c163 rxq = fep->rx_queues[q]; in enet_free_buffers()
343 rte_free(fep->rx_queues[i]); in enet_free_queue()
345 rte_free(fep->rx_queues[i]); in enet_free_queue()
471 fep->rx_queues[queue_idx] = rxq; in enetfec_rx_queue_setup()
479 rxq = fep->rx_queues[queue_idx]; in enetfec_rx_queue_setup()
532 dev->data->rx_queues[queue_idx] = fep->rx_queues[queue_idx]; in enetfec_rx_queue_setup()
533 rte_write32(0, fep->rx_queues[queue_idx]->bd.active_reg_desc); in enetfec_rx_queue_setup()
671 rxq = fep->rx_queues[0]; in pmd_enetfec_remove()
/dpdk/drivers/net/kni/
H A Drte_eth_kni.c59 struct pmd_queue rx_queues[KNI_MAX_QUEUE_PER_PORT]; member
130 mb_pool = internals->rx_queues[0].mb_pool; in eth_kni_start()
260 q = &internals->rx_queues[rx_queue_id]; in eth_kni_rx_queue_setup()
264 dev->data->rx_queues[rx_queue_id] = q; in eth_kni_rx_queue_setup()
306 q = data->rx_queues[i]; in eth_kni_stats_get()
339 q = data->rx_queues[i]; in eth_kni_stats_reset()
/dpdk/drivers/net/bnx2x/
H A Dbnx2x_rxtx.c41 bnx2x_rx_queue_release(dev->data->rx_queues[queue_idx]); in bnx2x_dev_rx_queue_release()
157 dev->data->rx_queues[queue_idx] = rxq; in bnx2x_dev_rx_queue_setup()
158 if (!sc->rx_queues) sc->rx_queues = dev->data->rx_queues; in bnx2x_dev_rx_queue_setup()
495 struct bnx2x_rx_queue *rxq = dev->data->rx_queues[i]; in bnx2x_dev_clear_queues()
498 dev->data->rx_queues[i] = NULL; in bnx2x_dev_clear_queues()
/dpdk/drivers/net/dpaa/
H A Ddpaa_ethdev.c495 rte_free(dpaa_intf->rx_queues); in dpaa_eth_dev_close()
496 dpaa_intf->rx_queues = NULL; in dpaa_eth_dev_close()
1125 dev->data->rx_queues[queue_idx] = rxq; in dpaa_eth_rx_queue_setup()
1205 dev->data->rx_queues[eth_rx_queue_id] = rxq; in dpaa_eth_eventq_attach()
1514 rxq = dev->data->rx_queues[queue_id]; in dpaa_rxq_info_get()
1917 dpaa_intf->rx_queues = rte_zmalloc(NULL, in dpaa_dev_init()
1919 if (!dpaa_intf->rx_queues) { in dpaa_dev_init()
1924 dpaa_intf->rx_queues = NULL; in dpaa_dev_init()
1987 dpaa_intf->rx_queues[loop].vsp_id = vsp_id; in dpaa_dev_init()
2116 rte_free(dpaa_intf->rx_queues); in dpaa_dev_init()
[all …]
/dpdk/drivers/net/mvneta/
H A Dmvneta_rxtx.c725 if (dev->data->rx_queues[idx]) { in mvneta_rx_queue_setup()
726 rte_free(dev->data->rx_queues[idx]); in mvneta_rx_queue_setup()
727 dev->data->rx_queues[idx] = NULL; in mvneta_rx_queue_setup()
745 dev->data->rx_queues[idx] = rxq; in mvneta_rx_queue_setup()
846 struct mvneta_rxq *rxq = dev->data->rx_queues[i]; in mvneta_alloc_rx_bufs()
947 struct mvneta_rxq *rxq = dev->data->rx_queues[i]; in mvneta_flush_queues()
971 struct mvneta_rxq *q = dev->data->rx_queues[qid]; in mvneta_rx_queue_release()
1001 struct mvneta_rxq *q = dev->data->rx_queues[rx_queue_id]; in mvneta_rxq_info_get()
/dpdk/drivers/net/af_xdp/
H A Drte_eth_af_xdp.c157 struct pkt_rx_queue *rx_queues; member
822 rxq = &internals->rx_queues[i]; in eth_stats_get()
857 memset(&internals->rx_queues[i].stats, 0, in eth_stats_reset()
910 rxq = &internals->rx_queues[i]; in eth_dev_close()
1010 &internals->rx_queues[i]; in get_shared_umem()
1021 *umem = internals->rx_queues[i].umem; in get_shared_umem()
1398 rxq = &internals->rx_queues[rx_queue_id]; in eth_rx_queue_setup()
1435 dev->data->rx_queues[rx_queue_id] = rxq; in eth_rx_queue_setup()
1774 internals->rx_queues = rte_zmalloc_socket(NULL, in init_internals()
1777 if (internals->rx_queues == NULL) { in init_internals()
[all …]
/dpdk/drivers/net/axgbe/
H A Daxgbe_rxtx.c35 axgbe_rx_queue_release(dev->data->rx_queues[queue_idx]); in axgbe_dev_rx_queue_release()
111 dev->data->rx_queues[queue_idx] = rxq; in axgbe_dev_rx_queue_setup()
112 if (!pdata->rx_queues) in axgbe_dev_rx_queue_setup()
113 pdata->rx_queues = dev->data->rx_queues; in axgbe_dev_rx_queue_setup()
160 rxq = dev->data->rx_queues[i]; in axgbe_dev_disable_rx()
166 rxq = dev->data->rx_queues[i]; in axgbe_dev_disable_rx()
180 rxq = dev->data->rx_queues[i]; in axgbe_dev_enable_rx()
896 rxq = dev->data->rx_queues[i]; in axgbe_dev_clear_queues()
900 dev->data->rx_queues[i] = NULL; in axgbe_dev_clear_queues()
/dpdk/drivers/net/failsafe/
H A Dfailsafe_intr.c300 fsrxq = fsdev->data->rx_queues[qid]; in failsafe_eth_rx_intr_ctl_subdevice()
333 rxq = (struct rxq **)fsdev->data->rx_queues; in failsafe_rx_intr_install_subdevice()
373 fsrxq = fsdev->data->rx_queues[qid]; in failsafe_rx_intr_uninstall_subdevice()
450 struct rxq *rxq = priv->data->rx_queues[i]; in fs_rx_intr_vec_install()
H A Dfailsafe_ops.c109 rxq = dev->data->rx_queues[i]; in fs_set_queues_state_start()
173 if (dev->data->rx_queues[i] != NULL) in fs_set_queues_state_stop()
365 struct rxq *rxq = dev->data->rx_queues[qid]; in fs_rx_queue_release()
373 if (ETH(sdev)->data->rx_queues != NULL && in fs_rx_queue_release()
377 dev->data->rx_queues[rxq->qid] = NULL; in fs_rx_queue_release()
423 rxq = dev->data->rx_queues[rx_queue_id]; in fs_rx_queue_setup()
426 dev->data->rx_queues[rx_queue_id] = NULL; in fs_rx_queue_setup()
451 dev->data->rx_queues[rx_queue_id] = rxq; in fs_rx_queue_setup()
484 rxq = dev->data->rx_queues[idx]; in fs_rx_intr_enable()
524 rxq = dev->data->rx_queues[idx]; in fs_rx_intr_disable()
[all …]
/dpdk/drivers/net/pcap/
H A Dpcap_ethdev.c116 struct pmd_devargs rx_queues; member
881 dev->data->rx_queues[rx_queue_id] = pcap_q; in eth_rx_queue_setup()
1283 struct pmd_devargs *rx_queues = &devargs_all->rx_queues; in eth_from_pcaps_common() local
1285 const unsigned int nb_rx_queues = rx_queues->num_of_queue; in eth_from_pcaps_common()
1296 struct devargs_queue *queue = &rx_queues->queue[i]; in eth_from_pcaps_common()
1322 struct pmd_devargs *rx_queues = &devargs_all->rx_queues; in eth_from_pcaps() local
1337 osdep_iface_index_get(rx_queues->queue[0].name); in eth_from_pcaps()
1340 if (rx_queues->phy_mac) { in eth_from_pcaps()
1341 if (eth_pcap_update_mac(rx_queues->queue[0].name, in eth_from_pcaps()
1608 devargs_all.rx_queues = pcaps; in pmd_pcap_probe()
/dpdk/drivers/net/atlantic/
H A Datl_rxtx.c127 if (dev->data->rx_queues[rx_queue_id] != NULL) { in atl_rx_queue_setup()
129 dev->data->rx_queues[rx_queue_id] = NULL; in atl_rx_queue_setup()
188 dev->data->rx_queues[rx_queue_id] = rxq; in atl_rx_queue_setup()
350 rxq = eth_dev->data->rx_queues[i]; in atl_rx_init()
452 rxq = dev->data->rx_queues[rx_queue_id]; in atl_rx_queue_start()
484 rxq = dev->data->rx_queues[rx_queue_id]; in atl_rx_queue_stop()
503 struct atl_rx_queue *rxq = dev->data->rx_queues[rx_queue_id]; in atl_rx_queue_release()
594 dev->data->rx_queues[i] = 0; in atl_free_queues()
669 rxq = dev->data->rx_queues[queue_id]; in atl_rxq_info_get()
772 rxq = dev->data->rx_queues[queue_id]; in atl_rx_enable_intr()
/dpdk/drivers/raw/ntb/
H A Dntb.c266 q_conf->nb_desc = hw->rx_queues[queue_id]->nb_rx_desc; in ntb_queue_conf_get()
267 q_conf->rx_mp = hw->rx_queues[queue_id]->mpool; in ntb_queue_conf_get()
352 hw->rx_queues[qp_id] = rxq; in ntb_rxq_setup()
488 ntb_rxq_release(hw->rx_queues[queue_id]); in ntb_queue_release()
489 hw->rx_queues[queue_id] = NULL; in ntb_queue_release()
505 struct ntb_rx_queue *rxq = hw->rx_queues[qp_id]; in ntb_queue_init()
874 hw->rx_queues = rte_zmalloc("ntb_rx_queues", in ntb_dev_configure()
888 rte_free(hw->rx_queues); in ntb_dev_configure()
890 hw->rx_queues = NULL; in ntb_dev_configure()
971 ntb_rxq_release_mbufs(hw->rx_queues[i]); in ntb_dev_start()
[all …]
/dpdk/drivers/net/nfp/
H A Dnfp_rxtx.c93 if (nfp_net_rx_fill_freelist(dev->data->rx_queues[i]) < 0) in nfp_net_rx_freelist_setup()
469 struct nfp_net_rxq *rxq = dev->data->rx_queues[queue_idx]; in nfp_net_rx_queue_release()
516 if (dev->data->rx_queues[queue_idx]) { in nfp_net_rx_queue_setup()
518 dev->data->rx_queues[queue_idx] = NULL; in nfp_net_rx_queue_setup()
527 dev->data->rx_queues[queue_idx] = rxq; in nfp_net_rx_queue_setup()
563 dev->data->rx_queues[queue_idx] = NULL; in nfp_net_rx_queue_setup()
577 dev->data->rx_queues[queue_idx] = NULL; in nfp_net_rx_queue_setup()

123456