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, keepAliveTimeout, pongMessageArray, replay, requestHeaderMessage, requiredSecret, responseMessage, sm, tmpMB, tomcatAuthentication
adapter, asyncStateMachine, endpoint, hostNameC, request, response, socketWrapper, userDataHelper
Constructor and Description |
---|
AjpNioProcessor(int packetSize,
NioEndpoint 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 blockFirstRead)
Read at least the specified amount of bytes, and place them
in the input buffer.
|
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<NioChannel> socketWrapper,
int timeout) |
protected void |
setupSocket(SocketWrapper<NioChannel> socketWrapper) |
action, asyncDispatch, event, finish, flush, getAjpFlush, getClientCertProvider, getKeepAliveTimeout, getLeftoverInput, getTomcatAuthentication, getTomcatAuthorization, getUpgradeToken, isComet, isUpgrade, populateHost, prepareRequest, prepareResponse, process, readMessage, receive, recycle, refillReadBuffer, setAjpFlush, setClientCertProvider, setKeepAliveTimeout, setRequiredSecret, setSslSupport, setTomcatAuthentication, setTomcatAuthorization, upgradeDispatch
asyncPostProcess, errorDispatch, getAdapter, getEndpoint, getErrorState, getExecutor, getMaxCookieCount, getRequest, getSocketWrapper, isAsync, parseHost, resetErrorState, setAdapter, setErrorState, setMaxCookieCount, setSocketWrapper
protected final NioSelectorPool pool
public AjpNioProcessor(int packetSize, NioEndpoint endpoint)
protected Log getLog()
getLog
in class AbstractProcessor<NioChannel>
protected void registerForEvent(boolean read, boolean write)
AbstractProcessor
registerForEvent
in class AbstractProcessor<NioChannel>
read
- Register the socket for read eventswrite
- Register the socket for write eventsprotected void resetTimeouts()
AbstractAjpProcessor
resetTimeouts
in class AbstractAjpProcessor<NioChannel>
protected void setupSocket(SocketWrapper<NioChannel> socketWrapper) throws java.io.IOException
setupSocket
in class AbstractAjpProcessor<NioChannel>
java.io.IOException
protected void setTimeout(SocketWrapper<NioChannel> socketWrapper, int timeout) throws java.io.IOException
setTimeout
in class AbstractAjpProcessor<NioChannel>
java.io.IOException
protected int output(byte[] src, int offset, int length, boolean block) throws java.io.IOException
output
in class AbstractAjpProcessor<NioChannel>
java.io.IOException
protected boolean read(byte[] buf, int pos, int n, boolean blockFirstRead) throws java.io.IOException
AbstractAjpProcessor
read
in class AbstractAjpProcessor<NioChannel>
buf
- Buffer to read data intopos
- Start positionn
- The minimum number of bytes to readblockFirstRead
- 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 false
java.io.IOException
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.