Method: Flydata::Output::TcpForwarder#connect

Defined in:
lib/flydata/output/forwarder.rb

#connect(server) ⇒ Object 



124
125
126
127
128
129
130
131
132
133
134
135
 
# File 'lib/flydata/output/forwarder.rb', line 124

def connect(server)
  host, port = server.split(':')
  sock = TCPSocket.new(host, port.to_i)

  # Set options
  opt = [1, DEFUALT_SEND_TIMEOUT].pack('I!I!')
  sock.setsockopt(Socket::SOL_SOCKET, Socket::SO_LINGER, opt)
  opt = [DEFUALT_SEND_TIMEOUT, 0].pack('L!L!')
  sock.setsockopt(Socket::SOL_SOCKET, Socket::SO_SNDTIMEO, opt)

  sock
end