gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-08-28 16:07:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #68 from rustfs/bucket-replication

Browse Source 
change some log level
This commit is contained in:
laoliu
2025-07-06 20:27:49 +08:00
committed by GitHub
parent 32e531bc61 ce470c95c4
commit 040b05c318
1 changed files with 13 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/heal/data_scanner.rs
+13 -8
View File
@@ -103,7 +103,7 @@ use tokio::{
}, },
time::sleep, time::sleep,
}; };
use tracing::{error, info}; use tracing::{debug, error, info};
const DATA_SCANNER_SLEEP_PER_FOLDER: Duration = Duration::from_millis(1); // Time to wait between folders. const DATA_SCANNER_SLEEP_PER_FOLDER: Duration = Duration::from_millis(1); // Time to wait between folders.
const DATA_USAGE_UPDATE_DIR_CYCLES: u32 = 16; // Visit all folders every n cycles. const DATA_USAGE_UPDATE_DIR_CYCLES: u32 = 16; // Visit all folders every n cycles.
@@ -741,13 +741,18 @@ impl ScannerItem {
// Create a mutable clone if you need to modify fields // Create a mutable clone if you need to modify fields
let mut oi = oi.clone(); let mut oi = oi.clone();
oi.replication_status = ReplicationStatusType::from(
oi.user_defined let versioned = BucketVersioningSys::prefix_enabled(&oi.bucket, &oi.name).await;
.get("x-amz-bucket-replication-status") if versioned {
.unwrap_or(&"PENDING".to_string()), oi.replication_status = ReplicationStatusType::from(
); oi.user_defined
info!("apply status is: {:?}", oi.replication_status); .get("x-amz-bucket-replication-status")
self.heal_replication(&oi, _size_s).await; .unwrap_or(&"PENDING".to_string()),
);
debug!("apply status is: {:?}", oi.replication_status);
self.heal_replication(&oi, _size_s).await;
}
done(); done();
if action.delete_all() { if action.delete_all() {