class Fluent::ForwardOutput::HeartbeatHandler
Public Class Methods
new(io, callback)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_forward.rb, line 393 def initialize(io, callback) super(io) @io = io @callback = callback end
Public Instance Methods
on_readable()
click to toggle source
# File lib/fluent/plugin/out_forward.rb, line 399 def on_readable begin msg, addr = @io.recvfrom(1024) rescue Errno::EAGAIN, Errno::EWOULDBLOCK, Errno::EINTR return end host = addr[3] port = addr[1] sockaddr = Socket.pack_sockaddr_in(port, host) @callback.call(sockaddr, msg) rescue # TODO log? end