Home
last modified time | relevance | path

Searched refs:rx_ring (Results 1 – 25 of 62) sorted by relevance

123

/f-stack/dpdk/drivers/net/enetc/
H A Denetc_rxtx.c134 i = rx_ring->next_to_use; in enetc_refill_rx_ring()
135 mb_pool = rx_ring->mb_pool; in enetc_refill_rx_ring()
136 rx_swbd = &rx_ring->q_swbd[i]; in enetc_refill_rx_ring()
137 rxbd = ENETC_RXBD(*rx_ring, i); in enetc_refill_rx_ring()
166 rx_ring->next_to_alloc = i; in enetc_refill_rx_ring()
167 rx_ring->next_to_use = i; in enetc_refill_rx_ring()
331 i = rx_ring->next_to_clean; in enetc_clean_rx_ring()
335 bd_count = rx_ring->bd_count; in enetc_clean_rx_ring()
362 rx_ring->crc_len; in enetc_clean_rx_ring()
364 rx_ring->crc_len; in enetc_clean_rx_ring()
[all …]
H A Denetc_ethdev.c396 int idx = rx_ring->index; in enetc_setup_rxbdr()
409 rx_ring->mb_pool = mb_pool; in enetc_setup_rxbdr()
412 enetc_refill_rx_ring(rx_ring, (enetc_bd_unused(rx_ring))); in enetc_setup_rxbdr()
428 struct enetc_bdr *rx_ring; in enetc_rx_queue_setup() local
439 if (rx_ring == NULL) { in enetc_rx_queue_setup()
450 rx_ring->ndev = dev; in enetc_rx_queue_setup()
470 rte_free(rx_ring); in enetc_rx_queue_setup()
509 enetc_free_bdr(rx_ring); in enetc_rx_queue_release()
510 rte_free(rx_ring); in enetc_rx_queue_release()
751 struct enetc_bdr *rx_ring; in enetc_rx_queue_start() local
[all …]
H A Denetc.h104 int enetc_refill_rx_ring(struct enetc_bdr *rx_ring, const int buff_cnt);
/f-stack/dpdk/drivers/net/bnxt/
H A Dbnxt_ring.c108 struct bnxt_ring *rx_ring; in bnxt_alloc_rings() local
239 rx_ring = rx_ring_info->rx_ring_struct; in bnxt_alloc_rings()
246 rx_ring->mem_zone = (const void *)mz; in bnxt_alloc_rings()
248 if (!rx_ring->bd) in bnxt_alloc_rings()
250 if (rx_ring->vmem_size) { in bnxt_alloc_rings()
251 rx_ring->vmem = in bnxt_alloc_rings()
264 rx_ring->mem_zone = (const void *)mz; in bnxt_alloc_rings()
266 if (!rx_ring->bd) in bnxt_alloc_rings()
268 if (rx_ring->vmem_size) { in bnxt_alloc_rings()
269 rx_ring->vmem = in bnxt_alloc_rings()
[all …]
H A Dbnxt_rxq.c210 if (!rxq || !rxq->rx_ring) in bnxt_rx_queue_release_mbufs()
213 sw_ring = rxq->rx_ring->rx_buf_ring; in bnxt_rx_queue_release_mbufs()
216 i < rxq->rx_ring->rx_ring_struct->ring_size; i++) { in bnxt_rx_queue_release_mbufs()
225 sw_ring = rxq->rx_ring->ag_buf_ring; in bnxt_rx_queue_release_mbufs()
237 tpa_info = rxq->rx_ring->tpa_info; in bnxt_rx_queue_release_mbufs()
273 if (rxq->rx_ring) { in bnxt_rx_queue_release_op()
274 bnxt_free_ring(rxq->rx_ring->rx_ring_struct); in bnxt_rx_queue_release_op()
275 rte_free(rxq->rx_ring->rx_ring_struct); in bnxt_rx_queue_release_op()
277 bnxt_free_ring(rxq->rx_ring->ag_ring_struct); in bnxt_rx_queue_release_op()
278 rte_free(rxq->rx_ring->ag_ring_struct); in bnxt_rx_queue_release_op()
[all …]
H A Dbnxt_rxr.c134 struct bnxt_rx_ring_info *rxr = rxq->rx_ring; in bnxt_tpa_start()
200 struct bnxt_rx_ring_info *rxr = rxq->rx_ring; in bnxt_prod_ag_mbuf()
223 struct bnxt_rx_ring_info *rxr = rxq->rx_ring; in bnxt_rx_pages()
281 struct bnxt_rx_ring_info *rxr = rxq->rx_ring; in bnxt_tpa_end()
665 struct bnxt_rx_ring_info *rxr = rxq->rx_ring; in bnxt_rx_pkt()
975 rte_free(rxq->rx_ring->rx_ring_struct); in bnxt_free_rx_rings()
979 rte_free(rxq->rx_ring->ag_ring_struct); in bnxt_free_rx_rings()
980 rxq->rx_ring->ag_ring_struct = NULL; in bnxt_free_rx_rings()
982 rte_free(rxq->rx_ring); in bnxt_free_rx_rings()
1009 rxq->rx_ring = rxr; in bnxt_init_rx_ring_struct()
[all …]
H A Dbnxt_reps.c54 rep_rxr = rep_rxq->rx_ring; in bnxt_vfr_recv()
88 rxr = rxq->rx_ring; in bnxt_rep_rx_burst()
574 rxq->rx_ring = rxr; in bnxt_init_rep_rx_ring()
652 rxq->rx_ring->rx_ring_struct->ring_size, in bnxt_rep_rx_queue_setup_op()
660 rxq->rx_ring->rx_buf_ring = buf_ring; in bnxt_rep_rx_queue_setup_op()
683 bnxt_free_ring(rxq->rx_ring->rx_ring_struct); in bnxt_rep_rx_queue_release_op()
684 rte_free(rxq->rx_ring->rx_ring_struct); in bnxt_rep_rx_queue_release_op()
685 rte_free(rxq->rx_ring); in bnxt_rep_rx_queue_release_op()
H A Dbnxt_rxq.h39 struct bnxt_rx_ring_info *rx_ring; member
/f-stack/freebsd/contrib/octeon-sdk/
H A Dcvmx-mgmt-port.c100 cvmx_mgmt_port_ring_entry_t rx_ring[CVMX_MGMT_PORT_NUM_RX_BUFFERS]; member
301 state->rx_ring[i].s.len = CVMX_MGMT_PORT_RX_BUFFER_SIZE - 8; in cvmx_mgmt_port_initialize()
307 iring1.s.ibase = cvmx_ptr_to_phys(state->rx_ring)>>3; in cvmx_mgmt_port_initialize()
680 while (state->rx_ring[state->rx_read_index].s.code == 16) in cvmx_mgmt_port_receive()
683 int length = state->rx_ring[state->rx_read_index].s.len; in cvmx_mgmt_port_receive()
694 state->rx_ring[state->rx_read_index].s.code = 0; in cvmx_mgmt_port_receive()
707 if (state->rx_ring[state->rx_read_index].s.code == 15) in cvmx_mgmt_port_receive()
711 int length = state->rx_ring[state->rx_read_index].s.len; in cvmx_mgmt_port_receive()
725 … state->rx_ring[state->rx_read_index].s.code, state->rx_ring[state->rx_read_index].s.len + result); in cvmx_mgmt_port_receive()
726 result = -state->rx_ring[state->rx_read_index].s.code; in cvmx_mgmt_port_receive()
[all …]
/f-stack/dpdk/drivers/net/ena/
H A Dena_ethdev.c392 ++rx_ring->rx_stats.bad_req_id; in validate_rx_req_id()
812 queues = adapter->rx_ring; in ena_queue_start_all()
1207 queues = adapter->rx_ring; in ena_queue_stop_all()
1351 rxq = &adapter->rx_ring[queue_idx]; in ena_rx_queue_setup()
2126 mbuf_head->port = rx_ring->port_id; in ena_rx_mbuf()
2214 descs_in_use = rx_ring->ring_size - in eth_ena_recv_pkts()
2225 rx_ring->ena_com_io_sq, in eth_ena_recv_pkts()
2229 rx_ring->adapter->reset_reason = in eth_ena_recv_pkts()
2236 mbuf = ena_rx_mbuf(rx_ring, in eth_ena_recv_pkts()
2244 rx_ring->ena_bufs[i].req_id; in eth_ena_recv_pkts()
[all …]
/f-stack/dpdk/examples/multi_process/client_server_mp/mp_client/
H A Dclient.c207 struct rte_ring *rx_ring; in main() local
226 rx_ring = rte_ring_lookup(get_rx_queue_name(client_id)); in main()
227 if (rx_ring == NULL) in main()
250 rx_pkts = rte_ring_dequeue_burst(rx_ring, pkts, in main()
/f-stack/dpdk/app/pdump/
H A Dmain.c123 struct rte_ring *rx_ring; member
509 if (pt->rx_ring) in cleanup_rings()
510 rte_ring_free(pt->rx_ring); in cleanup_rings()
667 pt->rx_ring = rte_ring_create(ring_name, pt->ring_size, in create_mp_ring_vdev()
669 if (pt->rx_ring == NULL) { in create_mp_ring_vdev()
752 if (pt->rx_ring == NULL) { in create_mp_ring_vdev()
839 pt->rx_ring, in enable_pdump()
850 pt->rx_ring, pt->mp, NULL); in enable_pdump()
860 pt->dir, pt->rx_ring, in enable_pdump()
865 pt->rx_ring, pt->mp, NULL); in enable_pdump()
[all …]
/f-stack/dpdk/examples/server_node_efd/node/
H A Dnode.c305 struct rte_ring *rx_ring; in main() local
326 rx_ring = rte_ring_lookup(get_rx_queue_name(node_id)); in main()
327 if (rx_ring == NULL) in main()
363 unlikely(rte_ring_dequeue_bulk(rx_ring, pkts, in main()
365 rx_pkts = (uint16_t)RTE_MIN(rte_ring_count(rx_ring), in main()
/f-stack/dpdk/examples/qos_sched/
H A Dmain.c56 flow->rx_thread.rx_ring = flow->rx_ring; in app_main_loop()
74 flow->wt_thread.rx_ring = flow->rx_ring; in app_main_loop()
H A Dapp_thread.c92 if (unlikely(rte_ring_sp_enqueue_bulk(conf->rx_ring, in app_rx_thread()
203 nb_pkt = rte_ring_sc_dequeue_burst(conf->rx_ring, (void **)mbufs, in app_worker_thread()
239 nb_pkt = rte_ring_sc_dequeue_burst(conf->rx_ring, (void **)mbufs, in app_mixed_thread()
H A Dmain.h86 struct rte_ring *rx_ring; member
105 struct rte_ring *rx_ring; member
/f-stack/dpdk/drivers/net/e1000/
H A Dem_rxtx.c700 rx_ring = rxq->rx_ring; in eth_em_recv_pkts()
711 rxdp = &rx_ring[rx_id]; in eth_em_recv_pkts()
774 rte_em_prefetch(&rx_ring[rx_id]); in eth_em_recv_pkts()
876 rx_ring = rxq->rx_ring; in eth_em_recv_scattered_pkts()
895 rxdp = &rx_ring[rx_id]; in eth_em_recv_scattered_pkts()
953 rte_em_prefetch(&rx_ring[rx_id]); in eth_em_recv_scattered_pkts()
1527 rxdp = &rxq->rx_ring[desc]; in eth_em_rx_descriptor_done()
1548 status = &rxq->rx_ring[desc].status; in eth_em_rx_descriptor_status()
1720 rxq->rx_ring[i] = rxd_init; in em_alloc_rx_queue_mbufs()
1722 rxd = &rxq->rx_ring[i]; in em_alloc_rx_queue_mbufs()
[all …]
H A Digb_rxtx.c828 rx_ring = rxq->rx_ring; in eth_igb_recv_pkts()
839 rxdp = &rx_ring[rx_id]; in eth_igb_recv_pkts()
901 rte_igb_prefetch(&rx_ring[rx_id]); in eth_igb_recv_pkts()
1015 rx_ring = rxq->rx_ring; in eth_igb_recv_scattered_pkts()
1034 rxdp = &rx_ring[rx_id]; in eth_igb_recv_scattered_pkts()
1092 rte_igb_prefetch(&rx_ring[rx_id]); in eth_igb_recv_scattered_pkts()
1622 rxq->rx_ring[i] = zeroed_desc; in igb_reset_rx_queue()
1780 rxdp = &(rxq->rx_ring[rxq->rx_tail]); in eth_igb_rx_queue_count()
1787 rxdp = &(rxq->rx_ring[rxq->rx_tail + in eth_igb_rx_queue_count()
1807 rxdp = &rxq->rx_ring[desc]; in eth_igb_rx_descriptor_done()
[all …]
/f-stack/dpdk/drivers/net/hns3/
H A Dhns3_rxtx_vec.c54 struct hns3_desc *rxdp = rxq->rx_ring + rxq->rx_rearm_start; in hns3_rxq_rearm_mbuf()
106 struct hns3_desc *rxdp = &rxq->rx_ring[rxq->next_to_use]; in hns3_recv_pkts_vec()
158 memset(&rxq->rx_ring[rxq->nb_rx_desc], 0, in hns3_rxq_vec_setup()
/f-stack/dpdk/drivers/net/iavf/
H A Diavf_rxtx.c262 rxd = &rxq->rx_ring[i]; in alloc_rxq_mbufs()
1128 rx_ring = rxq->rx_ring; in iavf_recv_pkts()
1132 rxdp = &rx_ring[rx_id]; in iavf_recv_pkts()
1166 rte_prefetch0(&rx_ring[rx_id]); in iavf_recv_pkts()
1235 rx_ring = rxq->rx_ring; in iavf_recv_pkts_flex_rxd()
1271 rte_prefetch0(&rx_ring[rx_id]); in iavf_recv_pkts_flex_rxd()
1325 volatile union iavf_rx_desc *rx_ring = rxq->rx_ring; in iavf_recv_scattered_pkts_flex_rxd() local
1362 rte_prefetch0(&rx_ring[rx_id]); in iavf_recv_scattered_pkts_flex_rxd()
1476 volatile union iavf_rx_desc *rx_ring = rxq->rx_ring; in iavf_recv_scattered_pkts() local
1481 rxdp = &rx_ring[rx_id]; in iavf_recv_scattered_pkts()
[all …]
/f-stack/dpdk/drivers/net/bnx2x/
H A Dbnx2x_rxtx.c99 rxq->rx_ring = (uint64_t*)dma->addr; in bnx2x_dev_rx_queue_setup()
100 memset((void *)rxq->rx_ring, 0, dma_size); in bnx2x_dev_rx_queue_setup()
104 rx_bd = &rxq->rx_ring[TOTAL_RX_BD_PER_PAGE * j - 2]; in bnx2x_dev_rx_queue_setup()
130 rxq->rx_ring[idx] = in bnx2x_dev_rx_queue_setup()
413 rxq->rx_ring[bd_prod] = in bnx2x_recv_pkts()
419 rte_prefetch0(&rxq->rx_ring[rx_pref]); in bnx2x_recv_pkts()
H A Dbnx2x_rxtx.h28 uint64_t *rx_ring; /**< RX ring virtual address. */ member
/f-stack/dpdk/drivers/net/igc/
H A Digc_txrx.c108 volatile union igc_adv_rx_desc *rx_ring; member
350 volatile union igc_adv_rx_desc * const rx_ring = rxq->rx_ring; in igc_recv_pkts() local
373 rxdp = &rx_ring[rx_id]; in igc_recv_pkts()
436 rte_igc_prefetch(&rx_ring[rx_id]); in igc_recv_pkts()
494 volatile union igc_adv_rx_desc * const rx_ring = rxq->rx_ring; in igc_recv_scattered_pkts() local
521 rxdp = &rx_ring[rx_id]; in igc_recv_scattered_pkts()
580 rte_igc_prefetch(&rx_ring[rx_id]); in igc_recv_scattered_pkts()
739 rxdp = &rxq->rx_ring[rxq->rx_tail]; in eth_igc_rx_queue_count()
772 rxdp = &rxq->rx_ring[desc]; in eth_igc_rx_descriptor_done()
818 rxd = &rxq->rx_ring[i]; in igc_alloc_rx_queue_mbufs()
[all …]
/f-stack/dpdk/drivers/net/netvsc/
H A Dhn_rxtx.c923 qinfo->nb_desc = rxq->rx_ring->size; in hn_dev_rx_queue_info()
962 rxq->rx_ring = rte_ring_create(ring_name, in hn_dev_rx_queue_setup()
965 if (!rxq->rx_ring) in hn_dev_rx_queue_setup()
977 rte_ring_free(rxq->rx_ring); in hn_dev_rx_queue_setup()
991 rte_ring_free(rxq->rx_ring); in hn_rx_queue_free()
992 rxq->rx_ring = NULL; in hn_rx_queue_free()
1025 return rte_ring_count(rxq->rx_ring); in hn_dev_rx_queue_count()
1041 if (offset >= rxq->rx_ring->capacity) in hn_dev_rx_queue_status()
1044 if (offset < rte_ring_count(rxq->rx_ring)) in hn_dev_rx_queue_status()
1609 if (likely(rte_ring_count(rxq->rx_ring) < nb_pkts)) in hn_recv_pkts()
[all …]
/f-stack/dpdk/drivers/net/i40e/
H A Di40e_rxtx.c426 rxdp = &rxq->rx_ring[rxq->rx_tail]; in i40e_rx_scan_hw_ring()
543 rxdp = &rxq->rx_ring[alloc_idx]; in i40e_rx_alloc_bufs()
654 volatile union i40e_rx_desc *rx_ring; in i40e_recv_pkts() local
675 rx_ring = rxq->rx_ring; in i40e_recv_pkts()
680 rxdp = &rx_ring[rx_id]; in i40e_recv_pkts()
712 rte_prefetch0(&rx_ring[rx_id]); in i40e_recv_pkts()
778 volatile union i40e_rx_desc *rx_ring = rxq->rx_ring; in i40e_recv_scattered_pkts() local
796 rxdp = &rx_ring[rx_id]; in i40e_recv_scattered_pkts()
828 rte_prefetch0(&rx_ring[rx_id]); in i40e_recv_scattered_pkts()
2053 rxdp = &(rxq->rx_ring[desc]); in i40e_dev_rx_descriptor_done()
[all …]

123