| 775 | } |
| 776 | |
| 777 | std::vector<BatchContextPtr> SyncValidator::GetLastBatches(std::function<bool(const BatchContextPtr&)> filter) const { |
| 778 | std::vector<BatchContextPtr> snapshot; |
| 779 | for (const QueueState& queue_state : queue_states_) { |
| 780 | auto batch = queue_state.LastBatch(); |
| 781 | if (batch && filter(batch)) { |
| 782 | snapshot.emplace_back(std::move(batch)); |
| 783 | } |
| 784 | } |
| 785 | return snapshot; |
| 786 | } |
| 787 | |
| 788 | const LastSynchronizedPresent& QueueState::GetLastSynchronizedPresent() const { |
| 789 | static const LastSynchronizedPresent empty; |
no test coverage detected