diff options
author | Alexander Rutkovsky <alexvru@mail.ru> | 2022-02-10 16:47:39 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:39 +0300 |
commit | f3646f91e0de459836a7800b9ce3e8dc57a2ab3a (patch) | |
tree | 25c1423200152570c1f8307e5b8304b9bc3840c5 /library/cpp/actors/core/events.h | |
parent | fccc62e9bfdce9be2fe7e0f23479da3a5512211a (diff) | |
download | ydb-f3646f91e0de459836a7800b9ce3e8dc57a2ab3a.tar.gz |
Restoring authorship annotation for Alexander Rutkovsky <alexvru@mail.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/core/events.h')
-rw-r--r-- | library/cpp/actors/core/events.h | 52 |
1 files changed, 26 insertions, 26 deletions
diff --git a/library/cpp/actors/core/events.h b/library/cpp/actors/core/events.h index 702cf50fad..841537888a 100644 --- a/library/cpp/actors/core/events.h +++ b/library/cpp/actors/core/events.h @@ -64,16 +64,16 @@ namespace NActors { } bool SerializeToArcadiaStream(TChunkSerializer *serializer) const override { - return serializer->WriteString(&Blob); + return serializer->WriteString(&Blob); } static IEventBase* Load(TEventSerializedData* bufs) noexcept { - return new TEvBlob(bufs->GetString()); - } - - bool IsSerializable() const override { - return true; + return new TEvBlob(bufs->GetString()); } + + bool IsSerializable() const override { + return true; + } }; struct TSystem { @@ -94,9 +94,9 @@ namespace NActors { Gone, // Generic notification of actor death TrackActor, UntrackActor, - InvokeResult, - CoroTimeout, - InvokeQuery, + InvokeResult, + CoroTimeout, + InvokeQuery, End, // Compatibility section @@ -139,33 +139,33 @@ namespace NActors { }; const ui32 SourceType; const EReason Reason; - const bool Unsure; - const TString Data; + const bool Unsure; + const TString Data; - TEvUndelivered(ui32 sourceType, ui32 reason, bool unsure = false) + TEvUndelivered(ui32 sourceType, ui32 reason, bool unsure = false) : SourceType(sourceType) , Reason(static_cast<EReason>(reason)) - , Unsure(unsure) - , Data(MakeData(sourceType, reason)) - {} + , Unsure(unsure) + , Data(MakeData(sourceType, reason)) + {} TString ToStringHeader() const override; bool SerializeToArcadiaStream(TChunkSerializer *serializer) const override; static IEventBase* Load(TEventSerializedData* bufs); - bool IsSerializable() const override; - - ui32 CalculateSerializedSize() const override { return 2 * sizeof(ui32); } + bool IsSerializable() const override; + ui32 CalculateSerializedSize() const override { return 2 * sizeof(ui32); } + static void Out(IOutputStream& o, EReason x); - - private: - static TString MakeData(ui32 sourceType, ui32 reason) { - TString s = TString::Uninitialized(sizeof(ui32) + sizeof(ui32)); + + private: + static TString MakeData(ui32 sourceType, ui32 reason) { + TString s = TString::Uninitialized(sizeof(ui32) + sizeof(ui32)); char *p = s.Detach(); WriteUnaligned<ui32>(p + 0, sourceType); WriteUnaligned<ui32>(p + 4, reason); - return s; - } + return s; + } }; struct TEvCompleted: public TEventBase<TEvCompleted, TSystem::Completed> { @@ -209,8 +209,8 @@ namespace NActors { DEFINE_SIMPLE_LOCAL_EVENT(TEvGone, "System: TEvGone") }; - struct TEvInvokeResult; - + struct TEvInvokeResult; + using TEvPoisonPill = TEvPoison; // Legacy name, deprecated using TEvActorDied = TEvGone; }; |