aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/message.cpp
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/message.cpp
parent3e7ff6e4ee637c04455854159e84850e613ebc16 (diff)
downloadydb-4bac7bacd041dac72ece081598805d03d2e80a3e.tar.gz
Restoring authorship annotation for <vladimir@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/message.cpp')
-rw-r--r--library/cpp/messagebus/message.cpp20
1 files changed, 10 insertions, 10 deletions
diff --git a/library/cpp/messagebus/message.cpp b/library/cpp/messagebus/message.cpp
index e4d483901d..bfa7ed8e9b 100644
--- a/library/cpp/messagebus/message.cpp
+++ b/library/cpp/messagebus/message.cpp
@@ -3,15 +3,15 @@
#include <util/random/random.h>
#include <util/string/printf.h>
-#include <util/system/atomic.h>
-
+#include <util/system/atomic.h>
+
#include <string.h>
-
+
using namespace NBus;
namespace NBus {
using namespace NBus::NPrivate;
-
+
TBusIdentity::TBusIdentity()
: MessageId(0)
, Size(0)
@@ -73,7 +73,7 @@ namespace NBus {
GetHeader()->Type = type;
DoReset();
}
-
+
TBusMessage::TBusMessage(ECreateUninitialized)
//: TCtr("BusMessage")
: TRefCounted<TBusMessage, TAtomicCounter, TDelete>(1)
@@ -81,11 +81,11 @@ namespace NBus {
, Data(nullptr)
{
}
-
+
TString TBusMessage::Describe() const {
return Sprintf("object type: %s, message type: %d", TypeName(*this).data(), int(GetHeader()->Type));
}
-
+
TBusMessage::~TBusMessage() {
#ifndef NDEBUG
Y_VERIFY(GetHeader()->Id != YBUS_KEYINVALID, "must not be invalid key, message type: %d, ", int(Type));
@@ -94,7 +94,7 @@ namespace NBus {
CheckClean();
#endif
}
-
+
void TBusMessage::DoReset() {
GetHeader()->SendTime = 0;
GetHeader()->Size = 0;
@@ -125,7 +125,7 @@ namespace NBus {
memcpy(this, data.data(), sizeof(TBusHeader));
return sizeof(TBusHeader);
}
-
+
///////////////////////////////////////////////////////
/// \brief Packs header to network order
@@ -140,7 +140,7 @@ namespace NBus {
data.Flags = GetHeader()->FlagsInternal;
//data.LocalFlags = LocalFlags;
}
-
+
////////////////////////////////////////////////////////////
/// \brief set message identity from serialized form