| 25 | } |
| 26 | |
| 27 | std::vector<TSharedRef> TChunkedOutputStream::Finish() |
| 28 | { |
| 29 | FinishedChunks_.push_back(TrackMemory( |
| 30 | MemoryUsageTracker_, |
| 31 | TSharedRef::FromBlob(std::move(CurrentChunk_)))); |
| 32 | |
| 33 | CurrentChunkMemoryUsageGuard_.Release(); |
| 34 | |
| 35 | YT_ASSERT(CurrentChunk_.IsEmpty()); |
| 36 | FinishedSize_ = 0; |
| 37 | |
| 38 | for (const auto& chunk : FinishedChunks_) { |
| 39 | NSan::CheckMemIsInitialized(chunk.Begin(), chunk.Size()); |
| 40 | } |
| 41 | |
| 42 | return std::move(FinishedChunks_); |
| 43 | } |
| 44 | |
| 45 | size_t TChunkedOutputStream::GetSize() const |
| 46 | { |
nothing calls this directly
no test coverage detected