aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/yson_pull/input.h
diff options
context:
space:
mode:
authorAnton Samokhvalov <pg83@yandex.ru>2022-02-10 16:45:15 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:15 +0300
commit72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch)
treeda2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/yson_pull/input.h
parent778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff)
downloadydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/yson_pull/input.h')
-rw-r--r--library/cpp/yson_pull/input.h114
1 files changed, 57 insertions, 57 deletions
diff --git a/library/cpp/yson_pull/input.h b/library/cpp/yson_pull/input.h
index 2cdfae857e..97cad44987 100644
--- a/library/cpp/yson_pull/input.h
+++ b/library/cpp/yson_pull/input.h
@@ -13,69 +13,69 @@
class IInputStream;
class IZeroCopyInput;
-namespace NYsonPull {
- namespace NInput {
- //! \brief Input stream adaptor interface.
- //!
- //! Represents a model of a chunked input data stream.
- class IStream {
- input_buffer buffer_;
- bool at_end_ = false;
-
- public:
- virtual ~IStream() = default;
-
- bool at_end() const {
- return at_end_;
- }
-
- input_buffer& buffer() noexcept {
- return buffer_;
- }
- const input_buffer& buffer() const noexcept {
- return buffer_;
- }
-
- void fill_buffer() {
- while (buffer_.is_empty() && !at_end()) {
- at_end_ = do_fill_buffer() == result::at_end;
- }
- }
-
- protected:
- enum class result {
- have_more_data, //! May continue reading
- at_end, //! Reached end of stream
- };
-
- //! \brief Read next chunk of data.
- //!
- //! The implementation is to discard the buffer contents
- //! and reset the buffer to a next chunk of data.
- //! End-of-stream condition is to be reported via return value.
- //!
- //! Read is assumed to always succeed unless it throws an exception.
- virtual result do_fill_buffer() = 0;
- };
-
- //! \brief Read data from a contiguous memory block (i.e. a string)
- //!
- //! Does not take ownership on memory.
+namespace NYsonPull {
+ namespace NInput {
+ //! \brief Input stream adaptor interface.
+ //!
+ //! Represents a model of a chunked input data stream.
+ class IStream {
+ input_buffer buffer_;
+ bool at_end_ = false;
+
+ public:
+ virtual ~IStream() = default;
+
+ bool at_end() const {
+ return at_end_;
+ }
+
+ input_buffer& buffer() noexcept {
+ return buffer_;
+ }
+ const input_buffer& buffer() const noexcept {
+ return buffer_;
+ }
+
+ void fill_buffer() {
+ while (buffer_.is_empty() && !at_end()) {
+ at_end_ = do_fill_buffer() == result::at_end;
+ }
+ }
+
+ protected:
+ enum class result {
+ have_more_data, //! May continue reading
+ at_end, //! Reached end of stream
+ };
+
+ //! \brief Read next chunk of data.
+ //!
+ //! The implementation is to discard the buffer contents
+ //! and reset the buffer to a next chunk of data.
+ //! End-of-stream condition is to be reported via return value.
+ //!
+ //! Read is assumed to always succeed unless it throws an exception.
+ virtual result do_fill_buffer() = 0;
+ };
+
+ //! \brief Read data from a contiguous memory block (i.e. a string)
+ //!
+ //! Does not take ownership on memory.
THolder<IStream> FromMemory(TStringBuf data);
- //! \brief Read data from C FILE* object.
- //!
- //! Does not take ownership on file object.
- //! Data is buffered internally regardless of file buffering.
+ //! \brief Read data from C FILE* object.
+ //!
+ //! Does not take ownership on file object.
+ //! Data is buffered internally regardless of file buffering.
THolder<IStream> FromStdioFile(FILE* file, size_t buffer_size = 65536);
- //! \brief Read data from POSIX file descriptor.
- //!
- //! Does not take ownership on streambuf.
+ //! \brief Read data from POSIX file descriptor.
+ //!
+ //! Does not take ownership on streambuf.
THolder<IStream> FromPosixFd(int fd, size_t buffer_size = 65536);
THolder<IStream> FromZeroCopyInput(IZeroCopyInput* input);
THolder<IStream> FromInputStream(IInputStream* input, size_t buffer_size = 65536);
- }
-}
+ }
+}