intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 51 insertions, 0 deletions

diff --git a/library/cpp/yson_pull/detail/stream_counter.h b/library/cpp/yson_pull/detail/stream_counter.h
new file mode 100644
index 0000000000..3b41b27eb6
--- /dev/null
+++ b/library/cpp/yson_pull/detail/stream_counter.h
@@ -0,0 +1,51 @@
+#pragma once
+
+#include <library/cpp/yson_pull/position_info.h>
+
+#include <cstddef>
+
+namespace NYsonPull {
+    namespace NDetail {
+        template <bool EnableLinePositionInfo>
+        class stream_counter;
+
+        template <>
+        class stream_counter<true> {
+        private:
+            size_t offset_ = 0;
+            size_t line_ = 1;
+            size_t column_ = 1;
+
+        public:
+            TPositionInfo info() const {
+                return {offset_, line_, column_};
+            }
+
+            void update(const ui8* begin, const ui8* end) {
+                offset_ += end - begin;
+                for (auto current = begin; current != end; ++current) {
+                    ++column_;
+                    if (*current == '\n') { //TODO: memchr
+                        ++line_;
+                        column_ = 1;
+                    }
+                }
+            }
+        };
+
+        template <>
+        class stream_counter<false> {
+        private:
+            size_t offset_ = 0;
+
+        public:
+            TPositionInfo info() const {
+                return {offset_, {}, {}};
+            }
+
+            void update(const ui8* begin, const ui8* end) {
+                offset_ += end - begin;
+            }
+        };
+    }
+}