Skip to content

Commit

Permalink
[ci skip] Add a comment
Browse files Browse the repository at this point in the history
  • Loading branch information
abicky committed Oct 23, 2017
1 parent 1a6f16b commit 2261428
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions lib/fluent/plugin/buffer.rb
Original file line number Diff line number Diff line change
Expand Up @@ -352,6 +352,8 @@ def enqueue_all
log.trace "enqueueing all chunks in buffer", instance: self.object_id
if block_given?
synchronize{ @stage.keys }.each do |metadata|
# NOTE: The following line might cause data race depending on Ruby implementations except CRuby
# cf. https://github.com/fluent/fluentd/pull/1721#discussion_r146170251
chunk = @stage[metadata]
next unless chunk
v = yield metadata, chunk
Expand Down

0 comments on commit 2261428

Please sign in to comment.