nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue,
pkts_burst, nb_pkt_per_burst);
+ inc_rx_burst_stats(fs, nb_rx);
if (unlikely(nb_rx == 0))
goto flush;
fs->rx_packets += nb_rx;
pkts_burst, nb_rx);
if (unlikely(nb_tx < nb_rx) && fs->retry_enabled)
nb_tx += do_retry(nb_rx, nb_tx, pkts_burst, fs);
+ inc_tx_burst_stats(fs, nb_tx);
fs->tx_packets += nb_tx;
fs->fwd_dropped += drop_pkts(pkts_burst, nb_rx, nb_tx);
return;
nb_deqd);
if (unlikely(nb_tx < nb_rx) && fs->retry_enabled)
nb_tx += do_retry(nb_rx, nb_tx, tmp_pkts, fs);
+ inc_tx_burst_stats(fs, nb_tx);
fs->fwd_dropped += drop_pkts(tmp_pkts, nb_deqd, nb_tx);
}
}
tmp_pkts, nb_deqd);
if (unlikely(sent < nb_deqd) && fs->retry_enabled)
nb_tx += do_retry(nb_rx, nb_tx, tmp_pkts, fs);
+ inc_tx_burst_stats(fs, nb_tx);
fs->fwd_dropped += drop_pkts(tmp_pkts, nb_deqd, sent);
ncf->prev_time = rte_get_timer_cycles();
}