From df1dd5c807611d39a158f3c304056f78da5a2dfa Mon Sep 17 00:00:00 2001 From: StekPerepolnen Date: Fri, 26 Apr 2024 08:00:47 +0000 Subject: [PATCH] json_tenantinfo disconected --- ydb/core/viewer/json_tenantinfo.h | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/ydb/core/viewer/json_tenantinfo.h b/ydb/core/viewer/json_tenantinfo.h index d507ff2a8b2f..dc63594f58bf 100644 --- a/ydb/core/viewer/json_tenantinfo.h +++ b/ydb/core/viewer/json_tenantinfo.h @@ -436,16 +436,17 @@ class TJsonTenantInfo : public TViewerPipeClient { } void Disconnected(TEvInterconnect::TEvNodeDisconnected::TPtr &ev) { - ui32 nodeId = ev->Get()->NodeId; + TNodeId nodeId = ev->Get()->NodeId; + TString& tenantId = NodeIdsToTenant[nodeId]; BLOG_TRACE("NodeDisconnected for node " << nodeId); - if (NodeSysInfo.emplace(nodeId, NKikimrWhiteboard::TEvSystemStateResponse{}).second) { - RequestDone(); - } - auto tenantId = NodeIdsToTenant[nodeId]; - if (TenantNodeTabletInfo[tenantId].emplace(nodeId, NKikimrWhiteboard::TEvTabletStateResponse{}).second) { - RequestDone(); - } - if (!TenantNodes[tenantId].empty()) { + if (!OffloadMerge) { + if (NodeSysInfo.emplace(nodeId, NKikimrWhiteboard::TEvSystemStateResponse{}).second) { + RequestDone(); + } + if (Tablets && TenantNodeTabletInfo[tenantId].emplace(nodeId, NKikimrWhiteboard::TEvTabletStateResponse{}).second) { + RequestDone(); + } + } else if (!TenantNodes[tenantId].empty()) { if (Tablets) { SendViewerTabletRequest(tenantId); RequestDone();