used the cache as mutex to prevent concurrent refreshs

iotaledger · Jul 8, 2024 · 50391e9 · 50391e9
1 parent f62bb55
commit 50391e9
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/src/bin/inx-chronicle/api/explorer/routes.rs b/src/bin/inx-chronicle/api/explorer/routes.rs
@@ -351,7 +351,7 @@ async fn richest_addresses_ledger_analytics(
     RichestAddressesQuery { top, ledger_index }: RichestAddressesQuery,
 ) -> ApiResult<RichestAddressesResponse> {
     let ledger_index = resolve_ledger_index(&database, ledger_index).await?;
-    let cache = RICHEST_ADDRESSES_CACHE.read().await;
+    let cache = RICHEST_ADDRESSES_CACHE.write().await;
     let seconds_until_midnight = calculate_seconds_until_midnight();
 
     if let Some(cached_data) = &*cache {
@@ -360,8 +360,6 @@ async fn richest_addresses_ledger_analytics(
         }
     }
 
-    drop(cache); // release the read lock
-
     info!("refreshing richest-addresses cache ...");
     let refresh_start = SystemTime::now();
 
@@ -411,7 +409,7 @@ async fn token_distribution_ledger_analytics(
     LedgerIndex { ledger_index }: LedgerIndex,
 ) -> ApiResult<TokenDistributionResponse> {
     let ledger_index = resolve_ledger_index(&database, ledger_index).await?;
-    let cache = TOKEN_DISTRIBUTION_CACHE.read().await;
+    let cache = TOKEN_DISTRIBUTION_CACHE.write().await;
 
     let seconds_until_midnight = calculate_seconds_until_midnight();
     if let Some(cached_data) = &*cache {
@@ -420,8 +418,6 @@ async fn token_distribution_ledger_analytics(
         }
     }
 
-    drop(cache); // release the read lock
-
     info!("refreshing token-distribution cache ...");
     let refresh_start = SystemTime::now();