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
commit863a59a65247c24db7cb06789bc5cf79d04da32f (patch)
tree139dc000c8cd4a40f5659e421b7c75135d080307 /util/stream/zlib.cpp
parentf64e95a9eb9ab03240599eb9581c5a9102426a96 (diff)
downloadydb-863a59a65247c24db7cb06789bc5cf79d04da32f.tar.gz
Restoring authorship annotation for Alexander Fokin <apfokin@gmail.com>. Commit 1 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 60f4e9439f..3ccfa625ab 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) {