diff options
author | ivanmorozov <[email protected]> | 2023-07-08 10:42:41 +0300 |
---|---|---|
committer | ivanmorozov <[email protected]> | 2023-07-08 10:42:41 +0300 |
commit | 81455e7b2b77e04a368defb143ff6662655c493e (patch) | |
tree | 93740ba5f14027d440543ed11263fb1ddc7b01b4 /library/cpp/actors/helpers | |
parent | 8b786ab7d76b124c88dbc7ed858770e56ae14206 (diff) |
KIKIMR-18568: remove dependency library/cpp/actors to ydb/core/protos
Diffstat (limited to 'library/cpp/actors/helpers')
5 files changed, 9 insertions, 7 deletions
diff --git a/library/cpp/actors/helpers/flow_controlled_queue.cpp b/library/cpp/actors/helpers/flow_controlled_queue.cpp index 104d239481b..49ed7c79f0d 100644 --- a/library/cpp/actors/helpers/flow_controlled_queue.cpp +++ b/library/cpp/actors/helpers/flow_controlled_queue.cpp @@ -153,7 +153,8 @@ class TFlowControlledRequestQueue : public IActorCallback { PassAway(); } public: - TFlowControlledRequestQueue(TActorId target, ui32 activity, const TFlowControlledQueueConfig &config) + template <class TEnum> + TFlowControlledRequestQueue(TActorId target, const TEnum activity, const TFlowControlledQueueConfig &config) : IActorCallback(static_cast<TReceiveFunc>(&TFlowControlledRequestQueue::StateWork), activity) , Target(target) , Config(config) @@ -206,8 +207,8 @@ void TFlowControlledRequestActor::HandleUndelivered(TEvents::TEvUndelivered::TPt PassAway(); } - -IActor* CreateFlowControlledRequestQueue(TActorId targetId, ui32 activity, const TFlowControlledQueueConfig &config) { +template <class TEnum> +IActor* CreateFlowControlledRequestQueue(TActorId targetId, const TEnum 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..bbfffa18d7f 100644 --- a/library/cpp/actors/helpers/flow_controlled_queue.h +++ b/library/cpp/actors/helpers/flow_controlled_queue.h @@ -13,6 +13,7 @@ namespace NActors { ui32 LatencyFactor = 4; }; - IActor* CreateFlowControlledRequestQueue(TActorId targetId, ui32 activity = IActor::ACTORLIB_COMMON, const TFlowControlledQueueConfig &config = TFlowControlledQueueConfig()); + template <class TEnum = IActor::EActivityType> + IActor* CreateFlowControlledRequestQueue(TActorId targetId, const TEnum activity = IActor::EActivityType::ACTORLIB_COMMON, const TFlowControlledQueueConfig &config = TFlowControlledQueueConfig()); } diff --git a/library/cpp/actors/helpers/future_callback.h b/library/cpp/actors/helpers/future_callback.h index 8ca0d99fdae..6626dd439d2 100644 --- a/library/cpp/actors/helpers/future_callback.h +++ b/library/cpp/actors/helpers/future_callback.h @@ -12,7 +12,7 @@ struct TActorFutureCallback : TActor<TActorFutureCallback<EventType>> { TCallback Callback; static constexpr IActor::EActivityType ActorActivityType() { - return IActor::ACTOR_FUTURE_CALLBACK; + return IActor::EActivityType::ACTOR_FUTURE_CALLBACK; } TActorFutureCallback(TCallback&& callback) diff --git a/library/cpp/actors/helpers/pool_stats_collector.h b/library/cpp/actors/helpers/pool_stats_collector.h index a122f7f2f0b..471fd7211c5 100644 --- a/library/cpp/actors/helpers/pool_stats_collector.h +++ b/library/cpp/actors/helpers/pool_stats_collector.h @@ -338,7 +338,7 @@ private: public: static constexpr IActor::EActivityType ActorActivityType() { - return IActor::ACTORLIB_STATS; + return IActor::EActivityType::ACTORLIB_STATS; } TStatsCollectingActor( diff --git a/library/cpp/actors/helpers/selfping_actor.cpp b/library/cpp/actors/helpers/selfping_actor.cpp index dcad5931c97..0ab1dc57e41 100644 --- a/library/cpp/actors/helpers/selfping_actor.cpp +++ b/library/cpp/actors/helpers/selfping_actor.cpp @@ -122,7 +122,7 @@ private: public: static constexpr auto ActorActivityType() { - return SELF_PING_ACTOR; + return EActivityType::SELF_PING_ACTOR; } TSelfPingActor(TDuration sendInterval, |