org.apache.coyote.http11
Class InternalNioInputBuffer

java.lang.Object
  org.apache.coyote.http11.AbstractInputBuffer
      org.apache.coyote.http11.InternalNioInputBuffer

All Implemented Interfaces:

InputBuffer

public class InternalNioInputBuffer
extends AbstractInputBuffer

Implementation of InputBuffer which provides HTTP request header parsing as well as transfer decoding.

Author:

Remy Maucherat, Filip Hanik

request

protected Request request

Associated Coyote request.

headers

protected MimeHeaders headers

Headers of the associated request.

parsingHeader

protected boolean parsingHeader

Parsing state - used for non blocking parsing so that when more data arrives, we can pick up where we left off.

parsingRequestLine

protected boolean parsingRequestLine

parsingRequestLinePhase

protected int parsingRequestLinePhase

parsingRequestLineEol

protected boolean parsingRequestLineEol

parsingRequestLineStart

protected int parsingRequestLineStart

parsingRequestLineQPos

protected int parsingRequestLineQPos

headerParsePos

protected org.apache.coyote.http11.InternalNioInputBuffer.HeaderParsePosition headerParsePos

swallowInput

protected boolean swallowInput

Swallow input ? (in the case of an expectation)

buf

protected byte[] buf

Pointer to the current read buffer.

lastValid

protected int lastValid

Last valid byte.

pos

protected int pos

Position in the buffer.

end

protected int end

Pos of the end of the header in the buffer, which is also the start of the body.

socket

protected NioChannel socket

Underlying socket.

pool

protected NioSelectorPool pool

Selector pool, for blocking reads and blocking writes

inputStreamInputBuffer

protected InputBuffer inputStreamInputBuffer

Underlying input buffer.

filterLibrary

protected InputFilter[] filterLibrary

Filter library. Note: Filter[0] is always the "chunked" filter.

activeFilters

protected InputFilter[] activeFilters

Active filters (in order).

lastActiveFilter

protected int lastActiveFilter

Index of the last active filter.

InternalNioInputBuffer

public InternalNioInputBuffer(Request request,
                              int headerBufferSize)

Alternate constructor.

setSocket

public void setSocket(NioChannel socket)

Set the underlying socket.

getSocket

public NioChannel getSocket()

Get the underlying socket input stream.

setSelectorPool

public void setSelectorPool(NioSelectorPool pool)

getSelectorPool

public NioSelectorPool getSelectorPool()

addFilter

public void addFilter(InputFilter filter)

Add an input filter to the filter library.

getFilters

public InputFilter[] getFilters()

Get filters.

clearFilters

public void clearFilters()

Clear filters.

addActiveFilter

public void addActiveFilter(InputFilter filter)

Add an input filter to the filter library.

setSwallowInput

public void setSwallowInput(boolean swallowInput)

Set the swallow input flag.

isReadable

public boolean isReadable()
                   throws java.io.IOException

Returns true if there are bytes available from the socket layer

Returns:

boolean

Throws:

java.io.IOException

nbRead

public int nbRead()
           throws java.io.IOException

Issues a non blocking read

Returns:

int

Throws:

java.io.IOException

recycle

public void recycle()

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

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.

endRequest

public void endRequest()
                throws java.io.IOException

End request (consumes leftover bytes).

Throws:

java.io.IOException - an undelying I/O error occured

parseRequestLine

public boolean parseRequestLine(boolean useAvailableDataOnly)
                         throws java.io.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.

Returns:

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

Throws:

java.io.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.

parseHeaders

public boolean parseHeaders()
                     throws java.io.IOException

Parse the HTTP headers.

Throws:

java.io.IOException

parseHeader

public org.apache.coyote.http11.InternalNioInputBuffer.HeaderParseStatus parseHeader()
                                                                              throws java.io.IOException

Parse an HTTP header.

Returns:

false after reading a blank line (which indicates that the HTTP header parsing is done

Throws:

java.io.IOException

available

public int available()

Available bytes (note that due to encoding, this may not correspond )

doRead

public int doRead(ByteChunk chunk,
                  Request req)
           throws java.io.IOException

Read some bytes.

Throws:

java.io.IOException

fill

protected boolean fill(boolean timeout,
                       boolean block)
                throws java.io.IOException,
                       java.io.EOFException

Fill the internal buffer using data from the undelying input stream.

Returns:

false if at end of stream

Throws:

java.io.IOException

java.io.EOFException