File tree Expand file tree Collapse file tree 3 files changed +16
-9
lines changed
Expand file tree Collapse file tree 3 files changed +16
-9
lines changed Original file line number Diff line number Diff line change @@ -824,7 +824,9 @@ async fn load_and_filter_data(
824824 if let Some ( drive_letter) = effective_drive {
825825 // Single drive search with proper path resolution
826826 let t_read = std:: time:: Instant :: now ( ) ;
827- eprintln ! ( "[DEBUG] search_dataframe: before load_or_build_dataframe_cached drive={drive_letter}" ) ;
827+ eprintln ! (
828+ "[DEBUG] search_dataframe: before load_or_build_dataframe_cached drive={drive_letter}"
829+ ) ;
828830
829831 // Use cached DataFrame path for performance (Windows only)
830832 #[ cfg( windows) ]
Original file line number Diff line number Diff line change @@ -372,9 +372,14 @@ fn load_or_build_dataframe_cached_sync(
372372 eprintln ! ( "[DEBUG] load_or_build_dataframe_cached_sync: cache MISS, reading MFT fresh" ) ;
373373 tracing:: info!( drive = %drive, "📖 Cache miss - reading MFT fresh" ) ;
374374 let reader = MftReader :: open_sync ( drive) ?;
375- eprintln ! ( "[DEBUG] load_or_build_dataframe_cached_sync: reader opened, calling read_all_index_sync" ) ;
375+ eprintln ! (
376+ "[DEBUG] load_or_build_dataframe_cached_sync: reader opened, calling read_all_index_sync"
377+ ) ;
376378 let index = reader. read_all_index_sync ( ) ?;
377- eprintln ! ( "[DEBUG] load_or_build_dataframe_cached_sync: read_all_index_sync done, records={}" , index. len( ) ) ;
379+ eprintln ! (
380+ "[DEBUG] load_or_build_dataframe_cached_sync: read_all_index_sync done, records={}" ,
381+ index. len( )
382+ ) ;
378383
379384 // Save to cache for next time
380385 let handle = VolumeHandle :: open ( drive) ?;
Original file line number Diff line number Diff line change @@ -933,19 +933,19 @@ impl MftReader {
933933 let mode = self . mode ;
934934 let merge_extensions = self . merge_extensions ;
935935 let use_bitmap = self . use_bitmap ;
936- let expand_hardlinks = self . expand_hardlinks ;
936+ let expand_links = self . expand_links ;
937937
938938 let result = tokio:: task:: spawn_blocking ( move || {
939939 eprintln ! ( "[DEBUG] read_all_index: INSIDE spawn_blocking volume={volume}" ) ;
940940 // Create a new reader in the blocking thread
941- let handle = crate :: platform :: VolumeHandle :: open ( volume) ?;
941+ let handle = VolumeHandle :: open ( volume) ?;
942942 let reader = MftReader {
943943 volume,
944944 handle,
945945 mode,
946946 merge_extensions,
947947 use_bitmap,
948- expand_hardlinks ,
948+ expand_links ,
949949 } ;
950950 let idx = reader. read_mft_index_internal ( None :: < fn ( MftProgress ) > ) ;
951951 eprintln ! ( "[DEBUG] read_all_index: read_mft_index_internal done" ) ;
@@ -1046,18 +1046,18 @@ impl MftReader {
10461046 let mode = self . mode ;
10471047 let merge_extensions = self . merge_extensions ;
10481048 let use_bitmap = self . use_bitmap ;
1049- let expand_hardlinks = self . expand_hardlinks ;
1049+ let expand_links = self . expand_links ;
10501050
10511051 tokio:: task:: spawn_blocking ( move || {
10521052 // Create a new reader in the blocking thread
1053- let handle = crate :: platform :: VolumeHandle :: open ( volume) ?;
1053+ let handle = VolumeHandle :: open ( volume) ?;
10541054 let reader = MftReader {
10551055 volume,
10561056 handle,
10571057 mode,
10581058 merge_extensions,
10591059 use_bitmap,
1060- expand_hardlinks ,
1060+ expand_links ,
10611061 } ;
10621062 reader. read_mft_index_internal ( Some ( callback) )
10631063 } )
You can’t perform that action at this time.
0 commit comments