Home
last modified time | relevance | path

Searched refs:rx_queue (Results 1 – 25 of 65) sorted by relevance

123

/dpdk/drivers/net/octeon_ep/
H A Dotx_ep_rxtx.h42 otx_ep_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t budget);
51 cnxk_ep_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t budget);
54 cnxk_ep_recv_pkts_sse(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t budget);
57 cnxk_ep_recv_pkts_avx(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t budget);
60 cnxk_ep_recv_pkts_mseg(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t budget);
63 cn9k_ep_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t budget);
66 cnxk_ep_recv_pkts_neon(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts);
69 cn9k_ep_recv_pkts_sse(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t budget);
72 cn9k_ep_recv_pkts_avx(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t budget);
75 cn9k_ep_recv_pkts_neon(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts);
[all …]
H A Dcnxk_ep_rx.c73 cnxk_ep_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts) in cnxk_ep_recv_pkts() argument
75 struct otx_ep_droq *droq = (struct otx_ep_droq *)rx_queue; in cnxk_ep_recv_pkts()
89 cn9k_ep_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts) in cn9k_ep_recv_pkts() argument
91 struct otx_ep_droq *droq = (struct otx_ep_droq *)rx_queue; in cn9k_ep_recv_pkts()
116 cnxk_ep_recv_pkts_mseg(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts) in cnxk_ep_recv_pkts_mseg() argument
118 struct otx_ep_droq *droq = (struct otx_ep_droq *)rx_queue; in cnxk_ep_recv_pkts_mseg()
132 cn9k_ep_recv_pkts_mseg(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts) in cn9k_ep_recv_pkts_mseg() argument
134 struct otx_ep_droq *droq = (struct otx_ep_droq *)rx_queue; in cn9k_ep_recv_pkts_mseg()
H A Dcnxk_ep_rx_avx.c79 cnxk_ep_recv_pkts_avx(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts) in cnxk_ep_recv_pkts_avx() argument
81 struct otx_ep_droq *droq = (struct otx_ep_droq *)rx_queue; in cnxk_ep_recv_pkts_avx()
97 cn9k_ep_recv_pkts_avx(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts) in cn9k_ep_recv_pkts_avx() argument
99 struct otx_ep_droq *droq = (struct otx_ep_droq *)rx_queue; in cn9k_ep_recv_pkts_avx()
H A Dcnxk_ep_rx.h91 cnxk_ep_check_rx_ism_mem(void *rx_queue) in cnxk_ep_check_rx_ism_mem() argument
93 struct otx_ep_droq *droq = (struct otx_ep_droq *)rx_queue; in cnxk_ep_check_rx_ism_mem()
128 cnxk_ep_check_rx_pkt_reg(void *rx_queue) in cnxk_ep_check_rx_pkt_reg() argument
130 struct otx_ep_droq *droq = (struct otx_ep_droq *)rx_queue; in cnxk_ep_check_rx_pkt_reg()
/dpdk/drivers/net/cnxk/rx/cn9k/
H A Drx_all_offload.c11 cn9k_nix_recv_pkts_all_offload(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts) in cn9k_nix_recv_pkts_all_offload() argument
13 return cn9k_nix_recv_pkts(rx_queue, rx_pkts, pkts, in cn9k_nix_recv_pkts_all_offload()
21 cn9k_nix_recv_pkts_vec_all_offload(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts) in cn9k_nix_recv_pkts_vec_all_offload() argument
23 return cn9k_nix_recv_pkts_vector(rx_queue, rx_pkts, pkts, in cn9k_nix_recv_pkts_vec_all_offload()
31 cn9k_nix_recv_pkts_all_offload_tst(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts) in cn9k_nix_recv_pkts_all_offload_tst() argument
33 return cn9k_nix_recv_pkts(rx_queue, rx_pkts, pkts, in cn9k_nix_recv_pkts_all_offload_tst()
41 cn9k_nix_recv_pkts_vec_all_offload_tst(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts) in cn9k_nix_recv_pkts_vec_all_offload_tst() argument
43 return cn9k_nix_recv_pkts_vector(rx_queue, rx_pkts, pkts, in cn9k_nix_recv_pkts_vec_all_offload_tst()
/dpdk/drivers/net/cnxk/rx/cn10k/
H A Drx_all_offload.c14 cn10k_nix_recv_pkts_all_offload(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts) in cn10k_nix_recv_pkts_all_offload() argument
16 return cn10k_nix_recv_pkts(rx_queue, rx_pkts, pkts, in cn10k_nix_recv_pkts_all_offload()
25 cn10k_nix_recv_pkts_vec_all_offload(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts) in cn10k_nix_recv_pkts_vec_all_offload() argument
27 return cn10k_nix_recv_pkts_vector(rx_queue, rx_pkts, pkts, in cn10k_nix_recv_pkts_vec_all_offload()
36 cn10k_nix_recv_pkts_all_offload_tst(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts) in cn10k_nix_recv_pkts_all_offload_tst() argument
38 return cn10k_nix_recv_pkts(rx_queue, rx_pkts, pkts, in cn10k_nix_recv_pkts_all_offload_tst()
47 cn10k_nix_recv_pkts_vec_all_offload_tst(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts) in cn10k_nix_recv_pkts_vec_all_offload_tst() argument
49 return cn10k_nix_recv_pkts_vector(rx_queue, rx_pkts, pkts, in cn10k_nix_recv_pkts_vec_all_offload_tst()
/dpdk/drivers/net/nfb/
H A Dnfb_stats.c23 struct ndp_rx_queue *rx_queue = *((struct ndp_rx_queue **) in nfb_eth_stats_get() local
30 stats->q_ipackets[i] = rx_queue[i].rx_pkts; in nfb_eth_stats_get()
31 stats->q_ibytes[i] = rx_queue[i].rx_bytes; in nfb_eth_stats_get()
33 rx_total += rx_queue[i].rx_pkts; in nfb_eth_stats_get()
34 rx_total_bytes += rx_queue[i].rx_bytes; in nfb_eth_stats_get()
62 struct ndp_rx_queue *rx_queue = *((struct ndp_rx_queue **) in nfb_eth_stats_reset() local
68 rx_queue[i].rx_pkts = 0; in nfb_eth_stats_reset()
69 rx_queue[i].rx_bytes = 0; in nfb_eth_stats_reset()
70 rx_queue[i].err_pkts = 0; in nfb_eth_stats_reset()
/dpdk/drivers/net/virtio/
H A Dvirtio_ethdev.h77 uint16_t virtio_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
79 uint16_t virtio_recv_pkts_packed(void *rx_queue, struct rte_mbuf **rx_pkts,
82 uint16_t virtio_recv_mergeable_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
85 uint16_t virtio_recv_mergeable_pkts_packed(void *rx_queue,
88 uint16_t virtio_recv_pkts_inorder(void *rx_queue,
102 uint16_t virtio_recv_pkts_vec(void *rx_queue, struct rte_mbuf **rx_pkts,
105 uint16_t virtio_recv_pkts_packed_vec(void *rx_queue, struct rte_mbuf **rx_pkts,
H A Dvirtio_rxtx_packed.c79 virtio_recv_pkts_packed_vec(void *rx_queue, in virtio_recv_pkts_packed_vec() argument
83 struct virtnet_rx *rxvq = rx_queue; in virtio_recv_pkts_packed_vec()
/dpdk/drivers/net/thunderx/
H A Dnicvf_rxtx.h86 uint32_t nicvf_dev_rx_queue_count(void *rx_queue);
93 uint16_t nicvf_recv_pkts_vlan_strip(void *rx_queue, struct rte_mbuf **rx_pkts,
95 uint16_t nicvf_recv_pkts_cksum_vlan_strip(void *rx_queue,
98 uint16_t nicvf_recv_pkts_multiseg_no_offload(void *rx_queue,
100 uint16_t nicvf_recv_pkts_multiseg_cksum(void *rx_queue,
102 uint16_t nicvf_recv_pkts_multiseg_vlan_strip(void *rx_queue,
104 uint16_t nicvf_recv_pkts_multiseg_cksum_vlan_strip(void *rx_queue,
H A Dnicvf_rxtx.c419 nicvf_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts, in nicvf_recv_pkts() argument
429 struct nicvf_rxq *rxq = rx_queue; in nicvf_recv_pkts()
489 nicvf_recv_pkts_no_offload(void *rx_queue, struct rte_mbuf **rx_pkts, in nicvf_recv_pkts_no_offload() argument
492 return nicvf_recv_pkts(rx_queue, rx_pkts, nb_pkts, in nicvf_recv_pkts_no_offload()
497 nicvf_recv_pkts_cksum(void *rx_queue, struct rte_mbuf **rx_pkts, in nicvf_recv_pkts_cksum() argument
500 return nicvf_recv_pkts(rx_queue, rx_pkts, nb_pkts, in nicvf_recv_pkts_cksum()
505 nicvf_recv_pkts_vlan_strip(void *rx_queue, struct rte_mbuf **rx_pkts, in nicvf_recv_pkts_vlan_strip() argument
508 return nicvf_recv_pkts(rx_queue, rx_pkts, nb_pkts, in nicvf_recv_pkts_vlan_strip()
513 nicvf_recv_pkts_cksum_vlan_strip(void *rx_queue, struct rte_mbuf **rx_pkts, in nicvf_recv_pkts_cksum_vlan_strip() argument
516 return nicvf_recv_pkts(rx_queue, rx_pkts, nb_pkts, in nicvf_recv_pkts_cksum_vlan_strip()
[all …]
/dpdk/drivers/net/ark/
H A Dark_ethdev_rx.h20 uint32_t eth_ark_dev_rx_queue_count(void *rx_queue);
23 uint16_t eth_ark_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
25 void eth_ark_dev_rx_queue_release(void *rx_queue);
/dpdk/examples/l3fwd-power/
H A Dmain.c871 struct lcore_rx_queue *rx_queue; in turn_on_off_intr()
876 rx_queue = &(qconf->rx_queue_list[i]); in turn_on_off_intr()
877 port_id = rx_queue->port_id; in turn_on_off_intr()
878 queue_id = rx_queue->queue_id; in turn_on_off_intr()
891 struct lcore_rx_queue *rx_queue; in event_register()
899 rx_queue = &(qconf->rx_queue_list[i]); in event_register()
900 portid = rx_queue->port_id; in event_register()
901 queueid = rx_queue->queue_id; in event_register()
924 struct lcore_rx_queue *rx_queue; in main_intr_loop()
985 rx_queue in main_intr_loop()
869 struct lcore_rx_queue *rx_queue; turn_on_off_intr() local
889 struct lcore_rx_queue *rx_queue; event_register() local
923 struct lcore_rx_queue *rx_queue; main_intr_loop() local
1089 struct lcore_rx_queue *rx_queue; main_telemetry_loop() local
1211 struct lcore_rx_queue *rx_queue; main_legacy_loop() local
[all...]
/dpdk/drivers/crypto/qat/dev/
H A Dqat_sym_pmd_gen1.c996 struct qat_queue *rx_queue = &qp->rx_q; in qat_sym_dp_dequeue_burst_gen1() local
1011 resp = (struct icp_qat_fw_comn_resp *)((uint8_t *)rx_queue->base_addr + in qat_sym_dp_dequeue_burst_gen1()
1034 head = (head + rx_queue->msg_size) & rx_queue->modulo_mask; in qat_sym_dp_dequeue_burst_gen1()
1045 (uint8_t *)rx_queue->base_addr + head); in qat_sym_dp_dequeue_burst_gen1()
1053 head = (head + rx_queue->msg_size) & in qat_sym_dp_dequeue_burst_gen1()
1054 rx_queue->modulo_mask; in qat_sym_dp_dequeue_burst_gen1()
1063 (uint8_t *)rx_queue->base_addr + head); in qat_sym_dp_dequeue_burst_gen1()
1067 head = (head + rx_queue->msg_size) & in qat_sym_dp_dequeue_burst_gen1()
1068 rx_queue->modulo_mask; in qat_sym_dp_dequeue_burst_gen1()
1085 struct qat_queue *rx_queue = &qp->rx_q; in qat_sym_dp_dequeue_single_gen1() local
[all …]
/dpdk/lib/eventdev/
H A Drte_event_eth_rx_adapter.c196 struct eth_rx_queue_info *rx_queue; member
286 *stats = dev_info->rx_queue[rx_queue_id].stats; in rxa_event_buf_get()
287 return dev_info->rx_queue[rx_queue_id].event_buf; in rxa_event_buf_get()
364 w = rx_adapter->eth_devices[d].rx_queue[q].wt; in rxa_wrr_next()
391 queue_info = &dev_info->rx_queue[rx_queue_id]; in rxa_intr_queue()
392 return dev_info->rx_queue && in rxa_intr_queue()
403 queue_info = &dev_info->rx_queue[rx_queue_id]; in rxa_polled_queue()
405 dev_info->rx_queue && in rxa_polled_queue()
486 wrr_len_diff = poll_diff ? dev_info->rx_queue[rx_queue_id].wt : in rxa_calc_nb_post_add_intr()
511 wrr_len_diff = poll_diff ? dev_info->rx_queue[rx_queue_i in rxa_calc_nb_post_poll_del()
2204 struct eth_rx_queue_info *rx_queue; rxa_sw_add() local
[all...]
/dpdk/app/test-pmd/
H A Dshared_rxq_fwd.c35 fsm[sm_id]->rx_queue == fs->rx_queue) in forward_stream_get()
109 fs->disabled = ports[fs->rx_port].rxq[fs->rx_queue].state == in shared_rxq_stream_init()
H A Drecycle_mbufs.c22 rte_eth_recycle_mbufs(fs->rx_port, fs->rx_queue, in pkt_burst_recycle_mbufs()
46 fs->rx_queue, &(fs->recycle_rxq_info)); in recycle_mbufs_stream_init()
/dpdk/drivers/net/cnxk/
H A Dcnxk_ethdev_cman.c54 if (config->obj_param.rx_queue >= dev->nb_rxq) { in nix_cman_config_validate()
55 plt_err("Invalid queue ID. Queue = %u", config->obj_param.rx_queue); in nix_cman_config_validate()
96 cq = &dev->cqs[config->obj_param.rx_queue]; in cnxk_nix_cman_config_set()
97 rq = &dev->rqs[config->obj_param.rx_queue]; in cnxk_nix_cman_config_set()
H A Dcn9k_rx.h476 cn9k_nix_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts, in cn9k_nix_recv_pkts() argument
479 struct cn9k_eth_rxq *rxq = rx_queue; in cn9k_nix_recv_pkts()
547 cn9k_nix_recv_pkts_vector(void *rx_queue, struct rte_mbuf **rx_pkts, in cn9k_nix_recv_pkts_vector() argument
550 struct cn9k_eth_rxq *rxq = rx_queue; in cn9k_nix_recv_pkts_vector()
867 packets += cn9k_nix_recv_pkts(rx_queue, &rx_pkts[packets], in cn9k_nix_recv_pkts_vector()
876 cn9k_nix_recv_pkts_vector(void *rx_queue, struct rte_mbuf **rx_pkts, in cn9k_nix_recv_pkts_vector() argument
879 RTE_SET_USED(rx_queue); in cn9k_nix_recv_pkts_vector()
1074 void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts); \
1076 void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts); \
1078 void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t pkts); \
[all …]
/dpdk/drivers/net/atlantic/
H A Datl_ethdev.h69 uint32_t atl_rx_queue_count(void *rx_queue);
71 int atl_dev_rx_descriptor_status(void *rx_queue, uint16_t offset);
98 uint16_t atl_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
/dpdk/drivers/net/tap/
H A Drte_eth_tap.h46 struct rx_queue { struct
92 struct rx_queue rxq[RTE_PMD_TAP_MAX_QUEUES]; /* List of RX queues */
/dpdk/drivers/net/octeontx/
H A Docteontx_rxtx.c23 octeontx_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts) in octeontx_recv_pkts() argument
30 rxq = rx_queue; in octeontx_recv_pkts()
/dpdk/drivers/net/ionic/
H A Dionic_rxtx.h74 int ionic_dev_rx_descriptor_status(void *rx_queue, uint16_t offset);
86 uint16_t ionic_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
94 uint16_t ionic_recv_pkts_sg(void *rx_queue, struct rte_mbuf **rx_pkts,
/dpdk/drivers/common/idpf/
H A Didpf_common_rxtx.h266 uint16_t idpf_dp_splitq_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
272 uint16_t idpf_dp_singleq_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
289 uint16_t idpf_dp_singleq_recv_pkts_avx512(void *rx_queue,
303 uint16_t idpf_dp_singleq_recv_scatter_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
/dpdk/drivers/net/nfp/
H A Dnfp_rxtx_vec.h13 uint16_t nfp_net_vec_avx2_recv_pkts(void *rx_queue,

123