org.apache.coyote.http11
Class Http11AprProcessor

java.lang.Object
  org.apache.coyote.http11.AbstractHttp11Processor
      org.apache.coyote.http11.Http11AprProcessor

All Implemented Interfaces:

ActionHook, Processor

public class Http11AprProcessor
extends AbstractHttp11Processor

Processes HTTP requests.

Author:

Remy Maucherat

Field Summary

protected boolean	comet Comet used.
protected AprEndpoint	endpoint Associated endpoint.
protected InternalAprInputBuffer	inputBuffer Input.
protected InternalAprOutputBuffer	outputBuffer Output.
protected AprEndpoint.SendfileData	sendfileData Sendfile data.
protected SocketWrapper<Long>	socket Socket associated with the current connection.
protected boolean	ssl SSL enabled ?

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

adapter, asyncStateMachine, compressableMimeTypes, compressionLevel, compressionMinSize, contentDelimitation, disableUploadTimeout, error, expectation, hostNameC, http09, http11, isSecurityEnabled, keepAlive, keepAliveTimeout, localAddr, localName, localPort, maxKeepAliveRequests, maxSavePostSize, noCompressionUserAgents, remoteAddr, remoteHost, remotePort, request, response, restrictedUserAgents, server, sm, socketBuffer, timeout

Constructor Summary

Http11AprProcessor(int headerBufferSize, AprEndpoint endpoint)

Method Summary

void	actionInternal(ActionCode actionCode, Object param) Send an action to the connector.
AbstractEndpoint.Handler.SocketState	asyncDispatch(SocketWrapper<Long> socket, SocketStatus status)
AbstractEndpoint.Handler.SocketState	event(SocketStatus status) Process pipelined HTTP requests using the specified input and output streams.
protected AbstractEndpoint	getEndpoint()
Executor	getExecutor()
protected AbstractInputBuffer	getInputBuffer() Exposes input buffer to super class to allow better code re-use.
protected Log	getLog()
protected AbstractOutputBuffer	getOutputBuffer() Exposes output buffer to super class to allow better code re-use.
void	parseHost(MessageBytes valueMB) Parse host.
protected void	prepareRequest() After reading the request headers, we have to setup the request filters.
protected boolean	prepareSendfile(OutputFilter[] outputFilters)
AbstractEndpoint.Handler.SocketState	process(SocketWrapper<Long> socket) Process pipelined HTTP requests using the specified input and output streams.
void	recycleInternal()

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

action, addCompressableMimeType, addFilter, addInputFilter, addNoCompressionUserAgent, addRestrictedUserAgent, asyncPostProcess, endRequest, findBytes, findCompressableMimeTypes, findRestrictedUserAgents, getAdapter, getCompression, getDisableUploadTimeout, getKeepAliveTimeout, getMaxKeepAliveRequests, getMaxSavePostSize, getRequest, getServer, getSocketBuffer, getTimeout, initializeFilters, isAsync, recycle, setAdapter, setCompressableMimeTypes, setCompressableMimeTypes, setCompression, setCompressionMinSize, setDisableUploadTimeout, setKeepAliveTimeout, setMaxKeepAliveRequests, setMaxSavePostSize, setNoCompressionUserAgents, setNoCompressionUserAgents, setRestrictedUserAgents, setRestrictedUserAgents, setServer, setSocketBuffer, setTimeout, statusDropsConnection

Methods inherited from class java.lang.Object

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

Field Detail

inputBuffer

protected InternalAprInputBuffer inputBuffer

Input.

outputBuffer

protected InternalAprOutputBuffer outputBuffer

Output.

sendfileData

protected AprEndpoint.SendfileData sendfileData

Sendfile data.

comet

protected boolean comet

Comet used.

ssl

protected boolean ssl

SSL enabled ?

socket

protected SocketWrapper<Long> socket

Socket associated with the current connection.

endpoint

protected AprEndpoint endpoint

Associated endpoint.

Constructor Detail

Http11AprProcessor

public Http11AprProcessor(int headerBufferSize,
                          AprEndpoint endpoint)

Method Detail

getLog

protected Log getLog()

Specified by:

getLog in class AbstractHttp11Processor

getEndpoint

protected AbstractEndpoint getEndpoint()

event

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

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

Throws:

IOException - error during an I/O operation

process

public AbstractEndpoint.Handler.SocketState process(SocketWrapper<Long> socket)
                                             throws IOException

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

Throws:

IOException - error during an I/O operation

asyncDispatch

public AbstractEndpoint.Handler.SocketState asyncDispatch(SocketWrapper<Long> socket,
                                                          SocketStatus status)

recycleInternal

public void recycleInternal()

Specified by:

recycleInternal in class AbstractHttp11Processor

actionInternal

public void actionInternal(ActionCode actionCode,
                           Object param)

Send an action to the connector.

Parameters:

actionCode - Type of the action

param - Action parameter

prepareRequest

protected void prepareRequest()

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

parseHost

public void parseHost(MessageBytes valueMB)

Parse host.

prepareSendfile

protected boolean prepareSendfile(OutputFilter[] outputFilters)

getInputBuffer

protected AbstractInputBuffer getInputBuffer()

Description copied from class: AbstractHttp11Processor

Exposes input buffer to super class to allow better code re-use.

Specified by:

getInputBuffer in class AbstractHttp11Processor

Returns:

The input buffer used by the processor.

getOutputBuffer

protected AbstractOutputBuffer getOutputBuffer()

Description copied from class: AbstractHttp11Processor

Exposes output buffer to super class to allow better code re-use.

Specified by:

getOutputBuffer in class AbstractHttp11Processor

Returns:

The output buffer used by the processor.

getExecutor

public Executor getExecutor()

Specified by:

getExecutor in interface Processor

Specified by:

getExecutor in class AbstractHttp11Processor