diff options
| author | Alexey Borzenkov <snaury@yandex-team.ru> | 2022-02-22 18:13:25 +0300 |
|---|---|---|
| committer | Alexey Borzenkov <snaury@yandex-team.ru> | 2022-02-22 18:13:25 +0300 |
| commit | 9f22442d0ebce1eddcf3aa59ce52b1e1d60594c0 (patch) | |
| tree | a5aa78cfbea515f25fd8f537826b113d5d899c52 | |
| parent | e919cbbed69c7d39eea8a62c9a9d52423581772f (diff) | |
| download | ydb-9f22442d0ebce1eddcf3aa59ce52b1e1d60594c0.tar.gz | |
Use separate activities for mediator-related actors, KIKIMR-14419
ref:11f660ce1969bbfeadc853c7f58ea690c62fc258
| -rw-r--r-- | ydb/core/protos/services.proto | 3 | ||||
| -rw-r--r-- | ydb/core/testlib/tablet_helpers.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/tx/mediator/execute_queue.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/tx/mediator/tablet_queue.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/tx/time_cast/time_cast.cpp | 2 |
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() |