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.



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

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

Instance Method Details

#remote_addr ⇒ Object 



498
499
500
 
# File 'lib/fluent/plugin_helper/server.rb', line 498

def remote_addr
  @peeraddr[3]
end

#remote_host ⇒ Object 



502
503
504
 
# File 'lib/fluent/plugin_helper/server.rb', line 502

def remote_host
  @peeraddr[2]
end

#remote_port ⇒ Object 



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

def remote_port
  @peeraddr[1]
end

#write(data) ⇒ Object 



510
511
512
 
# File 'lib/fluent/plugin_helper/server.rb', line 510

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