0.4.2

Author: MichaelTaylor3D

Cargo.lock

@@ -218,6 +218,11 @@ impl DigArchive {
         file.sync_all()?;
         drop(file);
 
+        // On Windows, add a small delay to ensure file handle is fully released
+        // before attempting to memory-map the file
+        #[cfg(windows)]
+        std::thread::sleep(std::time::Duration::from_millis(100));
+
         let mut archive = Self {
             archive_path,
             header,
@@ -226,7 +231,30 @@ impl DigArchive {
             dirty: false,
         };
 
+        // Retry memory mapping with backoff on Windows
+        #[cfg(windows)]
+        {
+            let mut attempts = 0;
+            const MAX_ATTEMPTS: usize = 5;
+            
+            loop {
+                match archive.load_mmap() {
+                    Ok(()) => break,
+                    Err(e) if attempts < MAX_ATTEMPTS => {
+                        attempts += 1;
+                        // Exponential backoff: 50ms, 100ms, 200ms, 400ms, 800ms
+                        let delay = 50 * (1 << attempts);
+                        std::thread::sleep(std::time::Duration::from_millis(delay));
+                        continue;
+                    }
+                    Err(e) => return Err(e),
+                }
+            }
+        }
+
+        #[cfg(not(windows))]
         archive.load_mmap()?;
+
         Ok(archive)
     }
 

src/storage/dig_archive.rs

@@ -93,11 +93,19 @@ impl Store {
                 }
             }
 
-            // Longer delay to ensure all file handles are released on Windows
-            std::thread::sleep(std::time::Duration::from_millis(500));
-
-            // Try to force garbage collection
-            std::hint::black_box(());
+            // On Windows, use longer delay and force garbage collection
+            #[cfg(windows)]
+            {
+                std::thread::sleep(std::time::Duration::from_millis(500));
+                // Force garbage collection multiple times to ensure cleanup
+                for _ in 0..3 {
+                    std::hint::black_box(());
+                    std::thread::sleep(std::time::Duration::from_millis(50));
+                }
+            }
+            
+            #[cfg(not(windows))]
+            std::thread::sleep(std::time::Duration::from_millis(100));
 
             // Remove existing .digstore file to proceed with new initialization
             std::fs::remove_file(&digstore_path)?;