org.apache.coyote.http11
Class Http11Processor

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

All Implemented Interfaces:

ActionHook, Processor

public class Http11Processor
extends AbstractHttp11Processor

Processes HTTP requests.

Author:

Remy Maucherat, fhanik

Field Summary

protected JIoEndpoint	endpoint Associated endpoint.
protected InternalInputBuffer	inputBuffer Input.
protected InternalOutputBuffer	outputBuffer Output.
protected SocketWrapper<Socket>	socket Socket associated with the current connection.
protected SSLSupport	sslSupport SSL information.

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

Http11Processor(int headerBufferSize, JIoEndpoint endpoint)

Method Summary

void	actionInternal(ActionCode actionCode, Object param) Send an action to the connector.
AbstractEndpoint.Handler.SocketState	asyncDispatch(SocketStatus status)
protected AbstractEndpoint	getEndpoint() Expose the endpoint.
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.
protected 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<Socket> socketWrapper) Process pipelined HTTP requests on the specified socket.
protected void	recycleInternal()
void	setSocketBuffer(int socketBuffer) Set the socket buffer flag.
void	setSSLSupport(SSLSupport sslSupport) Set the SSL information for this HTTP connection.

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, setTimeout, statusDropsConnection

Methods inherited from class java.lang.Object

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

Field Detail

inputBuffer

protected InternalInputBuffer inputBuffer

Input.

outputBuffer

protected InternalOutputBuffer outputBuffer

Output.

sslSupport

protected SSLSupport sslSupport

SSL information.

socket

protected SocketWrapper<Socket> socket

Socket associated with the current connection.

endpoint

protected JIoEndpoint endpoint

Associated endpoint.

Constructor Detail

Http11Processor

public Http11Processor(int headerBufferSize,
                       JIoEndpoint endpoint)

Method Detail

getLog

protected Log getLog()

Specified by:

getLog in class AbstractHttp11Processor

getEndpoint

protected AbstractEndpoint getEndpoint()

Expose the endpoint.

setSSLSupport

public void setSSLSupport(SSLSupport sslSupport)

Set the SSL information for this HTTP connection.

process

public AbstractEndpoint.Handler.SocketState process(SocketWrapper<Socket> socketWrapper)
                                             throws IOException

Process pipelined HTTP requests on the specified socket.

Parameters:

socketWrapper - Socket from which the HTTP requests will be read and the HTTP responses will be written.

Throws:

IOException - error during an I/O operation

asyncDispatch

public AbstractEndpoint.Handler.SocketState asyncDispatch(SocketStatus status)

recycleInternal

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

prepareSendfile

protected boolean prepareSendfile(OutputFilter[] outputFilters)

parseHost

protected void parseHost(MessageBytes valueMB)

Parse host.

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.

setSocketBuffer

public void setSocketBuffer(int socketBuffer)

Set the socket buffer flag.

Overrides:

setSocketBuffer in class AbstractHttp11Processor

getExecutor

public Executor getExecutor()

Specified by:

getExecutor in interface Processor

Specified by:

getExecutor in class AbstractHttp11Processor