Field Detail

• headerBufferSize

  protected final int headerBufferSize

  Maximum allowed size of the HTTP request line plus headers plus any leading blank lines.

• socketReadBufferSize

  protected int socketReadBufferSize

  Known size of the NioChannel read buffer.

Constructor Detail

• AbstractNioInputBuffer

  public AbstractNioInputBuffer(Request request,
                        int headerBufferSize)

  Alternate constructor.

Method Detail

• recycle

  public void recycle()

  Recycle the input buffer. This should be called when closing the connection.

  Overrides:

  recycle in class AbstractInputBuffer<S>

• nextRequest

  public void nextRequest()

  End processing of current HTTP request. Note: All bytes of the current request should have been already consumed. This method only resets all the pointers so that we are ready to parse the next HTTP request.

  Overrides:

  nextRequest in class AbstractInputBuffer<S>

• parseRequestLine

  public boolean parseRequestLine(boolean useAvailableDataOnly)
                           throws IOException

  Read the request line. This function is meant to be used during the HTTP request header parsing. Do NOT attempt to read the request body using it.

  Specified by:

  parseRequestLine in class AbstractInputBuffer<S>

  Returns:

  true if data is properly fed; false if no data is available immediately and thread should be freed

  Throws:

  IOException - If an exception occurs during the underlying socket read operations, or if the given buffer is not big enough to accommodate the whole line.

• expand

  protected void expand(int newsize)

• parseHeaders

  public boolean parseHeaders()
                       throws IOException

  Parse the HTTP headers.

  Specified by:

  parseHeaders in class AbstractInputBuffer<S>

  Throws:

  IOException

• getParsingRequestLinePhase

  public int getParsingRequestLinePhase()