aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream/zlib.cpp
diff options
context:
space:
mode:
authorArseny Smalyuk <smalukav@gmail.com>2022-02-10 16:48:05 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:05 +0300
commit12559cd7f2fa0cf54ffb0d961949fea58c0e18cb (patch)
tree1c6e1bb383ce1ed8ea168386f913410dd55ccb7f /util/stream/zlib.cpp
parent5b8d95df2f0cfca4d3f5499a4259aa2050ef1571 (diff)
downloadydb-12559cd7f2fa0cf54ffb0d961949fea58c0e18cb.tar.gz
Restoring authorship annotation for Arseny Smalyuk <smalukav@gmail.com>. Commit 1 of 2.
Diffstat (limited to 'util/stream/zlib.cpp')
-rw-r--r--util/stream/zlib.cpp32
1 files changed, 16 insertions, 16 deletions
diff --git a/util/stream/zlib.cpp b/util/stream/zlib.cpp
index 60f4e9439f0..983b753dc23 100644
--- a/util/stream/zlib.cpp
+++ b/util/stream/zlib.cpp
@@ -267,20 +267,20 @@ public:
}
inline void Flush() {
- int ret = deflate(Z(), Z_SYNC_FLUSH);
-
- while ((ret == Z_OK || ret == Z_BUF_ERROR) && !Z()->avail_out) {
- FlushBuffer();
- ret = deflate(Z(), Z_SYNC_FLUSH);
- }
-
- if (ret != Z_OK && ret != Z_BUF_ERROR) {
- ythrow TZLibCompressorError() << "deflate flush error(" << GetErrMsg() << ")";
- }
-
- if (Z()->avail_out < TmpBufLen()) {
- FlushBuffer();
- }
+ int ret = deflate(Z(), Z_SYNC_FLUSH);
+
+ while ((ret == Z_OK || ret == Z_BUF_ERROR) && !Z()->avail_out) {
+ FlushBuffer();
+ ret = deflate(Z(), Z_SYNC_FLUSH);
+ }
+
+ if (ret != Z_OK && ret != Z_BUF_ERROR) {
+ ythrow TZLibCompressorError() << "deflate flush error(" << GetErrMsg() << ")";
+ }
+
+ if (Z()->avail_out < TmpBufLen()) {
+ FlushBuffer();
+ }
}
inline void FlushBuffer() {
@@ -300,7 +300,7 @@ public:
if (ret == Z_STREAM_END) {
Stream_->Write(TmpBuf(), TmpBufLen() - Z()->avail_out);
} else {
- ythrow TZLibCompressorError() << "deflate finish error(" << GetErrMsg() << ")";
+ ythrow TZLibCompressorError() << "deflate finish error(" << GetErrMsg() << ")";
}
}
@@ -339,7 +339,7 @@ size_t TZLibDecompress::DoRead(void* buf, size_t size) {
}
void TZLibCompress::Init(const TParams& params) {
- Y_ENSURE(params.BufLen >= 16, "ZLib buffer too small");
+ Y_ENSURE(params.BufLen >= 16, "ZLib buffer too small");
Impl_.Reset(new (params.BufLen) TImpl(params));
}