Sha256: 0a96cab21bdb48f14ab1bbed18f2089d0f218ccd27232753027be2fc0899c34e
Contents?: true
Size: 1.56 KB
Versions: 11
Compression:
Stored size: 1.56 KB
Contents
class ProxyMachine
class ServerConnection < EventMachine::Connection
def self.request(host, port, client_side)
EventMachine.connect(host, port, self, client_side)
end
def initialize(conn)
@client_side = conn
@connected = false
@data_received = false
@timeout = nil
end
def receive_data(data)
fail "receive_data called after raw proxy enabled" if @data_received
@data_received = true
@client_side.send_data(data)
proxy_incoming_to(@client_side, 10240)
end
def connection_completed
@connected = Time.now
@timeout = comm_inactivity_timeout || 0.0
@client_side.server_connection_success
end
def unbind
now = Time.now
if @client_side.error?
# the client side disconnected while we were in progress with
# the server. do nothing.
$logger.info "Client closed while server connection in progress. Dropping."
elsif !@connected
# a connection error or timeout occurred
@client_side.server_connection_failed
elsif !@data_received
if @timeout > 0.0 && (elapsed = now - @connected) >= @timeout
# EM aborted the connection due to an inactivity timeout
@client_side.server_inactivity_timeout(@timeout, elapsed)
else
# server disconnected soon after connecting without sending data
# treat this like a failed server connection
@client_side.server_connection_failed
end
else
@client_side.close_connection_after_writing
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems