# File lib/rev/socket.rb, line 57 def on_writable evl = evloop detach if connect_successful? @rev_socket.instance_eval { @_connector = nil } @rev_socket.attach(evl) @ruby_socket.setsockopt(::Socket::IPPROTO_TCP, ::Socket::TCP_NODELAY, [1].pack("l")) @ruby_socket.setsockopt(::Socket::SOL_SOCKET, ::Socket::SO_KEEPALIVE, true) @rev_socket.__send__(:on_connect) else @rev_socket.instance_eval { @_failed = true } @rev_socket.__send__(:on_connect_failed) end end
# File lib/rev/socket.rb, line 52 def initialize(rev_socket, ruby_socket) @rev_socket, @ruby_socket = rev_socket, ruby_socket super(ruby_socket, :w) end