diff --git a/pageserver/communicator_pools/client_cache/src/lib.rs b/pageserver/communicator_pools/client_cache/src/lib.rs index e237932f05..7a72e37d4c 100644 --- a/pageserver/communicator_pools/client_cache/src/lib.rs +++ b/pageserver/communicator_pools/client_cache/src/lib.rs @@ -75,7 +75,7 @@ impl ClientCache { max_idle_duration: Duration, max_total_connections: usize, ) -> Arc { - let pool = Arc::new(Self { + Arc::new(Self { inner: Mutex::new(Inner:: { entries: HashMap::new(), pq: PriorityQueue::new(), @@ -91,13 +91,12 @@ impl ClientCache { max_idle_duration, max_total_connections, client_semaphore: Arc::new(Semaphore::new(0)), - }); - pool + }) } } impl PooledClient { pub fn client(&self) -> T { - return self.client.clone(); + self.client.clone() } }