From 723038c5f2b5be14cfec877c0099d659788027cd Mon Sep 17 00:00:00 2001 From: abicky Date: Fri, 20 Oct 2017 18:34:42 +0900 Subject: [PATCH] Enqueue chunks in buffer.synchronize Chunks could be purged by buffer.purge so buffer locks are required. --- lib/fluent/plugin/buffer.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/fluent/plugin/buffer.rb b/lib/fluent/plugin/buffer.rb index f62e92a713..72bf65c840 100644 --- 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