Class: Fluent::CallLater

Inherits:

Object

• Object
• Fluent::CallLater

Defined in:

lib/fluent/plugin/in_tail_multiline.rb

Instance Method Summary

• #call_later(delay, &block) ⇒ Object
• #cancel ⇒ Object
• #initialize ⇒ CallLater constructor

  A new instance of CallLater.

• #run ⇒ Object
• #shutdown ⇒ Object

Constructor Details

#initialize ⇒ CallLater

Returns a new instance of CallLater.

# File 'lib/fluent/plugin/in_tail_multiline.rb', line 169

def initialize
  @locker = Monitor::new
  initExecBlock()
  @thread = Thread.new(&method(:run))
end

Instance Method Details

#call_later(delay, &block) ⇒ Object

# File 'lib/fluent/plugin/in_tail_multiline.rb', line 175

def call_later(delay,&block)
  @locker.synchronize do
    @exec_time = Engine.now + delay
    @exec_block = block
  end
  @thread.run
end

#cancel ⇒ Object

# File 'lib/fluent/plugin/in_tail_multiline.rb', line 208

def cancel()
  initExecBlock()
end

#run ⇒ Object

# File 'lib/fluent/plugin/in_tail_multiline.rb', line 183

def run
  @running = true
  while true
    sleepSec = -1
    @locker.synchronize do
      now = Engine.now
      if @exec_block && @exec_time <= now
        @exec_block.call()
        initExecBlock()
      end          
      return unless @running
      unless(@exec_time == -1)
        sleepSec = @exec_time - now 
      end
    end
    if (sleepSec == -1)
      sleep()
    else
      sleep(sleepSec)
    end
  end
rescue => e
  puts e
end

#shutdown ⇒ Object

# File 'lib/fluent/plugin/in_tail_multiline.rb', line 212

def shutdown()
  @locker.synchronize do
    @running = false
  end
  if(@thread)
    @thread.run
    @thread.join
    @thread = nil
  end
end