From 0fd14ad74bdc6abb93bafd1cf87ce469805aab89 Mon Sep 17 00:00:00 2001 From: Joonas Koivunen Date: Mon, 21 Aug 2023 09:44:37 +0300 Subject: [PATCH] timeline: remove GenericRemoteStorage exposure --- pageserver/src/tenant/timeline.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pageserver/src/tenant/timeline.rs b/pageserver/src/tenant/timeline.rs index 4082df5c82..c482622452 100644 --- a/pageserver/src/tenant/timeline.rs +++ b/pageserver/src/tenant/timeline.rs @@ -15,7 +15,6 @@ use pageserver_api::models::{ DownloadRemoteLayersTaskInfo, DownloadRemoteLayersTaskSpawnRequest, LayerMapInfo, LayerResidenceEventReason, LayerResidenceStatus, TimelineState, }; -use remote_storage::GenericRemoteStorage; use serde_with::serde_as; use storage_broker::BrokerClientChannel; use tokio::sync::{oneshot, watch, TryAcquireError}; @@ -1012,7 +1011,7 @@ impl Timeline { .as_ref() .context("timeline must have RemoteTimelineClient")?; - self.evict_layer_batch(remote_client, layers_to_evict, &cancel) + self.evict_layer_batch(remote_client, layers_to_evict, cancel) .await } @@ -1063,10 +1062,11 @@ impl Timeline { let mut js = tokio::task::JoinSet::new(); - for (i, l) in layers_to_evict.into_iter().enumerate() { + for (i, l) in layers_to_evict.iter().enumerate() { js.spawn({ let l = l.to_owned(); - async move { (i, l.evict_and_wait().await) } + let remote_client = remote_client.clone(); + async move { (i, l.evict_and_wait(&remote_client).await) } }); }