aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/blockcodecs
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
commitbf9e69a933f89af083d895185f01ed65e4d90766 (patch)
treeb2cc84ee7850122e7ccf51d0ea21e4fa7e7a5685 /library/cpp/blockcodecs
parent863a59a65247c24db7cb06789bc5cf79d04da32f (diff)
downloadydb-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.cpp2
-rw-r--r--library/cpp/blockcodecs/core/common.h2
-rw-r--r--library/cpp/blockcodecs/core/stream.cpp22
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();
}