rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-15 17:32:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix style

Browse Source
This commit is contained in:
Konstantin Knizhnik
2023-06-03 14:35:43 +03:00
parent a3b7d068c1
commit 15fae34751
1 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
pageserver/src/tenant/mgr.rs
View File

@@ -615,18 +615,20 @@ pub async fn list_tenants() -> Result<Vec<(TenantId, TenantState)>, TenantMapLis
let tenants = TENANTS.read().await;
match &*tenants {
TenantsMap::Initializing => Err(TenantMapListError::Initializing),
TenantsMap::Open(m) => Ok(futures::future::join_all(m.map.iter().map(|(id, tenant)| async {
(
*id,
tenant
.get_or_try_init(|| m.try_load_tenant(id))
.await
.map_or(
TenantState::broken_from_reason("Failed to load tenant".to_string()),
|t| t.current_state(),
),
)
}))
TenantsMap::Open(m) => Ok(futures::future::join_all(m.map.iter().map(
|(id, tenant)| async {
(
*id,
tenant
.get_or_try_init(|| m.try_load_tenant(id))
.await
.map_or(
TenantState::broken_from_reason("Failed to load tenant".to_string()),
|t| t.current_state(),
),
)
},
))
.await),
TenantsMap::ShuttingDown(m) => Ok(m
.iter()