public class Http11AprProcessor extends AbstractHttp11Processor<Long>
Modifier and Type | Field and Description |
---|---|
protected String |
clientCertProvider
When client certificate information is presented in a form other than
instances of
X509Certificate it needs to be
converted before it can be used and this property controls which JSSE
provider is used to perform the conversion. |
protected InternalAprInputBuffer |
inputBuffer
Input.
|
protected InternalAprOutputBuffer |
outputBuffer
Output.
|
protected AprEndpoint.SendfileData |
sendfileData
Sendfile data.
|
comet, compressableMimeTypes, compressionLevel, compressionMinSize, connectionUploadTimeout, contentDelimitation, disableUploadTimeout, expectation, http09, http11, httpParser, httpUpgradeHandler, keepAlive, keepAliveTimeout, keptAlive, localAddr, localName, localPort, maxKeepAliveRequests, maxSavePostSize, noCompressionStrongETag, noCompressionUserAgents, openSocket, readComplete, remoteAddr, remoteHost, remotePort, restrictedUserAgents, sendfileInProgress, server, sm, socketBuffer, upgradeInbound
adapter, asyncStateMachine, endpoint, hostNameC, request, response, socketWrapper, userDataHelper
Constructor and Description |
---|
Http11AprProcessor(int headerBufferSize,
boolean rejectIllegalHeader,
AprEndpoint endpoint,
int maxTrailerSize,
Set<String> allowedTrailerHeaders,
int maxExtensionSize,
int maxSwallowSize,
String relaxedPathChars,
String relaxedQueryChars) |
Modifier and Type | Method and Description |
---|---|
void |
actionInternal(ActionCode actionCode,
Object param)
Send an action to the connector.
|
protected boolean |
breakKeepAliveLoop(SocketWrapper<Long> socketWrapper)
Checks to see if the keep-alive loop should be broken, performing any
processing (e.g. sendfile handling) that may have an impact on whether
or not the keep-alive loop should be broken.
|
protected boolean |
disableKeepAlive()
Processors (currently only HTTP BIO) may elect to disable HTTP keep-alive
in some circumstances.
|
AbstractEndpoint.Handler.SocketState |
event(SocketStatus status)
Process pipelined HTTP requests using the specified input and output
streams.
|
String |
getClientCertProvider() |
protected AbstractInputBuffer<Long> |
getInputBuffer()
Exposes input buffer to super class to allow better code re-use.
|
protected Log |
getLog() |
protected AbstractOutputBuffer<Long> |
getOutputBuffer()
Exposes output buffer to super class to allow better code re-use.
|
protected boolean |
handleIncompleteRequestLineRead()
Defines how a connector handles an incomplete request line read.
|
protected void |
prepareRequestInternal()
Connector implementation specific request preparation.
|
protected boolean |
prepareSendfile(OutputFilter[] outputFilters) |
void |
recycleInternal() |
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.
|
void |
setClientCertProvider(String s) |
protected void |
setCometTimeouts(SocketWrapper<Long> socketWrapper)
Provides a mechanism for those connectors (currently only NIO) that need
that need to set comet timeouts.
|
protected void |
setRequestLineReadTimeout()
Configures the timeout to be used for reading the request line.
|
protected void |
setSocketTimeout(int timeout)
Set the socket timeout.
|
void |
setSslSupport(SSLSupport sslSupport) |
action, addCompressableMimeType, addCompressibleMimeType, asyncDispatch, endRequest, findBytes, getAllowHostHeaderMismatch, getCompression, getConnectionUploadTimeout, getDisableUploadTimeout, getHttpUpgradeHandler, getKeepAliveTimeout, getMaxKeepAliveRequests, getMaxSavePostSize, getServer, getSocketBuffer, getUpgradeInbound, initializeFilters, isComet, isUpgrade, populatePort, prepareRequest, process, recycle, setAllowHostHeaderMismatch, setCompressableMimeTypes, setCompressableMimeTypes, setCompressibleMimeTypes, setCompressibleMimeTypes, setCompression, setCompressionMinSize, setConnectionUploadTimeout, setDisableUploadTimeout, setKeepAliveTimeout, setMaxKeepAliveRequests, setMaxSavePostSize, setNoCompressionStrongETag, setNoCompressionUserAgents, setRestrictedUserAgents, setServer, setSocketBuffer, statusDropsConnection, upgradeDispatch, upgradeDispatch
asyncPostProcess, errorDispatch, getAdapter, getAsyncStateMachine, getEndpoint, getErrorState, getExecutor, getMaxCookieCount, getRequest, getSocketWrapper, isAsync, parseHost, populateHost, resetErrorState, setAdapter, setErrorState, setMaxCookieCount, setSocketWrapper
protected InternalAprInputBuffer inputBuffer
protected InternalAprOutputBuffer outputBuffer
protected AprEndpoint.SendfileData sendfileData
protected String clientCertProvider
X509Certificate
it needs to be
converted before it can be used and this property controls which JSSE
provider is used to perform the conversion. For example it is used with
the AJP connectors, the HTTP APR connector and with the
SSLValve
. If not specified, the
default provider will be used.public Http11AprProcessor(int headerBufferSize, boolean rejectIllegalHeader, AprEndpoint endpoint, int maxTrailerSize, Set<String> allowedTrailerHeaders, int maxExtensionSize, int maxSwallowSize, String relaxedPathChars, String relaxedQueryChars)
protected Log getLog()
getLog
in class AbstractProcessor<Long>
public String getClientCertProvider()
public void setClientCertProvider(String s)
public AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws IOException
event
in interface Processor<Long>
event
in class AbstractProcessor<Long>
IOException
- error during an I/O operationprotected boolean disableKeepAlive()
AbstractHttp11Processor
disableKeepAlive
in class AbstractHttp11Processor<Long>
protected void setRequestLineReadTimeout() throws IOException
AbstractHttp11Processor
setRequestLineReadTimeout
in class AbstractHttp11Processor<Long>
IOException
protected boolean handleIncompleteRequestLineRead()
AbstractHttp11Processor
handleIncompleteRequestLineRead
in class AbstractHttp11Processor<Long>
true
if the processor should break out of the
processing loop, otherwise false
.protected void setSocketTimeout(int timeout)
AbstractHttp11Processor
setSocketTimeout
in class AbstractHttp11Processor<Long>
protected void setCometTimeouts(SocketWrapper<Long> socketWrapper)
AbstractHttp11Processor
setCometTimeouts
in class AbstractHttp11Processor<Long>
protected boolean breakKeepAliveLoop(SocketWrapper<Long> socketWrapper)
AbstractHttp11Processor
breakKeepAliveLoop
in class AbstractHttp11Processor<Long>
protected void resetTimeouts()
AbstractHttp11Processor
resetTimeouts
in class AbstractHttp11Processor<Long>
public void recycleInternal()
recycleInternal
in class AbstractHttp11Processor<Long>
public void setSslSupport(SSLSupport sslSupport)
public void actionInternal(ActionCode actionCode, Object param)
actionInternal
in class AbstractHttp11Processor<Long>
actionCode
- Type of the actionparam
- Action parameterprotected void prepareRequestInternal()
AbstractHttp11Processor
prepareRequestInternal
in class AbstractHttp11Processor<Long>
protected boolean prepareSendfile(OutputFilter[] outputFilters)
prepareSendfile
in class AbstractHttp11Processor<Long>
protected AbstractInputBuffer<Long> getInputBuffer()
AbstractHttp11Processor
getInputBuffer
in class AbstractHttp11Processor<Long>
protected AbstractOutputBuffer<Long> getOutputBuffer()
AbstractHttp11Processor
getOutputBuffer
in class AbstractHttp11Processor<Long>
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.