|
Apache Tomcat 7.0.28 | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.coyote.AbstractProcessor<S> org.apache.coyote.ajp.AbstractAjpProcessor<Long> org.apache.coyote.ajp.AjpAprProcessor
public class AjpAprProcessor
Processes AJP requests.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.coyote.ajp.AbstractAjpProcessor |
---|
AbstractAjpProcessor.SocketInputBuffer, AbstractAjpProcessor.SocketOutputBuffer |
Field Summary | |
---|---|
protected ByteBuffer |
inputBuffer
Direct buffer used for input. |
protected ByteBuffer |
outputBuffer
Direct buffer used for output. |
protected SocketWrapper<Long> |
socket
Socket associated with the current connection. |
Fields inherited from class org.apache.coyote.ajp.AbstractAjpProcessor |
---|
bodyBytes, bodyMessage, bytesWritten, certificates, clientCertProvider, empty, endAndCloseMessageArray, endMessageArray, endOfStream, error, finished, first, flushMessageArray, getBodyMessageArray, hostNameC, keepAliveTimeout, packetSize, pongMessageArray, replay, requestHeaderMessage, requiredSecret, responseMessage, sm, tmpMB, tomcatAuthentication |
Fields inherited from class org.apache.coyote.AbstractProcessor |
---|
adapter, asyncStateMachine, endpoint, request, response |
Constructor Summary | |
---|---|
AjpAprProcessor(int packetSize,
AprEndpoint endpoint)
|
Method Summary | |
---|---|
protected void |
actionInternal(ActionCode actionCode,
Object param)
Send an action to the connector. |
protected Log |
getLog()
|
protected void |
output(byte[] src,
int offset,
int length)
|
AbstractEndpoint.Handler.SocketState |
process(SocketWrapper<Long> socket)
Process pipelined HTTP requests using the specified input and output streams. |
protected boolean |
read(int n)
Read at least the specified amount of bytes, and place them in the input buffer. |
protected boolean |
readMessage(AjpMessage message,
boolean first,
boolean useAvailableData)
Read an AJP message. |
protected boolean |
readt(int n,
boolean useAvailableData)
Read at least the specified amount of bytes, and place them in the input buffer. |
boolean |
receive()
Receive a chunk of data. |
void |
recycle(boolean socketClosing)
Recycle the processor. |
Methods inherited from class org.apache.coyote.ajp.AbstractAjpProcessor |
---|
action, asyncDispatch, event, finish, flush, getClientCertProvider, getKeepAliveTimeout, getTomcatAuthentication, getUpgradeInbound, isComet, isUpgrade, parseHost, prepareRequest, prepareResponse, refillReadBuffer, setClientCertProvider, setKeepAliveTimeout, setRequiredSecret, setSslSupport, setTomcatAuthentication, upgradeDispatch |
Methods inherited from class org.apache.coyote.AbstractProcessor |
---|
asyncPostProcess, getAdapter, getEndpoint, getExecutor, getRequest, isAsync, setAdapter |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected SocketWrapper<Long> socket
protected ByteBuffer inputBuffer
protected ByteBuffer outputBuffer
Constructor Detail |
---|
public AjpAprProcessor(int packetSize, AprEndpoint endpoint)
Method Detail |
---|
protected Log getLog()
getLog
in class AbstractAjpProcessor<Long>
public AbstractEndpoint.Handler.SocketState process(SocketWrapper<Long> socket) throws IOException
process
in interface Processor<Long>
process
in class AbstractProcessor<Long>
IOException
- error during an I/O operationprotected void actionInternal(ActionCode actionCode, Object param)
actionInternal
in class AbstractAjpProcessor<Long>
actionCode
- Type of the actionparam
- Action parameterprotected void output(byte[] src, int offset, int length) throws IOException
output
in class AbstractAjpProcessor<Long>
IOException
protected boolean read(int n) throws IOException
IOException
protected boolean readt(int n, boolean useAvailableData) throws IOException
IOException
public boolean receive() throws IOException
receive
in class AbstractAjpProcessor<Long>
IOException
protected boolean readMessage(AjpMessage message, boolean first, boolean useAvailableData) throws IOException
first
- is true if the message is the first in the request, which
will cause a short duration blocking read
IOException
- any other failure, including incomplete readspublic void recycle(boolean socketClosing)
recycle
in interface Processor<Long>
recycle
in class AbstractAjpProcessor<Long>
socketClosing
- Indicates if the socket is about to be closed
allowing the processor to perform any additional
clean-up that may be required
|
Apache Tomcat 7.0.28 | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |