aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/synchandler.cpp
diff options
context:
space:
mode:
authoragorodilov <agorodilov@yandex-team.ru>2022-02-10 16:47:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:09 +0300
commitbd5ef432f5cfb1e18851381329d94665a4c22470 (patch)
treeb83306b6e37edeea782e9eed673d89286c4fef35 /library/cpp/messagebus/synchandler.cpp
parent7a4979e6211c3e78c7f9041d4a9e5d3405343c36 (diff)
downloadydb-bd5ef432f5cfb1e18851381329d94665a4c22470.tar.gz
Restoring authorship annotation for <agorodilov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/synchandler.cpp')
-rw-r--r--library/cpp/messagebus/synchandler.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/library/cpp/messagebus/synchandler.cpp b/library/cpp/messagebus/synchandler.cpp
index 5198eaadd5..8e891d66b3 100644
--- a/library/cpp/messagebus/synchandler.cpp
+++ b/library/cpp/messagebus/synchandler.cpp
@@ -19,7 +19,7 @@ struct TBusSyncMessageData {
EMessageStatus ReplyStatus;
TBusSyncMessageData()
- : Reply(nullptr)
+ : Reply(nullptr)
, ReplyStatus(MESSAGE_DONT_ASK)
{
}
@@ -29,13 +29,13 @@ class TSyncHandler: public IBusClientHandler {
public:
TSyncHandler(bool expectReply = true)
: ExpectReply(expectReply)
- , Session(nullptr)
+ , Session(nullptr)
{
}
~TSyncHandler() override {
}
- void OnReply(TAutoPtr<TBusMessage> pMessage0, TAutoPtr<TBusMessage> pReply0) override {
+ void OnReply(TAutoPtr<TBusMessage> pMessage0, TAutoPtr<TBusMessage> pReply0) override {
TBusMessage* pMessage = pMessage0.Release();
TBusMessage* pReply = pReply0.Release();
@@ -47,25 +47,25 @@ public:
SignalResult(data, pReply, MESSAGE_OK);
}
- void OnError(TAutoPtr<TBusMessage> pMessage0, EMessageStatus status) override {
+ void OnError(TAutoPtr<TBusMessage> pMessage0, EMessageStatus status) override {
TBusMessage* pMessage = pMessage0.Release();
TBusSyncMessageData* data = static_cast<TBusSyncMessageData*>(pMessage->Data);
if (!data) {
return;
}
- SignalResult(data, /*pReply=*/nullptr, status);
+ SignalResult(data, /*pReply=*/nullptr, status);
}
- void OnMessageSent(TBusMessage* pMessage) override {
+ void OnMessageSent(TBusMessage* pMessage) override {
Y_UNUSED(pMessage);
Y_ASSERT(ExpectReply);
}
- void OnMessageSentOneWay(TAutoPtr<TBusMessage> pMessage) override {
+ void OnMessageSentOneWay(TAutoPtr<TBusMessage> pMessage) override {
Y_ASSERT(!ExpectReply);
TBusSyncMessageData* data = static_cast<TBusSyncMessageData*>(pMessage.Release()->Data);
- SignalResult(data, /*pReply=*/nullptr, MESSAGE_OK);
+ SignalResult(data, /*pReply=*/nullptr, MESSAGE_OK);
}
void SetSession(TRemoteClientSession* session) {