aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorsnaury <snaury@ydb.tech>2022-09-16 13:38:32 +0300
committersnaury <snaury@ydb.tech>2022-09-16 13:38:32 +0300
commit353bf4878abf72bf834becde2eca008a84ea1855 (patch)
tree7079cdb6bb0adda1c00e5bfe48ecc2d731c2ddd7
parent4484f53766ffa41194f08f8da21c4cc5712a6f19 (diff)
downloadydb-353bf4878abf72bf834becde2eca008a84ea1855.tar.gz
Invalidate tablet resolver entries for missing nodes
-rw-r--r--ydb/core/tablet/tablet_pipe_client.cpp9
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() {