Fsync before close

cloudamqp · Oct 17, 2023 · 2615d2a · 2615d2a
1 parent 247049b
commit 2615d2a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/lavinmq/replication/client.cr b/src/lavinmq/replication/client.cr
@@ -217,7 +217,10 @@ module LavinMQ
         @closed = true
         @lz4.close
         @socket.close
-        @files.each_value &.close
+        @files.each_value do |f|
+          f.fsync
+          f.close
+        end
       end
 
       class Error < Exception; end