public class Http11Processor extends AbstractProcessor
Modifier and Type | Field and Description |
---|---|
protected int |
connectionUploadTimeout
Maximum timeout on uploads. 5 minutes as in Apache HTTPD server.
|
protected boolean |
contentDelimitation
Content delimiter for the request (if false, the connection will
be closed at the end of the request).
|
protected boolean |
disableUploadTimeout
Flag to disable setting a different time-out on uploads.
|
protected boolean |
http09
HTTP/0.9 flag.
|
protected boolean |
http11
HTTP/1.1 flag.
|
protected Http11InputBuffer |
inputBuffer
Input.
|
protected boolean |
keepAlive
Keep-alive.
|
protected int |
maxKeepAliveRequests
Maximum number of Keep-Alive requests to honor.
|
protected int |
maxSavePostSize
Max saved post size.
|
protected boolean |
openSocket
Flag used to indicate that the socket should be kept open (e.g. for keep
alive or send file.
|
protected Http11OutputBuffer |
outputBuffer
Output.
|
protected boolean |
readComplete
Flag that indicates if the request headers have been completely read.
|
protected Pattern |
restrictedUserAgents
Regular expression that defines the restricted user agents.
|
protected SendfileDataBase |
sendfileData
Sendfile data.
|
protected UpgradeToken |
upgradeToken
Instance of the new protocol to use after the HTTP connection has been
upgraded.
|
adapter, asyncStateMachine, endpoint, hostNameC, request, response, socketWrapper, sslSupport, userDataHelper
Constructor and Description |
---|
Http11Processor(AbstractHttp11Protocol<?> protocol,
AbstractEndpoint<?> endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
ack() |
protected void |
ack(ContinueResponseTiming continueResponseTiming) |
protected int |
available(boolean doRead) |
protected void |
disableSwallowRequest() |
protected AbstractEndpoint.Handler.SocketState |
dispatchEndRequest()
Perform any necessary clean-up processing if the dispatch resulted in the
completion of processing for the current request.
|
protected void |
doHttpUpgrade(UpgradeToken upgradeToken)
Process an HTTP upgrade.
|
protected void |
finishResponse() |
protected void |
flush() |
protected boolean |
flushBufferedWrite()
Flush any pending writes.
|
String |
getCompression()
Deprecated.
|
int |
getConnectionUploadTimeout()
Get the upload timeout.
|
boolean |
getDisableUploadTimeout()
Get the flag that controls upload time-outs.
|
ByteBuffer |
getLeftoverInput()
Allows retrieving additional input during the upgrade process.
|
protected Log |
getLog() |
int |
getMaxKeepAliveRequests()
Get the maximum number of Keep-Alive requests allowed.
|
int |
getMaxSavePostSize()
Return the maximum size of a POST which will be buffered in SSL mode.
|
UpgradeToken |
getUpgradeToken()
Generate an upgrade token.
|
protected boolean |
isReadyForWrite() |
protected boolean |
isRequestBodyFullyRead() |
boolean |
isUpgrade()
Processors that implement HTTP upgrade must override this method.
|
void |
pause()
Informs the processor that the underlying I/O layer has stopped accepting
new connections.
|
protected void |
populatePort()
Called when a host header is not present or is empty in the request (e.g.
|
protected void |
prepareResponse()
When committing the response, we have to validate the set of headers, as
well as setup the response filters.
|
void |
recycle()
Recycle the processor, ready for the next request which may be on the
same connection or a different connection.
|
protected void |
registerReadInterest() |
AbstractEndpoint.Handler.SocketState |
service(SocketWrapperBase<?> socketWrapper)
Service a 'standard' HTTP request.
|
void |
setCompressableMimeTypes(String[] compressibleMimeTypes)
Deprecated.
|
void |
setCompressibleMimeTypes(String[] compressibleMimeTypes)
Deprecated.
|
void |
setCompression(String compression)
Deprecated.
|
void |
setCompressionMinSize(int compressionMinSize)
Deprecated.
|
void |
setConnectionUploadTimeout(int timeout)
Set the upload timeout.
|
void |
setDisableUploadTimeout(boolean isDisabled)
Set the flag to control whether a separate connection timeout is used
during upload of a request body.
|
void |
setMaxKeepAliveRequests(int mkar)
Set the maximum number of Keep-Alive requests to allow.
|
void |
setMaxSavePostSize(int msps)
Set the maximum size of a POST which will be buffered in SSL mode.
|
void |
setNoCompressionUserAgents(String noCompressionUserAgents)
Deprecated.
|
protected void |
setRequestBody(ByteChunk body) |
void |
setRestrictedUserAgents(String restrictedUserAgents)
Set restricted user agent list (which will downgrade the connector
to HTTP/1.0 mode).
|
void |
setServer(String server)
Deprecated.
|
void |
setServerRemoveAppProvidedValues(boolean serverRemoveAppProvidedValues)
Deprecated.
|
protected void |
setSocketWrapper(SocketWrapperBase<?> socketWrapper)
Set the socket wrapper being used.
|
protected void |
setSwallowResponse() |
protected void |
sslReHandShake()
Processors that can perform a TLS re-handshake (e.g.
|
action, asyncPostProcess, checkAsyncTimeoutGeneration, dispatch, dispatchNonBlockingRead, doPush, executeDispatches, getAdapter, getAsyncTimeout, getConnectionID, getErrorState, getExecutor, getPopulateRequestAttributesFromSocket, getRequest, getSocketWrapper, getStreamID, isAsync, isPushSupported, isReadyForRead, logAccess, parseHost, populateHost, populateRequestAttributeRemoteHost, populateSslRequestAttributes, processSocketEvent, setAdapter, setAsyncTimeout, setErrorState, setSslSupport, timeoutAsync
addDispatch, clearDispatches, getIteratorAndClearDispatches, process
protected final Http11InputBuffer inputBuffer
protected final Http11OutputBuffer outputBuffer
protected volatile boolean keepAlive
protected boolean openSocket
protected boolean readComplete
protected boolean http11
protected boolean http09
protected boolean contentDelimitation
protected Pattern restrictedUserAgents
protected int maxKeepAliveRequests
protected int connectionUploadTimeout
protected boolean disableUploadTimeout
protected int maxSavePostSize
protected UpgradeToken upgradeToken
protected SendfileDataBase sendfileData
public Http11Processor(AbstractHttp11Protocol<?> protocol, AbstractEndpoint<?> endpoint)
@Deprecated public void setCompression(String compression)
AbstractHttp11Protocol.setCompression(String)
compression
- One of on
, force
,
off
or the minimum compression size in
bytes which implies on
@Deprecated public void setCompressionMinSize(int compressionMinSize)
AbstractHttp11Protocol.setCompressionMinSize(int)
compressionMinSize
- The minimum content length required for
compression in bytes@Deprecated public void setNoCompressionUserAgents(String noCompressionUserAgents)
AbstractHttp11Protocol.setNoCompressionUserAgents(String)
Pattern
. e.g.: gorilla|desesplorer|tigrus
.noCompressionUserAgents
- The regular expression for user agent
strings for which compression should not
be applied@Deprecated public void setCompressableMimeTypes(String[] compressibleMimeTypes)
AbstractHttp11Protocol.setCompressibleMimeType(String)
compressibleMimeTypes
- See
setCompressibleMimeTypes(String[])
@Deprecated public void setCompressibleMimeTypes(String[] compressibleMimeTypes)
AbstractHttp11Protocol.setCompressibleMimeType(String)
compressibleMimeTypes
- MIME types for which compression should be
enabled@Deprecated public String getCompression()
AbstractHttp11Protocol.getCompression()
public void setRestrictedUserAgents(String restrictedUserAgents)
Pattern
.restrictedUserAgents
- The regular expression as supported by
Pattern
for the user agents e.g.
"gorilla|desesplorer|tigrus"public void setMaxKeepAliveRequests(int mkar)
mkar
- The new maximum number of Keep-Alive requests allowedpublic int getMaxKeepAliveRequests()
public void setMaxSavePostSize(int msps)
msps
- The maximum size POST body to buffer in bytespublic int getMaxSavePostSize()
public void setDisableUploadTimeout(boolean isDisabled)
isDisabled
- true
if the separate upload timeout should be
disabledpublic boolean getDisableUploadTimeout()
true
if the separate upload timeout is disabledpublic void setConnectionUploadTimeout(int timeout)
timeout
- Upload timeout in millisecondspublic int getConnectionUploadTimeout()
@Deprecated public void setServer(String server)
AbstractHttp11Protocol.setServer(String)
server
- The new value to use for the server header@Deprecated public void setServerRemoveAppProvidedValues(boolean serverRemoveAppProvidedValues)
public AbstractEndpoint.Handler.SocketState service(SocketWrapperBase<?> socketWrapper) throws IOException
AbstractProcessorLight
AbstractProcessorLight.dispatch(SocketEvent)
. Requests may be pipe-lined.service
in class AbstractProcessorLight
socketWrapper
- The connection to processIOException
- If an I/O error occurs during the processing of the
requestprotected final void setSocketWrapper(SocketWrapperBase<?> socketWrapper)
AbstractProcessor
setSocketWrapper
in class AbstractProcessor
socketWrapper
- The socket wrapperprotected final void prepareResponse() throws IOException
prepareResponse
in class AbstractProcessor
IOException
protected void populatePort()
The default implementation is a NO-OP.
This implementation provides the server port from the local port.
populatePort
in class AbstractProcessor
protected boolean flushBufferedWrite() throws IOException
AbstractProcessor
flushBufferedWrite
in class AbstractProcessor
true
if data remains to be flushed at the end of
methodIOException
- If an I/O error occurs while attempting to flush the
dataprotected AbstractEndpoint.Handler.SocketState dispatchEndRequest()
AbstractProcessor
dispatchEndRequest
in class AbstractProcessor
protected Log getLog()
getLog
in class AbstractProcessorLight
protected final void finishResponse() throws IOException
finishResponse
in class AbstractProcessor
IOException
protected final void ack()
ack
in class AbstractProcessor
protected final void ack(ContinueResponseTiming continueResponseTiming)
ack
in class AbstractProcessor
protected final void flush() throws IOException
flush
in class AbstractProcessor
IOException
protected final int available(boolean doRead)
available
in class AbstractProcessor
protected final void setRequestBody(ByteChunk body)
setRequestBody
in class AbstractProcessor
protected final void setSwallowResponse()
setSwallowResponse
in class AbstractProcessor
protected final void disableSwallowRequest()
disableSwallowRequest
in class AbstractProcessor
protected final void sslReHandShake() throws IOException
AbstractProcessor
sslReHandShake
in class AbstractProcessor
IOException
- If authentication is required then there will be I/O
with the client and this exception will be thrown if
that goes wrongprotected final boolean isRequestBodyFullyRead()
isRequestBodyFullyRead
in class AbstractProcessor
protected final void registerReadInterest()
registerReadInterest
in class AbstractProcessor
protected final boolean isReadyForWrite()
isReadyForWrite
in class AbstractProcessor
public UpgradeToken getUpgradeToken()
AbstractProcessor
getUpgradeToken
in interface Processor
getUpgradeToken
in class AbstractProcessor
protected final void doHttpUpgrade(UpgradeToken upgradeToken)
AbstractProcessor
doHttpUpgrade
in class AbstractProcessor
upgradeToken
- Contains all the information necessary for the
Processor to process the upgradepublic ByteBuffer getLeftoverInput()
AbstractProcessor
getLeftoverInput
in interface Processor
getLeftoverInput
in class AbstractProcessor
public boolean isUpgrade()
AbstractProcessor
isUpgrade
in interface Processor
isUpgrade
in class AbstractProcessor
true
if the Processor is currently processing an upgrade
request, otherwise false
public final void recycle()
Processor
recycle
in interface Processor
recycle
in class AbstractProcessor
public void pause()
Processor
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.