aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/test/helper/example.h
diff options
context:
space:
mode:
authorvladimir <vladimir@yandex-team.ru>2022-02-10 16:50:29 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:29 +0300
commit4bac7bacd041dac72ece081598805d03d2e80a3e (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/test/helper/example.h
parent3e7ff6e4ee637c04455854159e84850e613ebc16 (diff)
downloadydb-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.h30
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;
};
-
+
}
}