diff options
author | somov <somov@yandex-team.ru> | 2022-02-10 16:45:49 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:49 +0300 |
commit | 7489e4682331202b9c7d863c0898eb83d7b12c2b (patch) | |
tree | 9142afc54d335ea52910662635b898e79e192e49 /library/cpp/messagebus/storage.h | |
parent | a5950576e397b1909261050b8c7da16db58f10b1 (diff) | |
download | ydb-7489e4682331202b9c7d863c0898eb83d7b12c2b.tar.gz |
Restoring authorship annotation for <somov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/storage.h')
-rw-r--r-- | library/cpp/messagebus/storage.h | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/library/cpp/messagebus/storage.h b/library/cpp/messagebus/storage.h index 3f8de480a1..7d168844ed 100644 --- a/library/cpp/messagebus/storage.h +++ b/library/cpp/messagebus/storage.h @@ -1,5 +1,5 @@ -#pragma once - +#pragma once + #include "message_ptr_and_header.h" #include "moved.h" #include "ybus.h" @@ -18,7 +18,7 @@ namespace NBus { public: TTimedMessages(); ~TTimedMessages(); - + struct TItem { THolder<TBusMessage> Message; @@ -36,31 +36,31 @@ namespace NBus { void Timeout(TInstant before, TMessagesPtrs* r); void Clear(TMessagesPtrs* r); - + private: TItems Items; }; - + class TSyncAckMessages : TNonCopyable { public: TSyncAckMessages(); ~TSyncAckMessages(); - + void Push(TBusMessagePtrAndHeader& m); TBusMessage* Pop(TBusKey id); void Timeout(TInstant before, TMessagesPtrs* r); void Clear(TMessagesPtrs* r); - + size_t Size() const { return KeyToMessage.size(); } - + void RemoveAll(const TMessagesPtrs&); - + void Gc(); - + void DumpState(); private: |