MCPcopy Create free account
hub / github.com/F-Stack/f-stack / flush_one_port

Function flush_one_port

dpdk/examples/distributor/main.c:374–388  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

372}
373
374static inline void
375flush_one_port(struct output_buffer *outbuf, uint8_t outp)
376{
377 unsigned int nb_tx = rte_eth_tx_burst(outp, 0,
378 outbuf->mbufs, outbuf->count);
379 app_stats.tx.tx_pkts += outbuf->count;
380
381 if (unlikely(nb_tx < outbuf->count)) {
382 app_stats.tx.enqdrop_pkts += outbuf->count - nb_tx;
383 do {
384 rte_pktmbuf_free(outbuf->mbufs[nb_tx]);
385 } while (++nb_tx < outbuf->count);
386 }
387 outbuf->count = 0;
388}
389
390static inline void
391flush_all_ports(struct output_buffer *tx_buffers)

Callers 2

flush_all_portsFunction · 0.85
lcore_txFunction · 0.85

Calls 2

rte_eth_tx_burstFunction · 0.85
rte_pktmbuf_freeFunction · 0.85

Tested by

no test coverage detected