org.apache.coyote.http11

Class Http11NioProcessor

java.lang.Object

org.apache.coyote.http11.Http11AbstractProcessor

org.apache.coyote.http11.Http11NioProcessor

All Implemented Interfaces:

ActionHook

public class Http11NioProcessor
extends Http11AbstractProcessor

Http11NioProcessor

Processes HTTP requests.

Created on Feb 22, 2012 at 3:00:29 PM

Author:

Nabil Benothman

Field Summary

Fields

Modifier 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.

Fields inherited from class org.apache.coyote.http11.Http11AbstractProcessor

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 Summary

Constructors

Constructor and Description
Http11NioProcessor(int headerBufferSize, NioEndpoint endpoint) Create a new instance of Http11NioProcessor

Method Summary

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()
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

Methods inherited from class org.apache.coyote.http11.Http11AbstractProcessor

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inputBuffer

protected InternalNioInputBuffer inputBuffer

Input.

outputBuffer

protected InternalNioOutputBuffer outputBuffer

Output.

sendfileData

protected NioEndpoint.SendfileData sendfileData

Sendfile data.

channel

protected NioChannel channel

Channel associated with the current connection.

endpoint

protected NioEndpoint endpoint

Associated endpoint.

Constructor Detail

Http11NioProcessor

public Http11NioProcessor(int headerBufferSize,
                          NioEndpoint endpoint)

Create a new instance of Http11NioProcessor

Parameters:

headerBufferSize -

endpoint -

Method Detail

startProcessing

public void startProcessing()

Mark the start of processing

endProcessing

public void endProcessing()

Mark the end of processing

isAvailable

public boolean isAvailable()

Returns:

true if the input buffer is available

addFilter

protected void addFilter(String className)

Add input or output filter.

Specified by:

addFilter in class Http11AbstractProcessor

Parameters:

className - class name of the filter

addStringArray

protected String[] addStringArray(String[] sArray,
                                  String value)

General use method

Overrides:

addStringArray in class Http11AbstractProcessor

Parameters:

sArray - the StringArray

value - string

event

public NioEndpoint.Handler.SocketState event(SocketStatus status)
                                      throws IOException

Description copied from class: Http11AbstractProcessor

Process pipelined HTTP requests using the specified input and output streams.

Specified by:

event in class Http11AbstractProcessor

Returns:

a SocketState

Throws:

IOException - error during an I/O operation

process

public NioEndpoint.Handler.SocketState process(NioChannel channel)
                                        throws IOException

Process pipelined HTTP requests using the specified input and output streams.

Parameters:

channel -

Returns:

the process state

Throws:

IOException - error during an I/O operation

endRequest

public void endRequest()

Specified by:

endRequest in class Http11AbstractProcessor

recycle

public void recycle()

Overrides:

recycle in class Http11AbstractProcessor

action

public void action(ActionCode actionCode,
                   Object param)

Description copied from interface: ActionHook

Send an action to the connector.

Parameters:

actionCode - Type of the action

param - Action parameter

prepareRequest

protected void prepareRequest()

Description copied from class: Http11AbstractProcessor

After reading the request headers, we have to setup the request filters.

Specified by:

prepareRequest in class Http11AbstractProcessor

parseHost

protected void parseHost(MessageBytes valueMB)

Parse host.

prepareResponse

protected void prepareResponse()

Description copied from class: Http11AbstractProcessor

When committing the response, we have to validate the set of headers, as well as setup the response filters.

Specified by:

prepareResponse in class Http11AbstractProcessor

initializeFilters

protected void initializeFilters()

Specified by:

initializeFilters in class Http11AbstractProcessor

addInputFilter

protected boolean addInputFilter(InputFilter[] inputFilters,
                                 String encodingName)

Add an input filter to the current request.

Returns:

false if the encoding was not found (which would mean it is unsupported)