diff options
author | alexvru <alexvru@ydb.tech> | 2022-09-09 15:07:03 +0300 |
---|---|---|
committer | alexvru <alexvru@ydb.tech> | 2022-09-09 15:07:03 +0300 |
commit | 7dbd7a386cada4de30e2313e53e164aa48121340 (patch) | |
tree | 9ed7360e9c9d63ba572a11850da92b573b77c6c6 | |
parent | 14b402db2f9000b53d033cee4458400d63d813ca (diff) | |
download | ydb-7dbd7a386cada4de30e2313e53e164aa48121340.tar.gz |
Markup actor activities
-rw-r--r-- | ydb/core/blob_depot/agent/agent_impl.h | 4 | ||||
-rw-r--r-- | ydb/core/blob_depot/assimilator.h | 4 | ||||
-rw-r--r-- | ydb/core/blob_depot/blob_depot_tablet.h | 4 | ||||
-rw-r--r-- | ydb/core/blob_depot/blocks.cpp | 4 | ||||
-rw-r--r-- | ydb/core/protos/services.proto | 4 |
5 files changed, 19 insertions, 1 deletions
diff --git a/ydb/core/blob_depot/agent/agent_impl.h b/ydb/core/blob_depot/agent/agent_impl.h index d0c97d7dcbe..94529a26e55 100644 --- a/ydb/core/blob_depot/agent/agent_impl.h +++ b/ydb/core/blob_depot/agent/agent_impl.h @@ -90,6 +90,10 @@ namespace NKikimr::NBlobDepot { }; public: + static constexpr NKikimrServices::TActivity::EType ActorActivityType() { + return NKikimrServices::TActivity::BLOB_DEPOT_AGENT_ACTOR; + } + TBlobDepotAgent(ui32 virtualGroupId, TIntrusivePtr<TBlobStorageGroupInfo> info, TActorId proxyId); ~TBlobDepotAgent(); diff --git a/ydb/core/blob_depot/assimilator.h b/ydb/core/blob_depot/assimilator.h index 385d4ce9e97..35222d5f0d1 100644 --- a/ydb/core/blob_depot/assimilator.h +++ b/ydb/core/blob_depot/assimilator.h @@ -30,6 +30,10 @@ namespace NKikimr::NBlobDepot { TActorId PipeId; public: + static constexpr NKikimrServices::TActivity::EType ActorActivityType() { + return NKikimrServices::TActivity::BLOB_DEPOT_ASSIMILATOR_ACTOR; + } + TGroupAssimilator(TBlobDepot *self) : Token(self->Token) , Self(self) diff --git a/ydb/core/blob_depot/blob_depot_tablet.h b/ydb/core/blob_depot/blob_depot_tablet.h index c3529148b11..79bec599baf 100644 --- a/ydb/core/blob_depot/blob_depot_tablet.h +++ b/ydb/core/blob_depot/blob_depot_tablet.h @@ -20,6 +20,10 @@ namespace NKikimr::NBlobDepot { }; public: + static constexpr NKikimrServices::TActivity::EType ActorActivityType() { + return NKikimrServices::TActivity::BLOB_DEPOT_ACTOR; + } + TBlobDepot(TActorId tablet, TTabletStorageInfo *info); ~TBlobDepot(); diff --git a/ydb/core/blob_depot/blocks.cpp b/ydb/core/blob_depot/blocks.cpp index a2604fdd807..8c6778f9918 100644 --- a/ydb/core/blob_depot/blocks.cpp +++ b/ydb/core/blob_depot/blocks.cpp @@ -66,6 +66,10 @@ namespace NKikimr::NBlobDepot { THashSet<ui32> NodesWaitingForPushResult; public: + static constexpr NKikimrServices::TActivity::EType ActorActivityType() { + return NKikimrServices::TActivity::BLOB_DEPOT_BLOCKS_PROCESSOR_ACTOR; + } + TBlockProcessorActor(TBlobDepot *self, ui64 tabletId, ui32 blockedGeneration, ui32 nodeId, ui64 issuerGuid, std::unique_ptr<IEventHandle> response) : Self(self) diff --git a/ydb/core/protos/services.proto b/ydb/core/protos/services.proto index 799648646c0..d661e5ef9c3 100644 --- a/ydb/core/protos/services.proto +++ b/ydb/core/protos/services.proto @@ -901,7 +901,7 @@ message TActivity { TX_COLUMNSHARD_EXPORT_ACTOR = 568; YQ_HEALTH_ACTOR = 569; BLOB_DEPOT_ACTOR = 570; - BLOB_DEPOT_AGENT = 571; + BLOB_DEPOT_AGENT_ACTOR = 571; KQP_STREAM_LOOKUP_ACTOR = 572; BS_STORAGE_STATS_ACTOR = 573; DS_LOAD_ACTOR = 574; @@ -910,5 +910,7 @@ message TActivity { ACTOR_COROUTINE = 577; LB_CM_ABC_ACTOR = 578; LB_CM_FOLDER_ACTOR = 579; + BLOB_DEPOT_ASSIMILATOR_ACTOR = 580; + BLOB_DEPOT_BLOCKS_PROCESSOR_ACTOR = 581; }; }; |