Home
last modified time | relevance | path

Searched refs:num_rx (Results 1 – 13 of 13) sorted by relevance

/dpdk/drivers/net/nfb/
H A Dnfb_rx.h148 uint16_t num_rx; in nfb_eth_ndp_rx() local
168 num_rx = ndp_rx_burst_get(ndp->queue, packets, nb_pkts); in nfb_eth_ndp_rx()
170 if (unlikely(num_rx != nb_pkts)) { in nfb_eth_ndp_rx()
171 for (i = num_rx; i < nb_pkts; i++) in nfb_eth_ndp_rx()
175 nb_pkts = num_rx; in nfb_eth_ndp_rx()
177 num_rx = 0; in nfb_eth_ndp_rx()
216 bufs[num_rx++] = mbuf; in nfb_eth_ndp_rx()
229 ndp->rx_pkts += num_rx; in nfb_eth_ndp_rx()
231 return num_rx; in nfb_eth_ndp_rx()
/dpdk/kernel/linux/kni/
H A Dkni_net.c230 uint32_t ret, i, num_dst, num_rx; in kni_fifo_trans_pa2va() local
242 num_rx = kni_fifo_get(src_pa, kni->pa, num_rx); in kni_fifo_trans_pa2va()
243 if (num_rx == 0) in kni_fifo_trans_pa2va()
246 for (i = 0; i < num_rx; i++) { in kni_fifo_trans_pa2va()
262 ret = kni_fifo_put(dst_va, kni->va, num_rx); in kni_fifo_trans_pa2va()
263 if (ret != num_rx) { in kni_fifo_trans_pa2va()
384 uint32_t i, num_rx, num_fq; in kni_net_rx_normal() local
401 num_rx = kni_fifo_get(kni->rx_q, kni->pa, num_rx); in kni_net_rx_normal()
402 if (num_rx == 0) in kni_net_rx_normal()
406 for (i = 0; i < num_rx; i++) { in kni_net_rx_normal()
[all …]
/dpdk/drivers/net/dpaa2/
H A Ddpaa2_rxtx.c679 num_rx++; in dump_err_pkts()
683 dpaa2_q->err_pkts += num_rx; in dump_err_pkts()
828 num_rx++; in dpaa2_dev_prefetch_rx()
850 dpaa2_q->rx_pkts += num_rx; in dpaa2_dev_prefetch_rx()
852 return num_rx; in dpaa2_dev_prefetch_rx()
1050 num_rx++; in dpaa2_dev_rx()
1056 dpaa2_q->rx_pkts += num_rx; in dpaa2_dev_rx()
1058 return num_rx; in dpaa2_dev_rx()
1977 num_rx++; in dpaa2_dev_loopback_rx()
1980 while (num_tx < num_rx) { in dpaa2_dev_loopback_rx()
[all …]
/dpdk/drivers/crypto/dpaa2_sec/
H A Ddpaa2_sec_raw_dp.c865 int ret, num_rx = 0; in dpaa2_sec_raw_dequeue_burst() local
938 out_user_data[num_rx] = user_data; in dpaa2_sec_raw_dequeue_burst()
949 post_dequeue(user_data, num_rx, is_success); in dpaa2_sec_raw_dequeue_burst()
951 num_rx++; in dpaa2_sec_raw_dequeue_burst()
955 dpaa2_qp->rx_vq.rx_pkts += num_rx; in dpaa2_sec_raw_dequeue_burst()
957 *n_success = num_rx; in dpaa2_sec_raw_dequeue_burst()
959 DPAA2_SEC_DP_DEBUG("SEC Received %d Packets\n", num_rx); in dpaa2_sec_raw_dequeue_burst()
961 return num_rx; in dpaa2_sec_raw_dequeue_burst()
H A Ddpaa2_sec_dpseci.c1927 int ret, num_rx = 0; in dpaa2_sec_dequeue_burst() local
1996 ops[num_rx] = sec_fd_to_mbuf(fd, dpaa2_qp); in dpaa2_sec_dequeue_burst()
2004 dpaa2_sec_dump(ops[num_rx]); in dpaa2_sec_dequeue_burst()
2008 ops[num_rx]->status = RTE_CRYPTO_OP_STATUS_ERROR; in dpaa2_sec_dequeue_burst()
2010 ops[num_rx]->status = RTE_CRYPTO_OP_STATUS_SUCCESS; in dpaa2_sec_dequeue_burst()
2013 num_rx++; in dpaa2_sec_dequeue_burst()
2017 dpaa2_qp->rx_vq.rx_pkts += num_rx; in dpaa2_sec_dequeue_burst()
2019 DPAA2_SEC_DP_DEBUG("SEC RX pkts %d err pkts %" PRIu64 "\n", num_rx, in dpaa2_sec_dequeue_burst()
2022 return num_rx; in dpaa2_sec_dequeue_burst()
/dpdk/drivers/raw/dpaa2_qdma/
H A Ddpaa2_qdma.c591 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()
/dpdk/drivers/crypto/dpaa_sec/
H A Ddpaa_sec_raw_dp.c944 uint16_t num_rx; in dpaa_sec_raw_dequeue_burst() local
955 num_rx = dpaa_sec_deq_raw(dpaa_qp, out_user_data, in dpaa_sec_raw_dequeue_burst()
958 dpaa_qp->rx_pkts += num_rx; in dpaa_sec_raw_dequeue_burst()
960 *n_success = num_rx; in dpaa_sec_raw_dequeue_burst()
962 DPAA_SEC_DP_DEBUG("SEC Received %d Packets\n", num_rx); in dpaa_sec_raw_dequeue_burst()
964 return num_rx; in dpaa_sec_raw_dequeue_burst()
H A Ddpaa_sec.c2108 uint16_t num_rx; in dpaa_sec_dequeue_burst() local
2118 num_rx = dpaa_sec_deq(dpaa_qp, ops, nb_ops); in dpaa_sec_dequeue_burst()
2120 dpaa_qp->rx_pkts += num_rx; in dpaa_sec_dequeue_burst()
2121 dpaa_qp->rx_errs += nb_ops - num_rx; in dpaa_sec_dequeue_burst()
2123 DPAA_SEC_DP_DEBUG("SEC Received %d Packets\n", num_rx); in dpaa_sec_dequeue_burst()
2125 return num_rx; in dpaa_sec_dequeue_burst()
/dpdk/drivers/net/af_packet/
H A Drte_eth_af_packet.c120 uint16_t num_rx = 0; in eth_af_packet_rx() local
166 num_rx++; in eth_af_packet_rx()
170 pkt_q->rx_pkts += num_rx; in eth_af_packet_rx()
172 return num_rx; in eth_af_packet_rx()
/dpdk/drivers/net/pcap/
H A Dpcap_ethdev.c281 uint16_t num_rx = 0; in eth_pcap_rx() local
330 bufs[num_rx] = mbuf; in eth_pcap_rx()
331 num_rx++; in eth_pcap_rx()
334 pcap_q->rx_stat.pkts += num_rx; in eth_pcap_rx()
337 return num_rx; in eth_pcap_rx()
/dpdk/drivers/crypto/caam_jr/
H A Dcaam_jr.c663 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()
/dpdk/drivers/net/tap/
H A Drte_eth_tap.c420 uint16_t num_rx; in pmd_rx_burst() local
428 for (num_rx = 0; num_rx < nb_pkts; ) { in pmd_rx_burst()
497 bufs[num_rx++] = mbuf; in pmd_rx_burst()
501 rxq->stats.ipackets += num_rx; in pmd_rx_burst()
504 if (trigger && num_rx < nb_pkts) in pmd_rx_burst()
507 return num_rx; in pmd_rx_burst()
/dpdk/drivers/net/dpaa/
H A Ddpaa_rxtx.c742 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()