| /f-stack/freebsd/contrib/octeon-sdk/ |
| H A D | cvmx-cmd-queue.h | 212 int cvmx_cmd_queue_length(cvmx_cmd_queue_id_t queue_id);
224 void *cvmx_cmd_queue_buffer(cvmx_cmd_queue_id_t queue_id);
234 static inline int __cvmx_cmd_queue_get_index(cvmx_cmd_queue_id_t queue_id) in __cvmx_cmd_queue_get_index() argument
240 int unit = queue_id>>16; in __cvmx_cmd_queue_get_index()
241 int q = (queue_id >> 4) & 0xf; in __cvmx_cmd_queue_get_index()
242 int core = queue_id & 0xf; in __cvmx_cmd_queue_get_index()
320 if (cvmx_unlikely(queue_id >= CVMX_CMD_QUEUE_END)) in __cvmx_cmd_queue_get_state()
322 if (cvmx_unlikely((queue_id & 0xffff) >= 256)) in __cvmx_cmd_queue_get_state()
360 __cvmx_cmd_queue_lock(queue_id, qptr); in cvmx_cmd_queue_write()
447 __cvmx_cmd_queue_lock(queue_id, qptr); in cvmx_cmd_queue_write2()
[all …]
|
| H A D | cvmx-cmd-queue.c | 150 qstate = __cvmx_cmd_queue_get_state(queue_id); in cvmx_cmd_queue_initialize()
229 cvmx_cmd_queue_result_t cvmx_cmd_queue_shutdown(cvmx_cmd_queue_id_t queue_id) in cvmx_cmd_queue_shutdown() argument
231 __cvmx_cmd_queue_state_t *qptr = __cvmx_cmd_queue_get_state(queue_id); in cvmx_cmd_queue_shutdown()
238 if (cvmx_cmd_queue_length(queue_id) > 0) in cvmx_cmd_queue_shutdown()
244 __cvmx_cmd_queue_lock(queue_id, qptr); in cvmx_cmd_queue_shutdown()
264 int cvmx_cmd_queue_length(cvmx_cmd_queue_id_t queue_id) in cvmx_cmd_queue_length() argument
268 if (__cvmx_cmd_queue_get_state(queue_id) == NULL) in cvmx_cmd_queue_length()
274 switch ((cvmx_cmd_queue_id_t)(queue_id & 0xff0000)) in cvmx_cmd_queue_length()
280 cvmx_write_csr(CVMX_PKO_REG_READ_IDX, queue_id & 0xffff); in cvmx_cmd_queue_length()
331 void *cvmx_cmd_queue_buffer(cvmx_cmd_queue_id_t queue_id) in cvmx_cmd_queue_buffer() argument
[all …]
|
| /f-stack/dpdk/app/test-bbdev/ |
| H A D | test_bbdev.c | 260 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 D | test_bbdev_perf.c | 756 for (queue_id = 0; queue_id < nb_queues; ++queue_id) { in add_bbdev_dev()
771 ad->queue_ids[queue_id] = queue_id; in add_bbdev_dev()
2584 if (tp->queue_id == queue_id) in dequeue_event_callback()
2708 const uint16_t queue_id = tp->queue_id; in throughput_intr_lcore_ldpc_dec() local
2811 const uint16_t queue_id = tp->queue_id; in throughput_intr_lcore_dec() local
2901 const uint16_t queue_id = tp->queue_id; in throughput_intr_lcore_enc() local
2991 const uint16_t queue_id = tp->queue_id; in throughput_intr_lcore_ldpc_enc() local
3083 const uint16_t queue_id = tp->queue_id; in throughput_pmd_lcore_dec() local
3180 const uint16_t queue_id = tp->queue_id; in bler_pmd_lcore_ldpc_dec() local
3311 const uint16_t queue_id = tp->queue_id; in throughput_pmd_lcore_ldpc_dec() local
[all …]
|
| /f-stack/dpdk/examples/qos_sched/ |
| H A D | stats.c | 17 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 …]
|
| /f-stack/dpdk/lib/librte_bbdev/ |
| H A D | rte_bbdev.h | 165 rte_bbdev_queue_configure(uint16_t dev_id, uint16_t queue_id,
227 rte_bbdev_queue_start(uint16_t dev_id, uint16_t queue_id);
243 rte_bbdev_queue_stop(uint16_t dev_id, uint16_t queue_id);
379 rte_bbdev_queue_info_get(uint16_t dev_id, uint16_t queue_id,
495 rte_bbdev_enqueue_enc_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_enqueue_enc_ops() argument
526 rte_bbdev_enqueue_dec_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_enqueue_dec_ops() argument
557 rte_bbdev_enqueue_ldpc_enc_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_enqueue_ldpc_enc_ops() argument
621 rte_bbdev_dequeue_enc_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_dequeue_enc_ops() argument
654 rte_bbdev_dequeue_dec_ops(uint16_t dev_id, uint16_t queue_id, in rte_bbdev_dequeue_dec_ops() argument
814 rte_bbdev_queue_intr_enable(uint16_t dev_id, uint16_t queue_id);
[all …]
|
| H A D | rte_bbdev.c | 72 queue_id, dev->data->dev_id); \
455 queue_id, dev_id); in rte_bbdev_queue_configure()
503 conf->priority, queue_id, dev_id, in rte_bbdev_queue_configure()
522 dev_id, queue_id); in rte_bbdev_queue_configure()
533 queue_id); in rte_bbdev_queue_configure()
664 queue_id, dev_id); in rte_bbdev_queue_start()
672 dev_id, queue_id); in rte_bbdev_queue_start()
694 queue_id, dev_id); in rte_bbdev_queue_stop()
702 dev_id, queue_id); in rte_bbdev_queue_stop()
830 queue_id, dev_id); in rte_bbdev_queue_info_get()
[all …]
|
| H A D | rte_bbdev_pmd.h | 93 uint16_t queue_id, const struct rte_bbdev_queue_conf *conf);
100 uint16_t queue_id);
113 uint16_t queue_id);
116 typedef int (*rte_bbdev_queue_stop_t)(struct rte_bbdev *dev, uint16_t queue_id);
134 uint16_t queue_id);
141 uint16_t queue_id);
|
| /f-stack/dpdk/drivers/event/dsw/ |
| H A D | dsw_xstats.c | 62 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 D | dsw_event.c | 221 if (qfs[i].queue_id == queue_id && in dsw_is_queue_flow_in_ary()
234 queue_id, flow_hash); in dsw_port_is_flow_paused()
248 qf->queue_id, qf->flow_hash); in dsw_port_add_paused_flows()
264 if (qf->queue_id == target_qf->queue_id && in dsw_port_remove_paused_flow()
705 if (event->queue_id == qf->queue_id && in dsw_port_flush_paused_events()
737 uint8_t queue_id = qf->queue_id; in dsw_port_end_emigration() local
786 uint8_t queue_id = qf->queue_id; in dsw_port_move_parallel_flows() local
884 bursts[0].queue_flow.queue_id, in dsw_port_consider_emigration()
961 uint8_t queue_id, in dsw_port_forward_emigrated_flow() argument
990 if (e->queue_id == queue_id && in dsw_port_forward_emigrated_flow()
[all …]
|
| /f-stack/dpdk/drivers/event/dlb/ |
| H A D | dlb_selftest.c | 198 queue_id = 1; in test_stop_flush()
357 queue_id = 1; in test_single_link()
363 queue_id = 0; in test_single_link()
370 queue_id = 0; in test_single_link()
376 queue_id = 1; in test_single_link()
668 queue_id = 1; in test_reconfiguration_link()
677 queue_id = 0; in test_reconfiguration_link()
743 queue_id = i; in test_reconfiguration_link()
851 queue_id = 0; in test_load_balanced_traffic()
979 queue_id = 0; in test_directed_traffic()
[all …]
|
| /f-stack/dpdk/drivers/event/dlb2/ |
| H A D | dlb2_selftest.c | 208 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 …]
|
| /f-stack/dpdk/lib/librte_vhost/ |
| H A D | rte_vhost_async.h | 64 uint32_t (*transfer_data)(int vid, uint16_t queue_id,
81 uint32_t (*check_completed_copies)(int vid, uint16_t queue_id,
133 int rte_vhost_async_channel_register(int vid, uint16_t queue_id,
147 int rte_vhost_async_channel_unregister(int vid, uint16_t queue_id);
166 uint16_t rte_vhost_submit_enqueue_burst(int vid, uint16_t queue_id,
186 uint16_t rte_vhost_poll_enqueue_completed(int vid, uint16_t queue_id,
|
| /f-stack/dpdk/lib/librte_ethdev/ |
| H A D | rte_ethdev.h | 4844 if (queue_id >= dev->data->nb_rx_queues) { in rte_eth_rx_burst()
4898 if (queue_id >= dev->data->nb_rx_queues || in rte_eth_rx_queue_count()
4899 dev->data->rx_queues[queue_id] == NULL) in rte_eth_rx_queue_count()
4979 if (queue_id >= dev->data->nb_rx_queues) in rte_eth_rx_descriptor_status()
4983 rxq = dev->data->rx_queues[queue_id]; in rte_eth_rx_descriptor_status()
5026 uint16_t queue_id, uint16_t offset) in rte_eth_tx_descriptor_status() argument
5036 if (queue_id >= dev->data->nb_tx_queues) in rte_eth_tx_descriptor_status()
5040 txq = dev->data->tx_queues[queue_id]; in rte_eth_tx_descriptor_status()
5121 if (queue_id >= dev->data->nb_tx_queues) { in rte_eth_tx_burst()
5226 if (queue_id >= dev->data->nb_tx_queues) { in rte_eth_tx_prepare()
[all …]
|
| H A D | rte_ethdev_trace_fp.h | 22 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);
|
| /f-stack/dpdk/lib/librte_port/ |
| H A D | rte_swx_port_ethdev.c | 37 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 D | rte_port_ethdev.c | 33 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 …]
|
| H A D | rte_port_ethdev.h | 31 uint16_t queue_id; member
43 uint16_t queue_id; member
59 uint16_t queue_id; member
|
| /f-stack/dpdk/drivers/net/atlantic/ |
| H A D | atl_rxtx.c | 61 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 …]
|
| /f-stack/dpdk/drivers/net/mlx5/linux/ |
| H A D | mlx5_mp_os.c | 69 (dev, param->args.queue_id.queue_id); in mlx5_mp_os_primary_handle()
75 (dev, param->args.queue_id.queue_id); in mlx5_mp_os_primary_handle()
81 (dev, param->args.queue_id.queue_id); in mlx5_mp_os_primary_handle()
87 (dev, param->args.queue_id.queue_id); in mlx5_mp_os_primary_handle()
256 mlx5_mp_os_req_queue_control(struct rte_eth_dev *dev, uint16_t queue_id, in mlx5_mp_os_req_queue_control() argument
271 req->args.queue_id.queue_id = queue_id; in mlx5_mp_os_req_queue_control()
|
| /f-stack/dpdk/drivers/net/netvsc/ |
| H A D | hn_rxtx.c | 83 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()
887 rxq->queue_id = queue_id; in hn_rx_queue_alloc()
897 if (queue_id) { in hn_rx_queue_alloc()
906 queue_id); in hn_rx_queue_alloc()
1071 rxq = queue_id == 0 ? hv->primary : dev->data->rx_queues[queue_id]; in hn_process_events()
1307 uint16_t queue_id, in hn_encap() argument
1332 *pi_data = queue_id; in hn_encap()
1475 uint16_t queue_id = txq->queue_id; in hn_xmit_pkts() local
[all …]
|
| H A D | hn_var.h | 59 uint16_t queue_id; member
89 uint16_t queue_id; member
164 uint32_t hn_process_events(struct hn_data *hv, uint16_t queue_id,
185 uint16_t queue_id,
192 void hn_dev_rx_queue_info(struct rte_eth_dev *dev, uint16_t queue_id,
195 uint32_t hn_dev_rx_queue_count(struct rte_eth_dev *dev, uint16_t queue_id);
244 void hn_vf_tx_queue_release(struct hn_data *hv, uint16_t queue_id);
245 int hn_vf_tx_queue_status(struct hn_data *hv, uint16_t queue_id, uint16_t offset);
252 void hn_vf_rx_queue_release(struct hn_data *hv, uint16_t queue_id);
|
| /f-stack/dpdk/app/test-eventdev/ |
| H A D | test_pipeline_queue.c | 35 ev.queue_id++; in pipeline_queue_worker_single_stage_tx()
58 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_queue_worker_single_stage_fwd()
89 ev[i].queue_id++; in pipeline_queue_worker_single_stage_burst_tx()
145 cq_id = ev.queue_id % nb_stages; in pipeline_queue_worker_multi_stage_tx()
153 ev.queue_id++; in pipeline_queue_worker_multi_stage_tx()
177 cq_id = ev.queue_id % nb_stages; in pipeline_queue_worker_multi_stage_fwd()
185 ev.queue_id++; in pipeline_queue_worker_multi_stage_fwd()
212 cq_id = ev[i].queue_id % nb_stages; in pipeline_queue_worker_multi_stage_burst_tx()
221 ev[i].queue_id++; in pipeline_queue_worker_multi_stage_burst_tx()
250 cq_id = ev[i].queue_id % nb_stages; in pipeline_queue_worker_multi_stage_burst_fwd()
[all …]
|
| /f-stack/dpdk/examples/vhost/ |
| H A D | ioat.h | 31 ioat_transfer_data_cb(int vid, uint16_t queue_id,
36 ioat_check_completed_copies_cb(int vid, uint16_t queue_id,
46 ioat_transfer_data_cb(int vid __rte_unused, uint16_t queue_id __rte_unused, in ioat_transfer_data_cb()
56 uint16_t queue_id __rte_unused, in ioat_check_completed_copies_cb()
|
| /f-stack/dpdk/drivers/event/opdl/ |
| H A D | opdl_evdev_init.c | 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()
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 …]
|