Send burst of outgoing packet, if timeout expires. */
| 374 | |
| 375 | /* Send burst of outgoing packet, if timeout expires. */ |
| 376 | static inline void |
| 377 | send_timeout_burst(struct lcore_queue_conf *qconf) |
| 378 | { |
| 379 | uint64_t cur_tsc; |
| 380 | uint16_t portid; |
| 381 | const uint64_t drain_tsc = (rte_get_tsc_hz() + US_PER_S - 1) / US_PER_S * BURST_TX_DRAIN_US; |
| 382 | |
| 383 | cur_tsc = rte_rdtsc(); |
| 384 | if (likely (cur_tsc < qconf->tx_tsc + drain_tsc)) |
| 385 | return; |
| 386 | |
| 387 | for (portid = 0; portid < MAX_PORTS; portid++) { |
| 388 | if (qconf->tx_mbufs[portid].len != 0) |
| 389 | send_burst(qconf, portid); |
| 390 | } |
| 391 | qconf->tx_tsc = cur_tsc; |
| 392 | } |
| 393 | |
| 394 | /* main processing loop */ |
| 395 | static int |
no test coverage detected