aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/streams/lzma
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:46 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:46 +0300
commit8cbc307de0221f84c80c42dcbe07d40727537e2c (patch)
tree625d5a673015d1df891e051033e9fcde5c7be4e5 /library/cpp/streams/lzma
parent30d1ef3941e0dc835be7609de5ebee66958f215a (diff)
downloadydb-8cbc307de0221f84c80c42dcbe07d40727537e2c.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/streams/lzma')
-rw-r--r--library/cpp/streams/lzma/lzma.cpp38
-rw-r--r--library/cpp/streams/lzma/lzma.h10
-rw-r--r--library/cpp/streams/lzma/lzma_ut.cpp6
3 files changed, 27 insertions, 27 deletions
diff --git a/library/cpp/streams/lzma/lzma.cpp b/library/cpp/streams/lzma/lzma.cpp
index f1942fa546..0a8235d02b 100644
--- a/library/cpp/streams/lzma/lzma.cpp
+++ b/library/cpp/streams/lzma/lzma.cpp
@@ -58,7 +58,7 @@ namespace {
TInverseFilter* Parent_;
};
- class TInput: public IInputStream {
+ class TInput: public IInputStream {
public:
inline TInput(TInverseFilter* parent)
: Parent_(parent)
@@ -76,7 +76,7 @@ namespace {
TInverseFilter* Parent_;
};
- class TOutput: public IOutputStream {
+ class TOutput: public IOutputStream {
public:
inline TOutput(TInverseFilter* parent)
: Parent_(parent)
@@ -95,7 +95,7 @@ namespace {
};
public:
- inline TInverseFilter(IOutputStream* slave, T* filter)
+ inline TInverseFilter(IOutputStream* slave, T* filter)
: Slave_(slave)
, Filter_(filter)
, TrampoLine_(this)
@@ -168,7 +168,7 @@ namespace {
}
inline void WriteImpl(const void* ptr, size_t len) {
- Y_ASSERT(!Out_.Avail());
+ Y_ASSERT(!Out_.Avail());
Out_.Reset(ptr, len);
@@ -205,7 +205,7 @@ namespace {
}
private:
- IOutputStream* Slave_;
+ IOutputStream* Slave_;
T* Filter_;
TTrampoLine TrampoLine_;
char Stack_[16 * 1024];
@@ -221,7 +221,7 @@ namespace {
public:
class TLzmaInput: public ISeqInStream {
public:
- inline TLzmaInput(IInputStream* slave)
+ inline TLzmaInput(IInputStream* slave)
: Slave_(slave)
{
Read = ReadFunc;
@@ -235,12 +235,12 @@ namespace {
}
private:
- IInputStream* Slave_;
+ IInputStream* Slave_;
};
class TLzmaOutput: public ISeqOutStream {
public:
- inline TLzmaOutput(IOutputStream* slave)
+ inline TLzmaOutput(IOutputStream* slave)
: Slave_(slave)
{
Write = WriteFunc;
@@ -254,7 +254,7 @@ namespace {
}
private:
- IOutputStream* Slave_;
+ IOutputStream* Slave_;
};
class TAlloc: public ISzAlloc {
@@ -321,7 +321,7 @@ namespace {
LzmaEnc_Destroy(H_, Alloc(), Alloc());
}
- inline void operator()(IInputStream* in, IOutputStream* out) {
+ inline void operator()(IInputStream* in, IOutputStream* out) {
TLzmaInput input(in);
TLzmaOutput output(out);
@@ -339,7 +339,7 @@ namespace {
class TLzmaCompress::TImpl: public TLzmaCompressBase, public TInverseFilter<TLzmaCompressBase> {
public:
- inline TImpl(IOutputStream* slave, size_t level)
+ inline TImpl(IOutputStream* slave, size_t level)
: TLzmaCompressBase(level)
, TInverseFilter<TLzmaCompressBase>(slave, this)
{
@@ -373,7 +373,7 @@ public:
pos += bufLen;
if (status == LZMA_STATUS_NEEDS_MORE_INPUT) {
- Y_ASSERT(InEnd_ == InBegin_);
+ Y_ASSERT(InEnd_ == InBegin_);
if (!Fill()) {
ythrow yexception() << "incomplete lzma stream";
}
@@ -395,7 +395,7 @@ protected:
class TLzmaDecompress::TImplStream: public TImpl {
public:
- inline TImplStream(IInputStream* slave)
+ inline TImplStream(IInputStream* slave)
: Slave_(slave)
{
Byte buf[LZMA_PROPS_SIZE];
@@ -417,13 +417,13 @@ private:
}
private:
- IInputStream* Slave_;
+ IInputStream* Slave_;
char In_[4096];
};
class TLzmaDecompress::TImplZeroCopy: public TLzmaDecompress::TImpl {
public:
- inline TImplZeroCopy(IZeroCopyInput* in)
+ inline TImplZeroCopy(IZeroCopyInput* in)
: Input_(in)
{
if (!Fill())
@@ -475,10 +475,10 @@ private:
return false;
}
- IZeroCopyInput* Input_;
+ IZeroCopyInput* Input_;
};
-TLzmaCompress::TLzmaCompress(IOutputStream* slave, size_t level)
+TLzmaCompress::TLzmaCompress(IOutputStream* slave, size_t level)
: Impl_(new TImpl(slave, level))
{
}
@@ -502,12 +502,12 @@ void TLzmaCompress::DoFinish() {
}
}
-TLzmaDecompress::TLzmaDecompress(IInputStream* slave)
+TLzmaDecompress::TLzmaDecompress(IInputStream* slave)
: Impl_(new TImplStream(slave))
{
}
-TLzmaDecompress::TLzmaDecompress(IZeroCopyInput* input)
+TLzmaDecompress::TLzmaDecompress(IZeroCopyInput* input)
: Impl_(new TImplZeroCopy(input))
{
}
diff --git a/library/cpp/streams/lzma/lzma.h b/library/cpp/streams/lzma/lzma.h
index ca1e06e9ef..9a86213655 100644
--- a/library/cpp/streams/lzma/lzma.h
+++ b/library/cpp/streams/lzma/lzma.h
@@ -6,9 +6,9 @@
#include <util/generic/ptr.h>
-class TLzmaCompress: public IOutputStream {
+class TLzmaCompress: public IOutputStream {
public:
- TLzmaCompress(IOutputStream* slave, size_t level = 7);
+ TLzmaCompress(IOutputStream* slave, size_t level = 7);
~TLzmaCompress() override;
private:
@@ -20,10 +20,10 @@ private:
THolder<TImpl> Impl_;
};
-class TLzmaDecompress: public IInputStream {
+class TLzmaDecompress: public IInputStream {
public:
- TLzmaDecompress(IInputStream* slave);
- TLzmaDecompress(IZeroCopyInput* input);
+ TLzmaDecompress(IInputStream* slave);
+ TLzmaDecompress(IZeroCopyInput* input);
~TLzmaDecompress() override;
private:
diff --git a/library/cpp/streams/lzma/lzma_ut.cpp b/library/cpp/streams/lzma/lzma_ut.cpp
index 847e98d1ca..e71e1bde49 100644
--- a/library/cpp/streams/lzma/lzma_ut.cpp
+++ b/library/cpp/streams/lzma/lzma_ut.cpp
@@ -6,7 +6,7 @@
#include <util/random/fast.h>
#include <util/random/random.h>
-class TStrokaByOneByte: public IZeroCopyInput {
+class TStrokaByOneByte: public IZeroCopyInput {
public:
TStrokaByOneByte(const TString& s)
: Data(s)
@@ -52,7 +52,7 @@ private:
}
inline void Test2() {
- class TExcOutput: public IOutputStream {
+ class TExcOutput: public IOutputStream {
public:
~TExcOutput() override {
}
@@ -93,7 +93,7 @@ private:
{
TMemoryInput mi(res.data(), res.size());
TStringOutput so(data1);
- TLzmaDecompress d((IInputStream*)&mi);
+ TLzmaDecompress d((IInputStream*)&mi);
TransferData(&d, &so);
}