public class Http11NioProcessor extends Http11AbstractProcessor
Http11NioProcessor
Processes HTTP requests.
Created on Feb 22, 2012 at 3:00:29 PMModifier and Type | Field and Description |
---|---|
protected NioChannel |
channel
Channel associated with the current connection.
|
protected NioEndpoint |
endpoint
Associated endpoint.
|
protected InternalNioInputBuffer |
inputBuffer
Input.
|
protected InternalNioOutputBuffer |
outputBuffer
Output.
|
protected NioEndpoint.SendfileData |
sendfileData
Sendfile data.
|
adapter, CHUNK_ON_CLOSE, compressableMimeTypes, compressionLevel, compressionMinSize, containerThread, contentDelimitation, disableUploadTimeout, error, event, expectation, hostNameC, http09, http11, keepAlive, keepAliveTimeout, localAddr, localName, localPort, maxKeepAliveRequests, maxSavePostSize, noCompressionUserAgents, processing, readNotifications, remoteAddr, remoteHost, remotePort, request, response, restrictedUserAgents, resumeNotification, server, sslEnabled, sslSupport, timeout, writeNotification
Constructor and Description |
---|
Http11NioProcessor(int headerBufferSize,
NioEndpoint endpoint)
Create a new instance of
Http11NioProcessor |
Modifier and Type | Method and Description |
---|---|
void |
action(ActionCode actionCode,
Object param)
Send an action to the connector.
|
protected void |
addFilter(String className)
Add input or output filter.
|
protected boolean |
addInputFilter(InputFilter[] inputFilters,
String encodingName)
Add an input filter to the current request.
|
protected String[] |
addStringArray(String[] sArray,
String value)
General use method
|
void |
endProcessing()
Mark the end of processing
|
void |
endRequest() |
NioEndpoint.Handler.SocketState |
event(SocketStatus status)
Process pipelined HTTP requests using the specified input and output
streams.
|
protected void |
initializeFilters() |
boolean |
isAvailable() |
boolean |
isProcessing() |
protected void |
parseHost(MessageBytes valueMB)
Parse host.
|
protected void |
prepareRequest()
After reading the request headers, we have to setup the request filters.
|
protected void |
prepareResponse()
When committing the response, we have to validate the set of headers, as
well as setup the response filters.
|
NioEndpoint.Handler.SocketState |
process(NioChannel channel)
Process pipelined HTTP requests using the specified input and output
streams.
|
void |
recycle() |
void |
startProcessing()
Mark the start of processing
|
addCompressableMimeType, addNoCompressionUserAgent, addREArray, addRestrictedUserAgent, findBytes, findCompressableMimeTypes, findRestrictedUserAgents, getAdapter, getCompressableMimeTypes, getCompression, getCompressionLevel, getCompressionMinSize, getDisableUploadTimeout, getHostNameC, getKeepAliveTimeout, getLocalAddr, getLocalName, getLocalPort, getMaxKeepAliveRequests, getMaxSavePostSize, getNoCompressionUserAgents, getReadNotifications, getRemoteAddr, getRemoteHost, getRemotePort, getRequest, getResponse, getRestrictedUserAgents, getResumeNotification, getServer, getSSLEnabled, getSSLSupport, getTimeout, getWriteNotification, isCompressable, isContentDelimitation, isError, isEvent, isExpectation, isHttp09, isHttp11, isKeepAlive, reset, setAdapter, setCompressableMimeTypes, setCompressableMimeTypes, setCompression, setCompressionLevel, setCompressionMinSize, setContentDelimitation, setDisableUploadTimeout, setError, setEvent, setExpectation, setHostNameC, setHttp09, setHttp11, setKeepAlive, setKeepAliveTimeout, setLocalAddr, setLocalName, setLocalPort, setMaxKeepAliveRequests, setMaxSavePostSize, setNoCompressionUserAgents, setNoCompressionUserAgents, setReadNotifications, setRemoteAddr, setRemoteHost, setRemotePort, setRequest, setResponse, setRestrictedUserAgents, setRestrictedUserAgents, setResumeNotification, setServer, setSSLEnabled, setSSLSupport, setTimeout, setWriteNotification, startsWithStringArray, statusDropsConnection
protected InternalNioInputBuffer inputBuffer
protected InternalNioOutputBuffer outputBuffer
protected NioEndpoint.SendfileData sendfileData
protected NioChannel channel
protected NioEndpoint endpoint
public Http11NioProcessor(int headerBufferSize, NioEndpoint endpoint)
Http11NioProcessor
headerBufferSize
- endpoint
- public void startProcessing()
public void endProcessing()
public boolean isAvailable()
public boolean isProcessing()
protected void addFilter(String className)
addFilter
in class Http11AbstractProcessor
className
- class name of the filterprotected String[] addStringArray(String[] sArray, String value)
addStringArray
in class Http11AbstractProcessor
sArray
- the StringArrayvalue
- stringpublic NioEndpoint.Handler.SocketState event(SocketStatus status) throws IOException
Http11AbstractProcessor
event
in class Http11AbstractProcessor
IOException
- error during an I/O operationpublic NioEndpoint.Handler.SocketState process(NioChannel channel) throws IOException
channel
- IOException
- error during an I/O operationpublic void endRequest()
endRequest
in class Http11AbstractProcessor
public void recycle()
recycle
in class Http11AbstractProcessor
public void action(ActionCode actionCode, Object param)
ActionHook
actionCode
- Type of the actionparam
- Action parameterprotected void prepareRequest()
Http11AbstractProcessor
prepareRequest
in class Http11AbstractProcessor
protected void parseHost(MessageBytes valueMB)
protected void prepareResponse()
Http11AbstractProcessor
prepareResponse
in class Http11AbstractProcessor
protected void initializeFilters()
initializeFilters
in class Http11AbstractProcessor
protected boolean addInputFilter(InputFilter[] inputFilters, String encodingName)
Copyright © 2016 JBoss by Red Hat. All rights reserved.