aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/encode/spack/compression.cpp
diff options
context:
space:
mode:
authorivanzhukov <ivanzhukov@yandex-team.ru>2022-02-10 16:49:40 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:40 +0300
commit0892d79ab411592ad25175c4bdadbcb09b466cf5 (patch)
tree98dfdd45463c9bd747101748a9ca25d2917390fd /library/cpp/monlib/encode/spack/compression.cpp
parent1b7466cb957659079ebebbb5d76e64e51f3306f0 (diff)
downloadydb-0892d79ab411592ad25175c4bdadbcb09b466cf5.tar.gz
Restoring authorship annotation for <ivanzhukov@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/monlib/encode/spack/compression.cpp')
-rw-r--r--library/cpp/monlib/encode/spack/compression.cpp24
1 files changed, 12 insertions, 12 deletions
diff --git a/library/cpp/monlib/encode/spack/compression.cpp b/library/cpp/monlib/encode/spack/compression.cpp
index 0d2152fc85..ff8c043bc4 100644
--- a/library/cpp/monlib/encode/spack/compression.cpp
+++ b/library/cpp/monlib/encode/spack/compression.cpp
@@ -241,7 +241,7 @@ namespace NMonitoring {
// TFramedOutputStream
///////////////////////////////////////////////////////////////////////////////
template <typename TCodecAlg, typename TCheckSumAlg>
- class TFramedCompressStream final: public IFramedCompressStream {
+ class TFramedCompressStream final: public IFramedCompressStream {
public:
explicit TFramedCompressStream(IOutputStream* out)
: Out_(out)
@@ -277,13 +277,13 @@ namespace NMonitoring {
}
}
- void FlushWithoutEmptyFrame() override {
+ void FlushWithoutEmptyFrame() override {
if (Out_ && !Uncompressed_.Empty()) {
WriteCompressedFrame();
}
}
- void FinishAndWriteEmptyFrame() override {
+ void FinishAndWriteEmptyFrame() override {
if (Out_) {
Y_DEFER {
Out_ = nullptr;
@@ -297,14 +297,14 @@ namespace NMonitoring {
}
}
- void DoFlush() override {
- FlushWithoutEmptyFrame();
- }
-
- void DoFinish() override {
- FinishAndWriteEmptyFrame();
- }
-
+ void DoFlush() override {
+ FlushWithoutEmptyFrame();
+ }
+
+ void DoFinish() override {
+ FinishAndWriteEmptyFrame();
+ }
+
void WriteCompressedFrame() {
static const auto framePayload = sizeof(TFrameHeader) + sizeof(TFrameFooter);
const auto maxFrameSize = ui64(TCodecAlg::MaxCompressedLength(Uncompressed_.Size())) + framePayload;
@@ -364,7 +364,7 @@ namespace NMonitoring {
Y_FAIL("invalid compression algorithm");
}
- THolder<IFramedCompressStream> CompressedOutput(IOutputStream* out, ECompression alg) {
+ THolder<IFramedCompressStream> CompressedOutput(IOutputStream* out, ECompression alg) {
switch (alg) {
case ECompression::IDENTITY:
return nullptr;