public class Http11Processor extends AbstractHttp11Processor<Socket>
| Modifier and Type | Field and Description |
|---|---|
protected InternalInputBuffer |
inputBuffer
Input.
|
protected InternalOutputBuffer |
outputBuffer
Output.
|
protected SSLSupport |
sslSupport
SSL information.
|
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, upgradeInboundadapter, asyncStateMachine, endpoint, hostNameC, request, response, socketWrapper, userDataHelper| Constructor and Description |
|---|
Http11Processor(int headerBufferSize,
boolean rejectIllegalHeader,
JIoEndpoint 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<Socket> 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 in-progress Comet requests.
|
int |
getDisableKeepAlivePercentage() |
protected AbstractInputBuffer<Socket> |
getInputBuffer()
Exposes input buffer to super class to allow better code re-use.
|
protected Log |
getLog() |
protected AbstractOutputBuffer<Socket> |
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) |
protected 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.
|
protected void |
setCometTimeouts(SocketWrapper<Socket> socketWrapper)
Provides a mechanism for those connectors (currently only NIO) that need
that need to set comet timeouts.
|
void |
setDisableKeepAlivePercentage(int disableKeepAlivePercentage) |
protected void |
setRequestLineReadTimeout()
Configures the timeout to be used for reading the request line.
|
void |
setSocketBuffer(int socketBuffer)
Set the socket buffer flag.
|
protected void |
setSocketTimeout(int timeout)
Set the socket timeout.
|
void |
setSslSupport(SSLSupport sslSupport)
Set the SSL information for this HTTP connection.
|
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, statusDropsConnection, upgradeDispatch, upgradeDispatchasyncPostProcess, errorDispatch, getAdapter, getAsyncStateMachine, getEndpoint, getErrorState, getExecutor, getMaxCookieCount, getRequest, getSocketWrapper, isAsync, parseHost, populateHost, resetErrorState, setAdapter, setErrorState, setMaxCookieCount, setSocketWrapperprotected InternalInputBuffer inputBuffer
protected InternalOutputBuffer outputBuffer
protected SSLSupport sslSupport
public Http11Processor(int headerBufferSize,
boolean rejectIllegalHeader,
JIoEndpoint endpoint,
int maxTrailerSize,
Set<String> allowedTrailerHeaders,
int maxExtensionSize,
int maxSwallowSize,
String relaxedPathChars,
String relaxedQueryChars)
protected Log getLog()
getLog in class AbstractProcessor<Socket>public void setSslSupport(SSLSupport sslSupport)
public int getDisableKeepAlivePercentage()
public void setDisableKeepAlivePercentage(int disableKeepAlivePercentage)
protected boolean disableKeepAlive()
AbstractHttp11ProcessordisableKeepAlive in class AbstractHttp11Processor<Socket>protected void setRequestLineReadTimeout()
throws IOException
AbstractHttp11ProcessorsetRequestLineReadTimeout in class AbstractHttp11Processor<Socket>IOExceptionprotected boolean handleIncompleteRequestLineRead()
AbstractHttp11ProcessorhandleIncompleteRequestLineRead in class AbstractHttp11Processor<Socket>true if the processor should break out of the
processing loop, otherwise false.protected void setSocketTimeout(int timeout)
throws IOException
AbstractHttp11ProcessorsetSocketTimeout in class AbstractHttp11Processor<Socket>IOExceptionprotected void setCometTimeouts(SocketWrapper<Socket> socketWrapper)
AbstractHttp11ProcessorsetCometTimeouts in class AbstractHttp11Processor<Socket>protected boolean breakKeepAliveLoop(SocketWrapper<Socket> socketWrapper)
AbstractHttp11ProcessorbreakKeepAliveLoop in class AbstractHttp11Processor<Socket>protected void resetTimeouts()
AbstractHttp11ProcessorresetTimeouts in class AbstractHttp11Processor<Socket>protected void recycleInternal()
recycleInternal in class AbstractHttp11Processor<Socket>public AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws IOException
AbstractProcessorevent in interface Processor<Socket>event in class AbstractProcessor<Socket>IOExceptionpublic void actionInternal(ActionCode actionCode, Object param)
actionInternal in class AbstractHttp11Processor<Socket>actionCode - Type of the actionparam - Action parameterprotected void prepareRequestInternal()
AbstractHttp11ProcessorprepareRequestInternal in class AbstractHttp11Processor<Socket>protected boolean prepareSendfile(OutputFilter[] outputFilters)
prepareSendfile in class AbstractHttp11Processor<Socket>protected AbstractInputBuffer<Socket> getInputBuffer()
AbstractHttp11ProcessorgetInputBuffer in class AbstractHttp11Processor<Socket>protected AbstractOutputBuffer<Socket> getOutputBuffer()
AbstractHttp11ProcessorgetOutputBuffer in class AbstractHttp11Processor<Socket>public void setSocketBuffer(int socketBuffer)
setSocketBuffer in class AbstractHttp11Processor<Socket>Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.