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.



507
508
509
510
 
# File 'lib/fluent/plugin_helper/server.rb', line 507

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

Instance Method Details

#remote_addr ⇒ Object 



512
513
514
 
# File 'lib/fluent/plugin_helper/server.rb', line 512

def remote_addr
  @peeraddr[3]
end

#remote_host ⇒ Object 



516
517
518
 
# File 'lib/fluent/plugin_helper/server.rb', line 516

def remote_host
  @peeraddr[2]
end

#remote_port ⇒ Object 



520
521
522
 
# File 'lib/fluent/plugin_helper/server.rb', line 520

def remote_port
  @peeraddr[1]
end

#write(data) ⇒ Object 



524
525
526
 
# File 'lib/fluent/plugin_helper/server.rb', line 524

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