public class InternalNioInputBuffer extends AbstractInputBuffer<NioChannel>
Modifier and Type | Class and Description |
---|---|
static class |
InternalNioInputBuffer.HeaderParseData |
protected class |
InternalNioInputBuffer.SocketInputBuffer
This class is an input buffer which will read its data from an input
stream.
|
activeFilters, buf, end, filterLibrary, headers, HTTP_TOKEN_CHAR, inputStreamInputBuffer, lastActiveFilter, lastValid, parsingHeader, pos, request, sm, swallowInput
Constructor and Description |
---|
InternalNioInputBuffer(Request request,
int headerBufferSize)
Alternate constructor.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
fill(boolean block)
Fill the internal buffer using data from the underlying input stream.
|
protected boolean |
fill(boolean timeout,
boolean block) |
int |
getParsingRequestLinePhase() |
protected void |
init(SocketWrapper<NioChannel> socketWrapper,
AbstractEndpoint<NioChannel> endpoint) |
void |
nextRequest()
End processing of current HTTP request.
|
boolean |
parseHeaders()
Parse the HTTP headers.
|
boolean |
parseRequestLine(boolean useAvailableDataOnly)
Read the request line.
|
void |
recycle()
Recycle the input buffer.
|
addActiveFilter, addFilter, available, doRead, endRequest, getFilters, setSwallowInput
public InternalNioInputBuffer(Request request, int headerBufferSize)
public void recycle()
recycle
in class AbstractInputBuffer<NioChannel>
public void nextRequest()
nextRequest
in class AbstractInputBuffer<NioChannel>
public boolean parseRequestLine(boolean useAvailableDataOnly) throws java.io.IOException
parseRequestLine
in class AbstractInputBuffer<NioChannel>
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.public boolean parseHeaders() throws java.io.IOException
parseHeaders
in class AbstractInputBuffer<NioChannel>
java.io.IOException
public int getParsingRequestLinePhase()
protected void init(SocketWrapper<NioChannel> socketWrapper, AbstractEndpoint<NioChannel> endpoint) throws java.io.IOException
init
in class AbstractInputBuffer<NioChannel>
java.io.IOException
protected boolean fill(boolean block) throws java.io.IOException, java.io.EOFException
fill
in class AbstractInputBuffer<NioChannel>
java.io.IOException
java.io.EOFException
protected boolean fill(boolean timeout, boolean block) throws java.io.IOException, java.io.EOFException
java.io.IOException
java.io.EOFException
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.