From 3dbdd3888968c1c9d09563bab8c82b035a87a297 Mon Sep 17 00:00:00 2001 From: weisd Date: Tue, 8 Apr 2025 22:10:47 +0800 Subject: [PATCH] rm log --- ecstore/src/heal/data_usage_cache.rs | 2 +- ecstore/src/store_list_objects.rs | 4 ++-- iam/src/manager.rs | 2 +- iam/src/store/object.rs | 2 +- rustfs/src/storage/access.rs | 21 ++++++++++----------- 5 files changed, 15 insertions(+), 16 deletions(-) diff --git a/ecstore/src/heal/data_usage_cache.rs b/ecstore/src/heal/data_usage_cache.rs index 9111d2a7f..cca9d79f3 100644 --- a/ecstore/src/heal/data_usage_cache.rs +++ b/ecstore/src/heal/data_usage_cache.rs @@ -380,7 +380,7 @@ impl DataUsageCache { let mut retries = 0; while retries < 5 { let path = Path::new(BUCKET_META_PREFIX).join(name); - warn!("Loading data usage cache from backend: {}", path.display()); + // warn!("Loading data usage cache from backend: {}", path.display()); match store .get_object_reader( RUSTFS_META_BUCKET, diff --git a/ecstore/src/store_list_objects.rs b/ecstore/src/store_list_objects.rs index 4ebd42e4f..08c671e77 100644 --- a/ecstore/src/store_list_objects.rs +++ b/ecstore/src/store_list_objects.rs @@ -25,7 +25,7 @@ use std::io::ErrorKind; use std::sync::Arc; use tokio::sync::broadcast::{self, Receiver as B_Receiver}; use tokio::sync::mpsc::{self, Receiver, Sender}; -use tracing::{error, warn}; +use tracing::error; use uuid::Uuid; const MAX_OBJECT_LIST: i32 = 1000; @@ -248,7 +248,7 @@ impl ECStore { ..Default::default() }; - warn!("list_objects_generic opts {:?}", &opts); + // warn!("list_objects_generic opts {:?}", &opts); // use get if !opts.prefix.is_empty() && opts.limit == 1 && opts.marker.is_none() { diff --git a/iam/src/manager.rs b/iam/src/manager.rs index 73994e220..19589d36b 100644 --- a/iam/src/manager.rs +++ b/iam/src/manager.rs @@ -135,7 +135,7 @@ where } async fn load(self: Arc) -> Result<()> { - debug!("load iam to cache"); + // debug!("load iam to cache"); self.api.load_all(&self.cache).await?; self.last_timestamp .store(OffsetDateTime::now_utc().unix_timestamp(), Ordering::Relaxed); diff --git a/iam/src/store/object.rs b/iam/src/store/object.rs index 20ab01289..7642fe2ea 100644 --- a/iam/src/store/object.rs +++ b/iam/src/store/object.rs @@ -133,7 +133,7 @@ impl ObjectStore { } async fn list_iam_config_items(&self, prefix: &str, ctx_rx: B_Receiver, sender: Sender) { - debug!("list iam config items, prefix: {}", &prefix); + // debug!("list iam config items, prefix: {}", &prefix); // todo, 实现walk,使用walk diff --git a/rustfs/src/storage/access.rs b/rustfs/src/storage/access.rs index fc6bb0b62..a3a3b0da3 100644 --- a/rustfs/src/storage/access.rs +++ b/rustfs/src/storage/access.rs @@ -8,7 +8,6 @@ use policy::policy::{Args, BucketPolicyArgs}; use s3s::access::{S3Access, S3AccessContext}; use s3s::{dto::*, s3_error, S3Error, S3ErrorCode, S3Request, S3Result}; use std::collections::HashMap; -use tracing::info; #[allow(dead_code)] #[derive(Default, Clone)] @@ -144,16 +143,16 @@ impl S3Access for FS { // /// + [`cx.extensions_mut()`](S3AccessContext::extensions_mut) async fn check(&self, cx: &mut S3AccessContext<'_>) -> S3Result<()> { // 上层验证了 ak/sk - info!( - "s3 check uri: {:?}, method: {:?} path: {:?}, s3_op: {:?}, cred: {:?}, headers:{:?}", - cx.uri(), - cx.method(), - cx.s3_path(), - cx.s3_op().name(), - cx.credentials(), - cx.headers(), - // cx.extensions_mut(), - ); + // info!( + // "s3 check uri: {:?}, method: {:?} path: {:?}, s3_op: {:?}, cred: {:?}, headers:{:?}", + // cx.uri(), + // cx.method(), + // cx.s3_path(), + // cx.s3_op().name(), + // cx.credentials(), + // cx.headers(), + // // cx.extensions_mut(), + // ); let (cred, is_owner) = if let Some(input_cred) = cx.credentials() { let (cred, is_owner) =