| 623 | } |
| 624 | |
| 625 | void getResponsesToSend(std::vector<LogsDBResponse>& responses) { |
| 626 | responses.swap(_responses); |
| 627 | update_atomic_stat_ema(_stats.responsesSent, responses.size()); |
| 628 | _responses.clear(); |
| 629 | } |
| 630 | |
| 631 | Duration getNextTimeout() const { |
| 632 | if (_requests.empty()) { |
no test coverage detected