Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 255) sorted by relevance

1234567891011

/dpdk/drivers/net/ark/
H A Dark_ethdev_rx.c23 static void ark_ethdev_rx_dump(const char *name, struct ark_rx_queue *queue);
24 static uint32_t eth_ark_rx_jumbo(struct ark_rx_queue *queue,
28 static inline int eth_ark_rx_seed_mbufs(struct ark_rx_queue *queue);
71 struct ark_rx_queue *queue, in eth_ark_rx_hw_setup() argument
78 queue_base = rte_malloc_virt2iova(queue); in eth_ark_rx_hw_setup()
82 phys_addr_q_base = rte_malloc_virt2iova(queue->paddress_q); in eth_ark_rx_hw_setup()
85 if (ark_mpu_verify(queue->mpu, sizeof(rte_iova_t))) { in eth_ark_rx_hw_setup()
91 ark_mpu_configure(queue->mpu, phys_addr_q_base, queue->queue_size, 0); in eth_ark_rx_hw_setup()
93 ark_udm_write_addr(queue->udm, phys_addr_prod_index); in eth_ark_rx_hw_setup()
96 ark_mpu_set_producer(queue->mpu, queue->seed_index); in eth_ark_rx_hw_setup()
[all …]
/dpdk/drivers/event/opdl/
H A Dopdl_evdev_init.c84 p->opdl->queue[p->queue_id].external_qid; in update_on_dequeue()
99 p->opdl->queue[p->queue_id].external_qid; in update_on_dequeue()
299 struct opdl_queue *queue = &device->queue[q_id]; in opdl_add_deps() local
300 struct opdl_queue *queue_deps = &device->queue[deps_q_id]; in opdl_add_deps()
304 for (i = 0; i < queue->nb_ports; i++) { in opdl_add_deps()
306 opdl_stage_get_opdl_ring(stage_for_port(queue, i)); in opdl_add_deps()
332 for (i = 0; i < queue->nb_ports; i++) { in opdl_add_deps()
334 ring = opdl_stage_get_opdl_ring(stage_for_port(queue, i)); in opdl_add_deps()
337 stage_for_port(queue, i), in opdl_add_deps()
338 queue->ports[i]->num_instance, in opdl_add_deps()
[all …]
/dpdk/drivers/net/mlx5/hws/
H A Dmlx5dr_send.h158 struct mlx5dr_send_engine *queue; member
219 mlx5dr_send_add_new_dep_wqe(struct mlx5dr_send_engine *queue);
221 void mlx5dr_send_abort_new_dep_wqe(struct mlx5dr_send_engine *queue);
223 void mlx5dr_send_all_dep_wqe(struct mlx5dr_send_engine *queue);
225 void mlx5dr_send_queue_close(struct mlx5dr_send_engine *queue);
228 struct mlx5dr_send_engine *queue,
238 mlx5dr_send_engine_post_start(struct mlx5dr_send_engine *queue);
246 void mlx5dr_send_ste(struct mlx5dr_send_engine *queue,
249 void mlx5dr_send_stes_fw(struct mlx5dr_send_engine *queue,
252 void mlx5dr_send_engine_flush_queue(struct mlx5dr_send_engine *queue);
[all …]
/dpdk/lib/bpf/
H A Dbpf_pkt.c35 uint16_t queue; member
126 bpf_eth_cbh_find(struct bpf_eth_cbh *cbh, uint16_t port, uint16_t queue) in bpf_eth_cbh_find() argument
131 if (cbi->port == port && cbi->queue == queue) in bpf_eth_cbh_find()
138 bpf_eth_cbh_add(struct bpf_eth_cbh *cbh, uint16_t port, uint16_t queue) in bpf_eth_cbh_add() argument
143 cbi = bpf_eth_cbh_find(cbh, port, queue); in bpf_eth_cbh_add()
150 cbi->queue = queue; in bpf_eth_cbh_add()
260 bpf_rx_callback_vm(__rte_unused uint16_t port, __rte_unused uint16_t queue, in bpf_rx_callback_vm() argument
278 bpf_rx_callback_jit(__rte_unused uint16_t port, __rte_unused uint16_t queue, in bpf_rx_callback_jit() argument
295 bpf_tx_callback_vm(__rte_unused uint16_t port, __rte_unused uint16_t queue, in bpf_tx_callback_vm() argument
311 bpf_tx_callback_jit(__rte_unused uint16_t port, __rte_unused uint16_t queue, in bpf_tx_callback_jit() argument
[all …]
H A Drte_bpf_ethdev.h48 rte_bpf_eth_rx_unload(uint16_t port, uint16_t queue);
60 rte_bpf_eth_tx_unload(uint16_t port, uint16_t queue);
83 rte_bpf_eth_rx_elf_load(uint16_t port, uint16_t queue,
108 rte_bpf_eth_tx_elf_load(uint16_t port, uint16_t queue,
/dpdk/lib/pdump/
H A Drte_pdump.c43 uint16_t queue; member
82 pdump_copy(uint16_t port_id, uint16_t queue, in pdump_copy() argument
120 p = rte_pcapng_copy(port_id, queue, in pdump_copy()
144 pdump_rx(uint16_t port, uint16_t queue, in pdump_rx() argument
149 struct rte_pdump_stats *stats = &pdump_stats->rx[port][queue]; in pdump_rx()
151 pdump_copy(port, queue, RTE_PCAPNG_DIRECTION_IN, in pdump_rx()
157 pdump_tx(uint16_t port, uint16_t queue, in pdump_tx() argument
161 struct rte_pdump_stats *stats = &pdump_stats->tx[port][queue]; in pdump_tx()
163 pdump_copy(port, queue, RTE_PCAPNG_DIRECTION_OUT, in pdump_tx()
170 uint16_t end_q, uint16_t port, uint16_t queue, in pdump_register_rx_callbacks() argument
[all …]
H A Drte_pdump.h80 rte_pdump_enable(uint16_t port, uint16_t queue, uint32_t flags,
110 rte_pdump_enable_bpf(uint16_t port_id, uint16_t queue,
134 rte_pdump_disable(uint16_t port, uint16_t queue, uint32_t flags);
161 rte_pdump_enable_by_deviceid(char *device_id, uint16_t queue,
193 rte_pdump_enable_bpf_by_deviceid(const char *device_id, uint16_t queue,
219 rte_pdump_disable_by_deviceid(char *device_id, uint16_t queue,
/dpdk/drivers/net/mana/
H A Dgdma.c11 gdma_get_wqe_pointer(struct mana_gdma_queue *queue) in gdma_get_wqe_pointer() argument
14 (queue->head * GDMA_WQE_ALIGNMENT_UNIT_SIZE) & in gdma_get_wqe_pointer()
15 (queue->size - 1); in gdma_get_wqe_pointer()
18 queue->head, queue->size, offset_in_bytes); in gdma_get_wqe_pointer()
20 if (offset_in_bytes + GDMA_WQE_ALIGNMENT_UNIT_SIZE > queue->size) in gdma_get_wqe_pointer()
24 return ((uint8_t *)queue->buffer) + offset_in_bytes; in gdma_get_wqe_pointer()
124 gdma_post_work_request(struct mana_gdma_queue *queue, in gdma_post_work_request() argument
141 uint32_t queue_free_units = queue->count - (queue->head - queue->tail); in gdma_post_work_request()
145 wqe_size, queue->count, queue->head, queue->tail); in gdma_post_work_request()
154 wq_buffer_pointer = gdma_get_wqe_pointer(queue); in gdma_post_work_request()
[all …]
/dpdk/doc/guides/nics/
H A Didpf.rst58 There are two queue modes supported by Intel\ |reg| IPU Ethernet ES2000 Series,
59 single queue mode and split queue mode for Rx queue.
60 User can choose Rx queue mode, example::
64 Then the PMD will configure Rx queue with single queue mode.
65 Otherwise, split queue mode is chosen by default.
69 There are two queue modes supported by Intel\ |reg| IPU Ethernet ES2000 Series,
70 single queue mode and split queue mode for Tx queue.
71 User can choose Tx queue mode, example::
75 Then the PMD will configure Tx queue with single queue mode.
76 Otherwise, split queue mode is chosen by default.
H A Dgve.rst34 GVE has 3 queue formats:
36 - GQI_QPL - GQI with queue page list
40 GQI_QPL queue format is queue page list mode.
43 Each queue has its own QPL.
50 GQI_RDA queue format works like usual NICs
53 DQO_RDA queue format has submission and completion queue pair
54 for each Tx/Rx queue.
59 to get more information about GVE queue formats.
76 Currently, only GQI_QPL and GQI_RDA queue format are supported in PMD.
79 Also, only GQI_QPL queue format is in use on GCP
/dpdk/app/graph/
H A Dethdev_rx.c27 rx_map_configure(uint8_t port_id, uint32_t queue, uint32_t core) in rx_map_configure() argument
33 lcore_conf[core].rx_queue_list[n_rx_queue].queue_id = queue; in rx_map_configure()
40 int queue = -1; in ethdev_rx_num_rx_queues_get() local
45 if (lcore_params[i].queue_id == queue + 1) in ethdev_rx_num_rx_queues_get()
46 queue = lcore_params[i].queue_id; in ethdev_rx_num_rx_queues_get()
55 return (uint8_t)(++queue); in ethdev_rx_num_rx_queues_get()
59 ethdev_rx_map_add(char *name, uint32_t queue, uint32_t core) in ethdev_rx_map_add() argument
77 rx_map_configure(port_id, queue, core); in ethdev_rx_map_add()
80 lcore_params_array[nb_lcore_params].queue_id = queue; in ethdev_rx_map_add()
H A Dl2fwd.c104 uint16_t queue, port_id; in ethdev_rx_to_tx_node_link() local
111 for (queue = 0; queue < qconf->n_rx_queue; ++queue) { in ethdev_rx_to_tx_node_link()
112 port_id = qconf->rx_queue_list[queue].port_id; in ethdev_rx_to_tx_node_link()
115 rx_id = rte_node_from_name(qconf->rx_queue_list[queue].node_name); in ethdev_rx_to_tx_node_link()
/dpdk/examples/vhost/
H A Dvirtio_net.c26 struct vhost_queue *queue; in vs_vhost_net_setup() local
47 queue = &dev->queues[i]; in vs_vhost_net_setup()
49 queue->last_used_idx = 0; in vs_vhost_net_setup()
50 queue->last_avail_idx = 0; in vs_vhost_net_setup()
51 rte_vhost_get_vhost_vring(vid, i, &queue->vr); in vs_vhost_net_setup()
191 struct vhost_queue *queue; in vs_enqueue_pkts() local
198 queue = &dev->queues[queue_id]; in vs_enqueue_pkts()
199 vr = &queue->vr; in vs_enqueue_pkts()
203 start_idx = queue->last_used_idx; in vs_enqueue_pkts()
237 queue->last_used_idx += count; in vs_enqueue_pkts()
[all …]
/dpdk/lib/node/
H A Dethdev_tx.c19 uint16_t port, queue; in ethdev_tx_node_process() local
24 queue = ctx->queue; in ethdev_tx_node_process()
26 count = rte_eth_tx_burst(port, queue, (struct rte_mbuf **)objs, in ethdev_tx_node_process()
56 ctx->queue = graph->id; in ethdev_tx_node_init()
H A Dethdev_rx.c21 uint16_t port, queue; in ethdev_rx_node_process_inline() local
24 queue = ctx->queue_id; in ethdev_rx_node_process_inline()
28 count = rte_eth_rx_burst(port, queue, (struct rte_mbuf **)node->objs, in ethdev_rx_node_process_inline()
67 eth_pkt_parse_cb(uint16_t port, uint16_t queue, struct rte_mbuf **mbufs, in eth_pkt_parse_cb() argument
76 RTE_SET_USED(queue); in eth_pkt_parse_cb()
145 ethdev_ptype_setup(uint16_t port, uint16_t queue) in ethdev_ptype_setup() argument
166 if (!rte_eth_add_rx_callback(port, queue, eth_pkt_parse_cb, in ethdev_ptype_setup()
170 port, queue); in ethdev_ptype_setup()
/dpdk/drivers/net/nfb/
H A Dnfb_tx.h19 struct ndp_queue *queue; /* tx queue */ member
123 nfb_eth_ndp_tx(void *queue, in nfb_eth_ndp_tx() argument
129 struct ndp_tx_queue *ndp = queue; in nfb_eth_ndp_tx()
142 if (unlikely(ndp->queue == NULL)) { in nfb_eth_ndp_tx()
152 num_tx = ndp_tx_burst_get(ndp->queue, packets, nb_pkts); in nfb_eth_ndp_tx()
191 ndp_tx_burst_flush(ndp->queue); in nfb_eth_ndp_tx()
H A Dnfb_rx.h31 struct ndp_queue *queue; /* rx queue */ member
143 nfb_eth_ndp_rx(void *queue, in nfb_eth_ndp_rx() argument
147 struct ndp_rx_queue *ndp = queue; in nfb_eth_ndp_rx()
160 if (unlikely(ndp->queue == NULL || nb_pkts == 0)) { in nfb_eth_ndp_rx()
170 num_rx = ndp_rx_burst_get(ndp->queue, packets, nb_pkts); in nfb_eth_ndp_rx()
229 ndp_rx_burst_put(ndp->queue); in nfb_eth_ndp_rx()
/dpdk/drivers/net/mlx5/
H A Dmlx5_flow_quota.c27 is_quota_sync_queue(const struct mlx5_priv *priv, uint32_t queue) in is_quota_sync_queue() argument
29 return queue >= priv->nb_queue - 1; in is_quota_sync_queue()
90 mlx5_quota_async_completion(struct rte_eth_dev *dev, uint32_t queue, in mlx5_quota_async_completion() argument
98 RTE_SET_USED(queue); in mlx5_quota_async_completion()
114 struct mlx5_quota_ctx *qctx, uint32_t queue) in mlx5_quota_wqe_set_aso_read() argument
116 struct mlx5_aso_sq *sq = qctx->sq + queue; in mlx5_quota_wqe_set_aso_read()
119 uint64_t rd_addr = (uint64_t)(qctx->read_buf[queue] + 2 * sq_head); in mlx5_quota_wqe_set_aso_read()
163 uint32_t queue, __rte_unused void *arg) in mlx5_quota_wqe_query() argument
165 mlx5_quota_wqe_set_aso_read(wqe, qctx, queue); in mlx5_quota_wqe_query()
172 __rte_unused uint32_t queue, void *arg) in mlx5_quota_wqe_update() argument
[all …]
/dpdk/lib/eventdev/
H A Deventdev_trace_points.c14 lib.eventdev.queue.setup)
66 lib.eventdev.rx.adapter.queue.add)
69 lib.eventdev.rx.adapter.queue.del)
85 lib.eventdev.tx.adapter.queue.add)
88 lib.eventdev.tx.adapter.queue.del)
129 lib.eventdev.crypto.queue.add)
132 lib.eventdev.crypto.queue.del)
186 lib.eventdev.eth.rx.adapter.queue.stats.get)
192 lib.eventdev.eth.rx.adapter.queue.stats.reset)
231 lib.eventdev.queue
[all...]
/dpdk/app/test-pmd/
H A Dbpf_cmd.c61 uint16_t queue; member
111 rc = rte_bpf_eth_rx_elf_load(res->port, res->queue, &prm, in cmd_operate_bpf_ld_parsed()
115 rc = rte_bpf_eth_tx_elf_load(res->port, res->queue, &prm, in cmd_operate_bpf_ld_parsed()
131 TOKEN_NUM_INITIALIZER(struct cmd_bpf_ld_result, queue, RTE_UINT16);
159 uint16_t queue; member
171 rte_bpf_eth_rx_unload(res->port, res->queue); in cmd_operate_bpf_unld_parsed()
173 rte_bpf_eth_tx_unload(res->port, res->queue); in cmd_operate_bpf_unld_parsed()
187 TOKEN_NUM_INITIALIZER(struct cmd_bpf_unld_result, queue, RTE_UINT16);
/dpdk/lib/graph/
H A Dgraph_ops.c110 struct graph_node **queue, *v, *tmp; in graph_bfs() local
116 queue = malloc(sz); in graph_bfs()
117 if (queue == NULL) in graph_bfs()
122 queue[tail++] = start; in graph_bfs()
125 v = queue[head++]; in graph_bfs()
129 queue[tail++] = tmp; in graph_bfs()
135 free(queue); in graph_bfs()
/dpdk/lib/power/
H A Drte_power_pmd_mgmt.c43 union queue {
53 union queue queue;
65 /**< State of power management for this queue */
67 /**< Callback mode for this queue */
71 /**< Prevent a queue from triggering sleep multiple times */
76 queue_equal(const union queue *l, const union queue *r) in queue_equal()
82 queue_copy(union queue *dst, const union queue *sr in queue_copy()
42 union queue { global() union
52 union queue queue; global() member
[all...]
/dpdk/drivers/net/failsafe/
H A Dfailsafe_rxtx.c80 failsafe_rx_burst(void *queue, in failsafe_rx_burst() argument
89 rxq = queue; in failsafe_rx_burst()
112 failsafe_rx_burst_fast(void *queue, in failsafe_rx_burst_fast() argument
121 rxq = queue; in failsafe_rx_burst_fast()
140 failsafe_tx_burst(void *queue, in failsafe_tx_burst() argument
149 txq = queue; in failsafe_tx_burst()
161 failsafe_tx_burst_fast(void *queue, in failsafe_tx_burst_fast() argument
170 txq = queue; in failsafe_tx_burst_fast()
/dpdk/drivers/event/dpaa2/
H A Ddpaa2_eventdev_selftest.c46 uint8_t queue; member
221 uint8_t queue, uint8_t port, uint8_t seq) in update_event_and_validation_attr() argument
231 attr->queue = queue; in update_event_and_validation_attr()
241 ev->queue_id = queue; in update_event_and_validation_attr()
247 uint8_t sched_type, uint8_t queue, uint8_t port, in inject_events() argument
260 sub_event_type, sched_type, queue, port, i); in inject_events()
332 RTE_TEST_ASSERT_EQUAL(attr->queue, ev->queue_id, in validate_event()
334 attr->queue, ev->queue_id); in validate_event()
660 uint8_t queue = (uint8_t)i; in test_queue_to_port_single_link() local
662 ret = rte_event_port_link(evdev, i, &queue, NULL, 1); in test_queue_to_port_single_link()
[all …]
/dpdk/doc/guides/vdpadevs/
H A Dmlx5.rst61 - 0, Completion queue scheduling will be managed by a timer thread which
64 - 1, Completion queue scheduling will be managed by a timer thread with fixed
67 - 2, Completion queue scheduling will be managed by interrupts. Each CQ burst
101 All the threads will be open on the same core of the event completion queue scheduling thread.
112 The completion queue moderation mode:
129 - 1 - 65535, The maximum number of pending packets completions in an HW queue.
135 - 1 - 1024, Virtio queue depth for pre-creating queue resource to speed up
136 first time queue creation. Set it together with ``queues`` parameter.
142 - 1 - 128, Maximum number of virtio queue pair (including 1 Rx queue and 1 Tx queue)
143 for pre-creating queue resource to speed up first time queue creation.

1234567891011