We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9348a0c commit 2382230Copy full SHA for 2382230
src/lavinmq/message_store.cr
@@ -235,16 +235,16 @@ module LavinMQ
235
end
236
237
private def delete_file(file : MFile, including_meta = false)
238
- File.delete?(meta_file_name(file)) if including_meta
239
file.delete(raise_on_missing: false)
240
if replicator = @replicator
241
- replicator.delete_file(meta_file_name(file), WaitGroup.new) if including_meta
242
wg = WaitGroup.new
+ replicator.delete_file(meta_file_name(file), wg) if including_meta
243
replicator.delete_file(file.path, wg)
244
spawn(name: "wait for file deletion is replicated") do
245
replicator.wait_for_sync do
246
wg.wait
247
ensure
+ File.delete?(meta_file_name(file)) if including_meta
248
file.close
249
250
0 commit comments