aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorilnaz <ilnaz@ydb.tech>2023-04-12 21:04:55 +0300
committerilnaz <ilnaz@ydb.tech>2023-04-12 21:04:55 +0300
commitfadb5549b73622cd3730ecdae38a643974e081b5 (patch)
tree70a76db82505808fd50f98183377f96cce3f261f
parent687bbce079756fd90df087c81ba6cdb85565edd1 (diff)
downloadydb-fadb5549b73622cd3730ecdae38a643974e081b5.tar.gz
Check invariants before calling ResponseProcessed()
-rw-r--r--ydb/core/cms/info_collector.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/ydb/core/cms/info_collector.cpp b/ydb/core/cms/info_collector.cpp
index d3958063b82..bcbd918b549 100644
--- a/ydb/core/cms/info_collector.cpp
+++ b/ydb/core/cms/info_collector.cpp
@@ -490,7 +490,9 @@ void TInfoCollector::Handle(TEvents::TEvUndelivered::TPtr& ev) {
}
if (msg.SourceType == TEvTenantPool::EvGetStatus && msg.Reason == TEvents::TEvUndelivered::ReasonActorUnknown) {
- ResponseProcessed(nodeId, TEvTenantPool::EvTenantPoolStatus);
+ if (IsNodeInfoRequired(nodeId, TEvTenantPool::EvTenantPoolStatus)) {
+ return ResponseProcessed(nodeId, TEvTenantPool::EvTenantPoolStatus);
+ }
} else {
UndeliveredNodes.insert(nodeId);
NodeEvents[nodeId].clear();