aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorgleb-kov <gleb-kov@yandex-team.ru>2022-02-10 16:46:22 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:22 +0300
commit918e8a1574070d0ec733f0b76cfad8f8892ad2e5 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/messagebus
parent7b1cfa32681104c8468c5824c79fd80d9a88a579 (diff)
downloadydb-918e8a1574070d0ec733f0b76cfad8f8892ad2e5.tar.gz
Restoring authorship annotation for <gleb-kov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/message.cpp6
-rw-r--r--library/cpp/messagebus/message.h18
-rw-r--r--library/cpp/messagebus/rain_check/core/task.cpp4
-rw-r--r--library/cpp/messagebus/remote_server_session.cpp4
-rw-r--r--library/cpp/messagebus/test/helper/object_count_check.h4
-rw-r--r--library/cpp/messagebus/ybus.h2
6 files changed, 19 insertions, 19 deletions
diff --git a/library/cpp/messagebus/message.cpp b/library/cpp/messagebus/message.cpp
index d0b09a3486..bfa7ed8e9b 100644
--- a/library/cpp/messagebus/message.cpp
+++ b/library/cpp/messagebus/message.cpp
@@ -24,7 +24,7 @@ namespace NBus {
// TODO: print local flags
#ifndef NDEBUG
Y_VERIFY(LocalFlags == 0, "local flags must be zero at this point; message type is %s",
- MessageType.value_or("unknown").c_str());
+ MessageType.value_or("unknown").c_str());
#else
Y_VERIFY(LocalFlags == 0, "local flags must be zero at this point");
#endif
@@ -83,7 +83,7 @@ namespace NBus {
}
TString TBusMessage::Describe() const {
- return Sprintf("object type: %s, message type: %d", TypeName(*this).data(), int(GetHeader()->Type));
+ return Sprintf("object type: %s, message type: %d", TypeName(*this).data(), int(GetHeader()->Type));
}
TBusMessage::~TBusMessage() {
@@ -184,7 +184,7 @@ namespace NBus {
<< " flags=" << Flags
<< " local-flags=" << LocalFlags
#ifndef NDEBUG
- << " msg-type= " << MessageType.value_or("unknown").c_str()
+ << " msg-type= " << MessageType.value_or("unknown").c_str()
#endif
;
return ss.Str();
diff --git a/library/cpp/messagebus/message.h b/library/cpp/messagebus/message.h
index 6e96c964d5..005ca10c65 100644
--- a/library/cpp/messagebus/message.h
+++ b/library/cpp/messagebus/message.h
@@ -11,12 +11,12 @@
#include <util/generic/ptr.h>
#include <util/generic/string.h>
#include <util/system/defaults.h>
-#include <util/system/type_name.h>
+#include <util/system/type_name.h>
#include <util/system/yassert.h>
-#include <optional>
-#include <typeinfo>
-
+#include <optional>
+#include <typeinfo>
+
namespace NBus {
///////////////////////////////////////////////////////////////////
/// \brief Structure to preserve identity from message to reply
@@ -37,10 +37,10 @@ namespace NBus {
TInstant RecvTime;
#ifndef NDEBUG
- std::optional<TString> MessageType;
+ std::optional<TString> MessageType;
#endif
- private:
+ private:
// TODO: drop
TNetAddr GetNetAddr() const;
@@ -91,12 +91,12 @@ namespace NBus {
}
}
- void SetMessageType(const std::type_info& messageTypeInfo) {
+ void SetMessageType(const std::type_info& messageTypeInfo) {
#ifndef NDEBUG
Y_VERIFY(!MessageType, "state check");
- MessageType = TypeName(messageTypeInfo);
+ MessageType = TypeName(messageTypeInfo);
#else
- Y_UNUSED(messageTypeInfo);
+ Y_UNUSED(messageTypeInfo);
#endif
}
};
diff --git a/library/cpp/messagebus/rain_check/core/task.cpp b/library/cpp/messagebus/rain_check/core/task.cpp
index dd7885ae16..a098437d53 100644
--- a/library/cpp/messagebus/rain_check/core/task.cpp
+++ b/library/cpp/messagebus/rain_check/core/task.cpp
@@ -2,7 +2,7 @@
#include <library/cpp/messagebus/actor/temp_tls_vector.h>
-#include <util/system/type_name.h>
+#include <util/system/type_name.h>
#include <util/system/tls.h>
using namespace NRainCheck;
@@ -208,7 +208,7 @@ ITaskBase* TTaskRunnerBase::CurrentTaskImpl() {
}
TString TTaskRunnerBase::GetStatusSingleLine() {
- return TypeName(*Impl);
+ return TypeName(*Impl);
}
bool NRainCheck::AreWeInsideTask() {
diff --git a/library/cpp/messagebus/remote_server_session.cpp b/library/cpp/messagebus/remote_server_session.cpp
index 7daf409811..6abbf88a60 100644
--- a/library/cpp/messagebus/remote_server_session.cpp
+++ b/library/cpp/messagebus/remote_server_session.cpp
@@ -103,8 +103,8 @@ void TRemoteServerSession::InvokeOnMessage(TBusMessagePtrAndHeader& request, TIn
ident.RecvTime = request.MessagePtr->RecvTime;
#ifndef NDEBUG
- auto& message = *request.MessagePtr;
- ident.SetMessageType(typeid(message));
+ auto& message = *request.MessagePtr;
+ ident.SetMessageType(typeid(message));
#endif
TOnMessageContext context(request.MessagePtr.Release(), ident, this);
diff --git a/library/cpp/messagebus/test/helper/object_count_check.h b/library/cpp/messagebus/test/helper/object_count_check.h
index b13ca07185..1c4756e58c 100644
--- a/library/cpp/messagebus/test/helper/object_count_check.h
+++ b/library/cpp/messagebus/test/helper/object_count_check.h
@@ -11,7 +11,7 @@
#include <library/cpp/messagebus/scheduler/scheduler.h>
#include <util/generic/object_counter.h>
-#include <util/system/type_name.h>
+#include <util/system/type_name.h>
#include <util/stream/output.h>
#include <typeinfo>
@@ -49,7 +49,7 @@ struct TObjectCountCheck {
}
void operator()() {
- UNIT_ASSERT_VALUES_EQUAL_C(0L, TObjectCounter<T>::ObjectCount(), TypeName<T>());
+ UNIT_ASSERT_VALUES_EQUAL_C(0L, TObjectCounter<T>::ObjectCount(), TypeName<T>());
}
};
diff --git a/library/cpp/messagebus/ybus.h b/library/cpp/messagebus/ybus.h
index 5878b87ca7..de21ad8521 100644
--- a/library/cpp/messagebus/ybus.h
+++ b/library/cpp/messagebus/ybus.h
@@ -30,7 +30,7 @@
#include <util/stream/input.h>
#include <util/system/atomic.h>
#include <util/system/condvar.h>
-#include <util/system/type_name.h>
+#include <util/system/type_name.h>
#include <util/system/event.h>
#include <util/system/mutex.h>