aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlexey Borzenkov <snaury@yandex-team.ru>2022-02-22 18:13:25 +0300
committerAlexey Borzenkov <snaury@yandex-team.ru>2022-02-22 18:13:25 +0300
commit9f22442d0ebce1eddcf3aa59ce52b1e1d60594c0 (patch)
treea5aa78cfbea515f25fd8f537826b113d5d899c52
parente919cbbed69c7d39eea8a62c9a9d52423581772f (diff)
downloadydb-9f22442d0ebce1eddcf3aa59ce52b1e1d60594c0.tar.gz
Use separate activities for mediator-related actors, KIKIMR-14419
ref:11f660ce1969bbfeadc853c7f58ea690c62fc258
-rw-r--r--ydb/core/protos/services.proto3
-rw-r--r--ydb/core/testlib/tablet_helpers.cpp2
-rw-r--r--ydb/core/tx/mediator/execute_queue.cpp2
-rw-r--r--ydb/core/tx/mediator/tablet_queue.cpp2
-rw-r--r--ydb/core/tx/time_cast/time_cast.cpp2
5 files changed, 7 insertions, 4 deletions
diff --git a/ydb/core/protos/services.proto b/ydb/core/protos/services.proto
index 32ba2238a6..5e669d88f8 100644
--- a/ydb/core/protos/services.proto
+++ b/ydb/core/protos/services.proto
@@ -817,6 +817,9 @@ message TActivity {
KQP_NODE_SERVICE = 494;
TX_DATASHARD_SOURCE_OFFSETS_CLIENT = 500;
COORDINATOR_READ_STEP_SUBSCRIPTION_MANAGER = 501;
+ TX_MEDIATOR_TIMECAST_ACTOR = 502;
+ TX_MEDIATOR_EXECUTE_QUEUE_ACTOR = 503;
+ TX_MEDIATOR_TABLET_QUEUE_ACTOR = 504;
YQL_PROXY_ACTOR = 510;
TEST_SHARD_ACTOR = 511;
FRONT_TEST_SHARD_REQUEST = 512;
diff --git a/ydb/core/testlib/tablet_helpers.cpp b/ydb/core/testlib/tablet_helpers.cpp
index a853040b93..ce5588e08d 100644
--- a/ydb/core/testlib/tablet_helpers.cpp
+++ b/ydb/core/testlib/tablet_helpers.cpp
@@ -69,7 +69,7 @@ namespace NKikimr {
class TFakeMediatorTimecastProxy : public TActor<TFakeMediatorTimecastProxy> {
public:
static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
- return NKikimrServices::TActivity::TX_MEDIATOR_ACTOR;
+ return NKikimrServices::TActivity::TX_MEDIATOR_TIMECAST_ACTOR;
}
TFakeMediatorTimecastProxy()
diff --git a/ydb/core/tx/mediator/execute_queue.cpp b/ydb/core/tx/mediator/execute_queue.cpp
index 07740e9f82..25ccba52fb 100644
--- a/ydb/core/tx/mediator/execute_queue.cpp
+++ b/ydb/core/tx/mediator/execute_queue.cpp
@@ -173,7 +173,7 @@ namespace NTxMediator {
public:
static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
- return NKikimrServices::TActivity::TX_MEDIATOR_ACTOR;
+ return NKikimrServices::TActivity::TX_MEDIATOR_EXECUTE_QUEUE_ACTOR;
}
TTxMediatorExecQueue(const TActorId &owner, ui64 mediator, ui64 hashRange, ui32 timecastBuckets)
diff --git a/ydb/core/tx/mediator/tablet_queue.cpp b/ydb/core/tx/mediator/tablet_queue.cpp
index b28179517c..111518714a 100644
--- a/ydb/core/tx/mediator/tablet_queue.cpp
+++ b/ydb/core/tx/mediator/tablet_queue.cpp
@@ -337,7 +337,7 @@ class TTxMediatorTabletQueue : public TActor<TTxMediatorTabletQueue> {
public:
static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
- return NKikimrServices::TActivity::TX_MEDIATOR_ACTOR;
+ return NKikimrServices::TActivity::TX_MEDIATOR_TABLET_QUEUE_ACTOR;
}
TTxMediatorTabletQueue(const TActorId &owner, ui64 mediator, ui64 hashRange, ui64 hashBucket)
diff --git a/ydb/core/tx/time_cast/time_cast.cpp b/ydb/core/tx/time_cast/time_cast.cpp
index 32047b725a..c2e538caa0 100644
--- a/ydb/core/tx/time_cast/time_cast.cpp
+++ b/ydb/core/tx/time_cast/time_cast.cpp
@@ -177,7 +177,7 @@ class TMediatorTimecastProxy : public TActor<TMediatorTimecastProxy> {
public:
static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
- return NKikimrServices::TActivity::TX_MEDIATOR_ACTOR;
+ return NKikimrServices::TActivity::TX_MEDIATOR_TIMECAST_ACTOR;
}
TMediatorTimecastProxy()