chore: development v0.2.47 - comprehensive testing complete [auto-commit]

Author: githubrobbi

Cargo.lock

@@ -37,7 +37,7 @@ exclude = [
 # Workspace Package Metadata (inherited by all crates)
 # ─────────────────────────────────────────────────────────────────────────────
 [workspace.package]
-version = "0.2.46"
+version = "0.2.47"
 edition = "2024"
 rust-version = "1.85"
 license = "MPL-2.0 OR LicenseRef-UFFS-Commercial"

Cargo.toml

@@ -21,7 +21,7 @@ Traditional file search tools (including `os.walk`, `FindFirstFile`, etc.) work
 
 **UFFS reads the MFT directly** - once - and queries it in memory using Polars DataFrames. This is like reading the entire phonebook once instead of looking up each name individually.
 
-### Benchmark Results (v0.2.46)
+### Benchmark Results (v0.2.47)
 
 | Drive Type | Records | Time | Throughput |
 |------------|---------|------|------------|
@@ -33,7 +33,7 @@ Traditional file search tools (including `os.walk`, `FindFirstFile`, etc.) work
 
 | Comparison | Records | Time | Notes |
 |------------|---------|------|-------|
-| **UFFS v0.2.46** | **18.7 Million** | **~142 seconds** | All disks, fast mode |
+| **UFFS v0.2.47** | **18.7 Million** | **~142 seconds** | All disks, fast mode |
 | UFFS v0.1.30 | 18.7 Million | ~315 seconds | Baseline |
 | Everything | 19 Million | 178 seconds | All disks |
 | WizFile | 6.5 Million | 299 seconds | Single HDD |

README.md

@@ -4117,8 +4117,7 @@ impl IocpMftReader {
                 // SAFETY: We need get_unchecked_mut to get a mutable reference to the
                 // pinned data for the OVERLAPPED pointer and buffer. The pin is maintained
                 // throughout the operation lifetime.
-                let overlapped_ptr =
-                    unsafe { op.as_mut().get_unchecked_mut().as_overlapped_ptr() };
+                let overlapped_ptr = unsafe { op.as_mut().get_unchecked_mut().as_overlapped_ptr() };
                 let read_result = unsafe {
                     ReadFile(
                         handle,

crates/uffs-mft/src/io.rs

@@ -52,14 +52,14 @@ use criterion as _;
 // Pipelining dependencies (used in io.rs PipelinedMftReader on Windows)
 #[cfg(windows)]
 use crossbeam_channel as _;
-// SmallVec for zero-copy parsing (used in io.rs on Windows)
-#[cfg(windows)]
-use smallvec as _;
 // Platform-gated dependencies (used on Windows only)
 #[cfg(not(windows))]
 use indicatif as _;
 #[cfg(windows)]
 use indicatif::{ProgressBar, ProgressStyle};
+// SmallVec for zero-copy parsing (used in io.rs on Windows)
+#[cfg(windows)]
+use smallvec as _;
 #[cfg(not(windows))]
 use tracing as _;
 #[cfg(windows)]

crates/uffs-mft/src/main.rs

@@ -17,8 +17,8 @@ use std::path::{Path, PathBuf};
 use windows::Win32::Foundation::{CloseHandle, HANDLE};
 use windows::Win32::Storage::FileSystem::{
     CreateFileW, FILE_FLAG_BACKUP_SEMANTICS, FILE_FLAG_NO_BUFFERING, FILE_FLAG_OPEN_REPARSE_POINT,
-    FILE_FLAGS_AND_ATTRIBUTES, FILE_READ_ATTRIBUTES, FILE_SHARE_DELETE, FILE_SHARE_READ,
-    FILE_SHARE_WRITE, OPEN_EXISTING, SYNCHRONIZE,
+    FILE_FLAG_OVERLAPPED, FILE_FLAGS_AND_ATTRIBUTES, FILE_READ_ATTRIBUTES, FILE_SHARE_DELETE,
+    FILE_SHARE_READ, FILE_SHARE_WRITE, OPEN_EXISTING, SYNCHRONIZE,
 };
 
 /// FILE_READ_DATA access right (0x0001) - required to read data from a
@@ -238,6 +238,45 @@ impl VolumeHandle {
         self.handle
     }
 
+    /// Opens a new handle to the same volume with `FILE_FLAG_OVERLAPPED`.
+    ///
+    /// This is required for IOCP (I/O Completion Port) operations which need
+    /// overlapped I/O support. The returned handle is separate from the main
+    /// handle and must be closed by the caller.
+    ///
+    /// # Errors
+    ///
+    /// Returns an error if the volume cannot be opened.
+    #[allow(unsafe_code)] // Required: Windows FFI (CreateFileW)
+    pub fn open_overlapped_handle(&self) -> Result<HANDLE> {
+        use windows::core::PCWSTR;
+
+        let volume_path: Vec<u16> = format!("\\\\.\\{}:", self.volume)
+            .encode_utf16()
+            .chain(core::iter::once(0))
+            .collect();
+
+        let handle = unsafe {
+            CreateFileW(
+                PCWSTR::from_raw(volume_path.as_ptr()),
+                FILE_READ_DATA | FILE_READ_ATTRIBUTES.0 | SYNCHRONIZE.0,
+                FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE,
+                None,
+                OPEN_EXISTING,
+                FILE_FLAG_BACKUP_SEMANTICS | FILE_FLAG_NO_BUFFERING | FILE_FLAG_OVERLAPPED,
+                None,
+            )
+        };
+
+        match handle {
+            Ok(h) => Ok(h),
+            Err(err) => Err(MftError::VolumeOpen {
+                volume: self.volume,
+                source: std::io::Error::from_raw_os_error(err.code().0 as i32),
+            }),
+        }
+    }
+
     /// Returns the byte offset of the MFT on the volume.
     #[must_use]
     pub fn mft_byte_offset(&self) -> u64 {