Object
# File lib/fluent/output.rb, line 98 def initialize(output) @output = output @finish = false @next_time = Engine.now + 1.0 end
# File lib/fluent/output.rb, line 104 def configure(conf) end
# File lib/fluent/output.rb, line 113 def shutdown @finish = true @mutex.synchronize { @cond.signal } Thread.pass @thread.join end
# File lib/fluent/output.rb, line 107 def start @mutex = Mutex.new @cond = ConditionVariable.new @thread = Thread.new(&method(:run)) end
# File lib/fluent/output.rb, line 122 def submit_flush @mutex.synchronize { @next_time = 0 @cond.signal } Thread.pass end
[Validate]
Generated with the Darkfish Rdoc Generator 2.