Sync file after allocation

crates/subspace-farmer-components/src/file_ext.rs

@@ -84,6 +84,9 @@ pub trait FileExt {
     /// Make sure file has specified number of bytes allocated for it
     fn preallocate(&self, len: u64) -> Result<()>;
 
+    /// Attempts to sync all OS-internal file content and metadata to disk
+    fn sync(&self) -> Result<()>;
+
     /// Advise OS/file system that file will use random access and read-ahead behavior is
     /// undesirable, on Windows this can only be set when file is opened, see [`OpenOptionsExt`]
     fn advise_random_access(&self) -> Result<()>;
@@ -111,6 +114,10 @@ impl FileExt for File {
         fs2::FileExt::allocate(self, len)
     }
 
+    fn sync(&self) -> Result<()> {
+        self.sync_all()
+    }
+
     #[cfg(target_os = "linux")]
     fn advise_random_access(&self) -> Result<()> {
         use std::os::unix::io::AsRawFd;

crates/subspace-farmer/src/disk_piece_cache.rs

@@ -258,6 +258,7 @@ impl DiskPieceCache {
                     .map_err(DiskPieceCacheError::CantPreallocateCacheFile)?;
                 // Truncating file (if necessary)
                 file.set_len(expected_size)?;
+                file.sync()?;
             }
         }
 

crates/subspace-farmer/src/single_disk_farm.rs

@@ -1392,6 +1392,7 @@ impl SingleDiskFarm {
             metadata_file
                 .preallocate(expected_metadata_size)
                 .map_err(SingleDiskFarmError::CantPreallocateMetadataFile)?;
+            metadata_file.sync()?;
             metadata_file.write_all_at(metadata_header.encode().as_slice(), 0)?;
 
             metadata_header
@@ -1404,6 +1405,7 @@ impl SingleDiskFarm {
                     .map_err(SingleDiskFarmError::CantPreallocateMetadataFile)?;
                 // Truncating file (if necessary)
                 metadata_file.set_len(expected_metadata_size)?;
+                metadata_file.sync()?;
             }
 
             let mut metadata_header_bytes = vec![0; PlotMetadataHeader::encoded_size()];
@@ -1476,6 +1478,7 @@ impl SingleDiskFarm {
                 .map_err(SingleDiskFarmError::CantPreallocatePlotFile)?;
             // Truncating file (if necessary)
             plot_file.set_len(allocated_space_distribution.plot_file_size)?;
+            plot_file.sync()?;
         }
 
         let plot_file = Arc::new(plot_file);

crates/subspace-farmer/src/single_disk_farm/direct_io_file.rs

@@ -66,6 +66,10 @@ impl FileExt for DirectIoFile {
         self.file.preallocate(len)
     }
 
+    fn sync(&self) -> io::Result<()> {
+        self.file.sync_all()
+    }
+
     fn advise_random_access(&self) -> io::Result<()> {
         // Ignore, already set
         Ok(())