Close tempfile after rename

cloudamqp · Oct 28, 2024 · e6abe2b · e6abe2b
1 parent a42b4f4
commit e6abe2b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/lavinmq/clustering/client.cr b/src/lavinmq/clustering/client.cr
@@ -233,7 +233,7 @@ module LavinMQ
             f = @files["#{filename}.tmp"]
             IO.copy(lz4, f, len) == len || raise IO::EOFError.new("Full file not received")
             f.rename f.path[0..-5]
-            @files.delete("#{filename}.tmp")
+            @files.delete("#{filename}.tmp").try &.close
           end
           ack_bytes = len.abs + sizeof(Int64) + filename_len + sizeof(Int32)
           acks.send(ack_bytes)