Class: Fluent::PluginHelper::Server::UDPCallbackSocket

Inherits:
CallbackSocket
  • Object
show all
Defined in:
lib/fluent/plugin_helper/server.rb

Constant Summary collapse

ENABLED_EVENTS = 
[]

Instance Method Summary collapse

Methods inherited from CallbackSocket

#close, #close_after_write_complete, #data, #on, #send

Constructor Details

#initialize(sock, peeraddr, **kwargs) ⇒ UDPCallbackSocket

Returns a new instance of UDPCallbackSocket.



476
477
478
479
 
# File 'lib/fluent/plugin_helper/server.rb', line 476

def initialize(sock, peeraddr, **kwargs)
  super("udp", sock, ENABLED_EVENTS, **kwargs)
  @peeraddr = peeraddr
end

Instance Method Details

#remote_addr ⇒ Object 



481
482
483
 
# File 'lib/fluent/plugin_helper/server.rb', line 481

def remote_addr
  @peeraddr[3]
end

#remote_host ⇒ Object 



485
486
487
 
# File 'lib/fluent/plugin_helper/server.rb', line 485

def remote_host
  @peeraddr[2]
end

#remote_port ⇒ Object 



489
490
491
 
# File 'lib/fluent/plugin_helper/server.rb', line 489

def remote_port
  @peeraddr[1]
end

#write(data) ⇒ Object 



493
494
495
 
# File 'lib/fluent/plugin_helper/server.rb', line 493

def write(data)
  @sock.send(data, 0, @peeraddr[3], @peeraddr[1])
end