Method: Fluent::Plugin::Output#submit_flush_all

Defined in:
lib/fluent/plugin/output.rb

#submit_flush_all ⇒ Object 



1408
1409
1410
1411
1412
1413
 
# File 'lib/fluent/plugin/output.rb', line 1408

def submit_flush_all
  while !@retry && @buffer.queued?
    submit_flush_once
    sleep @buffer_config.flush_thread_burst_interval
  end
end