aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/on_disk/chunks/writer.cpp
diff options
context:
space:
mode:
authordenplusplus <denplusplus@yandex-team.ru>2022-02-10 16:47:34 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:34 +0300
commit57c20d143e8a438cd76b9fdc3ca2e8ee3ac1f32a (patch)
treecc63639f8e502db19a82c20e2861c6d1edbf9fea /library/cpp/on_disk/chunks/writer.cpp
parent464ba3814a83db4f2d5327393b0b6eaf0c86bfd7 (diff)
downloadydb-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.cpp80
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();
+}