Skip to content

Commit

Permalink
Dont return shared nodes for serverless KIKIMR-21128 (#2264) (#2305)
Browse files Browse the repository at this point in the history
  • Loading branch information
pixcc authored Feb 29, 2024
1 parent 6a51e53 commit 18848f2
Show file tree
Hide file tree
Showing 2 changed files with 158 additions and 85 deletions.
30 changes: 14 additions & 16 deletions ydb/core/viewer/json_nodes.h
Original file line number Diff line number Diff line change
Expand Up @@ -411,27 +411,25 @@ class TJsonNodes : public TViewerPipeClient<TJsonNodes> {
const auto localPathId = entry.DomainInfo->DomainKey.LocalPathId;
FilterSubDomainKey = TSubDomainKey(ownerId, localPathId);
}

if (FilterTenant.empty()) {
RequestForTenant(path);
}

if (entry.DomainInfo->ResourcesDomainKey && entry.DomainInfo->DomainKey != entry.DomainInfo->ResourcesDomainKey) {
TPathId resourceDomainKey(entry.DomainInfo->ResourcesDomainKey);
BLOG_TRACE("Requesting navigate for resource domain " << resourceDomainKey);
RequestSchemeCacheNavigate(resourceDomainKey);
++RequestsBeforeNodeList;
} else {
if (FilterTenant.empty()) {
RequestForTenant(path);
}
if (Storage) {
if (entry.DomainDescription) {
for (const auto& storagePool : entry.DomainDescription->Description.GetStoragePools()) {
TString storagePoolName = storagePool.GetName();
THolder<TEvBlobStorage::TEvControllerSelectGroups> request = MakeHolder<TEvBlobStorage::TEvControllerSelectGroups>();
request->Record.SetReturnAllMatchingGroups(true);
request->Record.AddGroupParameters()->MutableStoragePoolSpecifier()->SetName(storagePoolName);
BLOG_TRACE("Requesting BSControllerSelectGroups for " << storagePoolName);
RequestBSControllerSelectGroups(std::move(request));
++RequestsBeforeNodeList;
}
}
} else if (Storage && entry.DomainDescription) {
for (const auto& storagePool : entry.DomainDescription->Description.GetStoragePools()) {
TString storagePoolName = storagePool.GetName();
THolder<TEvBlobStorage::TEvControllerSelectGroups> request = MakeHolder<TEvBlobStorage::TEvControllerSelectGroups>();
request->Record.SetReturnAllMatchingGroups(true);
request->Record.AddGroupParameters()->MutableStoragePoolSpecifier()->SetName(storagePoolName);
BLOG_TRACE("Requesting BSControllerSelectGroups for " << storagePoolName);
RequestBSControllerSelectGroups(std::move(request));
++RequestsBeforeNodeList;
}
}
} else {
Expand Down
Loading

0 comments on commit 18848f2

Please sign in to comment.