| /f-stack/dpdk/examples/server_node_efd/server/ |
| H A D | main.c | 252 uint16_t rx_count, unsigned int socket_id) in process_packets() argument
262 for (i = 0; i < rx_count; i++) { in process_packets()
270 rte_efd_lookup_bulk(efd_table, socket_id, rx_count, in process_packets()
272 for (i = 0; i < rx_count; i++) { in process_packets()
303 uint16_t rx_count; in do_packet_forwarding() local
306 rx_count = rte_eth_rx_burst(info->id[port_num], 0, in do_packet_forwarding()
308 info->rx_stats.rx[port_num] += rx_count; in do_packet_forwarding()
311 if (likely(rx_count > 0)) in do_packet_forwarding()
312 process_packets(port_num, buf, rx_count, socket_id); in do_packet_forwarding()
|
| /f-stack/dpdk/examples/multi_process/client_server_mp/mp_server/ |
| H A D | main.c | 233 struct rte_mbuf *pkts[], uint16_t rx_count) in process_packets() argument
238 for (i = 0; i < rx_count; i++) { in process_packets()
259 uint16_t rx_count; in do_packet_forwarding() local
262 rx_count = rte_eth_rx_burst(ports->id[port_num], 0, \ in do_packet_forwarding()
264 ports->rx_stats.rx[port_num] += rx_count; in do_packet_forwarding()
267 if (likely(rx_count > 0)) in do_packet_forwarding()
268 process_packets(port_num, buf, rx_count); in do_packet_forwarding()
|
| /f-stack/dpdk/examples/vhost/ |
| H A D | main.c | 780 unsigned rx_count; in unlink_vmdq() local
792 rx_count = rte_eth_rx_burst(ports[0], in unlink_vmdq()
795 while (rx_count) { in unlink_vmdq()
796 for (i = 0; i < rx_count; i++) in unlink_vmdq()
799 rx_count = rte_eth_rx_burst(ports[0], in unlink_vmdq()
1092 uint16_t rx_count, enqueue_count; in drain_eth_rx() local
1101 if (!rx_count) in drain_eth_rx()
1124 pkts, rx_count); in drain_eth_rx()
1127 VIRTIO_RXQ, pkts, rx_count); in drain_eth_rx()
1131 pkts, rx_count); in drain_eth_rx()
[all …]
|
| /f-stack/freebsd/mips/cavium/octe/ |
| H A D | ethernet-rx.c | 163 int rx_count = 0; in cvm_oct_tasklet_rx() local
183 if ((INTERRUPT_LIMIT == 0) || (rx_count < MAX_RX_PACKETS)) in cvm_oct_tasklet_rx()
200 rx_count++; in cvm_oct_tasklet_rx()
334 if (INTERRUPT_LIMIT != 0 && rx_count == MAX_RX_PACKETS) { in cvm_oct_tasklet_rx()
|
| /f-stack/dpdk/app/test/ |
| H A D | virtual_pmd.c | 332 int rx_count, i; in virtual_ethdev_rx_burst_success() local
338 rx_count = rte_ring_dequeue_burst(dev_private->rx_queue, (void **) bufs, in virtual_ethdev_rx_burst_success()
342 dev_private->eth_stats.ipackets += rx_count; in virtual_ethdev_rx_burst_success()
345 for (i = 0; i < rx_count; i++) in virtual_ethdev_rx_burst_success()
348 return rx_count; in virtual_ethdev_rx_burst_success()
|
| /f-stack/dpdk/doc/guides/sample_app_ug/ |
| H A D | server_node_efd.rst | 187 uint16_t rx_count, unsigned int socket_id)
197 for (i = 0; i < rx_count; i++) {
205 rte_efd_lookup_bulk(efd_table, socket_id, rx_count,
207 for (i = 0; i < rx_count; i++) {
|
| /f-stack/dpdk/drivers/net/szedata2/ |
| H A D | rte_eth_szedata2.c | 69 unsigned int rx_count; member
1518 internals->max_rx_queues = pi->rx_count; in rte_szedata2_eth_dev_init()
1723 if (pi[current].rx_count == 0 && in get_port_info()
1730 pi[current].rx_count) || in get_port_info()
1739 pi[current].rx_count += port_rx_queues; in get_port_info()
1745 pi[0].rx_count = max_rx_queues; in get_port_info()
|
| /f-stack/dpdk/drivers/net/nfp/ |
| H A D | nfp_net_pmd.h | 356 uint16_t rx_count; member
|
| H A D | nfp_net.c | 211 for (i = 0; i < rxq->rx_count; i++) { in nfp_net_rx_queue_release_mbufs()
1330 while (count < rxq->rx_count) { in nfp_net_rx_queue_count()
1339 if ((idx) == rxq->rx_count) in nfp_net_rx_queue_count()
1583 rxq->rx_count = nb_desc; in nfp_net_rx_queue_setup()
1643 rxq->rx_count); in nfp_net_rx_fill_freelist()
1645 for (i = 0; i < rxq->rx_count; i++) { in nfp_net_rx_fill_freelist()
1670 rxq->rx_count - 1); in nfp_net_rx_fill_freelist()
1672 nfp_qcp_ptr_add(rxq->qcp_fl, NFP_QCP_WRITE_PTR, rxq->rx_count - 1); in nfp_net_rx_fill_freelist()
2143 if (unlikely(rxq->rd_p == rxq->rx_count)) /* wrapping?*/ in nfp_net_recv_pkts()
|
| /f-stack/dpdk/drivers/net/bnx2x/ |
| H A D | bnx2x_vfpf.c | 246 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 D | bnx2x.h | 2017 int bnx2x_vf_get_resources(struct bnx2x_softc *sc, uint8_t tx_count, uint8_t rx_count);
|
| /f-stack/dpdk/drivers/net/bonding/ |
| H A D | rte_eth_bond_8023ad.c | 914 uint16_t rx_count = rte_eth_rx_burst(slave_id, in bond_mode_8023ad_periodic_cb() local
918 if (rx_count == 1) in bond_mode_8023ad_periodic_cb()
|
| /f-stack/dpdk/lib/librte_eventdev/ |
| H A D | rte_event_eth_rx_adapter.c | 809 uint32_t rx_count, in rxa_eth_rx() argument
839 if (rx_count + nb_rx > max_rx) in rxa_eth_rx()
|