diff options
author | denplusplus <denplusplus@yandex-team.ru> | 2022-02-10 16:47:34 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:34 +0300 |
commit | 57c20d143e8a438cd76b9fdc3ca2e8ee3ac1f32a (patch) | |
tree | cc63639f8e502db19a82c20e2861c6d1edbf9fea /library/cpp/on_disk/chunks/writer.cpp | |
parent | 464ba3814a83db4f2d5327393b0b6eaf0c86bfd7 (diff) | |
download | ydb-57c20d143e8a438cd76b9fdc3ca2e8ee3ac1f32a.tar.gz |
Restoring authorship annotation for <denplusplus@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/on_disk/chunks/writer.cpp')
-rw-r--r-- | library/cpp/on_disk/chunks/writer.cpp | 80 |
1 files changed, 40 insertions, 40 deletions
diff --git a/library/cpp/on_disk/chunks/writer.cpp b/library/cpp/on_disk/chunks/writer.cpp index 6dc7397f09..3c7747de0b 100644 --- a/library/cpp/on_disk/chunks/writer.cpp +++ b/library/cpp/on_disk/chunks/writer.cpp @@ -1,46 +1,46 @@ -#include <util/ysaveload.h> - -#include "writer.h" - +#include <util/ysaveload.h> + +#include "writer.h" + static inline void WriteAux(IOutputStream* out, const TVector<ui64>& data) { ::SavePodArray(out, data.data(), data.size()); -} - -/*************************** TBuffersWriter ***************************/ - +} + +/*************************** TBuffersWriter ***************************/ + TChunkedDataWriter::TChunkedDataWriter(IOutputStream& slave) - : Slave(slave) - , Offset(0) -{ -} - + : Slave(slave) + , Offset(0) +{ +} + TChunkedDataWriter::~TChunkedDataWriter() { -} - -void TChunkedDataWriter::NewBlock() { - if (Offsets.size()) { - Lengths.push_back(Offset - Offsets.back()); - } - - Pad(16); - Offsets.push_back(Offset); -} - -void TChunkedDataWriter::WriteFooter() { - Lengths.push_back(Offset - Offsets.back()); - WriteAux(this, Lengths); - WriteAux(this, Offsets); - WriteBinary<ui64>(Offsets.size()); - WriteBinary<ui64>(Version); - WriteBinary<ui64>(0); -} - -size_t TChunkedDataWriter::GetCurrentBlockOffset() const { +} + +void TChunkedDataWriter::NewBlock() { + if (Offsets.size()) { + Lengths.push_back(Offset - Offsets.back()); + } + + Pad(16); + Offsets.push_back(Offset); +} + +void TChunkedDataWriter::WriteFooter() { + Lengths.push_back(Offset - Offsets.back()); + WriteAux(this, Lengths); + WriteAux(this, Offsets); + WriteBinary<ui64>(Offsets.size()); + WriteBinary<ui64>(Version); + WriteBinary<ui64>(0); +} + +size_t TChunkedDataWriter::GetCurrentBlockOffset() const { Y_ASSERT(!Offsets.empty()); Y_ASSERT(Offset >= Offsets.back()); - return Offset - Offsets.back(); -} - -size_t TChunkedDataWriter::GetBlockCount() const { - return Offsets.size(); -} + return Offset - Offsets.back(); +} + +size_t TChunkedDataWriter::GetBlockCount() const { + return Offsets.size(); +} |