diff options
author | snaury <snaury@ydb.tech> | 2022-09-16 13:38:32 +0300 |
---|---|---|
committer | snaury <snaury@ydb.tech> | 2022-09-16 13:38:32 +0300 |
commit | 353bf4878abf72bf834becde2eca008a84ea1855 (patch) | |
tree | 7079cdb6bb0adda1c00e5bfe48ecc2d731c2ddd7 | |
parent | 4484f53766ffa41194f08f8da21c4cc5712a6f19 (diff) | |
download | ydb-353bf4878abf72bf834becde2eca008a84ea1855.tar.gz |
Invalidate tablet resolver entries for missing nodes
-rw-r--r-- | ydb/core/tablet/tablet_pipe_client.cpp | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/ydb/core/tablet/tablet_pipe_client.cpp b/ydb/core/tablet/tablet_pipe_client.cpp index a9c87904193..28f0b0e5c5a 100644 --- a/ydb/core/tablet/tablet_pipe_client.cpp +++ b/ydb/core/tablet/tablet_pipe_client.cpp @@ -190,7 +190,8 @@ namespace NTabletPipe { TActorId proxy = TActivationContext::InterconnectProxy(nodeId); if (!proxy) { - BLOG_ERROR("remote node on broken proxy"); + BLOG_ERROR("remote node " << nodeId << " on broken proxy"); + NotifyNodeProblem(nodeId, ctx); return NotifyConnectFail(ctx); } @@ -479,7 +480,11 @@ namespace NTabletPipe { } void NotifyNodeProblem(const TActorContext &ctx) { - ctx.Send(MakeTabletResolverID(), new TEvTabletResolver::TEvNodeProblem(InterconnectNodeId, LastCacheEpoch)); + NotifyNodeProblem(InterconnectNodeId, ctx); + } + + void NotifyNodeProblem(ui32 nodeId, const TActorContext &ctx) { + ctx.Send(MakeTabletResolverID(), new TEvTabletResolver::TEvNodeProblem(nodeId, LastCacheEpoch)); } void ForgetNetworkSession() { |