diff options
author | Artem Zuikov <chertus@gmail.com> | 2022-02-10 16:46:28 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:46:28 +0300 |
commit | 889e4ac5f8ac5a463b06b9b64de835d736c06980 (patch) | |
tree | 1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library | |
parent | d23c9e2333524245de2f721e04136f51c31411ef (diff) | |
download | ydb-889e4ac5f8ac5a463b06b9b64de835d736c06980.tar.gz |
Restoring authorship annotation for Artem Zuikov <chertus@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'library')
-rw-r--r-- | library/cpp/actors/core/actor.h | 6 | ||||
-rw-r--r-- | library/cpp/actors/core/hfunc.h | 6 | ||||
-rw-r--r-- | library/cpp/actors/core/log.h | 12 | ||||
-rw-r--r-- | library/cpp/actors/core/process_stats.cpp | 2 | ||||
-rw-r--r-- | library/cpp/actors/core/scheduler_actor.cpp | 6 | ||||
-rw-r--r-- | library/cpp/actors/interconnect/load.cpp | 6 |
6 files changed, 19 insertions, 19 deletions
diff --git a/library/cpp/actors/core/actor.h b/library/cpp/actors/core/actor.h index 0a8d3369a7..ed29bd14b9 100644 --- a/library/cpp/actors/core/actor.h +++ b/library/cpp/actors/core/actor.h @@ -247,7 +247,7 @@ namespace NActors { DNS_RESOLVER = 481, INTERCONNECT_PROXY_WRAPPER = 546, }; - + using EActivityType = EActorActivity; ui32 ActivityType; @@ -291,7 +291,7 @@ namespace NActors { void SetActivityType(ui32 activityType) { ActivityType = activityType; } - + public: TReceiveFunc CurrentStateFunc() const { return StateFunc; @@ -422,7 +422,7 @@ namespace NActors { static constexpr IActor::EActivityType ActorActivityType() { return EActorActivity::OTHER; } //*/ - + // static constexpr char ActorName[] = "UNNAMED"; TActor(void (TDerived::*func)(TAutoPtr<IEventHandle>& ev, const TActorContext& ctx), ui32 activityType = GetActivityTypeIndex()) diff --git a/library/cpp/actors/core/hfunc.h b/library/cpp/actors/core/hfunc.h index 7ffb0435ff..26f3c65013 100644 --- a/library/cpp/actors/core/hfunc.h +++ b/library/cpp/actors/core/hfunc.h @@ -4,7 +4,7 @@ #include "executor_thread.h" #include <util/system/defaults.h> - + #define HFunc(TEvType, HandleFunc) \ case TEvType::EventType: { \ typename TEvType::TPtr* x = reinterpret_cast<typename TEvType::TPtr*>(&ev); \ @@ -25,8 +25,8 @@ TEvType::TPtr* x = reinterpret_cast<TEvType::TPtr*>(&ev); \ HandleFunc(*x, ctx); \ break; \ - } - + } + #define hFuncTraced(TEvType, HandleFunc) \ case TEvType::EventType: { \ TRACE_EVENT_TYPE(Y_STRINGIZE(TEvType)); \ diff --git a/library/cpp/actors/core/log.h b/library/cpp/actors/core/log.h index 5ac2d92549..c11a7cf3c1 100644 --- a/library/cpp/actors/core/log.h +++ b/library/cpp/actors/core/log.h @@ -110,9 +110,9 @@ } else { \ LOG_TRACE(*TlsActivationContext, currentTracer, "%s, received event# %" PRIu32 ", Sender %s, Recipient %s", \ __FUNCTION__, ev->Type, ev->Sender.ToString().data(), ev->Recipient.ToString().data()); \ - } + } #define TRACE_EVENT_TYPE(eventType) LOG_TRACE(*TlsActivationContext, currentTracer, "%s, processing event %s", __FUNCTION__, eventType) - + class TLog; class TLogBackend; @@ -192,10 +192,10 @@ namespace NActors { class TLoggerActor: public TActor<TLoggerActor> { public: - static constexpr IActor::EActivityType ActorActivityType() { - return IActor::LOG_ACTOR; - } - + static constexpr IActor::EActivityType ActorActivityType() { + return IActor::LOG_ACTOR; + } + TLoggerActor(TIntrusivePtr<NLog::TSettings> settings, TAutoPtr<TLogBackend> logBackend, TIntrusivePtr<NMonitoring::TDynamicCounters> counters); diff --git a/library/cpp/actors/core/process_stats.cpp b/library/cpp/actors/core/process_stats.cpp index f686c2f406..0e1dbd0031 100644 --- a/library/cpp/actors/core/process_stats.cpp +++ b/library/cpp/actors/core/process_stats.cpp @@ -149,7 +149,7 @@ namespace { : Interval(interval) { } - + void Bootstrap(const TActorContext& ctx) { ctx.Schedule(Interval, new TEvents::TEvWakeup()); Self()->Become(&TDerived::StateWork); diff --git a/library/cpp/actors/core/scheduler_actor.cpp b/library/cpp/actors/core/scheduler_actor.cpp index bf3765611b..febc5e40dd 100644 --- a/library/cpp/actors/core/scheduler_actor.cpp +++ b/library/cpp/actors/core/scheduler_actor.cpp @@ -60,10 +60,10 @@ namespace NActors { TDeque<TAutoPtr<IEventHandle>> EventsToBeSent; public: - static constexpr IActor::EActivityType ActorActivityType() { + static constexpr IActor::EActivityType ActorActivityType() { return IActor::ACTOR_SYSTEM_SCHEDULER_ACTOR; - } - + } + TSchedulerActor(const TSchedulerConfig& cfg) : TActor(&TSchedulerActor::StateFunc) , Cfg(cfg) diff --git a/library/cpp/actors/interconnect/load.cpp b/library/cpp/actors/interconnect/load.cpp index 01c8cc84e6..2a8443da71 100644 --- a/library/cpp/actors/interconnect/load.cpp +++ b/library/cpp/actors/interconnect/load.cpp @@ -62,10 +62,10 @@ namespace NInterconnect { : TActor(&TLoadResponderActor::StateFunc) , Traffic(std::move(traffic)) {} - - static constexpr IActor::EActivityType ActorActivityType() { + + static constexpr IActor::EActivityType ActorActivityType() { return IActor::INTERCONNECT_LOAD_RESPONDER; - } + } private: std::shared_ptr<std::atomic_uint64_t> Traffic; |