public class Http11Processor extends AbstractHttp11Processor<java.net.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, hostNameC, http09, http11, httpUpgradeHandler, keepAlive, keepAliveTimeout, keptAlive, localAddr, localName, localPort, maxKeepAliveRequests, maxSavePostSize, noCompressionUserAgents, openSocket, readComplete, remoteAddr, remoteHost, remotePort, restrictedUserAgents, sendfileInProgress, server, sm, socketBuffer, upgradeInbound
adapter, asyncStateMachine, endpoint, request, response, socketWrapper
Constructor and Description |
---|
Http11Processor(int headerBufferSize,
JIoEndpoint endpoint,
int maxTrailerSize,
java.util.Set<java.lang.String> allowedTrailerHeaders,
int maxExtensionSize,
int maxSwallowSize) |
Modifier and Type | Method and Description |
---|---|
void |
actionInternal(ActionCode actionCode,
java.lang.Object param)
Send an action to the connector.
|
protected boolean |
breakKeepAliveLoop(SocketWrapper<java.net.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<java.net.Socket> |
getInputBuffer()
Exposes input buffer to super class to allow better code re-use.
|
protected Log |
getLog() |
protected AbstractOutputBuffer<java.net.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<java.net.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, asyncDispatch, endRequest, findBytes, getCompression, getConnectionUploadTimeout, getDisableUploadTimeout, getHttpUpgradeHandler, getKeepAliveTimeout, getMaxKeepAliveRequests, getMaxSavePostSize, getServer, getSocketBuffer, getUpgradeInbound, initializeFilters, isComet, isUpgrade, parseHost, prepareRequest, process, recycle, setCompressableMimeTypes, setCompressableMimeTypes, setCompression, setCompressionMinSize, setConnectionUploadTimeout, setDisableUploadTimeout, setKeepAliveTimeout, setMaxKeepAliveRequests, setMaxSavePostSize, setNoCompressionUserAgents, setRestrictedUserAgents, setServer, statusDropsConnection, upgradeDispatch, upgradeDispatch
asyncPostProcess, errorDispatch, getAdapter, getEndpoint, getErrorState, getExecutor, getRequest, getSocketWrapper, isAsync, resetErrorState, setAdapter, setErrorState, setSocketWrapper
protected InternalInputBuffer inputBuffer
protected InternalOutputBuffer outputBuffer
protected SSLSupport sslSupport
public Http11Processor(int headerBufferSize, JIoEndpoint endpoint, int maxTrailerSize, java.util.Set<java.lang.String> allowedTrailerHeaders, int maxExtensionSize, int maxSwallowSize)
protected Log getLog()
getLog
in class AbstractProcessor<java.net.Socket>
public void setSslSupport(SSLSupport sslSupport)
public int getDisableKeepAlivePercentage()
public void setDisableKeepAlivePercentage(int disableKeepAlivePercentage)
protected boolean disableKeepAlive()
AbstractHttp11Processor
disableKeepAlive
in class AbstractHttp11Processor<java.net.Socket>
protected void setRequestLineReadTimeout() throws java.io.IOException
AbstractHttp11Processor
setRequestLineReadTimeout
in class AbstractHttp11Processor<java.net.Socket>
java.io.IOException
protected boolean handleIncompleteRequestLineRead()
AbstractHttp11Processor
handleIncompleteRequestLineRead
in class AbstractHttp11Processor<java.net.Socket>
true
if the processor should break out of the
processing loop, otherwise false
.protected void setSocketTimeout(int timeout) throws java.io.IOException
AbstractHttp11Processor
setSocketTimeout
in class AbstractHttp11Processor<java.net.Socket>
java.io.IOException
protected void setCometTimeouts(SocketWrapper<java.net.Socket> socketWrapper)
AbstractHttp11Processor
setCometTimeouts
in class AbstractHttp11Processor<java.net.Socket>
protected boolean breakKeepAliveLoop(SocketWrapper<java.net.Socket> socketWrapper)
AbstractHttp11Processor
breakKeepAliveLoop
in class AbstractHttp11Processor<java.net.Socket>
protected void resetTimeouts()
AbstractHttp11Processor
resetTimeouts
in class AbstractHttp11Processor<java.net.Socket>
protected void recycleInternal()
recycleInternal
in class AbstractHttp11Processor<java.net.Socket>
public AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws java.io.IOException
AbstractProcessor
event
in interface Processor<java.net.Socket>
event
in class AbstractProcessor<java.net.Socket>
java.io.IOException
public void actionInternal(ActionCode actionCode, java.lang.Object param)
actionInternal
in class AbstractHttp11Processor<java.net.Socket>
actionCode
- Type of the actionparam
- Action parameterprotected void prepareRequestInternal()
AbstractHttp11Processor
prepareRequestInternal
in class AbstractHttp11Processor<java.net.Socket>
protected boolean prepareSendfile(OutputFilter[] outputFilters)
prepareSendfile
in class AbstractHttp11Processor<java.net.Socket>
protected AbstractInputBuffer<java.net.Socket> getInputBuffer()
AbstractHttp11Processor
getInputBuffer
in class AbstractHttp11Processor<java.net.Socket>
protected AbstractOutputBuffer<java.net.Socket> getOutputBuffer()
AbstractHttp11Processor
getOutputBuffer
in class AbstractHttp11Processor<java.net.Socket>
public void setSocketBuffer(int socketBuffer)
setSocketBuffer
in class AbstractHttp11Processor<java.net.Socket>
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.