Home
last modified time | relevance | path

Searched refs:nb_queues (Results 1 – 25 of 77) sorted by relevance

1234

/dpdk/drivers/net/sfc/
H A Dsfc_sw_stats.c230 return nb_queues > 0 ? sw_stat->provide_total + nb_queues : 0; in sfc_sw_xstat_per_queue_get_count()
237 unsigned int nb_queues; in sfc_sw_xstat_get_nb_supported() local
253 unsigned int nb_queues; in sfc_sw_stat_get_names() local
258 if (nb_queues == 0) in sfc_sw_stat_get_names()
300 unsigned int nb_queues; in sfc_sw_xstat_get_names_by_id() local
305 if (nb_queues == 0) in sfc_sw_xstat_get_names_by_id()
383 unsigned int nb_queues; in sfc_sw_xstat_get_values() local
386 if (nb_queues == 0) in sfc_sw_xstat_get_values()
434 unsigned int nb_queues; in sfc_sw_xstat_get_values_by_id() local
441 if (nb_queues == 0) in sfc_sw_xstat_get_values_by_id()
[all …]
/dpdk/lib/ethdev/
H A Dethdev_private.c377 eth_dev_rx_queue_config(struct rte_eth_dev *dev, uint16_t nb_queues) in eth_dev_rx_queue_config() argument
391 } else if (dev->data->rx_queues != NULL && nb_queues != 0) { /* re-configure */ in eth_dev_rx_queue_config()
392 for (i = nb_queues; i < old_nb_queues; i++) in eth_dev_rx_queue_config()
395 } else if (dev->data->rx_queues != NULL && nb_queues == 0) { in eth_dev_rx_queue_config()
396 for (i = nb_queues; i < old_nb_queues; i++) in eth_dev_rx_queue_config()
402 dev->data->nb_rx_queues = nb_queues; in eth_dev_rx_queue_config()
407 eth_dev_tx_queue_config(struct rte_eth_dev *dev, uint16_t nb_queues) in eth_dev_tx_queue_config() argument
422 for (i = nb_queues; i < old_nb_queues; i++) in eth_dev_tx_queue_config()
425 } else if (dev->data->tx_queues != NULL && nb_queues == 0) { in eth_dev_tx_queue_config()
426 for (i = nb_queues; i < old_nb_queues; i++) in eth_dev_tx_queue_config()
[all …]
H A Dethdev_private.h69 int eth_dev_rx_queue_config(struct rte_eth_dev *dev, uint16_t nb_queues);
70 int eth_dev_tx_queue_config(struct rte_eth_dev *dev, uint16_t nb_queues);
/dpdk/drivers/common/cnxk/
H A Droc_ree.c25 *nb_queues = rsp->ree0; in roc_ree_available_queues_get()
27 *nb_queues = rsp->ree1; in roc_ree_available_queues_get()
60 req->reelfs = nb_queues; in roc_ree_queues_attach()
67 vf->nb_queues = nb_queues; in roc_ree_queues_attach()
90 vf->nb_queues = 0; in roc_ree_queues_detach()
110 for (i = 0; i < vf->nb_queues; i++) { in roc_ree_msix_offsets_get()
459 for (i = 0; i < vf->nb_queues; i++) { in roc_ree_err_intr_unregister()
569 uint16_t nb_queues = 0; in roc_ree_dev_init() local
606 nb_queues = RTE_MIN(nb_queues, REE_MAX_QUEUES_PER_VF); in roc_ree_dev_init()
608 if (nb_queues == 0) { in roc_ree_dev_init()
[all …]
H A Droc_ree.h30 uint8_t nb_queues; member
111 int __roc_api roc_ree_queues_attach(struct roc_ree_vf *vf, uint8_t nb_queues);
/dpdk/drivers/raw/ioat/
H A Ddpdk_idxd_cfg.py75 nb_queues = min(queues, max_queues)
76 if queues > nb_queues:
80 nb_groups = min(max_engines, max_groups, nb_queues)
85 for q in range(nb_queues):
93 "size": int(max_work_queues_size / nb_queues)})
100 for q in range(nb_queues):
/dpdk/drivers/dma/idxd/
H A Ddpdk_idxd_cfg.py75 nb_queues = min(queues, max_queues)
76 if queues > nb_queues:
80 nb_groups = min(max_engines, max_groups, nb_queues)
85 for q in range(nb_queues):
93 "size": int(max_work_queues_size / nb_queues)})
100 for q in range(nb_queues):
/dpdk/lib/eventdev/
H A Drte_event_eth_tx_adapter.c102 uint32_t nb_queues; member
138 uint16_t nb_queues; member
742 if (txa->nb_queues) { in txa_service_adapter_free()
744 txa->nb_queues); in txa_service_adapter_free()
770 int nb_queues; in txa_service_queue_add() local
777 nb_queues -= tdi->nb_queues; in txa_service_queue_add()
836 tdi->nb_queues++; in txa_service_queue_add()
837 txa->nb_queues++; in txa_service_queue_add()
871 nb_queues = txa->txa_ethdev[port_id].nb_queues; in txa_service_queue_del()
872 if (nb_queues == 0) in txa_service_queue_del()
[all …]
H A Drte_eventdev.c210 uint8_t old_nb_queues = dev->data->nb_queues; in event_dev_queue_config()
217 if (nb_queues != 0) { in event_dev_queue_config()
221 for (i = nb_queues; i < old_nb_queues; i++) in event_dev_queue_config()
225 if (nb_queues > old_nb_queues) { in event_dev_queue_config()
226 uint8_t new_qs = nb_queues - old_nb_queues; in event_dev_queue_config()
234 for (i = nb_queues; i < old_nb_queues; i++) in event_dev_queue_config()
238 dev->data->nb_queues = nb_queues; in event_dev_queue_config()
768 *attr_value = dev->data->nb_queues; in rte_event_dev_attr_get()
935 nb_links = dev->data->nb_queues; in rte_event_port_link()
946 if (queues[i] >= dev->data->nb_queues) { in rte_event_port_link()
[all …]
/dpdk/examples/dma/
H A Ddmafwd.c40 uint16_t nb_queues; member
85 static uint16_t nb_queues = 1; variable
206 "Rx Queues = %d, ", nb_queues); in print_stats()
396 for (i = 0; i < rx_config->nb_queues; i++) { in dma_rx_port()
467 for (i = 0; i < tx_config->nb_queues; i++) { in dma_tx_port()
680 nb_queues = atoi(optarg); in dma_parse_args()
681 if (nb_queues == 0 || nb_queues > MAX_RX_QUEUES_COUNT) { in dma_parse_args()
813 for (j = 0; j < cfg.ports[i].nb_queues; j++) { in assign_dmadevs()
917 for (i = 0; i < nb_queues; i++) { in port_init()
974 cfg.ports[cfg.nb_ports++].nb_queues = nb_queues; in port_init()
[all …]
/dpdk/drivers/net/af_packet/
H A Drte_eth_af_packet.c72 unsigned nb_queues; member
419 for (i = 0; i < internal->nb_queues; i++) { in eth_stats_reset()
424 for (i = 0; i < internal->nb_queues; i++) { in eth_stats_reset()
705 nb_queues, in rte_pmd_init_internals()
709 nb_queues, in rte_pmd_init_internals()
716 for (q = 0; q < nb_queues; q++) { in rte_pmd_init_internals()
768 for (q = 0; q < nb_queues; q++) { in rte_pmd_init_internals()
902 (*internals)->nb_queues = nb_queues; in rte_pmd_init_internals()
906 data->nb_rx_queues = (uint16_t)nb_queues; in rte_pmd_init_internals()
907 data->nb_tx_queues = (uint16_t)nb_queues; in rte_pmd_init_internals()
[all …]
/dpdk/app/test/
H A Dtest_eventdev.c989 int ret, nb_queues, i; in test_eventdev_link() local
1001 nb_queues = queue_count; in test_eventdev_link()
1002 for (i = 0; i < nb_queues; i++) { in test_eventdev_link()
1008 priorities, nb_queues); in test_eventdev_link()
1017 int ret, nb_queues, i; in test_eventdev_unlink() local
1028 nb_queues = queue_count; in test_eventdev_unlink()
1029 for (i = 0; i < nb_queues; i++) in test_eventdev_unlink()
1059 for (i = 0; i < nb_queues; i++) in test_eventdev_link_get()
1070 for (i = 0; i < nb_queues; i++) { in test_eventdev_link_get()
1075 nb_queues); in test_eventdev_link_get()
[all …]
/dpdk/examples/l3fwd/
H A Dl3fwd_event_generic.c71 evt_rsrc->evq.nb_queues = event_d_conf.nb_event_queues; in l3fwd_event_device_setup_generic()
136 evt_rsrc->evq.nb_queues - 1); in l3fwd_event_port_setup_generic()
137 if (ret != (evt_rsrc->evq.nb_queues - 1)) in l3fwd_event_port_setup_generic()
165 evt_rsrc->evq.nb_queues); in l3fwd_event_queue_setup_generic()
176 for (event_q_id = 0; event_q_id < (evt_rsrc->evq.nb_queues - 1); in l3fwd_event_queue_setup_generic()
234 if (i < evt_rsrc->evq.nb_queues) in l3fwd_rx_tx_adapter_setup_generic()
291 evt_rsrc->evq.nb_queues - 1], in l3fwd_rx_tx_adapter_setup_generic()
H A Dl3fwd_event_internal_port.c71 evt_rsrc->evq.nb_queues = event_d_conf.nb_event_queues; in l3fwd_event_device_setup_internal_port()
176 evt_rsrc->evq.nb_queues); in l3fwd_event_queue_setup_internal_port()
180 for (event_q_id = 0; event_q_id < evt_rsrc->evq.nb_queues; in l3fwd_event_queue_setup_internal_port()
268 if (q_id < evt_rsrc->evq.nb_queues) in l3fwd_rx_tx_adapter_setup_internal_port()
/dpdk/examples/l2fwd-event/
H A Dl2fwd_event_generic.c84 evt_rsrc->evq.nb_queues = event_d_conf.nb_event_queues; in l2fwd_event_device_setup_generic()
150 evt_rsrc->evq.nb_queues - 1); in l2fwd_event_port_setup_generic()
151 if (ret != (evt_rsrc->evq.nb_queues - 1)) in l2fwd_event_port_setup_generic()
182 evt_rsrc->evq.nb_queues); in l2fwd_event_queue_setup_generic()
194 for (event_q_id = 0; event_q_id < (evt_rsrc->evq.nb_queues - 1); in l2fwd_event_queue_setup_generic()
273 if (i < evt_rsrc->evq.nb_queues) in l2fwd_rx_tx_adapter_setup_generic()
331 evt_rsrc->evq.nb_queues - 1], in l2fwd_rx_tx_adapter_setup_generic()
H A Dl2fwd_event_internal_port.c81 evt_rsrc->evq.nb_queues = event_d_conf.nb_event_queues; in l2fwd_event_device_setup_internal_port()
185 evt_rsrc->evq.nb_queues); in l2fwd_event_queue_setup_internal_port()
189 for (event_q_id = 0; event_q_id < evt_rsrc->evq.nb_queues; in l2fwd_event_queue_setup_internal_port()
275 if (q_id < evt_rsrc->evq.nb_queues) in l2fwd_rx_tx_adapter_setup_internal_port()
/dpdk/app/test-eventdev/
H A Dtest_pipeline_common.c29 pipeline_opt_dump(struct evt_options *opt, uint8_t nb_queues) in pipeline_opt_dump() argument
35 evt_dump("nb_evdev_queues", "%d", nb_queues); in pipeline_opt_dump()
111 pipeline_opt_check(struct evt_options *opt, uint64_t nb_queues) in pipeline_opt_check() argument
149 if (nb_queues > EVT_MAX_QUEUES) { in pipeline_opt_check()
174 uint8_t nb_queues = 1; in pipeline_ethdev_setup() local
254 if (rte_eth_dev_configure(i, opt->eth_queues, nb_queues, in pipeline_ethdev_setup()
291 uint8_t *queue_arr, uint8_t nb_queues, in pipeline_event_port_setup() argument
315 nb_queues) != nb_queues) in pipeline_event_port_setup()
H A Dtest_perf_atq.c200 uint8_t nb_queues; in perf_atq_eventdev_setup() local
211 nb_queues = atq_nb_event_queues(opt); in perf_atq_eventdev_setup()
220 ret = evt_configure_eventdev(opt, nb_queues, nb_ports); in perf_atq_eventdev_setup()
233 for (queue = 0; queue < nb_queues; queue++) { in perf_atq_eventdev_setup()
251 ret = perf_event_dev_port_setup(test, opt, 1 /* stride */, nb_queues, in perf_atq_eventdev_setup()
H A Dtest_perf_queue.c204 int nb_queues; in perf_queue_eventdev_setup() local
214 nb_queues = perf_queue_nb_event_queues(opt); in perf_queue_eventdev_setup()
223 ret = evt_configure_eventdev(opt, nb_queues, nb_ports); in perf_queue_eventdev_setup()
235 for (queue = 0; queue < nb_queues; queue++) { in perf_queue_eventdev_setup()
269 nb_queues, &p_conf); in perf_queue_eventdev_setup()
H A Dtest_perf_common.h169 int perf_opt_check(struct evt_options *opt, uint64_t nb_queues);
175 uint8_t stride, uint8_t nb_queues,
180 void perf_opt_dump(struct evt_options *opt, uint8_t nb_queues);
H A Dtest_pipeline_atq.c574 int nb_queues; in pipeline_atq_eventdev_setup() local
585 nb_queues = rte_eth_dev_count_avail(); in pipeline_atq_eventdev_setup()
592 tx_evqueue_id[prod] = nb_queues; in pipeline_atq_eventdev_setup()
593 nb_queues++; in pipeline_atq_eventdev_setup()
599 ret = evt_configure_eventdev(opt, nb_queues, nb_ports); in pipeline_atq_eventdev_setup()
611 for (queue = 0; queue < nb_queues; queue++) { in pipeline_atq_eventdev_setup()
651 ret = pipeline_event_port_setup(test, opt, NULL, nb_queues, in pipeline_atq_eventdev_setup()
H A Dtest_pipeline_common.h193 int pipeline_opt_check(struct evt_options *opt, uint64_t nb_queues);
202 uint8_t *queue_arr, uint8_t nb_queues,
206 void pipeline_opt_dump(struct evt_options *opt, uint8_t nb_queues);
/dpdk/drivers/net/hns3/
H A Dhns3_ethdev_dump.c321 uint32_t nb_queues, bool is_rxq) in get_queue_enable_state() argument
330 for (i = 0; i < nb_queues; i++) { in get_queue_enable_state()
343 uint32_t nb_queues, uint32_t line_num) in print_queue_state_perline() argument
357 if (qid >= nb_queues) { in print_queue_state_perline()
366 uint32_t nb_queues, bool is_rxq) in display_queue_enable_state() argument
371 if (nb_queues == 0) { in display_queue_enable_state()
380 for (i = 0; i < (nb_queues - 1) / NUM_QUEUE_PER_LINE + 1; i++) { in display_queue_enable_state()
384 nb_queues - 1 > line_end ? line_end : nb_queues - 1); in display_queue_enable_state()
387 print_queue_state_perline(file, queue_state, nb_queues, i); in display_queue_enable_state()
H A Dhns3_fdir.h116 uint16_t nb_queues; member
156 uint16_t nb_queues; member
/dpdk/drivers/regex/mlx5/
H A Dmlx5_rxp.c147 priv->nb_queues = cfg->nb_queue_pairs; in mlx5_regex_configure()
148 dev->data->dev_conf.nb_queue_pairs = priv->nb_queues; in mlx5_regex_configure()
150 priv->nb_queues, 0); in mlx5_regex_configure()

1234