diff options
author | Vasily Gerasimov <UgnineSirdis@gmail.com> | 2022-02-10 16:49:10 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:10 +0300 |
commit | 1eb755fbca92172a6aec2f57371b2b3a19dfab43 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus | |
parent | 6cdc8f140213c595e4ad38bc3d97fcef1146b8c3 (diff) | |
download | ydb-1eb755fbca92172a6aec2f57371b2b3a19dfab43.tar.gz |
Restoring authorship annotation for Vasily Gerasimov <UgnineSirdis@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r-- | library/cpp/messagebus/message_status.h | 12 | ||||
-rw-r--r-- | library/cpp/messagebus/remote_connection.cpp | 4 |
2 files changed, 8 insertions, 8 deletions
diff --git a/library/cpp/messagebus/message_status.h b/library/cpp/messagebus/message_status.h index be274d42522..e1878960b34 100644 --- a/library/cpp/messagebus/message_status.h +++ b/library/cpp/messagebus/message_status.h @@ -43,15 +43,15 @@ namespace NBus { // For lwtrace struct TMessageStatusField { typedef int TStoreType; - typedef int TFuncParam; - + typedef int TFuncParam; + static void ToString(int value, TString* out) { *out = GetMessageStatus((NBus::EMessageStatus)value); } - - static int ToStoreType(int value) { - return value; - } + + static int ToStoreType(int value) { + return value; + } }; } // ns diff --git a/library/cpp/messagebus/remote_connection.cpp b/library/cpp/messagebus/remote_connection.cpp index 283b277d7bd..22932569dbd 100644 --- a/library/cpp/messagebus/remote_connection.cpp +++ b/library/cpp/messagebus/remote_connection.cpp @@ -67,7 +67,7 @@ namespace NBus { } TRemoteConnection::TWriterData::~TWriterData() { - Y_VERIFY(AtomicGet(Down)); + Y_VERIFY(AtomicGet(Down)); Y_VERIFY(SendQueue.Empty()); } @@ -119,7 +119,7 @@ namespace NBus { } TRemoteConnection::TReaderData::~TReaderData() { - Y_VERIFY(AtomicGet(Down)); + Y_VERIFY(AtomicGet(Down)); } void TRemoteConnection::Send(TNonDestroyingAutoPtr<TBusMessage> msg) { |