Enqueue chunks in buffer.synchronize

Chunks could be purged by buffer.purge so buffer locks are required.
fluent · Oct 20, 2017 · 723038c · 723038c
1 parent ed9f921
commit 723038c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/fluent/plugin/buffer.rb b/lib/fluent/plugin/buffer.rb
@@ -325,8 +325,8 @@ def enqueue_chunk(metadata)
             synchronize do
               @queue << chunk
               @queued_num[metadata] = @queued_num.fetch(metadata, 0) + 1
+              chunk.enqueued!
             end
-            chunk.enqueued!
           end
         end
         bytesize = chunk.bytesize