diff options
author | hor911 <hor911@ydb.tech> | 2023-11-13 10:42:15 +0300 |
---|---|---|
committer | hor911 <hor911@ydb.tech> | 2023-11-13 11:04:54 +0300 |
commit | 977f49e54c144e59ce1299caf8e8249d09909e5b (patch) | |
tree | cd02483f8531d28e36e8e95708e1099aaac1eb19 | |
parent | 5315659cfcfc83a2997433487f8373a69f5b38a9 (diff) | |
download | ydb-977f49e54c144e59ce1299caf8e8249d09909e5b.tar.gz |
Handle IC TEvResolveError event
-rw-r--r-- | ydb/core/fq/libs/actors/nodes_manager.cpp | 8 |
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>(); |