Home
last modified time | relevance | path

Searched refs:rx_count (Results 1 – 10 of 10) sorted by relevance

/dpdk/examples/server_node_efd/server/
H A Dmain.c259 uint16_t rx_count, unsigned int socket_id) in process_packets() argument
269 for (i = 0; i < rx_count; i++) { in process_packets()
277 rte_efd_lookup_bulk(efd_table, socket_id, rx_count, in process_packets()
279 for (i = 0; i < rx_count; i++) { in process_packets()
311 uint16_t rx_count; in do_packet_forwarding() local
314 rx_count = rte_eth_rx_burst(info->id[port_num], 0, in do_packet_forwarding()
316 info->rx_stats.rx[port_num] += rx_count; in do_packet_forwarding()
319 if (likely(rx_count > 0)) in do_packet_forwarding()
320 process_packets(port_num, buf, rx_count, socket_id); in do_packet_forwarding()
/dpdk/examples/multi_process/client_server_mp/mp_server/
H A Dmain.c234 struct rte_mbuf *pkts[], uint16_t rx_count) in process_packets() argument
239 for (i = 0; i < rx_count; i++) { in process_packets()
260 uint16_t rx_count; in do_packet_forwarding() local
263 rx_count = rte_eth_rx_burst(ports->id[port_num], 0, \ in do_packet_forwarding()
265 ports->rx_stats.rx[port_num] += rx_count; in do_packet_forwarding()
268 if (likely(rx_count > 0)) in do_packet_forwarding()
269 process_packets(port_num, buf, rx_count); in do_packet_forwarding()
/dpdk/examples/vhost/
H A Dmain.c954 unsigned rx_count; in unlink_vmdq() local
966 rx_count = rte_eth_rx_burst(ports[0], in unlink_vmdq()
969 while (rx_count) { in unlink_vmdq()
970 for (i = 0; i < rx_count; i++) in unlink_vmdq()
973 rx_count = rte_eth_rx_burst(ports[0], in unlink_vmdq()
1331 uint16_t rx_count, enqueue_count; in drain_eth_rx() local
1337 if (!rx_count) in drain_eth_rx()
1360 pkts, rx_count); in drain_eth_rx()
1369 enqueue_fail = rx_count - enqueue_count; in drain_eth_rx()
1375 pkts, rx_count); in drain_eth_rx()
[all …]
/dpdk/drivers/net/nfp/
H A Dnfp_rxtx.c53 rxq->rx_count); in nfp_net_rx_fill_freelist()
55 for (i = 0; i < rxq->rx_count; i++) { in nfp_net_rx_fill_freelist()
80 rxq->rx_count - 1); in nfp_net_rx_fill_freelist()
82 nfp_qcp_ptr_add(rxq->qcp_fl, NFP_QCP_WRITE_PTR, rxq->rx_count - 1); in nfp_net_rx_fill_freelist()
121 while (count < rxq->rx_count) { in nfp_net_rx_queue_count()
130 if ((idx) == rxq->rx_count) in nfp_net_rx_queue_count()
421 if (unlikely(rxq->rd_p == rxq->rx_count)) /* wrapping?*/ in nfp_net_recv_pkts()
458 for (i = 0; i < rxq->rx_count; i++) { in nfp_net_rx_queue_release_mbufs()
545 rxq->rx_count = nb_desc; in nfp_net_rx_queue_setup()
H A Dnfp_rxtx.h248 uint16_t rx_count; member
/dpdk/app/test/
H A Dvirtual_pmd.c320 int rx_count, i; in virtual_ethdev_rx_burst_success() local
326 rx_count = rte_ring_dequeue_burst(dev_private->rx_queue, (void **) bufs, in virtual_ethdev_rx_burst_success()
330 dev_private->eth_stats.ipackets += rx_count; in virtual_ethdev_rx_burst_success()
333 for (i = 0; i < rx_count; i++) in virtual_ethdev_rx_burst_success()
336 return rx_count; in virtual_ethdev_rx_burst_success()
/dpdk/drivers/net/bnx2x/
H A Dbnx2x_vfpf.c246 int bnx2x_vf_get_resources(struct bnx2x_softc *sc, uint8_t tx_count, uint8_t rx_count) in bnx2x_vf_get_resources() argument
262 acq->res_query.num_rxqs = rx_count; in bnx2x_vf_get_resources()
H A Dbnx2x.h2018 int bnx2x_vf_get_resources(struct bnx2x_softc *sc, uint8_t tx_count, uint8_t rx_count);
/dpdk/drivers/net/bonding/
H A Drte_eth_bond_8023ad.c847 uint16_t rx_count = rte_eth_rx_burst(slave_id, in bond_mode_8023ad_dedicated_rxq_process() local
851 if (rx_count) { in bond_mode_8023ad_dedicated_rxq_process()
854 for (i = 0; i < rx_count; i++) in bond_mode_8023ad_dedicated_rxq_process()
/dpdk/lib/eventdev/
H A Drte_event_eth_rx_adapter.c1026 uint16_t queue_id, uint32_t rx_count, uint32_t max_rx, in rxa_eth_rx() argument
1055 if (rx_count + nb_rx > max_rx) in rxa_eth_rx()