aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoralexvru <alexvru@ydb.tech>2022-09-09 15:07:03 +0300
committeralexvru <alexvru@ydb.tech>2022-09-09 15:07:03 +0300
commit7dbd7a386cada4de30e2313e53e164aa48121340 (patch)
tree9ed7360e9c9d63ba572a11850da92b573b77c6c6
parent14b402db2f9000b53d033cee4458400d63d813ca (diff)
downloadydb-7dbd7a386cada4de30e2313e53e164aa48121340.tar.gz
Markup actor activities
-rw-r--r--ydb/core/blob_depot/agent/agent_impl.h4
-rw-r--r--ydb/core/blob_depot/assimilator.h4
-rw-r--r--ydb/core/blob_depot/blob_depot_tablet.h4
-rw-r--r--ydb/core/blob_depot/blocks.cpp4
-rw-r--r--ydb/core/protos/services.proto4
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;
};
};