storage: fix some issues for mirror health checking

Signed-off-by: Bin Tang <tangbin.bin@bytedance.com>
dragonflyoss · Nov 3, 2022 · 20532a6 · 20532a6
1 parent 9f5d136
commit 20532a6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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.