aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoralexvru <alexvru@ydb.tech>2023-08-09 11:02:09 +0300
committeralexvru <alexvru@ydb.tech>2023-08-09 12:25:24 +0300
commit70c23db3bd53d2227acd663a87b8a1576ed1cb4d (patch)
tree7222377ab8b79687187f41f4750b9aabeb88839a
parentbc6863b0191920feab54c82e2799cdaf0f395d69 (diff)
downloadydb-70c23db3bd53d2227acd663a87b8a1576ed1cb4d.tar.gz
Support static node list subscription in DSProxy KIKIMR-13309
-rw-r--r--ydb/core/blobstorage/dsproxy/dsproxy_state.cpp5
1 files changed, 4 insertions, 1 deletions
diff --git a/ydb/core/blobstorage/dsproxy/dsproxy_state.cpp b/ydb/core/blobstorage/dsproxy/dsproxy_state.cpp
index 079360657a..0092b7d436 100644
--- a/ydb/core/blobstorage/dsproxy/dsproxy_state.cpp
+++ b/ydb/core/blobstorage/dsproxy/dsproxy_state.cpp
@@ -109,7 +109,7 @@ namespace NKikimr {
LifeCyclePhase = Info->GetLifeCyclePhase();
GroupKeyNonce = Info->GetGroupKeyNonce();
CypherKey = *Info->GetCypherKey();
- Send(GetNameserviceActorId(), new TEvInterconnect::TEvListNodes);
+ Send(GetNameserviceActorId(), new TEvInterconnect::TEvListNodes(true));
}
if (counters) {
StoragePoolCounters = std::move(counters);
@@ -273,6 +273,9 @@ namespace NKikimr {
NodeMon->DecNumUnconnected(NumUnconnectedDisks);
}
+ TActivationContext::Send(new IEventHandle(TEvents::TSystem::Unsubscribe, 0, GetNameserviceActorId(), SelfId(),
+ nullptr, 0));
+
TActorBootstrapped::PassAway();
// TODO: Unsubscribe
}