Home
last modified time | relevance | path

Searched refs:rx_q (Results 1 – 25 of 27) sorted by relevance

12

/dpdk/examples/flow_filtering/
H A Dflow_blocks.c9 generate_ipv4_flow(uint16_t port_id, uint16_t rx_q,
40 generate_ipv4_flow(uint16_t port_id, uint16_t rx_q, in generate_ipv4_flow() argument
50 struct rte_flow_action_queue queue = { .index = rx_q }; in generate_ipv4_flow()
/dpdk/app/test/
H A Dvirtual_pmd.c109 struct virtual_ethdev_queue *rx_q; in virtual_ethdev_rx_queue_setup_success() local
111 rx_q = (struct virtual_ethdev_queue *)rte_zmalloc_socket(NULL, in virtual_ethdev_rx_queue_setup_success()
114 if (rx_q == NULL) in virtual_ethdev_rx_queue_setup_success()
117 rx_q->port_id = dev->data->port_id; in virtual_ethdev_rx_queue_setup_success()
118 rx_q->queue_id = rx_queue_id; in virtual_ethdev_rx_queue_setup_success()
120 dev->data->rx_queues[rx_queue_id] = rx_q; in virtual_ethdev_rx_queue_setup_success()
/dpdk/drivers/net/pfe/
H A Dpfe_hif_lib.c107 desc = client->rx_q[qno].base; in hif_lib_client_release_rx_buffers()
109 for (ii = 0; ii < client->rx_q[qno].size; ii++) { in hif_lib_client_release_rx_buffers()
150 queue = &client->rx_q[qno]; in hif_lib_client_init_rx_buffers()
165 queue = &client->rx_q[qno]; in hif_lib_client_init_rx_buffers()
345 struct hif_client_rx_queue *queue = &client->rx_q[qno]; in hif_lib_event_handler_start()
H A Dpfe_hif.h45 struct hif_rx_queue rx_q[HIF_CLIENT_QUEUES_MAX]; member
H A Dpfe_hif_lib.h68 struct hif_client_rx_queue rx_q[HIF_CLIENT_QUEUES_MAX]; member
H A Dpfe_ethdev.c280 ret = hif_lib_receive_pkt(&client->rx_q[0], in pfe_eth_open()
286 ret = hif_lib_receive_pkt(&client->rx_q[0], in pfe_eth_open()
475 dev->data->rx_queues[queue_idx] = &priv->client.rx_q[queue_idx]; in pfe_rx_queue_setup()
476 priv->client.rx_q[queue_idx].queue_id = queue_idx; in pfe_rx_queue_setup()
H A Dpfe_hif.c236 rx_queue = &client->rx_q[i]; in pfe_hif_client_register()
416 client_put_rxpacket(&hif->client[hif->client_id].rx_q[hif->qno], in pfe_hif_rx_process()
/dpdk/lib/kni/
H A Drte_kni.c69 struct rte_kni_fifo *rx_q; /**< RX queue */ member
280 kni->rx_q = kni->m_rx_q->addr; in rte_kni_alloc()
281 kni_fifo_init(kni->rx_q, KNI_FIFO_COUNT_MAX); in rte_kni_alloc()
437 while (kni_fifo_count(kni->rx_q) && retry--) in rte_kni_release()
440 if (kni_fifo_count(kni->rx_q)) in rte_kni_release()
615 num = RTE_MIN(kni_fifo_free_count(kni->rx_q), num); in rte_kni_tx_burst()
623 ret = kni_fifo_put(kni->rx_q, phy_mbufs, num); in rte_kni_tx_burst()
/dpdk/kernel/linux/kni/
H A Dkni_net.c275 kni_fifo_trans_pa2va(kni, kni->rx_q, kni->free_q); in kni_net_release_fifo_phy()
401 num_rx = kni_fifo_get(kni->rx_q, kni->pa, num_rx); in kni_net_rx_normal()
474 num_rq = kni_fifo_count(kni->rx_q); in kni_net_rx_lo_fifo()
496 ret = kni_fifo_get(kni->rx_q, kni->pa, num); in kni_net_rx_lo_fifo()
566 num_rq = kni_fifo_count(kni->rx_q); in kni_net_rx_lo_fifo_skb()
580 ret = kni_fifo_get(kni->rx_q, kni->pa, num); in kni_net_rx_lo_fifo_skb()
H A Dkni_dev.h64 struct rte_kni_fifo *rx_q; member
H A Dkni_misc.c360 kni->rx_q = iova_to_kva(current, dev_info.rx_phys); in kni_ioctl_create()
377 kni->rx_q = phys_to_virt(dev_info.rx_phys); in kni_ioctl_create()
393 (unsigned long long) dev_info.rx_phys, kni->rx_q); in kni_ioctl_create()
/dpdk/drivers/net/avp/
H A Davp_ethdev.c906 avp->rx_q[i] = avp_dev_translate_address(eth_dev, in avp_dev_create()
1389 struct rte_avp_fifo *rx_q; in avp_recv_scattered_pkts() local
1406 rx_q = avp->rx_q[rxq->queue_id]; in avp_recv_scattered_pkts()
1417 avail = avp_fifo_count(rx_q); in avp_recv_scattered_pkts()
1430 n = avp_fifo_get(rx_q, (void **)&avp_bufs, count); in avp_recv_scattered_pkts()
1432 count, rx_q); in avp_recv_scattered_pkts()
1491 struct rte_avp_fifo *rx_q; in avp_recv_pkts() local
1503 rx_q = avp->rx_q[rxq->queue_id]; in avp_recv_pkts()
1514 avail = avp_fifo_count(rx_q); in avp_recv_pkts()
1527 n = avp_fifo_get(rx_q, (void **)&avp_bufs, count); in avp_recv_pkts()
[all …]
/dpdk/examples/multi_process/client_server_mp/mp_server/
H A Dinit.c168 clients[i].rx_q = rte_ring_create(q_name, in init_shm_rings()
171 if (clients[i].rx_q == NULL) in init_shm_rings()
H A Dinit.h18 struct rte_ring *rx_q; member
H A Dmain.c206 if (rte_ring_enqueue_bulk(cl->rx_q, (void **)cl_rx_buf[client].buffer, in flush_rx_queue()
/dpdk/examples/server_node_efd/server/
H A Dinit.h18 struct rte_ring *rx_q; member
H A Dinit.c188 nodes[i].rx_q = rte_ring_create(q_name, in init_shm_rings()
191 if (nodes[i].rx_q == NULL) in init_shm_rings()
H A Dmain.c229 if (rte_ring_enqueue_bulk(cl->rx_q, (void **)cl_rx_buf[node].buffer, in flush_rx_queue()
/dpdk/drivers/common/qat/dev/
H A Dqat_dev_gen1.c153 struct qat_queue *q_tx = &qp->tx_q, *q_rx = &qp->rx_q; in qat_qp_adf_configure_queues_gen1()
187 qat_qp_csr_build_ring_base_gen1(io_addr, &qp->rx_q); in qat_qp_csr_setup_gen1()
H A Dqat_dev_gen4.c196 struct qat_queue *q_tx = &qp->tx_q, *q_rx = &qp->rx_q; in qat_qp_adf_configure_queues_gen4()
231 qat_qp_build_ring_base_gen4(io_addr, &qp->rx_q); in qat_qp_csr_setup_gen4()
/dpdk/drivers/common/qat/
H A Dqat_qp.c126 if (qat_queue_create(qat_dev, &(qp->rx_q), qat_qp_conf, in qat_qp_setup()
152 qat_queue_delete(&(qp->rx_q)); in qat_qp_setup()
317 qat_queue_delete(&(qp->rx_q)); in qat_qp_release()
817 rx_queue = &(tmp_qp->rx_q); in qat_dequeue_op_burst()
876 struct qat_queue *queue = &(qp->rx_q); in qat_cq_dequeue_response()
H A Dqat_qp.h87 struct qat_queue rx_q; member
/dpdk/drivers/crypto/qat/dev/
H A Dqat_sym_pmd_gen1.c910 struct qat_queue *rx_queue = &qp->rx_q; in qat_sym_dp_dequeue_burst_gen1()
999 struct qat_queue *rx_queue = &qp->rx_q; in qat_sym_dp_dequeue_single_gen1()
1047 struct qat_queue *rx_queue = &qp->rx_q; in qat_sym_dp_dequeue_done_gen1()
/dpdk/drivers/crypto/qat/
H A Dqat_sym.c385 dp_ctx->head = qp->rx_q.head; in qat_sym_configure_dp_ctx()
/dpdk/doc/guides/prog_guide/
H A Dkernel_nic_interface.rst341 This thread will enqueue the mbuf in the rx_q FIFO,
343 The KNI thread will poll all KNI active devices for the rx_q.

12