aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/blockcodecs/core/stream.cpp
diff options
context:
space:
mode:
authorAlexander Fokin <apfokin@gmail.com>2022-02-10 16:45:38 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:38 +0300
commit863a59a65247c24db7cb06789bc5cf79d04da32f (patch)
tree139dc000c8cd4a40f5659e421b7c75135d080307 /library/cpp/blockcodecs/core/stream.cpp
parentf64e95a9eb9ab03240599eb9581c5a9102426a96 (diff)
downloadydb-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.cpp22
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();
}