Avoid sync dir on windows

Author: allevo

src/bool/io.rs

@@ -221,13 +221,23 @@ pub fn ensure_version_dir(base_path: &Path, version_number: u64) -> Result<std::
 
 /// Sync a directory to ensure file operations are durable.
 pub fn sync_dir(path: &Path) -> Result<()> {
-    let dir = OpenOptions::new()
-        .read(true)
-        .open(path)
-        .with_context(|| format!("Failed to open directory for sync: {path:?}"))?;
+    // On Unix, we can sync the directory
+    #[cfg(unix)]
+    {
+        let dir = OpenOptions::new()
+            .read(true)
+            .open(path)
+            .with_context(|| format!("Failed to open directory for sync: {path:?}"))?;
+
+        dir.sync_all()
+            .with_context(|| format!("Failed to sync directory: {path:?}"))?;
+    }
 
-    dir.sync_all()
-        .with_context(|| format!("Failed to sync directory: {path:?}"))?;
+    // On non-Unix, this is a no-op
+    #[cfg(not(unix))]
+    {
+        let _ = path;
+    }
 
     Ok(())
 }

src/embedding/io.rs

@@ -59,8 +59,19 @@ pub fn ensure_version_dir(base_path: &Path, version_number: u64) -> Result<PathB
 }
 
 pub fn sync_dir(path: &Path) -> Result<(), Error> {
-    let dir = OpenOptions::new().read(true).open(path)?;
-    dir.sync_all()?;
+    // On Unix, we can sync the directory
+    #[cfg(unix)]
+    {
+        let dir = OpenOptions::new().read(true).open(path)?;
+        dir.sync_all()?;
+    }
+
+    // On non-Unix, this is a no-op
+    #[cfg(not(unix))]
+    {
+        let _ = path;
+    }
+
     Ok(())
 }
 

src/geopoint/io.rs

@@ -95,13 +95,23 @@ pub fn ensure_version_dir(base_path: &Path, version_id: u64) -> Result<PathBuf>
 }
 
 pub fn sync_dir(path: &Path) -> Result<()> {
-    let dir = OpenOptions::new()
-        .read(true)
-        .open(path)
-        .with_context(|| format!("Failed to open directory for sync: {path:?}"))?;
+    // On Unix, we can sync the directory
+    #[cfg(unix)]
+    {
+        let dir = OpenOptions::new()
+            .read(true)
+            .open(path)
+            .with_context(|| format!("Failed to open directory for sync: {path:?}"))?;
+
+        dir.sync_all()
+            .with_context(|| format!("Failed to sync directory: {path:?}"))?;
+    }
 
-    dir.sync_all()
-        .with_context(|| format!("Failed to sync directory: {path:?}"))?;
+    // On non-Unix, this is a no-op
+    #[cfg(not(unix))]
+    {
+        let _ = path;
+    }
 
     Ok(())
 }

src/string/io.rs

@@ -81,13 +81,23 @@ pub fn ensure_version_dir(base_path: &Path, version_number: u64) -> Result<std::
 }
 
 pub fn sync_dir(path: &Path) -> Result<()> {
-    let dir = OpenOptions::new()
-        .read(true)
-        .open(path)
-        .with_context(|| format!("Failed to open directory for sync: {path:?}"))?;
+    // On Unix, we can sync the directory
+    #[cfg(unix)]
+    {
+        let dir = OpenOptions::new()
+            .read(true)
+            .open(path)
+            .with_context(|| format!("Failed to open directory for sync: {path:?}"))?;
+
+        dir.sync_all()
+            .with_context(|| format!("Failed to sync directory: {path:?}"))?;
+    }
 
-    dir.sync_all()
-        .with_context(|| format!("Failed to sync directory: {path:?}"))?;
+    // On non-Unix, this is a no-op
+    #[cfg(not(unix))]
+    {
+        let _ = path;
+    }
 
     Ok(())
 }

src/string_filter/io.rs

@@ -128,13 +128,23 @@ pub fn ensure_version_dir(base_path: &Path, version_number: u64) -> Result<std::
 }
 
 pub fn sync_dir(path: &Path) -> Result<()> {
-    let dir = OpenOptions::new()
-        .read(true)
-        .open(path)
-        .with_context(|| format!("Failed to open directory for sync: {path:?}"))?;
+    // On Unix, we can sync the directory
+    #[cfg(unix)]
+    {
+        let dir = OpenOptions::new()
+            .read(true)
+            .open(path)
+            .with_context(|| format!("Failed to open directory for sync: {path:?}"))?;
+
+        dir.sync_all()
+            .with_context(|| format!("Failed to sync directory: {path:?}"))?;
+    }
 
-    dir.sync_all()
-        .with_context(|| format!("Failed to sync directory: {path:?}"))?;
+    // On non-Unix, this is a no-op
+    #[cfg(not(unix))]
+    {
+        let _ = path;
+    }
 
     Ok(())
 }