public class AjpProcessor extends AbstractAjpProcessor<java.net.Socket>
AbstractAjpProcessor.SocketInputBuffer, AbstractAjpProcessor.SocketOutputBuffer| Modifier and Type | Field and Description | 
|---|---|
| protected java.io.InputStream | inputInput stream. | 
| protected java.io.OutputStream | outputOutput stream. | 
bodyBytes, bodyMessage, bytesWritten, certificates, clientCertProvider, empty, endAndCloseMessageArray, endMessageArray, endOfStream, finished, first, flushMessageArray, getBodyMessageArray, hostNameC, keepAliveTimeout, packetSize, pongMessageArray, replay, requestHeaderMessage, requiredSecret, responseMessage, sm, tmpMB, tomcatAuthenticationadapter, 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, upgradeDispatchasyncPostProcess, errorDispatch, getAdapter, getEndpoint, getErrorState, getExecutor, getRequest, getSocketWrapper, isAsync, resetErrorState, setAdapter, setErrorState, setSocketWrapperprotected 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)
AbstractAjpProcessorrecycle 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()
AbstractAjpProcessorresetTimeouts 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.IOExceptionprotected boolean read(byte[] buf,
           int pos,
           int n)
                throws java.io.IOException
java.io.IOExceptionpublic boolean receive()
                throws java.io.IOException
receive in class AbstractAjpProcessor<java.net.Socket>java.io.IOExceptionprotected 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.