public class AjpAprProcessor extends AbstractAjpProcessor<java.lang.Long>
AbstractAjpProcessor.SocketInputBuffer, AbstractAjpProcessor.SocketOutputBuffer| Modifier and Type | Field and Description |
|---|---|
protected java.nio.ByteBuffer |
inputBuffer
Direct buffer used for input.
|
protected java.nio.ByteBuffer |
outputBuffer
Direct buffer used for output.
|
ajpFlush, bodyBytes, bodyMessage, bytesWritten, certificates, clientCertProvider, empty, endAndCloseMessageArray, endMessageArray, endOfStream, finished, first, flushMessageArray, getBodyMessageArray, keepAliveTimeout, pongMessageArray, replay, requestHeaderMessage, requiredSecret, responseMessage, sm, tmpMB, tomcatAuthenticationadapter, asyncStateMachine, endpoint, hostNameC, request, response, socketWrapper, userDataHelper| Constructor and Description |
|---|
AjpAprProcessor(int packetSize,
AprEndpoint endpoint) |
| Modifier and Type | Method and Description |
|---|---|
protected Log |
getLog() |
protected int |
output(byte[] src,
int offset,
int length,
boolean block) |
protected boolean |
read(byte[] buf,
int pos,
int n,
boolean block)
Read at least the specified amount of bytes, and place them
in the input buffer.
|
void |
recycle(boolean socketClosing)
Recycle the processor.
|
protected void |
registerForEvent(boolean read,
boolean write)
Register the socket for the specified events.
|
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.
|
protected void |
setTimeout(SocketWrapper<java.lang.Long> socketWrapper,
int timeout) |
protected void |
setupSocket(SocketWrapper<java.lang.Long> socketWrapper) |
action, asyncDispatch, event, finish, flush, getAjpFlush, getClientCertProvider, getKeepAliveTimeout, getLeftoverInput, getTomcatAuthentication, getTomcatAuthorization, getUpgradeToken, isComet, isUpgrade, populateHost, prepareRequest, prepareResponse, process, readMessage, receive, refillReadBuffer, setAjpFlush, setClientCertProvider, setKeepAliveTimeout, setRequiredSecret, setSslSupport, setTomcatAuthentication, setTomcatAuthorization, upgradeDispatchasyncPostProcess, errorDispatch, getAdapter, getEndpoint, getErrorState, getExecutor, getMaxCookieCount, getRequest, getSocketWrapper, isAsync, parseHost, resetErrorState, setAdapter, setErrorState, setMaxCookieCount, setSocketWrapperprotected final java.nio.ByteBuffer inputBuffer
protected final java.nio.ByteBuffer outputBuffer
public AjpAprProcessor(int packetSize,
AprEndpoint endpoint)
protected Log getLog()
getLog in class AbstractProcessor<java.lang.Long>protected void registerForEvent(boolean read,
boolean write)
AbstractProcessorregisterForEvent in class AbstractProcessor<java.lang.Long>read - Register the socket for read eventswrite - Register the socket for write eventsprotected void resetTimeouts()
AbstractAjpProcessorresetTimeouts in class AbstractAjpProcessor<java.lang.Long>protected void setupSocket(SocketWrapper<java.lang.Long> socketWrapper)
setupSocket in class AbstractAjpProcessor<java.lang.Long>protected void setTimeout(SocketWrapper<java.lang.Long> socketWrapper, int timeout) throws java.io.IOException
setTimeout in class AbstractAjpProcessor<java.lang.Long>java.io.IOExceptionprotected int output(byte[] src,
int offset,
int length,
boolean block)
throws java.io.IOException
output in class AbstractAjpProcessor<java.lang.Long>java.io.IOExceptionprotected boolean read(byte[] buf,
int pos,
int n,
boolean block)
throws java.io.IOException
AbstractAjpProcessorread in class AbstractAjpProcessor<java.lang.Long>buf - Buffer to read data intopos - Start positionn - The minimum number of bytes to readblock - If there is no data available to read when this method is
called, should this call block until data becomes available?true if the requested number of bytes were read
else falsejava.io.IOExceptionpublic void recycle(boolean socketClosing)
recycle in interface Processor<java.lang.Long>recycle in class AbstractAjpProcessor<java.lang.Long>socketClosing - Indicates if the socket is about to be closed
allowing the processor to perform any additional
clean-up that may be requiredCopyright © 2000-2018 Apache Software Foundation. All Rights Reserved.