default parameters we merge into the request env for Rack handlers
# File lib/unicorn/http_request.rb, line 109 def hijack_setup(e, socket) e[RACK_HIJACK] = proc { e[RACK_HIJACK_IO] = socket } end
# File lib/unicorn/http_request.rb, line 105 def hijacked? env.include?(RACK_HIJACK_IO) end
Does the majority of the IO processing. It has been written in Ruby using about 8 different IO processing strategies.
It is currently carefully constructed to make sure that it gets the best possible performance for the common case: GET requests that are fully complete after a single read(2)
Anyone who thinks they can make it faster is more than welcome to take a crack at it.
returns an environment hash suitable for Rack if successful This does minimal exception trapping and it is up to the caller to handle any socket errors (e.g. user aborted upload).
# File lib/unicorn/http_request.rb, line 64 def read(socket) clear e = env # From http://www.ietf.org/rfc/rfc3875: # "Script authors should be aware that the REMOTE_ADDR and # REMOTE_HOST meta-variables (see sections 4.1.8 and 4.1.9) # may not identify the ultimate source of the request. They # identify the client for the immediate request to the server; # that client may be a proxy, gateway, or other intermediary # acting on behalf of the actual source client." e[REMOTE_ADDR] = socket.kgio_addr # short circuit the common case with small GET requests first socket.kgio_read!(16384, buf) if parse.nil? # Parser is not done, queue up more data to read and continue parsing # an Exception thrown from the parser will throw us out of the loop false until add_parse(socket.kgio_read!(16384)) end # detect if the socket is valid by writing a partial response: if @@check_client_connection && headers? @response_start_sent = true Unicorn::Const::HTTP_RESPONSE_START.each { |c| socket.write(c) } end e[RACK_INPUT] = 0 == content_length ? NULL_IO : @@input_class.new(socket, self) hijack_setup(e, socket) e.merge!(DEFAULTS) end
Generated with the Darkfish Rdoc Generator 2.