From 3325d5b0b32316f073065836e483f609c54169f9 Mon Sep 17 00:00:00 2001
From: Ada Bohm <ada@kreatrix.org>
Date: Sun, 22 Feb 2026 22:13:29 +0100
Subject: [PATCH] data_sync added to journal flushing

---
 crates/hyperqueue/src/server/event/journal/write.rs | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/crates/hyperqueue/src/server/event/journal/write.rs b/crates/hyperqueue/src/server/event/journal/write.rs
index 5bd3137ad..e9296fb7a 100644
--- a/crates/hyperqueue/src/server/event/journal/write.rs
+++ b/crates/hyperqueue/src/server/event/journal/write.rs
@@ -65,11 +65,14 @@ impl JournalWriter {
 
     pub fn flush(&mut self) -> anyhow::Result<()> {
         self.file.flush()?;
+        /* Flush does not call file sync. We want to be sure that data
+          is written, especially on NFS.
+        */
+        self.file.get_ref().sync_data()?;
         Ok(())
     }
 
     pub fn finish(mut self) -> anyhow::Result<()> {
-        self.file.flush()?;
-        Ok(())
+        self.flush()
     }
 }