public abstract class AbstractHttp11Processor<S> extends AbstractProcessor<S>
Modifier and Type | Field and Description |
---|---|
protected boolean |
comet
Comet used.
|
protected java.lang.String[] |
compressableMimeTypes
List of MIMES which could be gzipped
Note: This is not spelled correctly but can't be changed without breaking
compatibility
|
protected int |
compressionLevel
Allowed compression level.
|
protected int |
compressionMinSize
Minimum content size to make compression.
|
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 |
expectation
Is there an expectation ?
|
protected boolean |
http09
HTTP/0.9 flag.
|
protected boolean |
http11
HTTP/1.1 flag.
|
protected HttpParser |
httpParser |
protected AbstractInputBuffer<S> |
inputBuffer
Input.
|
protected boolean |
keepAlive
Keep-alive.
|
protected int |
keepAliveTimeout
The number of seconds Tomcat will wait for a subsequent request
before closing the connection.
|
protected boolean |
keptAlive
Flag used to indicate that the socket should treat the next request
processed like a keep-alive connection - i.e. one where there may not be
any data to process.
|
protected int |
maxKeepAliveRequests
Maximum number of Keep-Alive requests to honor.
|
protected int |
maxSavePostSize
Max saved post size.
|
protected java.util.regex.Pattern |
noCompressionUserAgents
Regular expression that defines the user agents to not use gzip with
|
protected boolean |
openSocket
Flag used to indicate that the socket should be kept open (e.g. for keep
alive or send file.
|
protected AbstractOutputBuffer<S> |
outputBuffer
Output.
|
protected boolean |
readComplete
Flag that indicates if the request headers have been completely read.
|
protected java.util.regex.Pattern |
restrictedUserAgents
Regular expression that defines the restricted user agents.
|
protected boolean |
sendfileInProgress
Flag that indicates that send file processing is in progress and that the
socket should not be returned to the poller (where a poller is used).
|
protected java.lang.String |
server
Allow a customized the server header for the tin-foil hat folks.
|
protected static StringManager |
sm
The string manager for this package.
|
protected UpgradeToken |
upgradeToken
Instance of the new protocol to use after the HTTP connection has been
upgraded.
|
adapter, asyncStateMachine, endpoint, hostNameC, request, response, socketWrapper, userDataHelper
Constructor and Description |
---|
AbstractHttp11Processor(AbstractEndpoint<S> endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
action(ActionCode actionCode,
java.lang.Object param)
Send an action to the connector.
|
protected abstract void |
actionInternal(ActionCode actionCode,
java.lang.Object param) |
void |
addCompressableMimeType(java.lang.String mimeType)
Deprecated.
|
void |
addCompressibleMimeType(java.lang.String mimeType)
Add a mime-type which will be compressible
The mime-type String will be exactly matched
in the response mime-type header .
|
AbstractEndpoint.Handler.SocketState |
asyncDispatch(SocketStatus status)
Process in-progress Servlet 3.0 Async requests.
|
protected abstract boolean |
breakKeepAliveLoop(SocketWrapper<S> 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 abstract boolean |
disableKeepAlive()
Processors (currently only HTTP BIO) may elect to disable HTTP keep-alive
in some circumstances.
|
void |
endRequest() |
protected int |
findBytes(ByteChunk bc,
byte[] b)
Specialized utility method: find a sequence of lower case bytes inside
a ByteChunk.
|
boolean |
getAllowHostHeaderMismatch()
Will Tomcat accept an HTTP 1.1 request where the host header does not
agree with the host specified (if any) in the request line?
|
java.lang.String |
getCompression()
Return compression level.
|
int |
getConnectionUploadTimeout()
Get the upload timeout.
|
boolean |
getDisableUploadTimeout()
Get the flag that controls upload time-outs.
|
protected abstract AbstractInputBuffer<S> |
getInputBuffer()
Exposes input buffer to super class to allow better code re-use.
|
int |
getKeepAliveTimeout()
Return the number Keep-Alive timeout.
|
java.nio.ByteBuffer |
getLeftoverInput()
Allows retrieving additional input during the upgrade process
|
int |
getMaxKeepAliveRequests()
Return the number of Keep-Alive requests that we will honor.
|
int |
getMaxSavePostSize()
Return the maximum size of a POST which will be buffered in SSL mode.
|
protected abstract AbstractOutputBuffer<S> |
getOutputBuffer()
Exposes output buffer to super class to allow better code re-use.
|
java.lang.String |
getServer()
Get the server header name.
|
int |
getSocketBuffer()
Get the socket buffer flag.
|
UpgradeToken |
getUpgradeToken() |
protected abstract boolean |
handleIncompleteRequestLineRead()
Defines how a connector handles an incomplete request line read.
|
protected void |
initializeFilters(int maxTrailerSize,
java.util.Set<java.lang.String> allowedTrailerHeaders,
int maxExtensionSize,
int maxSwallowSize)
Initialize standard input and output filters.
|
boolean |
isComet() |
boolean |
isUpgrade() |
protected void |
populateHost()
Called when a host name is not present in the request (e.g.
|
protected void |
prepareRequest()
After reading the request headers, we have to setup the request filters.
|
protected abstract void |
prepareRequestInternal()
Connector implementation specific request preparation.
|
protected abstract boolean |
prepareSendfile(OutputFilter[] outputFilters) |
AbstractEndpoint.Handler.SocketState |
process(SocketWrapper<S> socketWrapper)
Process pipelined HTTP requests using the specified input and output
streams.
|
void |
recycle(boolean isSocketClosing) |
protected abstract void |
recycleInternal() |
protected abstract 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 |
setAllowHostHeaderMismatch(boolean allowHostHeaderMismatch)
Will Tomcat accept an HTTP 1.1 request where the host header does not
agree with the host specified (if any) in the request line?
|
protected abstract void |
setCometTimeouts(SocketWrapper<S> socketWrapper)
Provides a mechanism for those connectors (currently only NIO) that need
that need to set comet timeouts.
|
void |
setCompressableMimeTypes(java.lang.String compressibleMimeTypes)
Deprecated.
|
void |
setCompressableMimeTypes(java.lang.String[] compressibleMimeTypes)
Deprecated.
|
void |
setCompressibleMimeTypes(java.lang.String compressibleMimeTypes)
Set compressible mime-type list
List contains users agents separated by ',' :
ie: "text/html,text/xml,text/plain"
|
void |
setCompressibleMimeTypes(java.lang.String[] compressibleMimeTypes)
Set compressible mime-type list (this method is best when used with
a large number of connectors, where it would be better to have all of
them referenced a single array).
|
void |
setCompression(java.lang.String compression)
Set compression level.
|
void |
setCompressionMinSize(int compressionMinSize)
Set Minimum size to trigger compression.
|
void |
setConnectionUploadTimeout(int timeout)
Set the upload timeout.
|
void |
setDisableUploadTimeout(boolean isDisabled)
Set the flag to control upload time-outs.
|
void |
setKeepAliveTimeout(int timeout)
Set the Keep-Alive timeout.
|
void |
setMaxKeepAliveRequests(int mkar)
Set the maximum number of Keep-Alive requests to honor.
|
void |
setMaxSavePostSize(int msps)
Set the maximum size of a POST which will be buffered in SSL mode.
|
void |
setNoCompressionUserAgents(java.lang.String noCompressionUserAgents)
Set no compression user agent pattern.
|
protected abstract void |
setRequestLineReadTimeout()
Configures the timeout to be used for reading the request line.
|
void |
setRestrictedUserAgents(java.lang.String restrictedUserAgents)
Set restricted user agent list (which will downgrade the connector
to HTTP/1.0 mode).
|
void |
setServer(java.lang.String server)
Set the server header name.
|
void |
setSocketBuffer(int socketBuffer)
Set the socket buffer flag.
|
protected abstract void |
setSocketTimeout(int timeout)
Set the socket timeout.
|
protected boolean |
statusDropsConnection(int status)
Determine if we must drop the connection because of the HTTP status
code.
|
AbstractEndpoint.Handler.SocketState |
upgradeDispatch(SocketStatus status)
Processes data received on a connection that has been through an HTTP
upgrade.
|
asyncPostProcess, errorDispatch, event, getAdapter, getEndpoint, getErrorState, getExecutor, getLog, getMaxCookieCount, getRequest, getSocketWrapper, isAsync, parseHost, registerForEvent, resetErrorState, setAdapter, setErrorState, setMaxCookieCount, setSocketWrapper
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setSslSupport
protected static final StringManager sm
protected AbstractInputBuffer<S> inputBuffer
protected AbstractOutputBuffer<S> outputBuffer
protected volatile boolean keepAlive
protected boolean openSocket
protected boolean keptAlive
protected boolean sendfileInProgress
protected boolean readComplete
protected boolean http11
protected boolean http09
protected boolean contentDelimitation
protected boolean expectation
protected boolean comet
protected java.util.regex.Pattern restrictedUserAgents
protected int maxKeepAliveRequests
protected int keepAliveTimeout
protected int connectionUploadTimeout
protected boolean disableUploadTimeout
protected int compressionLevel
protected int compressionMinSize
protected int maxSavePostSize
protected java.util.regex.Pattern noCompressionUserAgents
protected java.lang.String[] compressableMimeTypes
protected java.lang.String server
protected UpgradeToken upgradeToken
protected HttpParser httpParser
public AbstractHttp11Processor(AbstractEndpoint<S> endpoint)
public boolean getAllowHostHeaderMismatch()
true
if Tomcat will allow such requests, otherwise
false
public void setAllowHostHeaderMismatch(boolean allowHostHeaderMismatch)
allowHostHeaderMismatch
- true
to allow such requests,
false
to reject them with a 400public void setCompression(java.lang.String compression)
public void setCompressionMinSize(int compressionMinSize)
public void setNoCompressionUserAgents(java.lang.String noCompressionUserAgents)
Pattern
.
ie: "gorilla|desesplorer|tigrus"@Deprecated public void addCompressableMimeType(java.lang.String mimeType)
addCompressibleMimeType(String)
@Deprecated public void setCompressableMimeTypes(java.lang.String[] compressibleMimeTypes)
setCompressibleMimeTypes(String[])
@Deprecated public void setCompressableMimeTypes(java.lang.String compressibleMimeTypes)
setCompressibleMimeTypes(String)
public void addCompressibleMimeType(java.lang.String mimeType)
mimeType
- mime-type stringpublic void setCompressibleMimeTypes(java.lang.String[] compressibleMimeTypes)
public void setCompressibleMimeTypes(java.lang.String compressibleMimeTypes)
public java.lang.String getCompression()
public void setRestrictedUserAgents(java.lang.String restrictedUserAgents)
Pattern
.
ie: "gorilla|desesplorer|tigrus"public void setMaxKeepAliveRequests(int mkar)
public int getMaxKeepAliveRequests()
public void setKeepAliveTimeout(int timeout)
public int getKeepAliveTimeout()
public void setMaxSavePostSize(int msps)
public int getMaxSavePostSize()
public void setDisableUploadTimeout(boolean isDisabled)
public boolean getDisableUploadTimeout()
public void setSocketBuffer(int socketBuffer)
public int getSocketBuffer()
public void setConnectionUploadTimeout(int timeout)
public int getConnectionUploadTimeout()
public void setServer(java.lang.String server)
public java.lang.String getServer()
protected int findBytes(ByteChunk bc, byte[] b)
protected boolean statusDropsConnection(int status)
protected abstract AbstractInputBuffer<S> getInputBuffer()
protected abstract AbstractOutputBuffer<S> getOutputBuffer()
protected void initializeFilters(int maxTrailerSize, java.util.Set<java.lang.String> allowedTrailerHeaders, int maxExtensionSize, int maxSwallowSize)
public final void action(ActionCode actionCode, java.lang.Object param)
actionCode
- Type of the actionparam
- Action parameterprotected abstract void actionInternal(ActionCode actionCode, java.lang.Object param)
protected abstract boolean disableKeepAlive()
protected abstract void setRequestLineReadTimeout() throws java.io.IOException
java.io.IOException
protected abstract boolean handleIncompleteRequestLineRead()
true
if the processor should break out of the
processing loop, otherwise false
.protected abstract void setSocketTimeout(int timeout) throws java.io.IOException
java.io.IOException
public AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> socketWrapper) throws java.io.IOException
protected void prepareRequest()
protected abstract void prepareRequestInternal()
protected abstract boolean prepareSendfile(OutputFilter[] outputFilters)
protected void populateHost()
The default implementation is a NO-OP.
This implementation provides the server name from the default host and the server port from the local port.
populateHost
in class AbstractProcessor<S>
public AbstractEndpoint.Handler.SocketState asyncDispatch(SocketStatus status)
AbstractProcessor
asyncDispatch
in interface Processor<S>
asyncDispatch
in class AbstractProcessor<S>
public boolean isComet()
public boolean isUpgrade()
public AbstractEndpoint.Handler.SocketState upgradeDispatch(SocketStatus status) throws java.io.IOException
AbstractProcessor
upgradeDispatch
in interface Processor<S>
upgradeDispatch
in class AbstractProcessor<S>
java.io.IOException
public UpgradeToken getUpgradeToken()
getUpgradeToken
in interface Processor<S>
getUpgradeToken
in class AbstractProcessor<S>
protected abstract void resetTimeouts()
protected abstract void setCometTimeouts(SocketWrapper<S> socketWrapper)
public void endRequest()
protected abstract boolean breakKeepAliveLoop(SocketWrapper<S> socketWrapper)
public final void recycle(boolean isSocketClosing)
protected abstract void recycleInternal()
public java.nio.ByteBuffer getLeftoverInput()
Processor
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.