summaryrefslogtreecommitdiffstats
path: root/library/cpp/yson_pull/detail/byte_reader.h
diff options
context:
space:
mode:
authorAnton Samokhvalov <[email protected]>2022-02-10 16:45:17 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:45:17 +0300
commitd3a398281c6fd1d3672036cb2d63f842d2cb28c5 (patch)
treedd4bd3ca0f36b817e96812825ffaf10d645803f2 /library/cpp/yson_pull/detail/byte_reader.h
parent72cb13b4aff9bc9cf22e49251bc8fd143f82538f (diff)
Restoring authorship annotation for Anton Samokhvalov <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/yson_pull/detail/byte_reader.h')
-rw-r--r--library/cpp/yson_pull/detail/byte_reader.h108
1 files changed, 54 insertions, 54 deletions
diff --git a/library/cpp/yson_pull/detail/byte_reader.h b/library/cpp/yson_pull/detail/byte_reader.h
index 915277518a9..7cea50d3236 100644
--- a/library/cpp/yson_pull/detail/byte_reader.h
+++ b/library/cpp/yson_pull/detail/byte_reader.h
@@ -6,69 +6,69 @@
#include <library/cpp/yson_pull/input.h>
-namespace NYsonPull {
- namespace NDetail {
- template <class StreamCounter>
- class byte_reader {
- NYsonPull::NInput::IStream& stream_;
- StreamCounter stream_counter_;
+namespace NYsonPull {
+ namespace NDetail {
+ template <class StreamCounter>
+ class byte_reader {
+ NYsonPull::NInput::IStream& stream_;
+ StreamCounter stream_counter_;
- public:
- byte_reader(NYsonPull::NInput::IStream& stream)
- : stream_(stream)
- {
- }
+ public:
+ byte_reader(NYsonPull::NInput::IStream& stream)
+ : stream_(stream)
+ {
+ }
- // const-ness added to prevent direct stream mutation
- const NYsonPull::NInput::IStream& stream() {
- return stream_;
- }
+ // const-ness added to prevent direct stream mutation
+ const NYsonPull::NInput::IStream& stream() {
+ return stream_;
+ }
- template <typename... Args>
- ATTRIBUTE(noinline, cold)
- void fail[[noreturn]](const char* msg, Args&&... args) {
- NYsonPull::NDetail::fail(
- stream_counter_.info(),
- msg,
- std::forward<Args>(args)...);
- }
+ template <typename... Args>
+ ATTRIBUTE(noinline, cold)
+ void fail[[noreturn]](const char* msg, Args&&... args) {
+ NYsonPull::NDetail::fail(
+ stream_counter_.info(),
+ msg,
+ std::forward<Args>(args)...);
+ }
- template <bool AllowFinish>
- void fill_buffer() {
- stream_.fill_buffer();
+ template <bool AllowFinish>
+ void fill_buffer() {
+ stream_.fill_buffer();
- if (!AllowFinish) {
- auto& buf = stream_.buffer();
+ if (!AllowFinish) {
+ auto& buf = stream_.buffer();
if (Y_UNLIKELY(buf.is_empty() && stream_.at_end())) {
- fail("Premature end of stream");
- }
- }
- }
+ fail("Premature end of stream");
+ }
+ }
+ }
- void fill_buffer() {
- return fill_buffer<true>();
+ void fill_buffer() {
+ return fill_buffer<true>();
}
- template <bool AllowFinish>
- ui8 get_byte() {
- fill_buffer<AllowFinish>();
- auto& buf = stream_.buffer();
- return !buf.is_empty()
- ? *buf.pos()
- : ui8{'\0'};
- }
+ template <bool AllowFinish>
+ ui8 get_byte() {
+ fill_buffer<AllowFinish>();
+ auto& buf = stream_.buffer();
+ return !buf.is_empty()
+ ? *buf.pos()
+ : ui8{'\0'};
+ }
- ui8 get_byte() {
- return get_byte<true>();
- }
+ ui8 get_byte() {
+ return get_byte<true>();
+ }
- void advance(size_t bytes) {
- auto& buf = stream_.buffer();
- stream_counter_.update(
- buf.pos(),
- buf.pos() + bytes);
- buf.advance(bytes);
- }
- };
+ void advance(size_t bytes) {
+ auto& buf = stream_.buffer();
+ stream_counter_.update(
+ buf.pos(),
+ buf.pos() + bytes);
+ buf.advance(bytes);
+ }
+ };
}
-}
+}