Parent

Class/Module Index [+]

Quicksearch

Fluent::OutputThread

Public Class Methods

new(output) click to toggle source
# File lib/fluent/output.rb, line 79
def initialize(output)
  @output = output
  @finish = false
  @next_time = Engine.now + 1.0
end

Public Instance Methods

configure(conf) click to toggle source
# File lib/fluent/output.rb, line 85
def configure(conf)
end
shutdown() click to toggle source
# File lib/fluent/output.rb, line 94
def shutdown
  @finish = true
  @mutex.synchronize {
    @cond.signal
  }
  Thread.pass
  @thread.join
end
start() click to toggle source
# File lib/fluent/output.rb, line 88
def start
  @mutex = Mutex.new
  @cond = ConditionVariable.new
  @thread = Thread.new(&method(:run))
end
submit_flush() click to toggle source
# File lib/fluent/output.rb, line 103
def submit_flush
  @mutex.synchronize {
    @next_time = 0
    @cond.signal
  }
  Thread.pass
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.