lib/fluent/plugin/output.rb
# only for tests of output plugin
only for tests of output plugin
only for tests of output plugin
def flush_thread_wakeup
        @output_flush_threads.each do |state|
          state.next_time = 0
          state.thread.run
        end
      end
def flush_thread_wakeup @output_flush_threads . each do | state | state . next_time = 0 state . thread . run end end
only for tests of output plugin
only for tests of output plugin