diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:17 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:17 +0300 |
commit | d3a398281c6fd1d3672036cb2d63f842d2cb28c5 (patch) | |
tree | dd4bd3ca0f36b817e96812825ffaf10d645803f2 /library/cpp/blockcodecs/core/stream.h | |
parent | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (diff) | |
download | ydb-d3a398281c6fd1d3672036cb2d63f842d2cb28c5.tar.gz |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/blockcodecs/core/stream.h')
-rw-r--r-- | library/cpp/blockcodecs/core/stream.h | 66 |
1 files changed, 33 insertions, 33 deletions
diff --git a/library/cpp/blockcodecs/core/stream.h b/library/cpp/blockcodecs/core/stream.h index b0d7929f05..fd44ef88f2 100644 --- a/library/cpp/blockcodecs/core/stream.h +++ b/library/cpp/blockcodecs/core/stream.h @@ -1,46 +1,46 @@ -#pragma once - -#include <util/stream/walk.h> -#include <util/stream/input.h> -#include <util/stream/output.h> -#include <util/stream/zerocopy.h> -#include <util/generic/buffer.h> - -namespace NBlockCodecs { +#pragma once + +#include <util/stream/walk.h> +#include <util/stream/input.h> +#include <util/stream/output.h> +#include <util/stream/zerocopy.h> +#include <util/generic/buffer.h> + +namespace NBlockCodecs { struct ICodec; - + class TCodedOutput: public IOutputStream { - public: + public: TCodedOutput(IOutputStream* out, const ICodec* c, size_t bufLen); ~TCodedOutput() override; - - private: + + private: void DoWrite(const void* buf, size_t len) override; void DoFlush() override; void DoFinish() override; - - bool FlushImpl(); - - private: - const ICodec* C_; - TBuffer D_; - TBuffer O_; + + bool FlushImpl(); + + private: + const ICodec* C_; + TBuffer D_; + TBuffer O_; IOutputStream* S_; - }; - + }; + class TDecodedInput: public IWalkInput { - public: + public: TDecodedInput(IInputStream* in); - TDecodedInput(IInputStream* in, const ICodec* codec); - + TDecodedInput(IInputStream* in, const ICodec* codec); + ~TDecodedInput() override; - - private: + + private: size_t DoUnboundedNext(const void** ptr) override; - - private: - TBuffer D_; + + private: + TBuffer D_; IInputStream* S_; - const ICodec* C_; - }; -} + const ICodec* C_; + }; +} |