diff options
author | vladimir <vladimir@yandex-team.ru> | 2022-02-10 16:50:29 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:29 +0300 |
commit | 4bac7bacd041dac72ece081598805d03d2e80a3e (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/test/helper/example.h | |
parent | 3e7ff6e4ee637c04455854159e84850e613ebc16 (diff) | |
download | ydb-4bac7bacd041dac72ece081598805d03d2e80a3e.tar.gz |
Restoring authorship annotation for <vladimir@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/test/helper/example.h')
-rw-r--r-- | library/cpp/messagebus/test/helper/example.h | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/library/cpp/messagebus/test/helper/example.h b/library/cpp/messagebus/test/helper/example.h index 5aa9b53df0..26b7475308 100644 --- a/library/cpp/messagebus/test/helper/example.h +++ b/library/cpp/messagebus/test/helper/example.h @@ -1,10 +1,10 @@ #pragma once - + #include <library/cpp/testing/unittest/registar.h> #include "alloc_counter.h" #include "message_handler_error.h" - + #include <library/cpp/messagebus/ybus.h> #include <library/cpp/messagebus/misc/test_sync.h> @@ -14,13 +14,13 @@ namespace NBus { namespace NTest { class TExampleRequest: public TBusMessage { friend class TExampleProtocol; - + private: TAllocCounter AllocCounter; public: TString Data; - + public: TExampleRequest(TAtomic* counterPtr, size_t payloadSize = 320); TExampleRequest(ECreateUninitialized, TAtomic* counterPtr); @@ -28,10 +28,10 @@ namespace NBus { class TExampleResponse: public TBusMessage { friend class TExampleProtocol; - + private: TAllocCounter AllocCounter; - + public: TString Data; TExampleResponse(TAtomic* counterPtr, size_t payloadSize = 320); @@ -47,11 +47,11 @@ namespace NBus { TAtomic StartCount; TExampleProtocol(int port = 0); - + ~TExampleProtocol() override; - + void Serialize(const TBusMessage* message, TBuffer& buffer) override; - + TAutoPtr<TBusMessage> Deserialize(ui16 messageType, TArrayRef<const char> payload) override; }; @@ -77,7 +77,7 @@ namespace NBus { ~TExampleClient() override; EMessageStatus SendMessage(const TNetAddr* addr = nullptr); - + void SendMessages(size_t count, const TNetAddr* addr = nullptr); void SendMessages(size_t count, const TNetAddr& addr); @@ -90,7 +90,7 @@ namespace NBus { void SendMessagesWaitReplies(size_t count, const TNetAddr& addr); void OnReply(TAutoPtr<TBusMessage> mess, TAutoPtr<TBusMessage> reply) override; - + void OnError(TAutoPtr<TBusMessage> mess, EMessageStatus) override; }; @@ -101,12 +101,12 @@ namespace NBus { bool AckMessageBeforeSendReply; TMaybe<size_t> DataSize; // Nothing means use request size bool ForgetRequest; - + TTestSync TestSync; TBusMessageQueuePtr Bus; TBusServerSessionPtr Session; - + public: TExampleServer( const char* name = "TExampleServer", @@ -115,7 +115,7 @@ namespace NBus { TExampleServer(unsigned port, const char* name = "TExampleServer"); ~TExampleServer() override; - + public: size_t GetInFlight() const; unsigned GetActualListenPort() const; @@ -127,6 +127,6 @@ namespace NBus { protected: void OnMessage(TOnMessageContext& mess) override; }; - + } } |