aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/encode/spack/compression.cpp
diff options
context:
space:
mode:
authordanlark <danlark@yandex-team.ru>2022-02-10 16:46:10 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:10 +0300
commitbaa58daefa91fde4b4769facdbd2903763b9c6a8 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/monlib/encode/spack/compression.cpp
parent3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (diff)
downloadydb-baa58daefa91fde4b4769facdbd2903763b9c6a8.tar.gz
Restoring authorship annotation for <danlark@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/monlib/encode/spack/compression.cpp')
-rw-r--r--library/cpp/monlib/encode/spack/compression.cpp50
1 files changed, 25 insertions, 25 deletions
diff --git a/library/cpp/monlib/encode/spack/compression.cpp b/library/cpp/monlib/encode/spack/compression.cpp
index 595af2b504..0d2152fc85 100644
--- a/library/cpp/monlib/encode/spack/compression.cpp
+++ b/library/cpp/monlib/encode/spack/compression.cpp
@@ -44,13 +44,13 @@ namespace NMonitoring {
struct TBlock: public TStringBuf {
template <typename T>
TBlock(T&& t)
- : TStringBuf(t.data(), t.size())
+ : TStringBuf(t.data(), t.size())
{
Y_ENSURE(t.data() != nullptr);
}
- char* data() noexcept {
- return const_cast<char*>(TStringBuf::data());
+ char* data() noexcept {
+ return const_cast<char*>(TStringBuf::data());
}
};
@@ -73,7 +73,7 @@ namespace NMonitoring {
///////////////////////////////////////////////////////////////////////////////
struct TAdler32 {
static TCheckSum Calc(TBlock in) {
- return adler32(1L, reinterpret_cast<const Bytef*>(in.data()), in.size());
+ return adler32(1L, reinterpret_cast<const Bytef*>(in.data()), in.size());
}
static bool Check(TBlock in, TCheckSum checksum) {
@@ -93,20 +93,20 @@ namespace NMonitoring {
static size_t Compress(TBlock in, TBlock out) {
int rc = LZ4_compress_default(
- in.data(),
- out.data(),
- SafeIntegerCast<int>(in.size()),
- SafeIntegerCast<int>(out.size()));
+ in.data(),
+ out.data(),
+ SafeIntegerCast<int>(in.size()),
+ SafeIntegerCast<int>(out.size()));
Y_ENSURE(rc != 0, "lz4 compression failed");
return rc;
}
static void Decompress(TBlock in, TBlock out) {
int rc = LZ4_decompress_safe(
- in.data(),
- out.data(),
- SafeIntegerCast<int>(in.size()),
- SafeIntegerCast<int>(out.size()));
+ in.data(),
+ out.data(),
+ SafeIntegerCast<int>(in.size()),
+ SafeIntegerCast<int>(out.size()));
Y_ENSURE(rc >= 0, "the lz4 stream is detected malformed");
}
};
@@ -122,7 +122,7 @@ namespace NMonitoring {
}
static size_t Compress(TBlock in, TBlock out) {
- size_t rc = ZSTD_compress(out.data(), out.size(), in.data(), in.size(), LEVEL);
+ size_t rc = ZSTD_compress(out.data(), out.size(), in.data(), in.size(), LEVEL);
if (Y_UNLIKELY(ZSTD_isError(rc))) {
ythrow yexception() << TStringBuf("zstd compression failed: ")
<< ZSTD_getErrorName(rc);
@@ -131,12 +131,12 @@ namespace NMonitoring {
}
static void Decompress(TBlock in, TBlock out) {
- size_t rc = ZSTD_decompress(out.data(), out.size(), in.data(), in.size());
+ size_t rc = ZSTD_decompress(out.data(), out.size(), in.data(), in.size());
if (Y_UNLIKELY(ZSTD_isError(rc))) {
ythrow yexception() << TStringBuf("zstd decompression failed: ")
<< ZSTD_getErrorName(rc);
}
- Y_ENSURE(rc == out.size(), "zstd decompressed wrong size");
+ Y_ENSURE(rc == out.size(), "zstd decompressed wrong size");
}
};
@@ -151,26 +151,26 @@ namespace NMonitoring {
}
static size_t Compress(TBlock in, TBlock out) {
- uLong ret = out.size();
+ uLong ret = out.size();
int rc = compress2(
- reinterpret_cast<Bytef*>(out.data()),
+ reinterpret_cast<Bytef*>(out.data()),
&ret,
- reinterpret_cast<const Bytef*>(in.data()),
- in.size(),
+ reinterpret_cast<const Bytef*>(in.data()),
+ in.size(),
LEVEL);
Y_ENSURE(rc == Z_OK, "zlib compression failed");
return ret;
}
static void Decompress(TBlock in, TBlock out) {
- uLong ret = out.size();
+ uLong ret = out.size();
int rc = uncompress(
- reinterpret_cast<Bytef*>(out.data()),
+ reinterpret_cast<Bytef*>(out.data()),
&ret,
- reinterpret_cast<const Bytef*>(in.data()),
- in.size());
+ reinterpret_cast<const Bytef*>(in.data()),
+ in.size());
Y_ENSURE(rc == Z_OK, "zlib decompression failed");
- Y_ENSURE(ret == out.size(), "zlib decompressed wrong size");
+ Y_ENSURE(ret == out.size(), "zlib decompressed wrong size");
}
};
@@ -321,7 +321,7 @@ namespace NMonitoring {
// add header
auto header = reinterpret_cast<TFrameHeader*>(Frame_.Data());
- header->CompressedSize = SafeIntegerCast<TCompressedSize>(compressedBlock.size());
+ header->CompressedSize = SafeIntegerCast<TCompressedSize>(compressedBlock.size());
header->UncompressedSize = SafeIntegerCast<TUncompressedSize>(Uncompressed_.Size());
// add footer