| 863 | } |
| 864 | |
| 865 | static inline uint16_t |
| 866 | common_fwd_stream_receive(struct fwd_stream *fs, struct rte_mbuf **burst, |
| 867 | unsigned int nb_pkts) |
| 868 | { |
| 869 | uint16_t nb_rx; |
| 870 | |
| 871 | nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, burst, nb_pkts); |
| 872 | if (record_burst_stats) |
| 873 | fs->rx_burst_stats.pkt_burst_spread[nb_rx]++; |
| 874 | fs->rx_packets += nb_rx; |
| 875 | return nb_rx; |
| 876 | } |
| 877 | |
| 878 | static inline uint16_t |
| 879 | common_fwd_stream_transmit(struct fwd_stream *fs, struct rte_mbuf **burst, |
no test coverage detected