Searched refs:nb_bufs (Results 1 - 13 of 13) sorted by relevance

/deb_dpdk/drivers/net/ixgbe/
H A Dixgbe_rxtx_vec_neon.c407 uint16_t nb_bufs = _recv_raw_pkts_vec(rxq, rx_pkts, nb_pkts, local
409 if (nb_bufs == 0)
417 return nb_bufs;
423 while (i < nb_bufs && !split_flags[i])
425 if (i == nb_bufs)
426 return nb_bufs;
428 return i + reassemble_packets(rxq, &rx_pkts[i], nb_bufs - i,
H A Dixgbe_rxtx_vec_sse.c502 uint16_t nb_bufs = _recv_raw_pkts_vec(rxq, rx_pkts, nb_pkts, local
504 if (nb_bufs == 0)
512 return nb_bufs;
518 while (i < nb_bufs && !split_flags[i])
520 if (i == nb_bufs)
521 return nb_bufs;
523 return i + reassemble_packets(rxq, &rx_pkts[i], nb_bufs - i,
H A Dixgbe_rxtx_vec_common.h44 uint16_t nb_bufs, uint8_t *split_flags)
46 struct rte_mbuf *pkts[nb_bufs]; /*finished pkts*/
51 for (buf_idx = 0, pkt_idx = 0; buf_idx < nb_bufs; buf_idx++) {
43 reassemble_packets(struct ixgbe_rx_queue *rxq, struct rte_mbuf **rx_bufs, uint16_t nb_bufs, uint8_t *split_flags) argument
/deb_dpdk/app/test/
H A Dtest_distributor_perf.c242 const unsigned nb_bufs = (511 * rte_lcore_count()) < BIG_BATCH ? local
245 p = rte_pktmbuf_pool_create("DPT_MBUF_POOL", nb_bufs, BURST,
H A Dtest_distributor.c528 const unsigned nb_bufs = (511 * rte_lcore_count()) < BIG_BATCH ? local
531 p = rte_pktmbuf_pool_create("DT_MBUF_POOL", nb_bufs, BURST,
/deb_dpdk/drivers/net/null/
H A Drte_eth_null.c100 eth_null_rx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
110 for (i = 0; i < nb_bufs; i++) {
127 eth_null_copy_rx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
137 for (i = 0; i < nb_bufs; i++) {
156 eth_null_tx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
164 for (i = 0; i < nb_bufs; i++)
173 eth_null_copy_tx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
183 for (i = 0; i < nb_bufs; i++) {
/deb_dpdk/drivers/net/i40e/
H A Di40e_rxtx_vec_neon.c481 uint16_t nb_bufs = _recv_raw_pkts_vec(rxq, rx_pkts, nb_pkts, local
483 if (nb_bufs == 0)
492 return nb_bufs;
499 while (i < nb_bufs && !split_flags[i])
501 if (i == nb_bufs)
502 return nb_bufs;
504 return i + reassemble_packets(rxq, &rx_pkts[i], nb_bufs - i,
H A Di40e_rxtx_vec_sse.c496 uint16_t nb_bufs = _recv_raw_pkts_vec(rxq, rx_pkts, nb_pkts, local
498 if (nb_bufs == 0)
507 return nb_bufs;
514 while (i < nb_bufs && !split_flags[i])
516 if (i == nb_bufs)
517 return nb_bufs;
519 return i + reassemble_packets(rxq, &rx_pkts[i], nb_bufs - i,
H A Di40e_rxtx_vec_altivec.c514 uint16_t nb_bufs = _recv_raw_pkts_vec(rxq, rx_pkts, nb_pkts, local
516 if (nb_bufs == 0)
525 return nb_bufs;
532 while (i < nb_bufs && !split_flags[i])
534 if (i == nb_bufs)
535 return nb_bufs;
537 return i + reassemble_packets(rxq, &rx_pkts[i], nb_bufs - i,
H A Di40e_rxtx_vec_common.h45 uint16_t nb_bufs, uint8_t *split_flags)
52 for (buf_idx = 0, pkt_idx = 0; buf_idx < nb_bufs; buf_idx++) {
44 reassemble_packets(struct i40e_rx_queue *rxq, struct rte_mbuf **rx_bufs, uint16_t nb_bufs, uint8_t *split_flags) argument
/deb_dpdk/drivers/net/ring/
H A Drte_eth_ring.c87 eth_ring_rx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
92 ptrs, nb_bufs);
101 eth_ring_tx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
106 ptrs, nb_bufs);
109 r->err_pkts.cnt += nb_bufs - nb_tx;
112 rte_atomic64_add(&(r->err_pkts), nb_bufs - nb_tx);
/deb_dpdk/drivers/net/fm10k/
H A Dfm10k_rxtx_vec.c613 uint16_t nb_bufs, uint8_t *split_flags)
620 for (buf_idx = 0, pkt_idx = 0; buf_idx < nb_bufs; buf_idx++) {
676 uint16_t nb_bufs = fm10k_recv_raw_pkts_vec(rxq, rx_pkts, nb_pkts, local
678 if (nb_bufs == 0)
687 return nb_bufs;
692 while (i < nb_bufs && !split_flags[i])
694 if (i == nb_bufs)
695 return nb_bufs;
697 return i + fm10k_reassemble_packets(rxq, &rx_pkts[i], nb_bufs - i,
611 fm10k_reassemble_packets(struct fm10k_rx_queue *rxq, struct rte_mbuf **rx_bufs, uint16_t nb_bufs, uint8_t *split_flags) argument
/deb_dpdk/drivers/net/vhost/
H A Drte_eth_vhost.c391 eth_vhost_rx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
406 r->virtqueue_id, r->mb_pool, bufs, nb_bufs);
424 eth_vhost_tx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
439 r->virtqueue_id, bufs, nb_bufs);
442 r->stats.missed_pkts += nb_bufs - nb_tx;
453 for (i = nb_tx; i < nb_bufs; i++)

Completed in 12 milliseconds