diff options
author | Sergey Polovko <[email protected]> | 2022-02-10 16:47:02 +0300 |
---|---|---|
committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:47:02 +0300 |
commit | 3e0b762a82514bac89c1dd6ea7211e381d8aa248 (patch) | |
tree | c2d1b379ecaf05ca8f11ed0b5da9d1a950e6e554 /library/cpp/actors/helpers | |
parent | ab3783171cc30e262243a0227c86118f7080c896 (diff) |
Restoring authorship annotation for Sergey Polovko <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/helpers')
-rw-r--r-- | library/cpp/actors/helpers/activeactors.h | 6 | ||||
-rw-r--r-- | library/cpp/actors/helpers/flow_controlled_queue.cpp | 12 | ||||
-rw-r--r-- | library/cpp/actors/helpers/flow_controlled_queue.h | 2 | ||||
-rw-r--r-- | library/cpp/actors/helpers/mon_histogram_helper.h | 8 | ||||
-rw-r--r-- | library/cpp/actors/helpers/selfping_actor.h | 2 | ||||
-rw-r--r-- | library/cpp/actors/helpers/ya.make | 2 |
6 files changed, 16 insertions, 16 deletions
diff --git a/library/cpp/actors/helpers/activeactors.h b/library/cpp/actors/helpers/activeactors.h index 0fdb0fab108..b0e4f5cc994 100644 --- a/library/cpp/actors/helpers/activeactors.h +++ b/library/cpp/actors/helpers/activeactors.h @@ -10,9 +10,9 @@ namespace NActors { // TActiveActors // This class helps manage created actors and kill them all on PoisonPill. //////////////////////////////////////////////////////////////////////////// - class TActiveActors : public THashSet<TActorId> { + class TActiveActors : public THashSet<TActorId> { public: - void Insert(const TActorId &aid) { + void Insert(const TActorId &aid) { bool inserted = insert(aid).second; Y_VERIFY(inserted); } @@ -23,7 +23,7 @@ namespace NActors { } } - void Erase(const TActorId &aid) { + void Erase(const TActorId &aid) { auto num = erase(aid); Y_VERIFY(num == 1); } diff --git a/library/cpp/actors/helpers/flow_controlled_queue.cpp b/library/cpp/actors/helpers/flow_controlled_queue.cpp index d75cc540236..61610ec3d36 100644 --- a/library/cpp/actors/helpers/flow_controlled_queue.cpp +++ b/library/cpp/actors/helpers/flow_controlled_queue.cpp @@ -18,12 +18,12 @@ class TFlowControlledRequestActor : public IActor { void HandleReply(TAutoPtr<IEventHandle> &ev); void HandleUndelivered(TEvents::TEvUndelivered::TPtr &ev); public: - const TActorId Source; + const TActorId Source; const ui64 Cookie; const ui32 Flags; const ui64 StartCounter; - TFlowControlledRequestActor(ui32 activity, TFlowControlledRequestQueue *queue, TActorId source, ui64 cookie, ui32 flags) + TFlowControlledRequestActor(ui32 activity, TFlowControlledRequestQueue *queue, TActorId source, ui64 cookie, ui32 flags) : IActor(static_cast<TReceiveFunc>(&TFlowControlledRequestActor::StateWait), activity) , QueueActor(queue) , Source(source) @@ -49,7 +49,7 @@ public: }; class TFlowControlledRequestQueue : public IActor { - const TActorId Target; + const TActorId Target; const TFlowControlledQueueConfig Config; TDeque<THolder<IEventHandle>> UnhandledRequests; @@ -123,7 +123,7 @@ class TFlowControlledRequestQueue : public IActor { if (reqActor) { if (reqActor->Flags & IEventHandle::FlagSubscribeOnSession) { TActivationContext::Send( - new IEventHandle(reqActor->Source, TActorId(), new TEvInterconnect::TEvNodeDisconnected(nodeid), 0, reqActor->Cookie) + new IEventHandle(reqActor->Source, TActorId(), new TEvInterconnect::TEvNodeDisconnected(nodeid), 0, reqActor->Cookie) ); } reqActor->PassAway(); @@ -153,7 +153,7 @@ class TFlowControlledRequestQueue : public IActor { PassAway(); } public: - TFlowControlledRequestQueue(TActorId target, ui32 activity, const TFlowControlledQueueConfig &config) + TFlowControlledRequestQueue(TActorId target, ui32 activity, const TFlowControlledQueueConfig &config) : IActor(static_cast<TReceiveFunc>(&TFlowControlledRequestQueue::StateWork), activity) , Target(target) , Config(config) @@ -208,7 +208,7 @@ void TFlowControlledRequestActor::HandleUndelivered(TEvents::TEvUndelivered::TPt } -IActor* CreateFlowControlledRequestQueue(TActorId targetId, ui32 activity, const TFlowControlledQueueConfig &config) { +IActor* CreateFlowControlledRequestQueue(TActorId targetId, ui32 activity, const TFlowControlledQueueConfig &config) { return new TFlowControlledRequestQueue(targetId, activity, config); } diff --git a/library/cpp/actors/helpers/flow_controlled_queue.h b/library/cpp/actors/helpers/flow_controlled_queue.h index d2504053047..1d03226103c 100644 --- a/library/cpp/actors/helpers/flow_controlled_queue.h +++ b/library/cpp/actors/helpers/flow_controlled_queue.h @@ -13,6 +13,6 @@ namespace NActors { ui32 LatencyFactor = 4; }; - IActor* CreateFlowControlledRequestQueue(TActorId targetId, ui32 activity = IActor::ACTORLIB_COMMON, const TFlowControlledQueueConfig &config = TFlowControlledQueueConfig()); + IActor* CreateFlowControlledRequestQueue(TActorId targetId, ui32 activity = IActor::ACTORLIB_COMMON, const TFlowControlledQueueConfig &config = TFlowControlledQueueConfig()); } diff --git a/library/cpp/actors/helpers/mon_histogram_helper.h b/library/cpp/actors/helpers/mon_histogram_helper.h index a9a57e38238..80b9690a757 100644 --- a/library/cpp/actors/helpers/mon_histogram_helper.h +++ b/library/cpp/actors/helpers/mon_histogram_helper.h @@ -1,9 +1,9 @@ #pragma once -#include <library/cpp/monlib/dynamic_counters/counters.h> - -#include <util/string/cast.h> +#include <library/cpp/monlib/dynamic_counters/counters.h> +#include <util/string/cast.h> + namespace NActors { namespace NMon { class THistogramCounterHelper { @@ -79,7 +79,7 @@ namespace NActors { ui64 FirstBucketVal; ui64 BucketCount; TVector<NMonitoring::TDynamicCounters::TCounterPtr> BucketsHolder; - TVector<NMonitoring::TDeprecatedCounter*> Buckets; + TVector<NMonitoring::TDeprecatedCounter*> Buckets; }; } diff --git a/library/cpp/actors/helpers/selfping_actor.h b/library/cpp/actors/helpers/selfping_actor.h index d7d07f9fa8b..d1f320509ed 100644 --- a/library/cpp/actors/helpers/selfping_actor.h +++ b/library/cpp/actors/helpers/selfping_actor.h @@ -1,7 +1,7 @@ #pragma once #include <library/cpp/actors/core/actor.h> -#include <library/cpp/monlib/dynamic_counters/counters.h> +#include <library/cpp/monlib/dynamic_counters/counters.h> namespace NActors { diff --git a/library/cpp/actors/helpers/ya.make b/library/cpp/actors/helpers/ya.make index d8771179de8..0169a2c7276 100644 --- a/library/cpp/actors/helpers/ya.make +++ b/library/cpp/actors/helpers/ya.make @@ -14,7 +14,7 @@ SRCS( PEERDIR( library/cpp/actors/core - library/cpp/monlib/dynamic_counters + library/cpp/monlib/dynamic_counters ) END() |