org.apache.coyote.http2

Class StreamProcessor

java.lang.Object

org.apache.coyote.AbstractProcessorLight

org.apache.coyote.AbstractProcessor

org.apache.coyote.http2.StreamProcessor

All Implemented Interfaces:

Runnable, ActionHook, Processor

public class StreamProcessor
extends AbstractProcessor
implements Runnable

Field Summary

Fields inherited from class org.apache.coyote.AbstractProcessor

adapter, asyncStateMachine, endpoint, request, response, socketWrapper

Constructor Summary

Constructors

Constructor and Description
StreamProcessor(Http2UpgradeHandler handler, Stream stream, Adapter adapter, SocketWrapperBase<?> socketWrapper)

Method Summary

Modifier and Type	Method and Description
void	action(ActionCode actionCode, Object param) Send an action to the connector.
protected AbstractEndpoint.Handler.SocketState	dispatchEndRequest() Perform any necessary clean-up processing if the dispatch resulted in the completion of processing for the current request.
protected boolean	flushBufferedWrite() Flush any pending writes.
ByteBuffer	getLeftoverInput() Allows retrieving additional input during the upgrade process
protected Log	getLog()
UpgradeToken	getUpgradeToken()
boolean	isUpgrade()
void	pause() Informs the processor that the underlying I/O layer has stopped accepting new connections.
void	recycle() Recycle the processor, ready for the next request which may be on the same connection or a different connection.
void	run()
AbstractEndpoint.Handler.SocketState	service(SocketWrapperBase<?> socket) Service a 'standard' HTTP request.

Methods inherited from class org.apache.coyote.AbstractProcessor

asyncPostProcess, dispatch, dispatchNonBlockingRead, getAdapter, getAsyncTimeout, getErrorState, getExecutor, getRequest, getSocketWrapper, isAsync, setAdapter, setAsyncTimeout, setErrorState, setSocketWrapper, setSslSupport, timeoutAsync

Methods inherited from class org.apache.coyote.AbstractProcessorLight

addDispatch, clearDispatches, getIteratorAndClearDispatches, process

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamProcessor

public StreamProcessor(Http2UpgradeHandler handler,
                       Stream stream,
                       Adapter adapter,
                       SocketWrapperBase<?> socketWrapper)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

action

public void action(ActionCode actionCode,
                   Object param)

Description copied from interface: ActionHook

Send an action to the connector.

Specified by:

action in interface ActionHook

Parameters:

actionCode - Type of the action

param - Action parameter

recycle

public void recycle()

Description copied from interface: Processor

Recycle the processor, ready for the next request which may be on the same connection or a different connection.

Specified by:

recycle in interface Processor

Overrides:

recycle in class AbstractProcessor

isUpgrade

public boolean isUpgrade()

Specified by:

isUpgrade in interface Processor

getLog

protected Log getLog()

Specified by:

getLog in class AbstractProcessorLight

pause

public void pause()

Description copied from interface: Processor

Informs the processor that the underlying I/O layer has stopped accepting new connections. This is primarily intended to enable processors that use multiplexed connections to prevent further 'streams' being added to an existing multiplexed connection.

Specified by:

pause in interface Processor

service

public AbstractEndpoint.Handler.SocketState service(SocketWrapperBase<?> socket)
                                             throws IOException

Description copied from class: AbstractProcessorLight

Service a 'standard' HTTP request. This method is called for both new requests and for requests that have partially read the HTTP request line or HTTP headers. Once the headers have been fully read this method is not called again until there is a new HTTP request to process. Note that the request type may change during processing which may result in one or more calls to AbstractProcessorLight.dispatch(SocketEvent). Requests may be pipe-lined.

Specified by:

service in class AbstractProcessorLight

Parameters:

socket - The connection to process

Returns:

The state the caller should put the socket in when this method returns

Throws:

IOException - If an I/O error occurs during the processing of the request

flushBufferedWrite

protected boolean flushBufferedWrite()
                              throws IOException

Description copied from class: AbstractProcessor

Flush any pending writes. Used during non-blocking writes to flush any remaining data from a previous incomplete write.

Specified by:

flushBufferedWrite in class AbstractProcessor

Returns:

true if data remains to be flushed at the end of method

Throws:

IOException - If an I/O error occurs while attempting to flush the data

dispatchEndRequest

protected AbstractEndpoint.Handler.SocketState dispatchEndRequest()

Description copied from class: AbstractProcessor

Perform any necessary clean-up processing if the dispatch resulted in the completion of processing for the current request.

Specified by:

dispatchEndRequest in class AbstractProcessor

Returns:

The state to return for the socket once the clean-up for the current request has completed

getUpgradeToken

public UpgradeToken getUpgradeToken()

Specified by:

getUpgradeToken in interface Processor

getLeftoverInput

public ByteBuffer getLeftoverInput()

Description copied from interface: Processor

Allows retrieving additional input during the upgrade process

Specified by:

getLeftoverInput in interface Processor

Returns:

leftover bytes