aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/comptable/ut/comptable_ut.cpp
diff options
context:
space:
mode:
authorsnow <snow@yandex-team.ru>2022-02-10 16:49:51 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:51 +0300
commitb3f165d1a2e8a2dbfcbb351310aeb05fae1f8a6c (patch)
tree8f92b813636cef1b46a00d28d05c485d385f1ac0 /library/cpp/comptable/ut/comptable_ut.cpp
parentc943ab142d4182af287664691cf116c143172792 (diff)
downloadydb-b3f165d1a2e8a2dbfcbb351310aeb05fae1f8a6c.tar.gz
Restoring authorship annotation for <snow@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/comptable/ut/comptable_ut.cpp')
-rw-r--r--library/cpp/comptable/ut/comptable_ut.cpp82
1 files changed, 41 insertions, 41 deletions
diff --git a/library/cpp/comptable/ut/comptable_ut.cpp b/library/cpp/comptable/ut/comptable_ut.cpp
index 5901d0246f..0f58a60e87 100644
--- a/library/cpp/comptable/ut/comptable_ut.cpp
+++ b/library/cpp/comptable/ut/comptable_ut.cpp
@@ -1,64 +1,64 @@
#include <library/cpp/comptable/comptable.h>
#include <library/cpp/testing/unittest/registar.h>
-
+
#include <util/random/random.h>
#include <util/random/fast.h>
-using namespace NCompTable;
-
+using namespace NCompTable;
+
template <bool HQ>
void DoTest(const TCompressorTable& table, const TVector<TString>& lines) {
TVector<char> compressed;
TVector<char> decompressed;
-
- TChunkCompressor compressor(HQ, table);
- TStringStream tmp;
- Save(&tmp, table);
- TCompressorTable tableLoaded;
- Load(&tmp, tableLoaded);
- UNIT_ASSERT(memcmp(&table, &tableLoaded, sizeof(table)) == 0);
- TChunkDecompressor deCompressor(HQ, tableLoaded);
-
- size_t origSize = 0;
- size_t compSize = 0;
+
+ TChunkCompressor compressor(HQ, table);
+ TStringStream tmp;
+ Save(&tmp, table);
+ TCompressorTable tableLoaded;
+ Load(&tmp, tableLoaded);
+ UNIT_ASSERT(memcmp(&table, &tableLoaded, sizeof(table)) == 0);
+ TChunkDecompressor deCompressor(HQ, tableLoaded);
+
+ size_t origSize = 0;
+ size_t compSize = 0;
for (size_t i = 0; i < lines.size(); ++i) {
const TString& line = lines[i];
- compressor.Compress(line, &compressed);
- origSize += line.size();
- compSize += compressed.size();
- TStringBuf in(compressed.data(), compressed.size());
- deCompressor.Decompress(in, &decompressed);
+ compressor.Compress(line, &compressed);
+ origSize += line.size();
+ compSize += compressed.size();
+ TStringBuf in(compressed.data(), compressed.size());
+ deCompressor.Decompress(in, &decompressed);
UNIT_ASSERT(decompressed.size() == line.size() && memcmp(decompressed.data(), line.data(), decompressed.size()) == 0);
- }
+ }
UNIT_ASSERT_EQUAL(origSize, 45491584);
- if (HQ) {
+ if (HQ) {
UNIT_ASSERT_EQUAL(compSize, 11074583);
- } else {
+ } else {
UNIT_ASSERT_EQUAL(compSize, 17459336);
- }
- UNIT_ASSERT(compSize < origSize);
-}
-
+ }
+ UNIT_ASSERT(compSize < origSize);
+}
+
Y_UNIT_TEST_SUITE(TestComptable) {
Y_UNIT_TEST(TestComptableCompressDecompress) {
TReallyFastRng32 rr(17);
TVector<TString> lines;
- for (size_t i = 0; i < 1000000; ++i) {
+ for (size_t i = 0; i < 1000000; ++i) {
size_t size = rr.Uniform(32);
TString res = "www.yandex.ru/yandsearch?text=";
- for (size_t j = 0; j < size; ++j) {
+ for (size_t j = 0; j < size; ++j) {
res += "qwer"[rr.Uniform(4)];
- }
- lines.push_back(res);
- }
- THolder<TDataSampler> sampler(new TDataSampler);
- for (size_t i = 0; i < lines.size(); ++i) {
+ }
+ lines.push_back(res);
+ }
+ THolder<TDataSampler> sampler(new TDataSampler);
+ for (size_t i = 0; i < lines.size(); ++i) {
sampler->AddStat(lines[i]);
- }
- TCompressorTable table;
- sampler->BuildTable(table);
-
- DoTest<true>(table, lines);
- DoTest<false>(table, lines);
- }
-}
+ }
+ TCompressorTable table;
+ sampler->BuildTable(table);
+
+ DoTest<true>(table, lines);
+ DoTest<false>(table, lines);
+ }
+}