Home
last modified time | relevance | path

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

12345678

/dpdk/app/test/
H A Dtest_ethdev_api.c42 for (uint16_t queue_id = 0; queue_id < NUM_RXQ; queue_id++) { in ethdev_api_queue_status() local
43 ret = rte_eth_rx_queue_setup(port_id, queue_id, NUM_RXD, in ethdev_api_queue_status()
47 port_id, queue_id); in ethdev_api_queue_status()
51 for (uint16_t queue_id = 0; queue_id < NUM_TXQ; queue_id++) { in ethdev_api_queue_status() local
52 ret = rte_eth_tx_queue_setup(port_id, queue_id, NUM_TXD, in ethdev_api_queue_status()
56 port_id, queue_id); in ethdev_api_queue_status()
64 for (uint16_t queue_id = 0; queue_id < dev_info.nb_rx_queues; queue_id++) { in ethdev_api_queue_status() local
65 ret = rte_eth_rx_queue_info_get(port_id, queue_id, &rx_qinfo); in ethdev_api_queue_status()
71 port_id, queue_id); in ethdev_api_queue_status()
75 queue_id, rx_qinfo.queue_state); in ethdev_api_queue_status()
[all …]
H A Dtest_dispatcher.c36 uint8_t queue_id; member
81 app->queues[i].queue_id = i; in test_app_create()
152 uint8_t queue_id = i; in test_app_setup_event_dev() local
154 rc = rte_event_queue_setup(app->event_dev_id, queue_id, in test_app_setup_event_dev()
157 TEST_ASSERT_SUCCESS(rc, "Unable to setup queue %d", queue_id); in test_app_setup_event_dev()
305 uintptr_t queue_id = (uintptr_t)cb_data; in match_queue() local
307 return event->queue_id == queue_id; in match_queue()
348 queues[app_queue->queue_id]); in test_app_process_queue()
350 bool intermediate_queue = app_queue->queue_id != LAST_QUEUE_ID; in test_app_process_queue()
369 if (in_event->queue_id != app_queue->queue_id) { in test_app_process_queue()
[all …]
/dpdk/lib/bbdev/
H A Drte_bbdev.h148 * @param queue_id
159 rte_bbdev_queue_configure(uint16_t dev_id, uint16_t queue_id,
209 * @param queue_id
217 rte_bbdev_queue_start(uint16_t dev_id, uint16_t queue_id);
224 * @param queue_id
232 rte_bbdev_queue_stop(uint16_t dev_id, uint16_t queue_id);
410 * @param queue_id
421 rte_bbdev_queue_info_get(uint16_t dev_id, uint16_t queue_id,
554 * @param queue_id
567 rte_bbdev_enqueue_enc_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_enqueue_enc_ops()
565 rte_bbdev_enqueue_enc_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_enc_op ** ops,uint16_t num_ops) rte_bbdev_enqueue_enc_ops() argument
595 rte_bbdev_enqueue_dec_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_dec_op ** ops,uint16_t num_ops) rte_bbdev_enqueue_dec_ops() argument
625 rte_bbdev_enqueue_ldpc_enc_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_enc_op ** ops,uint16_t num_ops) rte_bbdev_enqueue_ldpc_enc_ops() argument
655 rte_bbdev_enqueue_ldpc_dec_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_dec_op ** ops,uint16_t num_ops) rte_bbdev_enqueue_ldpc_dec_ops() argument
685 rte_bbdev_enqueue_fft_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_fft_op ** ops,uint16_t num_ops) rte_bbdev_enqueue_fft_ops() argument
715 rte_bbdev_enqueue_mldts_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_mldts_op ** ops,uint16_t num_ops) rte_bbdev_enqueue_mldts_ops() argument
746 rte_bbdev_dequeue_enc_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_enc_op ** ops,uint16_t num_ops) rte_bbdev_dequeue_enc_ops() argument
778 rte_bbdev_dequeue_dec_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_dec_op ** ops,uint16_t num_ops) rte_bbdev_dequeue_dec_ops() argument
809 rte_bbdev_dequeue_ldpc_enc_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_enc_op ** ops,uint16_t num_ops) rte_bbdev_dequeue_ldpc_enc_ops() argument
839 rte_bbdev_dequeue_ldpc_dec_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_dec_op ** ops,uint16_t num_ops) rte_bbdev_dequeue_ldpc_dec_ops() argument
869 rte_bbdev_dequeue_fft_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_fft_op ** ops,uint16_t num_ops) rte_bbdev_dequeue_fft_ops() argument
900 rte_bbdev_dequeue_mldts_ops(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_mldts_op ** ops,uint16_t num_ops) rte_bbdev_dequeue_mldts_ops() argument
[all...]
H A Drte_bbdev.c68 #define VALID_QUEUE_OR_RET_ERR(queue_id, dev) do { \ argument
69 if (queue_id >= dev->data->num_queues) { \
70 rte_bbdev_log(ERR, "Invalid queue_id %u for device %u", \
71 queue_id, dev->data->dev_id); \
436 rte_bbdev_queue_configure(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_queue_configure() argument
450 VALID_QUEUE_OR_RET_ERR(queue_id, dev); in rte_bbdev_queue_configure()
452 if (dev->data->queues[queue_id].started || dev->data->started) { in rte_bbdev_queue_configure()
455 queue_id, dev_id); in rte_bbdev_queue_configure()
489 conf->queue_size, queue_id, dev_id, in rte_bbdev_queue_configure()
496 conf->queue_size, queue_id, dev_i in rte_bbdev_queue_configure()
650 rte_bbdev_queue_start(uint16_t dev_id,uint16_t queue_id) rte_bbdev_queue_start() argument
680 rte_bbdev_queue_stop(uint16_t dev_id,uint16_t queue_id) rte_bbdev_queue_stop() argument
810 rte_bbdev_queue_info_get(uint16_t dev_id,uint16_t queue_id,struct rte_bbdev_queue_info * queue_info) rte_bbdev_queue_info_get() argument
1075 rte_bbdev_queue_intr_enable(uint16_t dev_id,uint16_t queue_id) rte_bbdev_queue_intr_enable() argument
1086 rte_bbdev_queue_intr_disable(uint16_t dev_id,uint16_t queue_id) rte_bbdev_queue_intr_disable() argument
1097 rte_bbdev_queue_intr_ctl(uint16_t dev_id,uint16_t queue_id,int epfd,int op,void * data) rte_bbdev_queue_intr_ctl() argument
[all...]
H A Drte_bbdev_pmd.h86 uint16_t queue_id, const struct rte_bbdev_queue_conf *conf);
93 uint16_t queue_id);
106 uint16_t queue_id);
109 typedef int (*rte_bbdev_queue_stop_t)(struct rte_bbdev *dev, uint16_t queue_id);
127 uint16_t queue_id);
134 uint16_t queue_id);
141 uint16_t queue_id, FILE *file);
/dpdk/lib/vhost/
H A Drte_vhost_async.h22 * @param queue_id
28 int rte_vhost_async_channel_register(int vid, uint16_t queue_id);
35 * @param queue_id
41 int rte_vhost_async_channel_unregister(int vid, uint16_t queue_id);
52 * @param queue_id
58 int rte_vhost_async_channel_register_thread_unsafe(int vid, uint16_t queue_id);
69 * @param queue_id
76 uint16_t queue_id);
85 * @param queue_id
99 uint16_t rte_vhost_submit_enqueue_burst(int vid, uint16_t queue_id,
[all...]
H A Drte_vhost.h281 int (*vring_state_changed)(int vid, uint16_t queue_id, int enable); /**< triggered when a vring is enabled or disabled */
308 bool (*guest_notify)(int vid, uint16_t queue_id);
441 int rte_vhost_enable_guest_notification(int vid, uint16_t queue_id, int enable);
452 * @param queue_id
456 void rte_vhost_notify_guest(int vid, uint16_t queue_id);
729 * @param queue_id
735 uint16_t rte_vhost_avail_entries(int vid, uint16_t queue_id);
746 * @param queue_id
755 uint16_t rte_vhost_enqueue_burst(int vid, uint16_t queue_id,
764 * @param queue_id
[all...]
/dpdk/lib/ethdev/
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);
31 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t queue_id,
34 rte_trace_point_emit_u16(queue_id);
41 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t queue_id,
44 rte_trace_point_emit_u16(queue_id);
51 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t queue_id,
54 rte_trace_point_emit_u16(queue_id);
61 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t queue_id,
64 rte_trace_point_emit_u16(queue_id);
[all...]
H A Drte_ethdev.h2766 * @param queue_id
2770 * - -EINVAL: if queue_id is out of range or queue has not been setup.
2774 int rte_eth_rx_queue_is_valid(uint16_t port_id, uint16_t queue_id);
2785 * @param queue_id
2789 * - -EINVAL: if queue_id is out of range or queue has not been setup.
2793 int rte_eth_tx_queue_is_valid(uint16_t port_id, uint16_t queue_id);
2808 * - -EINVAL: The queue_id out of range or belong to hairpin.
2826 * - -EINVAL: The queue_id out of range or belong to hairpin.
2845 * - -EINVAL: The queue_id out of range or belong to hairpin.
2863 * - -EINVAL: The queue_id ou
6084 rte_eth_rx_burst(uint16_t port_id,uint16_t queue_id,struct rte_mbuf ** rx_pkts,const uint16_t nb_pkts) rte_eth_rx_burst() argument
6157 rte_eth_rx_queue_count(uint16_t port_id,uint16_t queue_id) rte_eth_rx_queue_count() argument
6229 rte_eth_rx_descriptor_status(uint16_t port_id,uint16_t queue_id,uint16_t offset) rte_eth_rx_descriptor_status() argument
6301 rte_eth_tx_descriptor_status(uint16_t port_id,uint16_t queue_id,uint16_t offset) rte_eth_tx_descriptor_status() argument
6424 rte_eth_tx_burst(uint16_t port_id,uint16_t queue_id,struct rte_mbuf ** tx_pkts,uint16_t nb_pkts) rte_eth_tx_burst() argument
6534 rte_eth_tx_prepare(uint16_t port_id,uint16_t queue_id,struct rte_mbuf ** tx_pkts,uint16_t nb_pkts) rte_eth_tx_prepare() argument
6588 rte_eth_tx_prepare(__rte_unused uint16_t port_id,__rte_unused uint16_t queue_id,__rte_unused struct rte_mbuf ** tx_pkts,uint16_t nb_pkts) rte_eth_tx_prepare() argument
6619 rte_eth_tx_buffer_flush(uint16_t port_id,uint16_t queue_id,struct rte_eth_dev_tx_buffer * buffer) rte_eth_tx_buffer_flush() argument
6672 rte_eth_tx_buffer(uint16_t port_id,uint16_t queue_id,struct rte_eth_dev_tx_buffer * buffer,struct rte_mbuf * tx_pkt) rte_eth_tx_buffer() argument
6880 rte_eth_tx_queue_count(uint16_t port_id,uint16_t queue_id) rte_eth_tx_queue_count() argument
[all...]
H A Drte_flow_driver.h90 uint32_t queue_id,
337 uint32_t queue_id,
347 uint32_t queue_id,
355 uint32_t queue_id,
360 uint32_t queue_id,
368 uint32_t queue_id,
377 uint32_t queue_id,
385 uint32_t queue_id,
395 uint32_t queue_id,
404 uint32_t queue_id,
[all...]
/dpdk/examples/qos_sched/
H A Dstats.c17 uint32_t count, i, queue_id = 0; in qavg_q() local
35 queue_id += subport_params[i].n_pipes_per_subport_enabled * in qavg_q()
38 queue_id += pipe_id * RTE_SCHED_QUEUES_PER_PIPE + tc; in qavg_q()
40 queue_id += pipe_id * RTE_SCHED_QUEUES_PER_PIPE + tc + q; in qavg_q()
44 rte_sched_queue_read_stats(port, queue_id, &stats, &qlen); in qavg_q()
63 uint32_t count, i, queue_id = 0; in qavg_tcpipe() local
79 queue_id += in qavg_tcpipe()
83 queue_id += pipe_id * RTE_SCHED_QUEUES_PER_PIPE + tc; in qavg_tcpipe()
91 rte_sched_queue_read_stats(port, queue_id, in qavg_tcpipe()
96 rte_sched_queue_read_stats(port, queue_id + i, in qavg_tcpipe()
[all …]
/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()
281 TEST_ASSERT_FAIL(rte_bbdev_queue_configure(dev_id, queue_id, in test_bbdev_configure_stop_queue()
285 queue_id, dev_id); in test_bbdev_configure_stop_queue()
290 TEST_ASSERT_FAIL(rte_bbdev_queue_configure(dev_id, queue_id, in test_bbdev_configure_stop_queue()
294 queue_id, dev_id); in test_bbdev_configure_stop_queue()
296 TEST_ASSERT_FAIL(rte_bbdev_queue_stop(RTE_BBDEV_MAX_DEVS, queue_id), in test_bbdev_configure_stop_queue()
305 rte_bbdev_queue_stop(dev_id, queue_id); in test_bbdev_configure_stop_queue()
307 TEST_ASSERT_SUCCESS(rte_bbdev_queue_configure(dev_id, queue_id, in test_bbdev_configure_stop_queue()
310 "queue:%u on device:%u should be stopped", queue_id, in test_bbdev_configure_stop_queue()
[all …]
/dpdk/drivers/event/dsw/
H A Ddsw_xstats.c40 uint8_t port_id, uint8_t queue_id);
62 uint8_t queue_id __rte_unused) \
73 uint8_t queue_id) in DSW_GEN_PORT_ACCESS_FN()
75 return dsw->ports[port_id].queue_enqueued[queue_id]; in DSW_GEN_PORT_ACCESS_FN()
82 uint8_t queue_id) in DSW_GEN_PORT_ACCESS_FN()
84 return dsw->ports[port_id].queue_dequeued[queue_id]; in DSW_GEN_PORT_ACCESS_FN()
92 uint8_t queue_id __rte_unused) in DSW_GEN_PORT_ACCESS_FN()
102 uint8_t queue_id __rte_unused) in dsw_xstats_port_get_event_proc_latency()
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()
[all …]
/dpdk/drivers/event/dlb2/
H A Ddlb2_selftest.c184 uint8_t queue_id; in test_stop_flush() local
208 queue_id = 1; in test_stop_flush()
210 if (rte_event_port_unlink(evdev, 0, &queue_id, 1) != 1) { in test_stop_flush()
233 ev.queue_id = 0; in test_stop_flush()
245 ev.queue_id = 1; in test_stop_flush()
288 uint8_t queue_id; in test_single_link() local
367 queue_id = 1; in test_single_link()
368 if (rte_event_port_link(evdev, 0, &queue_id, NULL, 1) == 1) { in test_single_link()
373 queue_id = 0; in test_single_link()
374 if (rte_event_port_link(evdev, 1, &queue_id, NULL, 1) == 1) { in test_single_link()
[all …]
H A Ddlb2_sse.c37 uint8_t *queue_id) in dlb2_event_build_hcws() argument
87 queue_id[0]; in dlb2_event_build_hcws()
90 queue_id[1]; in dlb2_event_build_hcws()
93 queue_id[2]; in dlb2_event_build_hcws()
96 queue_id[3]; in dlb2_event_build_hcws()
209 qe[i].qid = queue_id[i]; in dlb2_event_build_hcws()
216 info->qid = queue_id[i]; in dlb2_event_build_hcws()
/dpdk/examples/vhost/
H A Dmain.h65 uint16_t queue_id, struct rte_mbuf **pkts,
69 uint16_t queue_id, struct rte_mempool *mbuf_pool,
111 uint16_t vs_enqueue_pkts(struct vhost_dev *dev, uint16_t queue_id,
114 uint16_t builtin_enqueue_pkts(struct vhost_dev *dev, uint16_t queue_id,
116 uint16_t builtin_dequeue_pkts(struct vhost_dev *dev, uint16_t queue_id,
119 uint16_t sync_enqueue_pkts(struct vhost_dev *dev, uint16_t queue_id,
121 uint16_t sync_dequeue_pkts(struct vhost_dev *dev, uint16_t queue_id,
124 uint16_t async_enqueue_pkts(struct vhost_dev *dev, uint16_t queue_id,
126 uint16_t async_dequeue_pkts(struct vhost_dev *dev, uint16_t queue_id,
/dpdk/app/test-eventdev/
H A Dtest_pipeline_queue.c39 ev.queue_id++; in pipeline_queue_worker_single_stage_tx()
64 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_queue_worker_single_stage_fwd()
96 ev[i].queue_id++; in pipeline_queue_worker_single_stage_burst_tx()
125 ev[i].queue_id = tx_queue[ev[i].mbuf->port]; in pipeline_queue_worker_single_stage_burst_fwd()
159 ev.queue_id++; in pipeline_queue_worker_single_stage_tx_vector()
185 ev.queue_id = tx_queue[ev.vec->port]; in pipeline_queue_worker_single_stage_fwd_vector()
219 ev[i].queue_id++; in pipeline_queue_worker_single_stage_burst_tx_vector()
250 ev[i].queue_id = tx_queue[ev[i].vec->port]; in pipeline_queue_worker_single_stage_burst_fwd_vector()
280 cq_id = ev.queue_id % nb_stages; in pipeline_queue_worker_multi_stage_tx()
282 if (ev.queue_id == tx_queue[ev.mbuf->port]) { in pipeline_queue_worker_multi_stage_tx()
[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
197 CHECK((status == -ENOTSUP) || (params->queue_id < info.nb_tx_queues)); in writer_create()
213 p->params.queue_id = params->queue_id; in writer_create()
232 p->params.queue_id, in __writer_flush()
[all …]
H A Drte_port_ethdev.c35 uint16_t queue_id; member
62 port->queue_id = conf->queue_id; in rte_port_ethdev_reader_create()
74 rx_pkt_cnt = rte_eth_rx_burst(p->port_id, p->queue_id, pkts, n_pkts); in rte_port_ethdev_reader_rx()
131 uint16_t queue_id; member
161 port->queue_id = conf->queue_id; in rte_port_ethdev_writer_create()
174 nb_tx = rte_eth_tx_burst(p->port_id, p->queue_id, in send_burst()
218 n_pkts_ok = rte_eth_tx_burst(p->port_id, p->queue_id, pkts, in rte_port_ethdev_writer_tx_bulk()
312 uint16_t queue_id; member
342 port->queue_id = conf->queue_id; in rte_port_ethdev_writer_nodrop_create()
362 nb_tx = rte_eth_tx_burst(p->port_id, p->queue_id, p->tx_buf, in send_burst_nodrop()
[all …]
H A Drte_port_ethdev.h30 uint16_t queue_id; member
42 uint16_t queue_id; member
58 uint16_t queue_id; member
H A Drte_port_sym_crypto.h36 uint16_t queue_id; member
55 uint16_t queue_id; member
73 uint16_t queue_id; member
/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()
319 mlx5_mp_os_req_queue_control(struct rte_eth_dev *dev, uint16_t queue_id, in mlx5_mp_os_req_queue_control() argument
334 req->args.queue_id.queue_id = queue_id; in mlx5_mp_os_req_queue_control()
/dpdk/drivers/net/mana/
H A Dgdma.c212 uint32_t queue_id, uint32_t tail_incr, uint8_t arm) in mana_ring_short_doorbell() argument
217 if ((queue_id & ~GDMA_SHORT_DB_QID_MASK) || in mana_ring_short_doorbell()
221 __func__, queue_id, tail_incr, queue_type); in mana_ring_short_doorbell()
227 e.sq.id = queue_id; in mana_ring_short_doorbell()
233 e.rq.id = queue_id; in mana_ring_short_doorbell()
239 e.cq.id = queue_id; in mana_ring_short_doorbell()
254 db_page, addr, queue_id, queue_type, tail_incr, arm); in mana_ring_short_doorbell()
302 uint32_t queue_id, uint32_t tail, uint8_t arm) in mana_ring_doorbell() argument
309 e.sq.id = queue_id; in mana_ring_doorbell()
315 e.rq.id = queue_id; in mana_ring_doorbell()
[all …]
/dpdk/drivers/net/sfc/
H A Dsfc_repr_proxy_api.h32 uint16_t queue_id, struct rte_ring *rx_ring,
35 uint16_t queue_id);
38 uint16_t queue_id, struct rte_ring *tx_ring,
41 uint16_t queue_id);
/dpdk/drivers/event/opdl/
H A Dopdl_evdev_init.c29 if (ev[i].queue_id != p->next_external_qid) { in enqueue_check()
36 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()
84 p->opdl->queue[p->queue_id].external_qid; in update_on_dequeue()
98 ev[0].queue_id = in update_on_dequeue()
99 p->opdl->queue[p->queue_id].external_qid; in update_on_dequeue()
709 struct opdl_queue *queue = &device->queue[port->queue_id]; in initialise_all_other_ports()
711 if (port->queue_id == 0) { in initialise_all_other_ports()
737 port->queue_id); in initialise_all_other_ports()
[all …]

12345678