Method: Fluent::Plugin::Output#enqueue_thread_wait

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

#enqueue_thread_wait ⇒ Object

only for tests of output plugin



1421
1422
1423
1424
1425
1426
1427
1428
1429
1430
 
# File 'lib/fluent/plugin/output.rb', line 1421

def enqueue_thread_wait
  @output_enqueue_thread_mutex.synchronize do
    @output_flush_interrupted = false
    @output_enqueue_thread_waiting = true
  end
  require 'timeout'
  Timeout.timeout(10) do
    Thread.pass while @output_enqueue_thread_waiting
  end
end