diff options
author | agorodilov <agorodilov@yandex-team.ru> | 2022-02-10 16:47:09 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:09 +0300 |
commit | bd5ef432f5cfb1e18851381329d94665a4c22470 (patch) | |
tree | b83306b6e37edeea782e9eed673d89286c4fef35 /library/cpp/blockcodecs | |
parent | 7a4979e6211c3e78c7f9041d4a9e5d3405343c36 (diff) | |
download | ydb-bd5ef432f5cfb1e18851381329d94665a4c22470.tar.gz |
Restoring authorship annotation for <agorodilov@yandex-team.ru>. 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 | 16 | ||||
-rw-r--r-- | library/cpp/blockcodecs/core/stream.cpp | 6 | ||||
-rw-r--r-- | library/cpp/blockcodecs/core/stream.h | 8 |
4 files changed, 16 insertions, 16 deletions
diff --git a/library/cpp/blockcodecs/core/codecs.cpp b/library/cpp/blockcodecs/core/codecs.cpp index e096ef79b4..21506e812b 100644 --- a/library/cpp/blockcodecs/core/codecs.cpp +++ b/library/cpp/blockcodecs/core/codecs.cpp @@ -145,4 +145,4 @@ void ICodec::Decode(const TData& in, TString& out) const { out.resize(actualLen); } -ICodec::~ICodec() = default; +ICodec::~ICodec() = default; diff --git a/library/cpp/blockcodecs/core/common.h b/library/cpp/blockcodecs/core/common.h index 7d754b6419..f05df4d334 100644 --- a/library/cpp/blockcodecs/core/common.h +++ b/library/cpp/blockcodecs/core/common.h @@ -35,21 +35,21 @@ namespace NBlockCodecs { }; struct TNullCodec: public ICodec { - size_t DecompressedLength(const TData& in) const override { + size_t DecompressedLength(const TData& in) const override { return in.size(); } - size_t MaxCompressedLength(const TData& in) const override { + size_t MaxCompressedLength(const TData& in) const override { return in.size(); } - size_t Compress(const TData& in, void* out) const override { + size_t Compress(const TData& in, void* out) const override { MemCopy((char*)out, in.data(), in.size()); return in.size(); } - size_t Decompress(const TData& in, void* out) const override { + size_t Decompress(const TData& in, void* out) const override { MemCopy((char*)out, in.data(), in.size()); return in.size(); @@ -68,17 +68,17 @@ namespace NBlockCodecs { } } - size_t DecompressedLength(const TData& in) const override { + size_t DecompressedLength(const TData& in) const override { Check(in); return ReadUnaligned<ui64>(in.data()); } - size_t MaxCompressedLength(const TData& in) const override { + size_t MaxCompressedLength(const TData& in) const override { return T::DoMaxCompressedLength(in.size()) + sizeof(ui64); } - size_t Compress(const TData& in, void* out) const override { + size_t Compress(const TData& in, void* out) const override { ui64* ptr = (ui64*)out; WriteUnaligned<ui64>(ptr, (ui64) in.size()); @@ -86,7 +86,7 @@ namespace NBlockCodecs { return Base()->DoCompress(!in ? TData(TStringBuf("")) : in, ptr + 1) + sizeof(*ptr); } - size_t Decompress(const TData& in, void* out) const override { + size_t Decompress(const TData& in, void* out) const override { Check(in); const auto len = ReadUnaligned<ui64>(in.data()); diff --git a/library/cpp/blockcodecs/core/stream.cpp b/library/cpp/blockcodecs/core/stream.cpp index 6584d51460..4f7db3c32b 100644 --- a/library/cpp/blockcodecs/core/stream.cpp +++ b/library/cpp/blockcodecs/core/stream.cpp @@ -136,7 +136,7 @@ void TCodedOutput::DoFlush() { void TCodedOutput::DoFinish() { if (S_) { Y_DEFER { - S_ = nullptr; + S_ = nullptr; }; if (FlushImpl()) { @@ -158,7 +158,7 @@ TDecodedInput::TDecodedInput(IInputStream* in, const ICodec* codec) { } -TDecodedInput::~TDecodedInput() = default; +TDecodedInput::~TDecodedInput() = default; size_t TDecodedInput::DoUnboundedNext(const void** ptr) { if (!S_) { @@ -181,7 +181,7 @@ size_t TDecodedInput::DoUnboundedNext(const void** ptr) { } if (!blockLen) { - S_ = nullptr; + S_ = nullptr; return 0; } diff --git a/library/cpp/blockcodecs/core/stream.h b/library/cpp/blockcodecs/core/stream.h index 51ee695a6f..fd44ef88f2 100644 --- a/library/cpp/blockcodecs/core/stream.h +++ b/library/cpp/blockcodecs/core/stream.h @@ -15,9 +15,9 @@ namespace NBlockCodecs { ~TCodedOutput() override; private: - void DoWrite(const void* buf, size_t len) override; - void DoFlush() override; - void DoFinish() override; + void DoWrite(const void* buf, size_t len) override; + void DoFlush() override; + void DoFinish() override; bool FlushImpl(); @@ -36,7 +36,7 @@ namespace NBlockCodecs { ~TDecodedInput() override; private: - size_t DoUnboundedNext(const void** ptr) override; + size_t DoUnboundedNext(const void** ptr) override; private: TBuffer D_; |