public class InternalNio2InputBuffer extends AbstractNioInputBuffer<Nio2Channel>
Modifier and Type | Class and Description |
---|---|
protected class |
InternalNio2InputBuffer.SocketInputBuffer
This class is an input buffer which will read its data from an input
stream.
|
AbstractNioInputBuffer.HeaderParseData
Modifier and Type | Field and Description |
---|---|
protected java.io.IOException |
e
Exception that occurred during writing.
|
protected AbstractEndpoint<Nio2Channel> |
endpoint
The associated endpoint.
|
protected boolean |
flipped
Track if the byte buffer is flipped
|
protected boolean |
interest
Track write interest
|
protected boolean |
readPending
Read pending flag.
|
headerBufferSize, socketReadBufferSize
activeFilters, buf, end, filterLibrary, headers, httpParser, inputStreamInputBuffer, lastActiveFilter, lastValid, parsingHeader, pos, rejectIllegalHeaderName, request, sm, swallowInput
Constructor and Description |
---|
InternalNio2InputBuffer(Request request,
int headerBufferSize,
boolean rejectIllegalHeaderName,
HttpParser httpParser) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
fill(boolean block)
Attempts to read some data into the input buffer.
|
protected Log |
getLog() |
protected void |
init(SocketWrapper<Nio2Channel> socketWrapper,
AbstractEndpoint<Nio2Channel> associatedEndpoint) |
boolean |
isPending() |
void |
nextRequest()
End processing of current HTTP request.
|
void |
recycle()
Recycle the input buffer.
|
void |
registerReadInterest() |
expand, getParsingRequestLinePhase, parseHeaders, parseRequestLine
addActiveFilter, addFilter, available, doRead, endRequest, getFilters, isBlocking, isFinished, setSwallowInput
protected volatile boolean interest
protected AbstractEndpoint<Nio2Channel> endpoint
protected volatile boolean readPending
protected java.io.IOException e
protected volatile boolean flipped
public InternalNio2InputBuffer(Request request, int headerBufferSize, boolean rejectIllegalHeaderName, HttpParser httpParser)
protected final Log getLog()
getLog
in class AbstractInputBuffer<Nio2Channel>
public void recycle()
recycle
in class AbstractNioInputBuffer<Nio2Channel>
public void nextRequest()
nextRequest
in class AbstractNioInputBuffer<Nio2Channel>
public boolean isPending()
protected void init(SocketWrapper<Nio2Channel> socketWrapper, AbstractEndpoint<Nio2Channel> associatedEndpoint) throws java.io.IOException
init
in class AbstractInputBuffer<Nio2Channel>
java.io.IOException
protected boolean fill(boolean block) throws java.io.IOException, java.io.EOFException
AbstractInputBuffer
fill
in class AbstractInputBuffer<Nio2Channel>
true
if more data was added to the input buffer
otherwise false
java.io.IOException
java.io.EOFException
public void registerReadInterest()
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.