lib/fluent/plugin/output.rb
# only for tests of output plugin
only for tests of output plugin
only for tests of output plugin
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
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
only for tests of output plugin
only for tests of output plugin