From 0854e6b9219f5c6451ee047eac9ebbd335751e00 Mon Sep 17 00:00:00 2001 From: junxiang Mu <1948535941@qq.com> Date: Tue, 22 Jul 2025 09:52:57 +0800 Subject: [PATCH] Chore: rename init_heal_manager_with_channel Signed-off-by: junxiang Mu <1948535941@qq.com> --- crates/ahm/src/lib.rs | 2 +- rustfs/src/main.rs | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/crates/ahm/src/lib.rs b/crates/ahm/src/lib.rs index 207973e9..ae130714 100644 --- a/crates/ahm/src/lib.rs +++ b/crates/ahm/src/lib.rs @@ -63,7 +63,7 @@ static GLOBAL_HEAL_MANAGER: OnceLock> = OnceLock::new(); static GLOBAL_HEAL_CHANNEL_PROCESSOR: OnceLock>> = OnceLock::new(); /// Initialize and start heal manager with channel processor -pub async fn init_heal_manager_with_channel( +pub async fn init_heal_manager( storage: Arc, config: Option, ) -> Result<()> { diff --git a/rustfs/src/main.rs b/rustfs/src/main.rs index b7cc0a32..c4065832 100644 --- a/rustfs/src/main.rs +++ b/rustfs/src/main.rs @@ -30,7 +30,7 @@ use clap::Parser; use license::init_license; use rustfs_ahm::scanner::data_scanner::ScannerConfig; use rustfs_ahm::{ - Scanner, create_ahm_services_cancel_token, heal::storage::ECStoreHealStorage, init_heal_manager_with_channel, + Scanner, create_ahm_services_cancel_token, heal::storage::ECStoreHealStorage, init_heal_manager, shutdown_ahm_services, }; use rustfs_common::globals::set_global_addr; @@ -191,7 +191,7 @@ async fn run(opt: config::Opt) -> Result<()> { // Initialize heal manager with channel processor let heal_storage = Arc::new(ECStoreHealStorage::new(store.clone())); - init_heal_manager_with_channel(heal_storage, None).await?; + init_heal_manager(heal_storage, None).await?; let scanner = Scanner::new(Some(ScannerConfig::default()), None); scanner.start().await?;