diff --git a/storage/src/backend/connection.rs b/storage/src/backend/connection.rs index a42e04a83e8..8ea2b31d24a 100644 --- a/storage/src/backend/connection.rs +++ b/storage/src/backend/connection.rs @@ -303,7 +303,7 @@ impl Connection { connection.start_proxy_health_thread(config.connect_timeout as u64); // Start mirrors' health checking thread. - connection.start_mirror_health_thread(config.timeout as u64); + connection.start_mirrors_health_thread(config.timeout as u64); Ok(connection) } @@ -351,7 +351,7 @@ impl Connection { } } - fn start_mirror_health_thread(&self, timeout: u64) { + fn start_mirrors_health_thread(&self, timeout: u64) { for mirror in self.mirrors.iter() { let mirror_cloned = mirror.clone(); thread::spawn(move || { diff --git a/storage/src/backend/registry.rs b/storage/src/backend/registry.rs index 455e02d3c1b..47835e6ac8e 100644 --- a/storage/src/backend/registry.rs +++ b/storage/src/backend/registry.rs @@ -647,7 +647,7 @@ impl Registry { for mirror in mirrors.iter() { if !mirror.config.auth_through { - registry.run_refresh_token_thread(); + registry.start_refresh_token_thread(); info!("Refresh token thread started."); break; } @@ -681,7 +681,7 @@ impl Registry { } } - fn run_refresh_token_thread(&self) { + fn start_refresh_token_thread(&self) { let conn = self.connection.clone(); let state = self.state.clone(); // The default refresh token internal is 10 minutes.