Home
last modified time | relevance | path

Searched refs:queue_id (Results 1 – 25 of 353) sorted by relevance

12345678910>>...15

/dpdk/app/test-bbdev/
H A Dtest_bbdev.c260 uint16_t queue_id; in test_bbdev_configure_stop_queue() local
267 queue_id = 0; in test_bbdev_configure_stop_queue()
285 queue_id, dev_id); in test_bbdev_configure_stop_queue()
294 queue_id, dev_id); in test_bbdev_configure_stop_queue()
314 queue_id, &qinfo), in test_bbdev_configure_stop_queue()
354 queue_id, &qinfo), in test_bbdev_configure_stop_queue()
373 queue_id, &qinfo), in test_bbdev_configure_stop_queue()
392 uint16_t queue_id; in test_bbdev_configure_invalid_queue_configure() local
398 queue_id = 0; in test_bbdev_configure_invalid_queue_configure()
423 queue_id = 0; in test_bbdev_configure_invalid_queue_configure()
[all …]
H A Dtest_bbdev_perf.c799 for (queue_id = 0; queue_id < nb_queues; ++queue_id) { in add_bbdev_dev()
814 ad->queue_ids[queue_id] = queue_id; in add_bbdev_dev()
2630 if (tp->queue_id == queue_id) in dequeue_event_callback()
2754 const uint16_t queue_id = tp->queue_id; in throughput_intr_lcore_ldpc_dec() local
2854 const uint16_t queue_id = tp->queue_id; in throughput_intr_lcore_dec() local
2941 const uint16_t queue_id = tp->queue_id; in throughput_intr_lcore_enc() local
3028 const uint16_t queue_id = tp->queue_id; in throughput_intr_lcore_ldpc_enc() local
3117 const uint16_t queue_id = tp->queue_id; in throughput_pmd_lcore_dec() local
3213 const uint16_t queue_id = tp->queue_id; in bler_pmd_lcore_ldpc_dec() local
3343 const uint16_t queue_id = tp->queue_id; in throughput_pmd_lcore_ldpc_dec() local
[all …]
/dpdk/lib/bbdev/
H A Drte_bbdev.h151 rte_bbdev_queue_configure(uint16_t dev_id, uint16_t queue_id,
209 rte_bbdev_queue_start(uint16_t dev_id, uint16_t queue_id);
224 rte_bbdev_queue_stop(uint16_t dev_id, uint16_t queue_id);
360 rte_bbdev_queue_info_get(uint16_t dev_id, uint16_t queue_id,
475 rte_bbdev_enqueue_enc_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_enqueue_enc_ops() argument
505 rte_bbdev_enqueue_dec_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_enqueue_dec_ops() argument
535 rte_bbdev_enqueue_ldpc_enc_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_enqueue_ldpc_enc_ops() argument
597 rte_bbdev_dequeue_enc_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_dequeue_enc_ops() argument
629 rte_bbdev_dequeue_dec_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_dequeue_dec_ops() argument
784 rte_bbdev_queue_intr_enable(uint16_t dev_id, uint16_t queue_id);
[all …]
H A Drte_bbdev.c68 queue_id, dev->data->dev_id); \
451 queue_id, dev_id); in rte_bbdev_queue_configure()
499 conf->priority, queue_id, dev_id, in rte_bbdev_queue_configure()
518 dev_id, queue_id); in rte_bbdev_queue_configure()
530 dev_id, queue_id); in rte_bbdev_queue_configure()
661 queue_id, dev_id); in rte_bbdev_queue_start()
669 dev_id, queue_id); in rte_bbdev_queue_start()
691 queue_id, dev_id); in rte_bbdev_queue_stop()
699 dev_id, queue_id); in rte_bbdev_queue_stop()
827 queue_id, dev_id); in rte_bbdev_queue_info_get()
[all …]
H A Drte_bbdev_pmd.h87 uint16_t queue_id, const struct rte_bbdev_queue_conf *conf);
94 uint16_t queue_id);
107 uint16_t queue_id);
110 typedef int (*rte_bbdev_queue_stop_t)(struct rte_bbdev *dev, uint16_t queue_id);
128 uint16_t queue_id);
135 uint16_t queue_id);
/dpdk/examples/qos_sched/
H A Dstats.c17 uint32_t count, i, queue_id = 0; in qavg_q() local
63 uint32_t count, i, queue_id = 0; in qavg_tcpipe() local
79 queue_id += in qavg_tcpipe()
91 rte_sched_queue_read_stats(port, queue_id, in qavg_tcpipe()
118 uint32_t count, i, queue_id = 0; in qavg_pipe() local
137 queue_id += pipe_id * RTE_SCHED_QUEUES_PER_PIPE; in qavg_pipe()
194 queue_id = subport_queue_id + in qavg_tcsubport()
196 rte_sched_queue_read_stats(port, queue_id, in qavg_tcsubport()
201 queue_id = subport_queue_id + in qavg_tcsubport()
204 rte_sched_queue_read_stats(port, queue_id, in qavg_tcsubport()
[all …]
/dpdk/lib/vhost/
H A Drte_vhost_async.h28 int rte_vhost_async_channel_register(int vid, uint16_t queue_id);
41 int rte_vhost_async_channel_unregister(int vid, uint16_t queue_id);
58 int rte_vhost_async_channel_register_thread_unsafe(int vid, uint16_t queue_id);
76 uint16_t queue_id);
99 uint16_t rte_vhost_submit_enqueue_burst(int vid, uint16_t queue_id,
124 uint16_t rte_vhost_poll_enqueue_completed(int vid, uint16_t queue_id,
140 int rte_vhost_async_get_inflight(int vid, uint16_t queue_id);
157 int rte_vhost_async_get_inflight_thread_unsafe(int vid, uint16_t queue_id);
182 uint16_t rte_vhost_clear_queue_thread_unsafe(int vid, uint16_t queue_id,
H A Dvhost.c1320 vq = dev->virtqueue[queue_id]; in rte_vhost_avail_entries()
1412 vq = dev->virtqueue[queue_id]; in rte_vhost_enable_guest_notification()
1529 vq = dev->virtqueue[queue_id]; in rte_vhost_get_vring_base()
1559 vq = dev->virtqueue[queue_id]; in rte_vhost_set_vring_base()
1578 uint16_t queue_id, in rte_vhost_get_vring_base_from_inflight() argument
1635 dev->ifname, queue_id); in async_channel_register()
1642 dev->ifname, queue_id); in async_channel_register()
1650 dev->ifname, queue_id); in async_channel_register()
1658 dev->ifname, queue_id); in async_channel_register()
1668 dev->ifname, queue_id); in async_channel_register()
[all …]
/dpdk/drivers/event/dlb2/
H A Ddlb2_selftest.c208 queue_id = 1; in test_stop_flush()
367 queue_id = 1; in test_single_link()
373 queue_id = 0; in test_single_link()
380 queue_id = 0; in test_single_link()
386 queue_id = 1; in test_single_link()
691 queue_id = 1; in test_reconfiguration_link()
700 queue_id = 0; in test_reconfiguration_link()
766 queue_id = i; in test_reconfiguration_link()
874 queue_id = 0; in test_load_balanced_traffic()
1002 queue_id = 0; in test_directed_traffic()
[all …]
/dpdk/drivers/event/dsw/
H A Ddsw_xstats.c62 uint8_t queue_id __rte_unused) \
73 uint8_t queue_id) in DSW_GEN_PORT_ACCESS_FN()
82 uint8_t queue_id) in DSW_GEN_PORT_ACCESS_FN()
114 uint8_t queue_id __rte_unused) in dsw_xstats_port_get_busy_cycles()
125 uint8_t queue_id __rte_unused) in DSW_GEN_PORT_ACCESS_FN()
189 uint8_t queue_id; in dsw_xstats_port_foreach() local
192 for (stat_idx = 0, queue_id = 0; in dsw_xstats_port_foreach()
202 queue_id); in dsw_xstats_port_foreach()
203 queue_id++; in dsw_xstats_port_foreach()
215 queue_id = 0; in dsw_xstats_port_foreach()
[all …]
H A Ddsw_event.c224 if (qfs[i].queue_id == queue_id && in dsw_is_queue_flow_in_ary()
237 queue_id, flow_hash); in dsw_port_is_flow_paused()
251 qf->queue_id, qf->flow_hash); in dsw_port_add_paused_flows()
267 if (qf->queue_id == target_qf->queue_id && in dsw_port_remove_paused_flow()
710 if (event->queue_id == qf->queue_id && in dsw_port_flush_paused_events()
742 uint8_t queue_id = qf->queue_id; in dsw_port_end_emigration() local
791 uint8_t queue_id = qf->queue_id; in dsw_port_move_parallel_flows() local
890 bursts[0].queue_flow.queue_id, in dsw_port_consider_emigration()
967 uint8_t queue_id, in dsw_port_forward_emigrated_flow() argument
996 if (e->queue_id == queue_id && in dsw_port_forward_emigrated_flow()
[all …]
/dpdk/app/test-eventdev/
H A Dtest_pipeline_queue.c39 ev.queue_id++; in pipeline_queue_worker_single_stage_tx()
96 ev[i].queue_id++; in pipeline_queue_worker_single_stage_burst_tx()
159 ev.queue_id++; in pipeline_queue_worker_single_stage_tx_vector()
219 ev[i].queue_id++; in pipeline_queue_worker_single_stage_burst_tx_vector()
289 ev.queue_id++; in pipeline_queue_worker_multi_stage_tx()
324 ev.queue_id++; in pipeline_queue_worker_multi_stage_fwd()
360 ev[i].queue_id++; in pipeline_queue_worker_multi_stage_burst_tx()
399 ev[i].queue_id++; in pipeline_queue_worker_multi_stage_burst_fwd()
439 ev.queue_id++; in pipeline_queue_worker_multi_stage_tx_vector()
474 ev.queue_id++; in pipeline_queue_worker_multi_stage_fwd_vector()
[all …]
/dpdk/lib/port/
H A Drte_swx_port_ethdev.c37 uint16_t queue_id; member
63 CHECK((status == -ENOTSUP) || (params->queue_id < info.nb_rx_queues)); in reader_create()
79 p->params.queue_id = params->queue_id; in reader_create()
95 p->params.queue_id, in reader_pkt_rx()
105 (uint32_t)p->params.queue_id, in reader_pkt_rx()
120 (uint32_t)p->params.queue_id, in reader_pkt_rx()
169 uint16_t queue_id; member
211 p->params.queue_id = params->queue_id; in writer_create()
224 p->params.queue_id, in __writer_flush()
230 (uint32_t)p->params.queue_id, in __writer_flush()
[all …]
H A Drte_port_ethdev.c33 uint16_t queue_id; member
60 port->queue_id = conf->queue_id; in rte_port_ethdev_reader_create()
129 uint16_t queue_id; member
159 port->queue_id = conf->queue_id; in rte_port_ethdev_writer_create()
172 nb_tx = rte_eth_tx_burst(p->port_id, p->queue_id, in send_burst()
216 n_pkts_ok = rte_eth_tx_burst(p->port_id, p->queue_id, pkts, in rte_port_ethdev_writer_tx_bulk()
310 uint16_t queue_id; member
340 port->queue_id = conf->queue_id; in rte_port_ethdev_writer_nodrop_create()
360 nb_tx = rte_eth_tx_burst(p->port_id, p->queue_id, p->tx_buf, in send_burst_nodrop()
370 nb_tx += rte_eth_tx_burst(p->port_id, p->queue_id, in send_burst_nodrop()
[all …]
/dpdk/drivers/event/cnxk/
H A Dcnxk_eventdev.c291 RTE_SET_USED(queue_id); in cnxk_sso_queue_def_conf()
331 RTE_SET_USED(queue_id); in cnxk_sso_queue_release()
341 *attr_value = dev->mlt_prio[queue_id].weight; in cnxk_sso_queue_attribute_get()
358 conf = &event_dev->data->queues_cfg[queue_id]; in cnxk_sso_queue_attribute_set()
365 dev->mlt_prio[queue_id].weight = attr_value; in cnxk_sso_queue_attribute_set()
368 dev->mlt_prio[queue_id].affinity = attr_value; in cnxk_sso_queue_attribute_set()
470 uint8_t queue_id, i; in cnxk_sso_cleanup() local
491 queue_id = pend_list[i]; in cnxk_sso_cleanup()
493 roc_sso_hwgrp_base_get(&dev->sso, queue_id); in cnxk_sso_cleanup()
494 if (flush_fn(ws, queue_id, hwgrp_base, in cnxk_sso_cleanup()
[all …]
/dpdk/drivers/net/atlantic/
H A Datl_rxtx.c61 uint16_t queue_id; member
78 uint16_t queue_id; member
144 rxq->queue_id = rx_queue_id; in atl_rx_queue_setup()
161 rxq->port_id, rxq->queue_id); in atl_rx_queue_setup()
178 rxq->port_id, rxq->queue_id); in atl_rx_queue_setup()
265 txq->queue_id = tx_queue_id; in atl_tx_queue_setup()
276 txq->port_id, txq->queue_id); in atl_tx_queue_setup()
292 txq->port_id, txq->queue_id); in atl_tx_queue_setup()
322 txq->queue_id, in atl_tx_init()
329 txq->port_id, txq->queue_id); in atl_tx_init()
[all …]
/dpdk/drivers/net/netvsc/
H A Dhn_rxtx.c83 uint16_t queue_id; member
158 txd->queue_id = txq->queue_id; in hn_txd_init()
274 txq->queue_id = queue_idx; in hn_dev_tx_queue_setup()
885 rxq->queue_id = queue_id; in hn_rx_queue_alloc()
895 if (queue_id) { in hn_rx_queue_alloc()
904 queue_id); in hn_rx_queue_alloc()
1069 rxq = queue_id == 0 ? hv->primary : dev->data->rx_queues[queue_id]; in hn_process_events()
1305 uint16_t queue_id, in hn_encap() argument
1330 *pi_data = queue_id; in hn_encap()
1480 uint16_t queue_id = txq->queue_id; in hn_xmit_pkts() local
[all …]
/dpdk/drivers/net/mlx5/linux/
H A Dmlx5_mp_os.c108 (dev, param->args.queue_id.queue_id); in mlx5_mp_os_primary_handle()
114 (dev, param->args.queue_id.queue_id); in mlx5_mp_os_primary_handle()
120 (dev, param->args.queue_id.queue_id); in mlx5_mp_os_primary_handle()
126 (dev, param->args.queue_id.queue_id); in mlx5_mp_os_primary_handle()
315 mlx5_mp_os_req_queue_control(struct rte_eth_dev *dev, uint16_t queue_id, in mlx5_mp_os_req_queue_control() argument
330 req->args.queue_id.queue_id = queue_id; in mlx5_mp_os_req_queue_control()
/dpdk/lib/ethdev/
H A Drte_ethdev.h5584 port_id, queue_id); in rte_eth_rx_burst()
5591 qd = p->rxq.data[queue_id]; in rte_eth_rx_burst()
5598 queue_id, port_id); in rte_eth_rx_burst()
5650 port_id, queue_id); in rte_eth_rx_queue_count()
5656 qd = p->rxq.data[queue_id]; in rte_eth_rx_queue_count()
5719 port_id, queue_id); in rte_eth_rx_descriptor_status()
5789 port_id, queue_id); in rte_eth_tx_descriptor_status()
5907 port_id, queue_id); in rte_eth_tx_burst()
5921 queue_id, port_id); in rte_eth_tx_burst()
6018 port_id, queue_id); in rte_eth_tx_prepare()
[all …]
H A Drte_ethdev_trace_fp.h22 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t queue_id,
25 rte_trace_point_emit_u16(queue_id);
32 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t queue_id,
35 rte_trace_point_emit_u16(queue_id);
/dpdk/drivers/event/opdl/
H A Dopdl_evdev_init.c36 ev[i].queue_id, in enqueue_check()
65 ev[0].queue_id != p->next_external_qid) { in enqueue_check()
83 ev[i].queue_id = in update_on_dequeue()
98 ev[0].queue_id = in update_on_dequeue()
711 if (port->queue_id == 0) { in initialise_all_other_ports()
737 port->queue_id); in initialise_all_other_ports()
838 &device->queue[port->queue_id]; in initialise_all_other_ports()
884 port->queue_id = 0; in initialise_queue_zero_ports()
900 if (port->queue_id == 0) { in initialise_queue_zero_ports()
928 port->queue_id = in assign_internal_queue_ids()
[all …]
H A Dopdl_evdev.c169 p->queue_id = OPDL_INVALID_QID; in opdl_port_unlink()
199 p->queue_id = OPDL_INVALID_QID; in opdl_port_setup()
236 uint8_t queue_id, in opdl_queue_setup() argument
248 queue_id); in opdl_queue_setup()
296 queue_id); in opdl_queue_setup()
314 RTE_SET_USED(queue_id); in opdl_queue_release()
323 uint8_t queue_id, in opdl_queue_def_conf() argument
327 RTE_SET_USED(queue_id); in opdl_queue_def_conf()
406 char queue_id[64]; in opdl_dump() local
427 snprintf(queue_id, sizeof(queue_id), "%02u", in opdl_dump()
[all …]
/dpdk/lib/power/
H A Drte_power_pmd_mgmt.c381 queue_stopped(const uint16_t port_id, const uint16_t queue_id) in queue_stopped() argument
385 int ret = rte_eth_rx_queue_info_get(port_id, queue_id, &qinfo); in queue_stopped()
477 uint16_t queue_id, enum rte_power_pmd_mgmt_type mode) in rte_power_ethdev_pmgmt_queue_enable() argument
479 const union queue qdata = {.portid = port_id, .qid = queue_id}; in rte_power_ethdev_pmgmt_queue_enable()
499 if (queue_id >= info.nb_rx_queues) { in rte_power_ethdev_pmgmt_queue_enable()
505 ret = queue_stopped(port_id, queue_id); in rte_power_ethdev_pmgmt_queue_enable()
583 queue_cfg->cb = rte_eth_add_rx_callback(port_id, queue_id, in rte_power_ethdev_pmgmt_queue_enable()
593 uint16_t port_id, uint16_t queue_id) in rte_power_ethdev_pmgmt_queue_disable() argument
606 ret = queue_stopped(port_id, queue_id); in rte_power_ethdev_pmgmt_queue_disable()
642 rte_eth_remove_rx_callback(port_id, queue_id, queue_cfg->cb); in rte_power_ethdev_pmgmt_queue_disable()
[all …]
/dpdk/drivers/net/sfc/
H A Dsfc_repr_proxy_api.h30 uint16_t queue_id, struct rte_ring *rx_ring,
33 uint16_t queue_id);
36 uint16_t queue_id, struct rte_ring *tx_ring,
39 uint16_t queue_id);
/dpdk/drivers/net/hns3/
H A Dhns3_ethdev_dump.c232 uint32_t queue_id; in get_rx_queue() local
235 for (queue_id = 0; queue_id < dev->data->nb_rx_queues; queue_id++) { 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()
257 uint32_t queue_id; in get_tx_queue() local
260 for (queue_id = 0; queue_id < dev->data->nb_tx_queues; queue_id++) { in get_tx_queue()
267 txq = (struct hns3_tx_queue *)tx_queues[queue_id]; in get_tx_queue()
271 return tx_queues[queue_id]; in get_tx_queue()
283 uint32_t queue_id = 0; in get_rxtx_fake_queue_info() local
296 rxq = (struct hns3_rx_queue *)rx_queues[queue_id]; in get_rxtx_fake_queue_info()
[all …]

12345678910>>...15