From ee04cc77a0d7ba88fee6838ff0c5255f829cef33 Mon Sep 17 00:00:00 2001 From: Shyim Date: Wed, 26 Nov 2025 04:56:01 +0100 Subject: [PATCH] remove debug (#912) * remove debug * Refactor get_global_encryption_service function * Refactor get_global_encryption_service function --------- Co-authored-by: loverustfs Co-authored-by: houseme --- crates/ecstore/src/disk/local.rs | 15 --------------- crates/kms/src/service_manager.rs | 14 ++------------ rustfs/src/main.rs | 8 -------- 3 files changed, 2 insertions(+), 35 deletions(-) diff --git a/crates/ecstore/src/disk/local.rs b/crates/ecstore/src/disk/local.rs index 7f746af3..7f13cd47 100644 --- a/crates/ecstore/src/disk/local.rs +++ b/crates/ecstore/src/disk/local.rs @@ -2003,17 +2003,6 @@ impl DiskAPI for LocalDisk { } }; - // CLAUDE DEBUG: Check if inline data is being preserved - tracing::info!( - "CLAUDE DEBUG: rename_data - Adding version to xlmeta. fi.data.is_some()={}, fi.inline_data()={}, fi.size={}", - fi.data.is_some(), - fi.inline_data(), - fi.size - ); - if let Some(ref data) = fi.data { - tracing::info!("CLAUDE DEBUG: rename_data - FileInfo has inline data: {} bytes", data.len()); - } - xlmeta.add_version(fi.clone())?; if xlmeta.versions.len() <= 10 { @@ -2021,10 +2010,6 @@ impl DiskAPI for LocalDisk { } let new_dst_buf = xlmeta.marshal_msg()?; - tracing::info!( - "CLAUDE DEBUG: rename_data - Marshaled xlmeta, new_dst_buf size: {} bytes", - new_dst_buf.len() - ); self.write_all(src_volume, format!("{}/{}", &src_path, STORAGE_FORMAT_FILE).as_str(), new_dst_buf.into()) .await?; diff --git a/crates/kms/src/service_manager.rs b/crates/kms/src/service_manager.rs index 59388549..c5d40fce 100644 --- a/crates/kms/src/service_manager.rs +++ b/crates/kms/src/service_manager.rs @@ -71,9 +71,6 @@ impl KmsServiceManager { /// Configure KMS with new configuration pub async fn configure(&self, new_config: KmsConfig) -> Result<()> { - info!("CLAUDE DEBUG: configure() called with backend: {:?}", new_config.backend); - info!("Configuring KMS with backend: {:?}", new_config.backend); - // Update configuration { let mut config = self.config.write().await; @@ -92,7 +89,6 @@ impl KmsServiceManager { /// Start KMS service with current configuration pub async fn start(&self) -> Result<()> { - info!("CLAUDE DEBUG: start() called"); let config = { let config_guard = self.config.read().await; match config_guard.as_ref() { @@ -270,12 +266,6 @@ pub fn get_global_kms_service_manager() -> Option> { /// Get global encryption service (if KMS is running) pub async fn get_global_encryption_service() -> Option> { - info!("CLAUDE DEBUG: get_global_encryption_service called"); - let manager = get_global_kms_service_manager().unwrap_or_else(|| { - warn!("CLAUDE DEBUG: KMS service manager not initialized, initializing now as fallback"); - init_global_kms_service_manager() - }); - let service = manager.get_encryption_service().await; - info!("CLAUDE DEBUG: get_encryption_service returned: {}", service.is_some()); - service + let manager = get_global_kms_service_manager().unwrap_or_else(init_global_kms_service_manager); + manager.get_encryption_service().await } diff --git a/rustfs/src/main.rs b/rustfs/src/main.rs index f5ae2c57..559aead5 100644 --- a/rustfs/src/main.rs +++ b/rustfs/src/main.rs @@ -540,14 +540,6 @@ async fn add_bucket_notification_configuration(buckets: Vec) { /// Initialize KMS system and configure if enabled #[instrument(skip(opt))] async fn init_kms_system(opt: &config::Opt) -> Result<()> { - println!("CLAUDE DEBUG: init_kms_system called!"); - info!("CLAUDE DEBUG: init_kms_system called!"); - info!("Initializing KMS service manager..."); - info!( - "CLAUDE DEBUG: KMS configuration - kms_enable: {}, kms_backend: {}, kms_key_dir: {:?}, kms_default_key_id: {:?}", - opt.kms_enable, opt.kms_backend, opt.kms_key_dir, opt.kms_default_key_id - ); - // Initialize global KMS service manager (starts in NotConfigured state) let service_manager = rustfs_kms::init_global_kms_service_manager();