diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:15 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:15 +0300 |
commit | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch) | |
tree | da2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/messagebus/left_right_buffer.h | |
parent | 778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff) | |
download | ydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/left_right_buffer.h')
-rw-r--r-- | library/cpp/messagebus/left_right_buffer.h | 140 |
1 files changed, 70 insertions, 70 deletions
diff --git a/library/cpp/messagebus/left_right_buffer.h b/library/cpp/messagebus/left_right_buffer.h index f937cefad0..a221324c23 100644 --- a/library/cpp/messagebus/left_right_buffer.h +++ b/library/cpp/messagebus/left_right_buffer.h @@ -4,75 +4,75 @@ #include <util/generic/noncopyable.h> #include <util/system/yassert.h> -namespace NBus { - namespace NPrivate { - class TLeftRightBuffer : TNonCopyable { - private: - TBuffer Buffer; - size_t Left; - - void CheckInvariant() { - Y_ASSERT(Left <= Buffer.Size()); - } - - public: - TLeftRightBuffer() - : Left(0) - { - } - - TBuffer& GetBuffer() { - return Buffer; - } - - size_t Capacity() { - return Buffer.Capacity(); - } - - void Clear() { - Buffer.Clear(); - Left = 0; - } - - void Reset() { - Buffer.Reset(); - Left = 0; - } - - void Compact() { - Buffer.ChopHead(Left); - Left = 0; - } - - char* LeftPos() { - return Buffer.Data() + Left; - } - - size_t LeftSize() { - return Left; - } - - void LeftProceed(size_t count) { - Y_ASSERT(count <= Size()); - Left += count; - } - - size_t Size() { - return Buffer.Size() - Left; - } - - bool Empty() { - return Size() == 0; - } - - char* RightPos() { - return Buffer.Data() + Buffer.Size(); - } - - size_t Avail() { - return Buffer.Avail(); - } - }; +namespace NBus { + namespace NPrivate { + class TLeftRightBuffer : TNonCopyable { + private: + TBuffer Buffer; + size_t Left; + + void CheckInvariant() { + Y_ASSERT(Left <= Buffer.Size()); + } + + public: + TLeftRightBuffer() + : Left(0) + { + } + + TBuffer& GetBuffer() { + return Buffer; + } + + size_t Capacity() { + return Buffer.Capacity(); + } + + void Clear() { + Buffer.Clear(); + Left = 0; + } + + void Reset() { + Buffer.Reset(); + Left = 0; + } + + void Compact() { + Buffer.ChopHead(Left); + Left = 0; + } + + char* LeftPos() { + return Buffer.Data() + Left; + } + + size_t LeftSize() { + return Left; + } + + void LeftProceed(size_t count) { + Y_ASSERT(count <= Size()); + Left += count; + } + + size_t Size() { + return Buffer.Size() - Left; + } + + bool Empty() { + return Size() == 0; + } + + char* RightPos() { + return Buffer.Data() + Buffer.Size(); + } + + size_t Avail() { + return Buffer.Avail(); + } + }; } -} +} |