Parent

Unicorn::HttpParser

Constants

DEFAULTS

default parameters we merge into the request env for Rack handlers

NULL_IO
RACK_HIJACK
RACK_HIJACK_IO

Attributes

response_start_sent[RW]

Public Instance Methods

hijack_setup(e, socket) click to toggle source
# File lib/unicorn/http_request.rb, line 109
def hijack_setup(e, socket)
  e[RACK_HIJACK] = proc { e[RACK_HIJACK_IO] = socket }
end
hijacked?() click to toggle source
# File lib/unicorn/http_request.rb, line 105
def hijacked?
  env.include?(RACK_HIJACK_IO)
end
read(socket) click to toggle source

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

[Validate]

Generated with the Darkfish Rdoc Generator 2.