aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/streams/lz
diff options
context:
space:
mode:
authordanlark <danlark@yandex-team.ru>2022-02-10 16:46:08 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:08 +0300
commit3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (patch)
tree26154e1e9990f1bb4525d3e3fb5b6dac2c2c1da2 /library/cpp/streams/lz
parentcb68f224c46a8ee52ac3fdd2a32534b8bb8dc134 (diff)
downloadydb-3426a9bc7f169ae9da54cef557ad2a33f6e8eee0.tar.gz
Restoring authorship annotation for <danlark@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/streams/lz')
-rw-r--r--library/cpp/streams/lz/lz.cpp2
-rw-r--r--library/cpp/streams/lz/lz_ut.cpp8
2 files changed, 5 insertions, 5 deletions
diff --git a/library/cpp/streams/lz/lz.cpp b/library/cpp/streams/lz/lz.cpp
index b65bb3ed96..01798a780c 100644
--- a/library/cpp/streams/lz/lz.cpp
+++ b/library/cpp/streams/lz/lz.cpp
@@ -679,7 +679,7 @@ static TAutoPtr<IInputStream> TryOpenLzDecompressorX(const TDecompressSignature&
template <class T>
static inline TAutoPtr<IInputStream> TryOpenLzDecompressorImpl(const TStringBuf& signature, T input) {
if (signature.size() == SIGNATURE_SIZE) {
- TMemoryInput mem(signature.data(), signature.size());
+ TMemoryInput mem(signature.data(), signature.size());
TDecompressSignature s(&mem);
return TryOpenLzDecompressorX(s, input);
diff --git a/library/cpp/streams/lz/lz_ut.cpp b/library/cpp/streams/lz/lz_ut.cpp
index 6876f070fc..ba6bb47ba5 100644
--- a/library/cpp/streams/lz/lz_ut.cpp
+++ b/library/cpp/streams/lz/lz_ut.cpp
@@ -32,7 +32,7 @@ namespace {
}
} while (!sym);
Y_ASSERT(sym);
- j = (j + 1) % entropy.size();
+ j = (j + 1) % entropy.size();
result += char(sym + entropy[j]);
}
return result;
@@ -56,7 +56,7 @@ namespace {
}
TString TestFileName(const TString& d, size_t bufferSize) {
- return LDATA_RANDOM + TString(".") + ToString(d.size()) + TString(".") + ToString(bufferSize);
+ return LDATA_RANDOM + TString(".") + ToString(d.size()) + TString(".") + ToString(bufferSize);
}
struct TRandomData: public TVector<TString> {
@@ -90,7 +90,7 @@ static inline void TestGoodDataCompress() {
TString d = data;
for (size_t i = 0; i < 10; ++i) {
- c.Write(d.data(), d.size());
+ c.Write(d.data(), d.size());
c << Endl;
d = d + d;
}
@@ -104,7 +104,7 @@ static inline void TestIncompressibleDataCompress(const TString& d, size_t buffe
TString testFileName = TestFileName(d, bufferSize);
TFixedBufferFileOutput o(testFileName);
C c(&o, bufferSize);
- c.Write(d.data(), d.size());
+ c.Write(d.data(), d.size());
c.Finish();
o.Finish();
}