| /f-stack/dpdk/drivers/net/nfb/ |
| H A D | nfb_rx.h | 148 uint16_t num_rx; in nfb_eth_ndp_rx() local
170 num_rx = ndp_rx_burst_get(ndp->queue, packets, nb_pkts); in nfb_eth_ndp_rx()
172 if (unlikely(num_rx != nb_pkts)) { in nfb_eth_ndp_rx()
173 for (i = num_rx; i < nb_pkts; i++) in nfb_eth_ndp_rx()
177 nb_pkts = num_rx; in nfb_eth_ndp_rx()
179 num_rx = 0; in nfb_eth_ndp_rx()
218 bufs[num_rx++] = mbuf; in nfb_eth_ndp_rx()
231 ndp->rx_pkts += num_rx; in nfb_eth_ndp_rx()
233 return num_rx; in nfb_eth_ndp_rx()
|
| /f-stack/dpdk/kernel/linux/kni/ |
| H A D | kni_net.c | 200 uint32_t ret, i, num_dst, num_rx; in kni_fifo_trans_pa2va() local
212 num_rx = kni_fifo_get(src_pa, kni->pa, num_rx); in kni_fifo_trans_pa2va()
213 if (num_rx == 0) in kni_fifo_trans_pa2va()
216 for (i = 0; i < num_rx; i++) { in kni_fifo_trans_pa2va()
232 ret = kni_fifo_put(dst_va, kni->va, num_rx); in kni_fifo_trans_pa2va()
233 if (ret != num_rx) { in kni_fifo_trans_pa2va()
354 uint32_t i, num_rx, num_fq; in kni_net_rx_normal() local
371 num_rx = kni_fifo_get(kni->rx_q, kni->pa, num_rx); in kni_net_rx_normal()
372 if (num_rx == 0) in kni_net_rx_normal()
376 for (i = 0; i < num_rx; i++) { in kni_net_rx_normal()
[all …]
|
| /f-stack/dpdk/drivers/net/dpaa2/ |
| H A D | dpaa2_rxtx.c | 526 int ret, num_rx = 0, pull_size; in dpaa2_dev_prefetch_rx() local
648 rte_vlan_strip(bufs[num_rx]); in dpaa2_dev_prefetch_rx()
651 num_rx++; in dpaa2_dev_prefetch_rx()
673 dpaa2_q->rx_pkts += num_rx; in dpaa2_dev_prefetch_rx()
675 return num_rx; in dpaa2_dev_prefetch_rx()
862 num_rx++; in dpaa2_dev_rx()
868 dpaa2_q->rx_pkts += num_rx; in dpaa2_dev_rx()
870 return num_rx; in dpaa2_dev_rx()
1616 num_rx++; in dpaa2_dev_loopback_rx()
1619 while (num_tx < num_rx) { in dpaa2_dev_loopback_rx()
[all …]
|
| /f-stack/dpdk/drivers/net/szedata2/ |
| H A D | rte_eth_szedata2.c | 118 uint16_t num_rx = 0; in eth_szedata2_rx() local
322 bufs[num_rx] = mbuf; in eth_szedata2_rx()
323 num_rx++; in eth_szedata2_rx()
339 sze_q->rx_pkts += num_rx; in eth_szedata2_rx()
341 return num_rx; in eth_szedata2_rx()
353 uint16_t num_rx = 0; in eth_szedata2_rx_scattered() local
670 bufs[num_rx] = mbuf; in eth_szedata2_rx_scattered()
671 num_rx++; in eth_szedata2_rx_scattered()
676 sze_q->rx_pkts += num_rx; in eth_szedata2_rx_scattered()
678 return num_rx; in eth_szedata2_rx_scattered()
|
| /f-stack/dpdk/drivers/raw/dpaa2_qdma/ |
| H A D | dpaa2_qdma.c | 591 uint8_t num_rx = 0; in dpdmai_dev_dequeue_multijob_prefetch() local
696 vqid = qdma_vq->get_job(qdma_vq, fd, &job[num_rx], in dpdmai_dev_dequeue_multijob_prefetch()
699 vq_id[num_rx] = vqid; in dpdmai_dev_dequeue_multijob_prefetch()
702 num_rx += num_rx_ret; in dpdmai_dev_dequeue_multijob_prefetch()
725 return num_rx; in dpdmai_dev_dequeue_multijob_prefetch()
745 uint8_t num_rx = 0; in dpdmai_dev_dequeue_multijob_no_prefetch() local
827 &job[num_rx], &num_rx_ret); in dpdmai_dev_dequeue_multijob_no_prefetch()
829 vq_id[num_rx] = vqid; in dpdmai_dev_dequeue_multijob_no_prefetch()
832 num_rx += num_rx_ret; in dpdmai_dev_dequeue_multijob_no_prefetch()
839 return num_rx; in dpdmai_dev_dequeue_multijob_no_prefetch()
|
| /f-stack/dpdk/drivers/net/af_packet/ |
| H A D | rte_eth_af_packet.c | 118 uint16_t num_rx = 0; in eth_af_packet_rx() local
161 num_rx++; in eth_af_packet_rx()
165 pkt_q->rx_pkts += num_rx; in eth_af_packet_rx()
167 return num_rx; in eth_af_packet_rx()
|
| /f-stack/dpdk/drivers/net/pcap/ |
| H A D | rte_eth_pcap.c | 231 uint16_t num_rx = 0; in eth_pcap_rx() local
277 bufs[num_rx] = mbuf; in eth_pcap_rx()
278 num_rx++; in eth_pcap_rx()
281 pcap_q->rx_stat.pkts += num_rx; in eth_pcap_rx()
284 return num_rx; in eth_pcap_rx()
|
| /f-stack/dpdk/drivers/crypto/caam_jr/ |
| H A D | caam_jr.c | 663 int num_rx; in caam_jr_dequeue_burst() local
674 num_rx = hw_poll_job_ring(ring, ops, nb_ops, jr_qp); in caam_jr_dequeue_burst()
675 if (num_rx < 0) { in caam_jr_dequeue_burst()
676 CAAM_JR_ERR("Error polling SEC engine (%d)", num_rx); in caam_jr_dequeue_burst()
680 CAAM_JR_DP_DEBUG("Jr[%p].Jobs notified[%d]. ", ring, num_rx); in caam_jr_dequeue_burst()
683 if (num_rx < nb_ops) { in caam_jr_dequeue_burst()
696 jr_qp->rx_pkts += num_rx; in caam_jr_dequeue_burst()
698 return num_rx; in caam_jr_dequeue_burst()
|
| /f-stack/dpdk/drivers/net/tap/ |
| H A D | rte_eth_tap.c | 419 uint16_t num_rx; in pmd_rx_burst() local
427 for (num_rx = 0; num_rx < nb_pkts; ) { in pmd_rx_burst()
496 bufs[num_rx++] = mbuf; in pmd_rx_burst()
500 rxq->stats.ipackets += num_rx; in pmd_rx_burst()
503 if (trigger && num_rx < nb_pkts) in pmd_rx_burst()
506 return num_rx; in pmd_rx_burst()
|
| /f-stack/dpdk/drivers/net/dpaa/ |
| H A D | dpaa_rxtx.c | 742 uint32_t num_rx = 0, ifid = ((struct dpaa_if *)fq->dpaa_intf)->ifid; in dpaa_eth_queue_rx() local
786 bufs[num_rx++] = dpaa_eth_fd_to_mbuf(&dq->fd, ifid); in dpaa_eth_queue_rx()
791 return num_rx; in dpaa_eth_queue_rx()
|
| /f-stack/dpdk/drivers/crypto/dpaa2_sec/ |
| H A D | dpaa2_sec_dpseci.c | 1639 int ret, num_rx = 0; in dpaa2_sec_dequeue_burst() local
1708 ops[num_rx] = sec_fd_to_mbuf(fd); in dpaa2_sec_dequeue_burst()
1714 ops[num_rx]->status = RTE_CRYPTO_OP_STATUS_ERROR; in dpaa2_sec_dequeue_burst()
1716 ops[num_rx]->status = RTE_CRYPTO_OP_STATUS_SUCCESS; in dpaa2_sec_dequeue_burst()
1719 num_rx++; in dpaa2_sec_dequeue_burst()
1723 dpaa2_qp->rx_vq.rx_pkts += num_rx; in dpaa2_sec_dequeue_burst()
1725 DPAA2_SEC_DP_DEBUG("SEC Received %d Packets\n", num_rx); in dpaa2_sec_dequeue_burst()
1727 return num_rx; in dpaa2_sec_dequeue_burst()
|
| /f-stack/dpdk/drivers/crypto/dpaa_sec/ |
| H A D | dpaa_sec.c | 1916 uint16_t num_rx; in dpaa_sec_dequeue_burst() local
1919 num_rx = dpaa_sec_deq(dpaa_qp, ops, nb_ops); in dpaa_sec_dequeue_burst()
1921 dpaa_qp->rx_pkts += num_rx; in dpaa_sec_dequeue_burst()
1922 dpaa_qp->rx_errs += nb_ops - num_rx; in dpaa_sec_dequeue_burst()
1924 DPAA_SEC_DP_DEBUG("SEC Received %d Packets\n", num_rx); in dpaa_sec_dequeue_burst()
1926 return num_rx; in dpaa_sec_dequeue_burst()
|