aboutsummaryrefslogtreecommitdiffstats
path: root/library
diff options
context:
space:
mode:
authoryuryalekseev <yuryalekseev@yandex-team.ru>2022-02-10 16:50:33 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:33 +0300
commit37b41bf0956ce3c4d47e240dc8fc6b5a2e4638c0 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library
parentdde1573d56354127a7cb8b3461dd08bcdd48a045 (diff)
downloadydb-37b41bf0956ce3c4d47e240dc8fc6b5a2e4638c0.tar.gz
Restoring authorship annotation for <yuryalekseev@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library')
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp8
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_client.h6
2 files changed, 7 insertions, 7 deletions
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp
index 6d9cdf3800..daac8d9a99 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp
@@ -49,10 +49,10 @@ void TBusClientService::SendOneWay(
ProcessResultCommon(message, addr, future, ok);
}
-NBus::TBusClientSessionPtr TBusClientService::GetSessionForMonitoring() const {
- return Session;
-}
-
+NBus::TBusClientSessionPtr TBusClientService::GetSessionForMonitoring() const {
+ return Session;
+}
+
void TBusClientService::Send(
TBusMessageAutoPtr message, const TNetAddr& addr,
TBusFuture* future) {
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h
index c43e54161a..0a291cdea6 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h
@@ -52,9 +52,9 @@ namespace NRainCheck {
void Send(NBus::TBusMessageAutoPtr, const NBus::TNetAddr&, TBusFuture* future);
void SendOneWay(NBus::TBusMessageAutoPtr, const NBus::TNetAddr&, TBusFuture* future);
- // Use it only for monitoring
- NBus::TBusClientSessionPtr GetSessionForMonitoring() const;
-
+ // Use it only for monitoring
+ NBus::TBusClientSessionPtr GetSessionForMonitoring() const;
+
private:
void SendCommon(NBus::TBusMessage*, const NBus::TNetAddr&, TBusFuture* future);
void ProcessResultCommon(NBus::TBusMessageAutoPtr, const NBus::TNetAddr&, TBusFuture* future, NBus::EMessageStatus);