Skip to content

Commit ff60209

Browse files
committed
Add some debugging
1 parent bb4980d commit ff60209

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

src/file/reader.rs

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -540,9 +540,11 @@ impl BoxFileReader {
540540
for (box_path, record, expected_hash) in files {
541541
let tx = tx.clone();
542542
let progress = progress.clone();
543+
eprintln!("[box] acquiring permit for {}", box_path);
543544
let permit = semaphore.clone().acquire_owned().await.map_err(|e| {
544545
ExtractError::DecompressionFailed(std::io::Error::other(e), box_path.to_path_buf())
545546
})?;
547+
eprintln!("[box] got permit for {}", box_path);
546548

547549
let mmap = mmap.clone();
548550
let out_base = output_path.to_path_buf();
@@ -556,6 +558,7 @@ impl BoxFileReader {
556558
});
557559
}
558560

561+
eprintln!("[box] extracting {}", box_path);
559562
let result = extract_single_file_from_mmap(
560563
mmap,
561564
archive_offset,
@@ -565,10 +568,10 @@ impl BoxFileReader {
565568
verify_checksums,
566569
expected_hash.as_deref(),
567570
)
568-
.await
569-
.map(|s| (box_path, s));
571+
.await;
572+
eprintln!("[box] extracted {} result={:?}", box_path, result.is_ok());
570573

571-
let _ = tx.send(result).await;
574+
let _ = tx.send(result.map(|s| (box_path, s))).await;
572575
});
573576
}
574577

0 commit comments

Comments
 (0)