public class AjpProcessor extends AbstractAjpProcessor<java.net.Socket>
AbstractAjpProcessor.SocketInputBuffer, AbstractAjpProcessor.SocketOutputBuffer
Modifier and Type | Field and Description |
---|---|
protected java.io.InputStream |
input
Input stream.
|
protected java.io.OutputStream |
output
Output stream.
|
bodyBytes, bodyMessage, bytesWritten, certificates, clientCertProvider, empty, endAndCloseMessageArray, endMessageArray, endOfStream, finished, first, flushMessageArray, getBodyMessageArray, hostNameC, keepAliveTimeout, packetSize, pongMessageArray, replay, requestHeaderMessage, requiredSecret, responseMessage, sm, tmpMB, tomcatAuthentication
adapter, asyncStateMachine, endpoint, request, response, socketWrapper
Constructor and Description |
---|
AjpProcessor(int packetSize,
JIoEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
actionInternal(ActionCode actionCode,
java.lang.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<java.net.Socket> socket)
Process pipelined HTTP requests using the specified input and output
streams.
|
protected boolean |
read(byte[] buf,
int pos,
int n)
Read at least the specified amount of bytes, and place them
in the input buffer.
|
protected boolean |
readMessage(AjpMessage message)
Read an AJP message.
|
boolean |
receive()
Receive a chunk of data.
|
void |
recycle(boolean socketClosing)
Recycle the processor, ready for the next request which may be on the
same connection or a different connection.
|
protected void |
resetTimeouts()
Provides a mechanism for those connector implementations (currently only
NIO) that need to reset timeouts from Async timeouts to standard HTTP
timeouts once async processing completes.
|
action, asyncDispatch, event, finish, flush, getClientCertProvider, getHttpUpgradeHandler, getKeepAliveTimeout, getTomcatAuthentication, getTomcatAuthorization, getUpgradeInbound, isComet, isUpgrade, parseHost, prepareRequest, prepareResponse, refillReadBuffer, setClientCertProvider, setKeepAliveTimeout, setRequiredSecret, setSslSupport, setTomcatAuthentication, setTomcatAuthorization, upgradeDispatch, upgradeDispatch
asyncPostProcess, errorDispatch, getAdapter, getEndpoint, getErrorState, getExecutor, getRequest, getSocketWrapper, isAsync, resetErrorState, setAdapter, setErrorState, setSocketWrapper
protected java.io.InputStream input
protected java.io.OutputStream output
public AjpProcessor(int packetSize, JIoEndpoint endpoint)
protected Log getLog()
getLog
in class AbstractProcessor<java.net.Socket>
public AbstractEndpoint.Handler.SocketState process(SocketWrapper<java.net.Socket> socket) throws java.io.IOException
process
in interface Processor<java.net.Socket>
process
in class AbstractProcessor<java.net.Socket>
java.io.IOException
- error during an I/O operationpublic void recycle(boolean socketClosing)
AbstractAjpProcessor
recycle
in interface Processor<java.net.Socket>
recycle
in class AbstractAjpProcessor<java.net.Socket>
socketClosing
- Indicates if the socket is about to be closed
allowing the processor to perform any additional
clean-up that may be requiredprotected void actionInternal(ActionCode actionCode, java.lang.Object param)
actionInternal
in class AbstractAjpProcessor<java.net.Socket>
actionCode
- Type of the actionparam
- Action parameterprotected void resetTimeouts()
AbstractAjpProcessor
resetTimeouts
in class AbstractAjpProcessor<java.net.Socket>
protected void output(byte[] src, int offset, int length) throws java.io.IOException
output
in class AbstractAjpProcessor<java.net.Socket>
java.io.IOException
protected boolean read(byte[] buf, int pos, int n) throws java.io.IOException
java.io.IOException
public boolean receive() throws java.io.IOException
receive
in class AbstractAjpProcessor<java.net.Socket>
java.io.IOException
protected boolean readMessage(AjpMessage message) throws java.io.IOException
java.io.IOException
- any other failure, including incomplete readsCopyright © 2000-2015 Apache Software Foundation. All Rights Reserved.