aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/streams
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
commit7a4979e6211c3e78c7f9041d4a9e5d3405343c36 (patch)
tree9e9943579e5a14679af7cd2cda3c36d8c0b775d3 /library/cpp/streams
parent676340c42e269f3070f194d160f42a83a10568d4 (diff)
downloadydb-7a4979e6211c3e78c7f9041d4a9e5d3405343c36.tar.gz
Restoring authorship annotation for <agorodilov@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/streams')
-rw-r--r--library/cpp/streams/bzip2/bzip2.h8
-rw-r--r--library/cpp/streams/lz/lz.cpp12
-rw-r--r--library/cpp/streams/lz/lz.h40
-rw-r--r--library/cpp/streams/lz/lz_ut.cpp2
-rw-r--r--library/cpp/streams/lzma/lzma.cpp12
-rw-r--r--library/cpp/streams/lzma/lzma.h6
-rw-r--r--library/cpp/streams/lzma/lzma_ut.cpp4
-rw-r--r--library/cpp/streams/zc_memory_input/zc_memory_input.h2
8 files changed, 43 insertions, 43 deletions
diff --git a/library/cpp/streams/bzip2/bzip2.h b/library/cpp/streams/bzip2/bzip2.h
index 2322277ef6..feb8f7531f 100644
--- a/library/cpp/streams/bzip2/bzip2.h
+++ b/library/cpp/streams/bzip2/bzip2.h
@@ -28,7 +28,7 @@ public:
~TBZipDecompress() override;
private:
- size_t DoRead(void* buf, size_t size) override;
+ size_t DoRead(void* buf, size_t size) override;
private:
class TImpl;
@@ -41,9 +41,9 @@ public:
~TBZipCompress() override;
private:
- void DoWrite(const void* buf, size_t size) override;
- void DoFlush() override;
- void DoFinish() override;
+ void DoWrite(const void* buf, size_t size) override;
+ void DoFlush() override;
+ void DoFinish() override;
public:
class TImpl;
diff --git a/library/cpp/streams/lz/lz.cpp b/library/cpp/streams/lz/lz.cpp
index b65bb3ed96..a57750d553 100644
--- a/library/cpp/streams/lz/lz.cpp
+++ b/library/cpp/streams/lz/lz.cpp
@@ -72,7 +72,7 @@ public:
inline void Finish() {
this->Flush();
- this->WriteBlock(nullptr, 0);
+ this->WriteBlock(nullptr, 0);
}
template <class T>
@@ -188,7 +188,7 @@ public:
inline TDecompressorBaseImpl(IInputStream* slave)
: Slave_(slave)
- , Input_(nullptr, 0)
+ , Input_(nullptr, 0)
, Eof_(false)
, Version_(CheckVer(Load<ui32>()))
, BlockSize_(Load<ui16>())
@@ -543,7 +543,7 @@ public:
}
inline TQuickLZBase()
- : Table_(nullptr)
+ : Table_(nullptr)
{
}
@@ -647,7 +647,7 @@ namespace {
}
private:
- size_t DoRead(void* buf, size_t len) override {
+ size_t DoRead(void* buf, size_t len) override {
return Impl_.Read(buf, len);
}
@@ -673,7 +673,7 @@ static TAutoPtr<IInputStream> TryOpenLzDecompressorX(const TDecompressSignature&
if (s.Check<TQuickLZDecompress>())
return new TLzDecompressInput<T, TQuickLZDecompress>(input);
- return nullptr;
+ return nullptr;
}
template <class T>
@@ -685,7 +685,7 @@ static inline TAutoPtr<IInputStream> TryOpenLzDecompressorImpl(const TStringBuf&
return TryOpenLzDecompressorX(s, input);
}
- return nullptr;
+ return nullptr;
}
template <class T>
diff --git a/library/cpp/streams/lz/lz.h b/library/cpp/streams/lz/lz.h
index 3a2eaad88b..10e67dfb71 100644
--- a/library/cpp/streams/lz/lz.h
+++ b/library/cpp/streams/lz/lz.h
@@ -36,9 +36,9 @@ public:
~TLz4Compress() 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;
private:
class TImpl;
@@ -56,7 +56,7 @@ public:
~TLz4Decompress() override;
private:
- size_t DoRead(void* buf, size_t len) override;
+ size_t DoRead(void* buf, size_t len) override;
private:
class TImpl;
@@ -74,9 +74,9 @@ public:
~TSnappyCompress() 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;
private:
class TImpl;
@@ -94,7 +94,7 @@ public:
~TSnappyDecompress() override;
private:
- size_t DoRead(void* buf, size_t len) override;
+ size_t DoRead(void* buf, size_t len) override;
private:
class TImpl;
@@ -110,9 +110,9 @@ public:
~TLzoCompress() 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;
private:
class TImpl;
@@ -128,7 +128,7 @@ public:
~TLzoDecompress() override;
private:
- size_t DoRead(void* buf, size_t len) override;
+ size_t DoRead(void* buf, size_t len) override;
private:
class TImpl;
@@ -144,9 +144,9 @@ public:
~TLzfCompress() 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;
private:
class TImpl;
@@ -162,7 +162,7 @@ public:
~TLzfDecompress() override;
private:
- size_t DoRead(void* buf, size_t len) override;
+ size_t DoRead(void* buf, size_t len) override;
private:
class TImpl;
@@ -196,9 +196,9 @@ public:
~TLzqCompress() 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;
private:
class TImpl;
@@ -214,7 +214,7 @@ public:
~TLzqDecompress() override;
private:
- size_t DoRead(void* buf, size_t len) override;
+ size_t DoRead(void* buf, size_t len) override;
private:
class TImpl;
diff --git a/library/cpp/streams/lz/lz_ut.cpp b/library/cpp/streams/lz/lz_ut.cpp
index 6876f070fc..6eea541b2a 100644
--- a/library/cpp/streams/lz/lz_ut.cpp
+++ b/library/cpp/streams/lz/lz_ut.cpp
@@ -168,7 +168,7 @@ public:
}
private:
- size_t DoRead(void* buf, size_t len) override {
+ size_t DoRead(void* buf, size_t len) override {
return Slave_->Read(buf, len);
}
diff --git a/library/cpp/streams/lzma/lzma.cpp b/library/cpp/streams/lzma/lzma.cpp
index f1942fa546..f466a27659 100644
--- a/library/cpp/streams/lzma/lzma.cpp
+++ b/library/cpp/streams/lzma/lzma.cpp
@@ -50,7 +50,7 @@ namespace {
{
}
- void DoRun() override {
+ void DoRun() override {
Parent_->RunFilter();
}
@@ -68,7 +68,7 @@ namespace {
~TInput() override {
}
- size_t DoRead(void* ptr, size_t len) override {
+ size_t DoRead(void* ptr, size_t len) override {
return Parent_->ReadImpl(ptr, len);
}
@@ -86,7 +86,7 @@ namespace {
~TOutput() override {
}
- void DoWrite(const void* ptr, size_t len) override {
+ void DoWrite(const void* ptr, size_t len) override {
Parent_->WriteImpl(ptr, len);
}
@@ -101,7 +101,7 @@ namespace {
, TrampoLine_(this)
, FilterCtx_(FilterClosure())
, Finished_(false)
- , In_(nullptr, 0)
+ , In_(nullptr, 0)
{
}
@@ -180,7 +180,7 @@ namespace {
inline bool FlushImpl() {
if (Out_.Avail()) {
TransferData(&Out_, Slave_);
- Out_.Reset(nullptr, 0);
+ Out_.Reset(nullptr, 0);
return true;
}
@@ -327,7 +327,7 @@ namespace {
out->Write(PropsBuf_, sizeof(PropsBuf_));
- Check(LzmaEnc_Encode(H_, &output, &input, nullptr, Alloc(), Alloc()));
+ Check(LzmaEnc_Encode(H_, &output, &input, nullptr, Alloc(), Alloc()));
}
private:
diff --git a/library/cpp/streams/lzma/lzma.h b/library/cpp/streams/lzma/lzma.h
index ca1e06e9ef..db292b0c52 100644
--- a/library/cpp/streams/lzma/lzma.h
+++ b/library/cpp/streams/lzma/lzma.h
@@ -12,8 +12,8 @@ public:
~TLzmaCompress() override;
private:
- void DoWrite(const void* buf, size_t len) override;
- void DoFinish() override;
+ void DoWrite(const void* buf, size_t len) override;
+ void DoFinish() override;
private:
class TImpl;
@@ -27,7 +27,7 @@ public:
~TLzmaDecompress() override;
private:
- size_t DoRead(void* buf, size_t len) override;
+ size_t DoRead(void* buf, size_t len) override;
private:
class TImpl;
diff --git a/library/cpp/streams/lzma/lzma_ut.cpp b/library/cpp/streams/lzma/lzma_ut.cpp
index 847e98d1ca..89f59abefe 100644
--- a/library/cpp/streams/lzma/lzma_ut.cpp
+++ b/library/cpp/streams/lzma/lzma_ut.cpp
@@ -15,7 +15,7 @@ public:
}
private:
- size_t DoNext(const void** ptr, size_t len) override {
+ size_t DoNext(const void** ptr, size_t len) override {
if (Pos < Data.end()) {
len = Min(len, static_cast<size_t>(1));
*ptr = Pos;
@@ -57,7 +57,7 @@ private:
~TExcOutput() override {
}
- void DoWrite(const void*, size_t) override {
+ void DoWrite(const void*, size_t) override {
throw 12345;
}
};
diff --git a/library/cpp/streams/zc_memory_input/zc_memory_input.h b/library/cpp/streams/zc_memory_input/zc_memory_input.h
index c939d8e426..3515904926 100644
--- a/library/cpp/streams/zc_memory_input/zc_memory_input.h
+++ b/library/cpp/streams/zc_memory_input/zc_memory_input.h
@@ -32,7 +32,7 @@ public:
template <class T>
Y_FORCE_INLINE T LoadPOD() {
- const char* buf = nullptr;
+ const char* buf = nullptr;
if (!ReadFixed(buf, sizeof(T)))
ythrow yexception() << "TZCMemoryInput::LoadPOD failed: not enough data ("
<< Avail() << " of " << sizeof(T) << " bytes)";