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 | 863a59a65247c24db7cb06789bc5cf79d04da32f (patch) | |
tree | 139dc000c8cd4a40f5659e421b7c75135d080307 /library/cpp/blockcodecs/core/stream.cpp | |
parent | f64e95a9eb9ab03240599eb9581c5a9102426a96 (diff) | |
download | ydb-863a59a65247c24db7cb06789bc5cf79d04da32f.tar.gz |
Restoring authorship annotation for Alexander Fokin <apfokin@gmail.com>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/blockcodecs/core/stream.cpp')
-rw-r--r-- | library/cpp/blockcodecs/core/stream.cpp | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/library/cpp/blockcodecs/core/stream.cpp b/library/cpp/blockcodecs/core/stream.cpp index 4f7db3c32b..ab9d3099de 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(); } |