Method: Fluent::PluginHelper::Server::TCPCallbackSocket#initialize

Defined in:
lib/fluent/plugin_helper/server.rb

#initialize(sock) ⇒ TCPCallbackSocket

Returns a new instance of TCPCallbackSocket.



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

def initialize(sock)
  super("tcp", sock, ENABLED_EVENTS)
  @peeraddr = (@sock.peeraddr rescue PEERADDR_FAILED)
  @buffer = ''
end