diff --git a/crates/e2e_test/src/kms/kms_fault_recovery_test.rs b/crates/e2e_test/src/kms/kms_fault_recovery_test.rs index d2942d26b..4905eea92 100644 --- a/crates/e2e_test/src/kms/kms_fault_recovery_test.rs +++ b/crates/e2e_test/src/kms/kms_fault_recovery_test.rs @@ -393,11 +393,10 @@ async fn test_kms_multipart_upload_interruption() -> Result<(), Box Result<(), Box> { +async fn test_kms_concurrent_encryption_requests() -> Result<(), Box> { init_logging(); - info!("๐Ÿงช Testing KMS behavior under resource constraints"); let mut kms_env = LocalKMSTestEnvironment::new().await?; let _default_key_id = kms_env.start_rustfs_for_local_kms().await?; @@ -431,29 +430,27 @@ async fn test_kms_resource_constraints() -> Result<(), Box { - successful_uploads += 1; info!("โœ… Rapid upload {} succeeded", object_key); } Err(e) => { - failed_uploads += 1; warn!("โŒ Rapid upload {} failed: {}", object_key, e); + failures.push(format!("{object_key}: {e}")); } } } - info!("๐Ÿ“Š Rapid upload results: {} succeeded, {} failed", successful_uploads, failed_uploads); - - // We expect most uploads to succeed even under load - assert!(successful_uploads >= 7, "Expected at least 7/10 rapid uploads to succeed"); + assert!( + failures.is_empty(), + "all 10 concurrent KMS uploads must succeed; failures: {}", + failures.join("; ") + ); kms_env.base_env.delete_test_bucket(TEST_BUCKET).await?; - info!("โœ… Resource constraints test completed successfully"); Ok(()) }