aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/blockcodecs
diff options
context:
space:
mode:
authoragorodilov <agorodilov@yandex-team.ru>2022-02-10 16:47:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:09 +0300
commitbd5ef432f5cfb1e18851381329d94665a4c22470 (patch)
treeb83306b6e37edeea782e9eed673d89286c4fef35 /library/cpp/blockcodecs
parent7a4979e6211c3e78c7f9041d4a9e5d3405343c36 (diff)
downloadydb-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.cpp2
-rw-r--r--library/cpp/blockcodecs/core/common.h16
-rw-r--r--library/cpp/blockcodecs/core/stream.cpp6
-rw-r--r--library/cpp/blockcodecs/core/stream.h8
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_;