| 278 | // --------------------------------------------------------------------------- |
| 279 | |
| 280 | std::vector<TopicId> DataEngine::commitChunks( |
| 281 | std::vector<std::pair<TopicId, TopicChunk>> chunks) { // NOLINT(performance-unnecessary-value-param) |
| 282 | std::unique_lock<std::recursive_mutex> lock(impl_->mutex_); |
| 283 | return commitChunksLocked(std::move(chunks)); |
| 284 | } |
| 285 | |
| 286 | std::vector<TopicId> DataEngine::commitChunksLocked( |
| 287 | std::vector<std::pair<TopicId, TopicChunk>> chunks) { // NOLINT(performance-unnecessary-value-param) |
no outgoing calls