summaryrefslogtreecommitdiff
path: root/src/chunker/rw/storage/build.rs
diff options
context:
space:
mode:
author魏曹先生 <1992414357@qq.com>2026-03-07 21:49:29 +0800
committer魏曹先生 <1992414357@qq.com>2026-03-07 21:49:29 +0800
commitf5133df198050b82dbdf19a4b2b09c4c27ea07b0 (patch)
treecc4e489ce4468f00d0c29321b96989e63d10b1b9 /src/chunker/rw/storage/build.rs
parent846dd60ef3f167b60f5472493f30a6705de692d5 (diff)
Rename subcommands and constants for clarity
Diffstat (limited to 'src/chunker/rw/storage/build.rs')
-rw-r--r--src/chunker/rw/storage/build.rs9
1 files changed, 6 insertions, 3 deletions
diff --git a/src/chunker/rw/storage/build.rs b/src/chunker/rw/storage/build.rs
index 51b5bf5..d565693 100644
--- a/src/chunker/rw/storage/build.rs
+++ b/src/chunker/rw/storage/build.rs
@@ -8,8 +8,10 @@ use crate::{
chunker::{
constants::BUTCK_INDEX_FILE_SUFFIX,
context::ButckContext,
- rw::error::{ButckRWError, ButckRWErrorKind},
- rw::storage,
+ rw::{
+ error::{ButckRWError, ButckRWErrorKind},
+ storage,
+ },
},
utils::size_display::size_display,
};
@@ -110,6 +112,7 @@ async fn rebuild_from_bidx(
progress::update_progress(progress_name.as_str(), 0.0);
let step = 1.0 / chunk_count as f64;
+ let storage_dir = ctx.storage_path.as_ref().unwrap();
let mut tasks = Vec::with_capacity(chunk_count);
for (index, hash_bytes) in chunk_hashes.iter().enumerate() {
@@ -118,7 +121,7 @@ async fn rebuild_from_bidx(
progress_name.as_str(),
step,
hash_hex,
- &ctx.output_dir,
+ &storage_dir,
index,
));
}