Try to fsync message log on drop

clockworklabs · Dec 4, 2023 · d303451 · d303451
1 parent 4ef1bd5
commit d303451
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/crates/core/src/db/message_log.rs b/crates/core/src/db/message_log.rs
@@ -195,6 +195,14 @@ impl std::fmt::Debug for MessageLog {
     }
 }
 
+impl Drop for MessageLog {
+    fn drop(&mut self) {
+        if let Err(e) = self.sync_all() {
+            log::warn!("Unable to fsync on drop: {e}");
+        }
+    }
+}
+
 // TODO: do we build the concept of batches into the message log?
 impl MessageLog {
     #[tracing::instrument(skip(path))]