Coolio::IO
# File lib/fluent/plugin/out_forward.rb, line 304 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
Generated with the Darkfish Rdoc Generator 2.