Class: Fluent::NetflowInput::UdpHandler

Inherits:
Coolio::IO
  • Object
show all
Defined in:
lib/fluent/plugin/in_netflow.rb

Instance Method Summary collapse

Constructor Details

#initialize(io, callback) ⇒ UdpHandler

Returns a new instance of UdpHandler.



103
104
105
106
107
 
# File 'lib/fluent/plugin/in_netflow.rb', line 103

def initialize(io, callback)
  super(io)
  @io = io
  @callback = callback
end

Instance Method Details

#on_readable ⇒ Object 



109
110
111
112
113
114
 
# File 'lib/fluent/plugin/in_netflow.rb', line 109

def on_readable
  msg, addr = @io.recvfrom_nonblock(4096)
  @callback.call(addr[3], msg)
rescue
  # TODO log?
end