Parent

Class/Module Index [+]

Quicksearch

Fluent::ForwardInput::HeartbeatRequestHandler

Public Class Methods

new(io, callback) click to toggle source
# File lib/fluent/plugin/in_forward.rb, line 193
def initialize(io, callback)
  super(io)
  @io = io
  @callback = callback
end

Public Instance Methods

on_readable() click to toggle source
# File lib/fluent/plugin/in_forward.rb, line 199
def on_readable
  begin
    msg, addr = @io.recvfrom(1024)
  rescue Errno::EAGAIN, Errno::EWOULDBLOCK, Errno::EINTR
    return
  end
  host = addr[3]
  port = addr[1]
  @callback.call(host, port, msg)
rescue
  # TODO log?
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.