diff options
author | Alexander Fokin <apfokin@gmail.com> | 2022-02-10 16:45:38 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:38 +0300 |
commit | bf9e69a933f89af083d895185f01ed65e4d90766 (patch) | |
tree | b2cc84ee7850122e7ccf51d0ea21e4fa7e7a5685 /library/cpp/blockcodecs | |
parent | 863a59a65247c24db7cb06789bc5cf79d04da32f (diff) | |
download | ydb-bf9e69a933f89af083d895185f01ed65e4d90766.tar.gz |
Restoring authorship annotation for Alexander Fokin <apfokin@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/blockcodecs')
-rw-r--r-- | library/cpp/blockcodecs/core/codecs.cpp | 2 | ||||
-rw-r--r-- | library/cpp/blockcodecs/core/common.h | 2 | ||||
-rw-r--r-- | library/cpp/blockcodecs/core/stream.cpp | 22 |
3 files changed, 13 insertions, 13 deletions
diff --git a/library/cpp/blockcodecs/core/codecs.cpp b/library/cpp/blockcodecs/core/codecs.cpp index 8c6b37b2a5..21506e812b 100644 --- a/library/cpp/blockcodecs/core/codecs.cpp +++ b/library/cpp/blockcodecs/core/codecs.cpp @@ -3,7 +3,7 @@ #include "register.h" #include <util/ysaveload.h> -#include <util/stream/null.h> +#include <util/stream/null.h> #include <util/stream/mem.h> #include <util/string/cast.h> #include <util/string/join.h> diff --git a/library/cpp/blockcodecs/core/common.h b/library/cpp/blockcodecs/core/common.h index d001ceadad..f05df4d334 100644 --- a/library/cpp/blockcodecs/core/common.h +++ b/library/cpp/blockcodecs/core/common.h @@ -3,7 +3,7 @@ #include "codecs.h" #include <util/ysaveload.h> -#include <util/stream/null.h> +#include <util/stream/null.h> #include <util/stream/mem.h> #include <util/string/cast.h> #include <util/string/join.h> diff --git a/library/cpp/blockcodecs/core/stream.cpp b/library/cpp/blockcodecs/core/stream.cpp index ab9d3099de..4f7db3c32b 100644 --- a/library/cpp/blockcodecs/core/stream.cpp +++ b/library/cpp/blockcodecs/core/stream.cpp @@ -160,13 +160,13 @@ TDecodedInput::TDecodedInput(IInputStream* in, const ICodec* codec) TDecodedInput::~TDecodedInput() = default; -size_t TDecodedInput::DoUnboundedNext(const void** ptr) { +size_t TDecodedInput::DoUnboundedNext(const void** ptr) { if (!S_) { - return 0; + return 0; } - TCodecID codecId; - TBlockLen blockLen; + TCodecID codecId; + TBlockLen blockLen; { const size_t payload = sizeof(TCodecID) + sizeof(TBlockLen); @@ -176,14 +176,14 @@ size_t TDecodedInput::DoUnboundedNext(const void** ptr) { TMemoryInput in(buf, payload); - ::Load(&in, codecId); - ::Load(&in, blockLen); + ::Load(&in, codecId); + ::Load(&in, blockLen); } - if (!blockLen) { + if (!blockLen) { S_ = nullptr; - return 0; + return 0; } if (Y_UNLIKELY(blockLen > 1024 * 1024 * 1024)) { @@ -191,9 +191,9 @@ size_t TDecodedInput::DoUnboundedNext(const void** ptr) { } TBuffer block; - block.Resize(blockLen); + block.Resize(blockLen); - S_->LoadOrFail(block.Data(), blockLen); + S_->LoadOrFail(block.Data(), blockLen); auto codec = CodecByID(codecId); @@ -208,5 +208,5 @@ size_t TDecodedInput::DoUnboundedNext(const void** ptr) { codec->Decode(block, D_); *ptr = D_.Data(); - return D_.Size(); + return D_.Size(); } |