| 609 | } |
| 610 | |
| 611 | void getRequestsToSend(std::vector<LogsDBRequest*>& requests) { |
| 612 | requests.swap(_requestsToSend); |
| 613 | update_atomic_stat_ema(_stats.requestsSent, requests.size()); |
| 614 | _requestsToSend.clear(); |
| 615 | } |
| 616 | |
| 617 | LogsDBResponse& newResponse(ReplicaId targetReplicaId, uint64_t requestId) { |
| 618 | _responses.emplace_back(); |
no test coverage detected