mirror of
https://github.com/rustfs/rustfs.git
synced 2026-08-22 04:16:38 +00:00
@@ -1030,13 +1030,11 @@ impl FolderScanner {
|
|||||||
|
|
||||||
#[tracing::instrument(level = "info", skip(into, folder_scanner))]
|
#[tracing::instrument(level = "info", skip(into, folder_scanner))]
|
||||||
async fn scan(folder: &CachedFolder, into: &mut DataUsageEntry, folder_scanner: &mut FolderScanner) {
|
async fn scan(folder: &CachedFolder, into: &mut DataUsageEntry, folder_scanner: &mut FolderScanner) {
|
||||||
let mut dst = if into.compacted {
|
if !into.compacted {
|
||||||
DataUsageEntry::default()
|
*into = DataUsageEntry::default();
|
||||||
} else {
|
}
|
||||||
into.clone()
|
|
||||||
};
|
|
||||||
|
|
||||||
if Box::pin(folder_scanner.scan_folder(folder, &mut dst)).await.is_err() {
|
if Box::pin(folder_scanner.scan_folder(folder, into)).await.is_err() {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if !into.compacted {
|
if !into.compacted {
|
||||||
|
|||||||
@@ -541,7 +541,7 @@ impl DataUsageCache {
|
|||||||
match self.find(path) {
|
match self.find(path) {
|
||||||
Some(root) => {
|
Some(root) => {
|
||||||
if root.children.is_empty() {
|
if root.children.is_empty() {
|
||||||
return None;
|
return Some(root);
|
||||||
}
|
}
|
||||||
let mut flat = self.flatten(&root);
|
let mut flat = self.flatten(&root);
|
||||||
if flat.replication_stats.is_some() && flat.replication_stats.as_ref().unwrap().empty() {
|
if flat.replication_stats.is_some() && flat.replication_stats.as_ref().unwrap().empty() {
|
||||||
|
|||||||
Reference in New Issue
Block a user