public class Http11NioProcessor extends AbstractHttp11Processor<NioChannel>
Modifier and Type | Field and Description |
---|---|
protected NioEndpoint.SendfileData |
sendfileData
Sendfile data.
|
protected SSLSupport |
sslSupport
SSL information.
|
comet, compressableMimeTypes, compressionLevel, compressionMinSize, connectionUploadTimeout, contentDelimitation, disableUploadTimeout, expectation, http09, http11, httpParser, inputBuffer, keepAlive, keepAliveTimeout, keptAlive, maxKeepAliveRequests, maxSavePostSize, noCompressionUserAgents, openSocket, outputBuffer, readComplete, restrictedUserAgents, sendfileInProgress, server, sm, upgradeToken
adapter, asyncStateMachine, endpoint, hostNameC, request, response, socketWrapper, userDataHelper
Constructor and Description |
---|
Http11NioProcessor(int maxHttpHeaderSize,
boolean rejectIllegalHeaderName,
NioEndpoint endpoint,
int maxTrailerSize,
java.util.Set<java.lang.String> allowedTrailerHeaders,
int maxExtensionSize,
int maxSwallowSize,
java.lang.String relaxedPathChars,
java.lang.String relaxedQueryChars) |
Modifier and Type | Method and Description |
---|---|
void |
actionInternal(ActionCode actionCode,
java.lang.Object param)
Send an action to the connector.
|
protected boolean |
breakKeepAliveLoop(SocketWrapper<NioChannel> 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.
|
protected AbstractInputBuffer<NioChannel> |
getInputBuffer()
Exposes input buffer to super class to allow better code re-use.
|
protected Log |
getLog() |
protected AbstractOutputBuffer<NioChannel> |
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 |
registerForEvent(boolean read,
boolean write)
Register the socket for the specified events.
|
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<NioChannel> 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)
Set the SSL information for this HTTP connection.
|
action, addCompressableMimeType, addCompressibleMimeType, asyncDispatch, endRequest, findBytes, getAllowHostHeaderMismatch, getCompression, getConnectionUploadTimeout, getDisableUploadTimeout, getKeepAliveTimeout, getLeftoverInput, getMaxKeepAliveRequests, getMaxSavePostSize, getServer, getSocketBuffer, getUpgradeToken, initializeFilters, isComet, isUpgrade, populateHost, prepareRequest, process, recycle, setAllowHostHeaderMismatch, setCompressableMimeTypes, setCompressableMimeTypes, setCompressibleMimeTypes, setCompressibleMimeTypes, setCompression, setCompressionMinSize, setConnectionUploadTimeout, setDisableUploadTimeout, setKeepAliveTimeout, setMaxKeepAliveRequests, setMaxSavePostSize, setNoCompressionUserAgents, setRestrictedUserAgents, setServer, setSocketBuffer, statusDropsConnection, upgradeDispatch
asyncPostProcess, errorDispatch, getAdapter, getEndpoint, getErrorState, getExecutor, getMaxCookieCount, getRequest, getSocketWrapper, isAsync, parseHost, resetErrorState, setAdapter, setErrorState, setMaxCookieCount, setSocketWrapper
protected SSLSupport sslSupport
protected NioEndpoint.SendfileData sendfileData
public Http11NioProcessor(int maxHttpHeaderSize, boolean rejectIllegalHeaderName, NioEndpoint endpoint, int maxTrailerSize, java.util.Set<java.lang.String> allowedTrailerHeaders, int maxExtensionSize, int maxSwallowSize, java.lang.String relaxedPathChars, java.lang.String relaxedQueryChars)
protected Log getLog()
getLog
in class AbstractProcessor<NioChannel>
public AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws java.io.IOException
event
in interface Processor<NioChannel>
event
in class AbstractProcessor<NioChannel>
java.io.IOException
- error during an I/O operationprotected void registerForEvent(boolean read, boolean write)
AbstractProcessor
registerForEvent
in class AbstractProcessor<NioChannel>
read
- Register the socket for read eventswrite
- Register the socket for write eventsprotected void resetTimeouts()
AbstractHttp11Processor
resetTimeouts
in class AbstractHttp11Processor<NioChannel>
protected boolean disableKeepAlive()
AbstractHttp11Processor
disableKeepAlive
in class AbstractHttp11Processor<NioChannel>
protected void setRequestLineReadTimeout() throws java.io.IOException
AbstractHttp11Processor
setRequestLineReadTimeout
in class AbstractHttp11Processor<NioChannel>
java.io.IOException
protected boolean handleIncompleteRequestLineRead()
AbstractHttp11Processor
handleIncompleteRequestLineRead
in class AbstractHttp11Processor<NioChannel>
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<NioChannel>
java.io.IOException
protected void setCometTimeouts(SocketWrapper<NioChannel> socketWrapper)
AbstractHttp11Processor
setCometTimeouts
in class AbstractHttp11Processor<NioChannel>
protected boolean breakKeepAliveLoop(SocketWrapper<NioChannel> socketWrapper)
AbstractHttp11Processor
breakKeepAliveLoop
in class AbstractHttp11Processor<NioChannel>
public void recycleInternal()
recycleInternal
in class AbstractHttp11Processor<NioChannel>
public void actionInternal(ActionCode actionCode, java.lang.Object param)
actionInternal
in class AbstractHttp11Processor<NioChannel>
actionCode
- Type of the actionparam
- Action parameterprotected void prepareRequestInternal()
AbstractHttp11Processor
prepareRequestInternal
in class AbstractHttp11Processor<NioChannel>
protected boolean prepareSendfile(OutputFilter[] outputFilters)
prepareSendfile
in class AbstractHttp11Processor<NioChannel>
protected AbstractInputBuffer<NioChannel> getInputBuffer()
AbstractHttp11Processor
getInputBuffer
in class AbstractHttp11Processor<NioChannel>
protected AbstractOutputBuffer<NioChannel> getOutputBuffer()
AbstractHttp11Processor
getOutputBuffer
in class AbstractHttp11Processor<NioChannel>
public void setSslSupport(SSLSupport sslSupport)
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.