diff options
author | alexvru <alexvru@ydb.tech> | 2023-08-09 11:02:09 +0300 |
---|---|---|
committer | alexvru <alexvru@ydb.tech> | 2023-08-09 12:25:24 +0300 |
commit | 70c23db3bd53d2227acd663a87b8a1576ed1cb4d (patch) | |
tree | 7222377ab8b79687187f41f4750b9aabeb88839a | |
parent | bc6863b0191920feab54c82e2799cdaf0f395d69 (diff) | |
download | ydb-70c23db3bd53d2227acd663a87b8a1576ed1cb4d.tar.gz |
Support static node list subscription in DSProxy KIKIMR-13309
-rw-r--r-- | ydb/core/blobstorage/dsproxy/dsproxy_state.cpp | 5 |
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 } |