summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/helpers
diff options
context:
space:
mode:
authorivanmorozov <[email protected]>2023-07-08 10:42:41 +0300
committerivanmorozov <[email protected]>2023-07-08 10:42:41 +0300
commit81455e7b2b77e04a368defb143ff6662655c493e (patch)
tree93740ba5f14027d440543ed11263fb1ddc7b01b4 /library/cpp/actors/helpers
parent8b786ab7d76b124c88dbc7ed858770e56ae14206 (diff)
KIKIMR-18568: remove dependency library/cpp/actors to ydb/core/protos
Diffstat (limited to 'library/cpp/actors/helpers')
-rw-r--r--library/cpp/actors/helpers/flow_controlled_queue.cpp7
-rw-r--r--library/cpp/actors/helpers/flow_controlled_queue.h3
-rw-r--r--library/cpp/actors/helpers/future_callback.h2
-rw-r--r--library/cpp/actors/helpers/pool_stats_collector.h2
-rw-r--r--library/cpp/actors/helpers/selfping_actor.cpp2
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,