Method: Fluent::Plugin::Output#flush_thread_wakeup

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

#flush_thread_wakeup ⇒ Object

only for tests of output plugin



1433
1434
1435
1436
1437
1438
1439
1440
1441
1442
1443
 
# File 'lib/fluent/plugin/output.rb', line 1433

def flush_thread_wakeup
  @output_flush_threads.each do |state|
    state.mutex.synchronize {
      if state.thread && state.thread.status
        state.next_clock = 0
        state.cond_var.signal
      end
    }
    Thread.pass
  end
end