aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream/zlib.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
commitbf9e69a933f89af083d895185f01ed65e4d90766 (patch)
treeb2cc84ee7850122e7ccf51d0ea21e4fa7e7a5685 /util/stream/zlib.cpp
parent863a59a65247c24db7cb06789bc5cf79d04da32f (diff)
downloadydb-bf9e69a933f89af083d895185f01ed65e4d90766.tar.gz
Restoring authorship annotation for Alexander Fokin <apfokin@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'util/stream/zlib.cpp')
-rw-r--r--util/stream/zlib.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/util/stream/zlib.cpp b/util/stream/zlib.cpp
index 3ccfa625ab..60f4e9439f 100644
--- a/util/stream/zlib.cpp
+++ b/util/stream/zlib.cpp
@@ -55,8 +55,8 @@ namespace {
template <class P, class T>
inline bool Next(P** buf, T* len) {
if (!Len) {
- Len = In->Next(&Buf);
- if (!Len) {
+ Len = In->Next(&Buf);
+ if (!Len) {
return false;
}
}
@@ -177,7 +177,7 @@ namespace {
void* buf = AdditionalData();
*ptr = buf;
- return Stream_->Read(buf, Min(len, AdditionalDataLength()));
+ return Stream_->Read(buf, Min(len, AdditionalDataLength()));
}
private:
@@ -327,7 +327,7 @@ TZLibDecompress::TZLibDecompress(IInputStream* input, ZLib::StreamType type, siz
: Impl_(new (buflen) TDecompressStream(input, type, dict))
{
}
-
+
void TZLibDecompress::SetAllowMultipleStreams(bool allowMultipleStreams) {
Impl_->SetAllowMultipleStreams(allowMultipleStreams);
}
@@ -338,9 +338,9 @@ size_t TZLibDecompress::DoRead(void* buf, size_t size) {
return Impl_->Read(buf, MaxPortion(size));
}
-void TZLibCompress::Init(const TParams& params) {
+void TZLibCompress::Init(const TParams& params) {
Y_ENSURE(params.BufLen >= 16, "ZLib buffer too small");
- Impl_.Reset(new (params.BufLen) TImpl(params));
+ Impl_.Reset(new (params.BufLen) TImpl(params));
}
void TZLibCompress::TDestruct::Destroy(TImpl* impl) {