public class AjpNioProcessor extends AbstractAjpProcessor<NioChannel>
AbstractAjpProcessor.SocketInputBuffer, AbstractAjpProcessor.SocketOutputBuffer
Modifier and Type | Field and Description |
---|---|
protected NioSelectorPool |
pool
Selector pool for the associated endpoint.
|
ajpFlush, 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 |
---|
AjpNioProcessor(int packetSize,
NioEndpoint 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<NioChannel> socket)
Process pipelined HTTP requests using the specified input and output
streams.
|
protected int |
read(byte[] buf,
int pos,
int n,
boolean blockFirstRead)
Read the specified amount of bytes, and place them in the input buffer.
|
protected int |
readMessage(AjpMessage message,
boolean blockFirstRead)
Read an AJP message.
|
boolean |
receive()
Receive a chunk of data.
|
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, getAjpFlush, getClientCertProvider, getHttpUpgradeHandler, getKeepAliveTimeout, getTomcatAuthentication, getTomcatAuthorization, getUpgradeInbound, isComet, isUpgrade, parseHost, prepareRequest, prepareResponse, recycle, refillReadBuffer, setAjpFlush, setClientCertProvider, setKeepAliveTimeout, setRequiredSecret, setSslSupport, setTomcatAuthentication, setTomcatAuthorization, upgradeDispatch, upgradeDispatch
asyncPostProcess, errorDispatch, getAdapter, getEndpoint, getErrorState, getExecutor, getMaxCookieCount, getRequest, getSocketWrapper, isAsync, resetErrorState, setAdapter, setErrorState, setMaxCookieCount, setSocketWrapper
protected NioSelectorPool pool
public AjpNioProcessor(int packetSize, NioEndpoint endpoint)
protected Log getLog()
getLog
in class AbstractProcessor<NioChannel>
public AbstractEndpoint.Handler.SocketState process(SocketWrapper<NioChannel> socket) throws java.io.IOException
process
in interface Processor<NioChannel>
process
in class AbstractProcessor<NioChannel>
java.io.IOException
- error during an I/O operationprotected void actionInternal(ActionCode actionCode, java.lang.Object param)
actionInternal
in class AbstractAjpProcessor<NioChannel>
actionCode
- Type of the actionparam
- Action parameterprotected void resetTimeouts()
AbstractAjpProcessor
resetTimeouts
in class AbstractAjpProcessor<NioChannel>
protected void output(byte[] src, int offset, int length) throws java.io.IOException
output
in class AbstractAjpProcessor<NioChannel>
java.io.IOException
protected int read(byte[] buf, int pos, int n, boolean blockFirstRead) throws java.io.IOException
java.io.IOException
public boolean receive() throws java.io.IOException
receive
in class AbstractAjpProcessor<NioChannel>
java.io.IOException
protected int readMessage(AjpMessage message, boolean blockFirstRead) throws java.io.IOException
java.io.IOException
- any other failure, including incomplete readsCopyright © 2000-2018 Apache Software Foundation. All Rights Reserved.