aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhor911 <hor911@ydb.tech>2023-11-13 10:42:15 +0300
committerhor911 <hor911@ydb.tech>2023-11-13 11:04:54 +0300
commit977f49e54c144e59ce1299caf8e8249d09909e5b (patch)
treecd02483f8531d28e36e8e95708e1099aaac1eb19
parent5315659cfcfc83a2997433487f8373a69f5b38a9 (diff)
downloadydb-977f49e54c144e59ce1299caf8e8249d09909e5b.tar.gz
Handle IC TEvResolveError event
-rw-r--r--ydb/core/fq/libs/actors/nodes_manager.cpp8
1 files changed, 7 insertions, 1 deletions
diff --git a/ydb/core/fq/libs/actors/nodes_manager.cpp b/ydb/core/fq/libs/actors/nodes_manager.cpp
index 5a0f052b40..2a672eb22e 100644
--- a/ydb/core/fq/libs/actors/nodes_manager.cpp
+++ b/ydb/core/fq/libs/actors/nodes_manager.cpp
@@ -188,6 +188,7 @@ private:
hFunc(NActors::TEvents::TEvUndelivered, OnUndelivered)
hFunc(NFq::TEvInternalService::TEvHealthCheckResponse, HandleResponse)
hFunc(NActors::TEvAddressInfo, Handle)
+ hFunc(NActors::TEvResolveError, Handle)
)
void HandleWakeup(NActors::TEvents::TEvWakeup::TPtr& ev) {
@@ -205,11 +206,16 @@ private:
Address = NAddr::PrintHost(*ev->Get()->Address);
NodesHealthCheck();
} else {
- LOG_E("TNodesManagerActor error resolving");
+ LOG_E("TNodesManagerActor::TEvAddressInfo: empty Address");
ResolveSelfAddress();
}
}
+ void Handle(NActors::TEvResolveError::TPtr& ev) {
+ LOG_E("TNodesManagerActor::TEvResolveError: " << ev->Get()->Explain << ", Host: " << ev->Get()->Host);
+ ResolveSelfAddress();
+ }
+
void ResolveSelfAddress() {
LOG_D("TNodesManagerActor::ResolveSelfAddress");
auto resolve = MakeHolder<NActors::TEvResolveAddress>();