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?;