Do nothing if chunks have been already enqueued

fluent · Oct 20, 2017 · 93088bf · 93088bf
1 parent cc25a3c
commit 93088bf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/fluent/plugin/buffer.rb b/lib/fluent/plugin/buffer.rb
@@ -319,6 +319,8 @@ def enqueue_chunk(metadata)
         return nil unless chunk
 
         chunk.synchronize do
+          return nil if chunk.queued?
+
           if chunk.empty?
             chunk.close
           else