diff options
author | Vasily Gerasimov <UgnineSirdis@gmail.com> | 2022-02-10 16:49:09 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:09 +0300 |
commit | 6cdc8f140213c595e4ad38bc3d97fcef1146b8c3 (patch) | |
tree | f69637041e6fed76ebae0c74ae1fa0c4be6ab5b4 /library/cpp/actors | |
parent | e5d4696304c6689379ac7ce334512404d4b7836c (diff) | |
download | ydb-6cdc8f140213c595e4ad38bc3d97fcef1146b8c3.tar.gz |
Restoring authorship annotation for Vasily Gerasimov <UgnineSirdis@gmail.com>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors')
-rw-r--r-- | library/cpp/actors/core/actor.h | 6 | ||||
-rw-r--r-- | library/cpp/actors/core/executor_thread.cpp | 4 | ||||
-rw-r--r-- | library/cpp/actors/core/mon_stats.h | 6 | ||||
-rw-r--r-- | library/cpp/actors/helpers/selfping_actor.cpp | 2 | ||||
-rw-r--r-- | library/cpp/actors/ya.make | 2 |
5 files changed, 10 insertions, 10 deletions
diff --git a/library/cpp/actors/core/actor.h b/library/cpp/actors/core/actor.h index ed29bd14b9..7c08f2a49d 100644 --- a/library/cpp/actors/core/actor.h +++ b/library/cpp/actors/core/actor.h @@ -401,7 +401,7 @@ namespace NActors { template <typename T> struct HasActorName<T, decltype((void)T::ActorName, (const char*)nullptr)>: std::true_type { }; - static ui32 GetActivityTypeIndex() { + static ui32 GetActivityTypeIndex() { if constexpr(HasActorName<TDerived>::value) { return TLocalProcessKey<TActorActivityTag, TDerived::ActorName>::GetIndex(); } else { @@ -425,8 +425,8 @@ namespace NActors { // static constexpr char ActorName[] = "UNNAMED"; - TActor(void (TDerived::*func)(TAutoPtr<IEventHandle>& ev, const TActorContext& ctx), ui32 activityType = GetActivityTypeIndex()) - : IActor(static_cast<TReceiveFunc>(func), activityType) + TActor(void (TDerived::*func)(TAutoPtr<IEventHandle>& ev, const TActorContext& ctx), ui32 activityType = GetActivityTypeIndex()) + : IActor(static_cast<TReceiveFunc>(func), activityType) { } public: diff --git a/library/cpp/actors/core/executor_thread.cpp b/library/cpp/actors/core/executor_thread.cpp index 446b651efd..5d292462bb 100644 --- a/library/cpp/actors/core/executor_thread.cpp +++ b/library/cpp/actors/core/executor_thread.cpp @@ -72,7 +72,7 @@ namespace NActors { } void TExecutorThread::Schedule(TInstant deadline, TAutoPtr<IEventHandle> ev, ISchedulerCookie* cookie) { - ++CurrentActorScheduledEventsCounter; + ++CurrentActorScheduledEventsCounter; Ctx.Executor->Schedule(deadline, ev, cookie, Ctx.WorkerId); } @@ -153,7 +153,7 @@ namespace NActors { TCallstack::GetTlsCallstack().SetLinesToSkip(); #endif CurrentRecipient = recipient; - CurrentActorScheduledEventsCounter = 0; + CurrentActorScheduledEventsCounter = 0; if (executed == 0) { double usec = Ctx.AddActivationStats(AtomicLoad(&mailbox->ScheduleMoment), hpprev); diff --git a/library/cpp/actors/core/mon_stats.h b/library/cpp/actors/core/mon_stats.h index d55552af0c..96ba808854 100644 --- a/library/cpp/actors/core/mon_stats.h +++ b/library/cpp/actors/core/mon_stats.h @@ -79,7 +79,7 @@ namespace NActors { TVector<NHPTimer::STime> ElapsedTicksByActivity; TVector<ui64> ReceivedEventsByActivity; TVector<i64> ActorsAliveByActivity; // the sum should be positive, but per-thread might be negative - TVector<ui64> ScheduledEventsByActivity; + TVector<ui64> ScheduledEventsByActivity; ui64 PoolActorRegistrations = 0; ui64 PoolDestroyedActors = 0; ui64 PoolAllocatedMailboxes = 0; @@ -91,7 +91,7 @@ namespace NActors { : ElapsedTicksByActivity(activityVecSize) , ReceivedEventsByActivity(activityVecSize) , ActorsAliveByActivity(activityVecSize) - , ScheduledEventsByActivity(activityVecSize) + , ScheduledEventsByActivity(activityVecSize) {} template <typename T> @@ -126,7 +126,7 @@ namespace NActors { AggregateOne(ElapsedTicksByActivity, other.ElapsedTicksByActivity); AggregateOne(ReceivedEventsByActivity, other.ReceivedEventsByActivity); AggregateOne(ActorsAliveByActivity, other.ActorsAliveByActivity); - AggregateOne(ScheduledEventsByActivity, other.ScheduledEventsByActivity); + AggregateOne(ScheduledEventsByActivity, other.ScheduledEventsByActivity); RelaxedStore( &PoolActorRegistrations, diff --git a/library/cpp/actors/helpers/selfping_actor.cpp b/library/cpp/actors/helpers/selfping_actor.cpp index f9bfaf8dc0..9fe2e7875f 100644 --- a/library/cpp/actors/helpers/selfping_actor.cpp +++ b/library/cpp/actors/helpers/selfping_actor.cpp @@ -64,7 +64,7 @@ private: const NMonitoring::TDynamicCounters::TCounterPtr Counter; const NMonitoring::TDynamicCounters::TCounterPtr CalculationTimeCounter; - NSlidingWindow::TSlidingWindow<NSlidingWindow::TMaxOperation<ui64>> SlidingWindow; + NSlidingWindow::TSlidingWindow<NSlidingWindow::TMaxOperation<ui64>> SlidingWindow; NSlidingWindow::TSlidingWindow<TAvgOperation<ui64>> CalculationSlidingWindow; THPTimer Timer; diff --git a/library/cpp/actors/ya.make b/library/cpp/actors/ya.make index 737c7fbc18..3c308c0899 100644 --- a/library/cpp/actors/ya.make +++ b/library/cpp/actors/ya.make @@ -1,7 +1,7 @@ RECURSE_FOR_TESTS(ut) RECURSE( - log_backend + log_backend core dnsresolver examples |