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

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

Instance Method Summary collapse

Methods inherited from CallbackSocket

#close, #data, #on, #send

Constructor Details

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

Returns a new instance of UDPCallbackSocket.



450
451
452
453
 
# File 'lib/fluent/plugin_helper/server.rb', line 450

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

Instance Method Details

#remote_addr ⇒ Object 



455
456
457
 
# File 'lib/fluent/plugin_helper/server.rb', line 455

def remote_addr
  @peeraddr[3]
end

#remote_host ⇒ Object 



459
460
461
 
# File 'lib/fluent/plugin_helper/server.rb', line 459

def remote_host
  @peeraddr[2]
end

#remote_port ⇒ Object 



463
464
465
 
# File 'lib/fluent/plugin_helper/server.rb', line 463

def remote_port
  @peeraddr[1]
end

#write(data) ⇒ Object 



467
468
469
 
# File 'lib/fluent/plugin_helper/server.rb', line 467

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