diff options
author | vladimir <vladimir@yandex-team.ru> | 2022-02-10 16:50:29 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:29 +0300 |
commit | 4bac7bacd041dac72ece081598805d03d2e80a3e (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/message.cpp | |
parent | 3e7ff6e4ee637c04455854159e84850e613ebc16 (diff) | |
download | ydb-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.cpp | 20 |
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 |