public abstract class AbstractProcessor<S> extends java.lang.Object implements ActionHook, Processor<S>
Modifier and Type | Field and Description |
---|---|
protected Adapter |
adapter |
protected AsyncStateMachine<S> |
asyncStateMachine |
protected AbstractEndpoint<S> |
endpoint |
protected Request |
request |
protected Response |
response |
protected static StringManager |
sm |
protected SocketWrapper<S> |
socketWrapper |
Modifier | Constructor and Description |
---|---|
protected |
AbstractProcessor()
Intended for use by the Upgrade sub-classes that have no need to
initialise the request, response, etc.
|
|
AbstractProcessor(AbstractEndpoint<S> endpoint) |
Modifier and Type | Method and Description |
---|---|
abstract AbstractEndpoint.Handler.SocketState |
asyncDispatch(SocketStatus status)
Process in-progress Servlet 3.0 Async requests.
|
AbstractEndpoint.Handler.SocketState |
asyncPostProcess() |
void |
errorDispatch() |
abstract AbstractEndpoint.Handler.SocketState |
event(SocketStatus status)
Process in-progress Comet requests.
|
Adapter |
getAdapter()
Get the associated adapter.
|
protected AbstractEndpoint<S> |
getEndpoint()
The endpoint receiving connections that are handled by this processor.
|
protected ErrorState |
getErrorState() |
java.util.concurrent.Executor |
getExecutor()
Obtain the Executor used by the underlying endpoint.
|
protected abstract Log |
getLog() |
Request |
getRequest()
The request associated with this processor.
|
protected SocketWrapper<S> |
getSocketWrapper()
Get the socket wrapper being used.
|
abstract UpgradeInbound |
getUpgradeInbound()
Deprecated.
Will be removed in Tomcat 8.0.x.
|
boolean |
isAsync() |
abstract boolean |
isComet() |
abstract boolean |
isUpgrade() |
abstract AbstractEndpoint.Handler.SocketState |
process(SocketWrapper<S> socket)
Process HTTP requests.
|
protected void |
resetErrorState() |
void |
setAdapter(Adapter adapter)
Set the associated adapter.
|
protected void |
setErrorState(ErrorState errorState,
java.lang.Throwable t)
Update the current error state to the new error state if the new error
state is more severe than the current error state.
|
protected void |
setSocketWrapper(SocketWrapper<S> socketWrapper)
Set the socket wrapper being used.
|
abstract AbstractEndpoint.Handler.SocketState |
upgradeDispatch()
Processes data received on a connection that has been through an HTTP
upgrade.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
action
getHttpUpgradeHandler, recycle, setSslSupport, upgradeDispatch
protected static final StringManager sm
protected Adapter adapter
protected AsyncStateMachine<S> asyncStateMachine
protected AbstractEndpoint<S> endpoint
protected Request request
protected Response response
protected SocketWrapper<S> socketWrapper
protected AbstractProcessor()
public AbstractProcessor(AbstractEndpoint<S> endpoint)
protected void setErrorState(ErrorState errorState, java.lang.Throwable t)
protected void resetErrorState()
protected ErrorState getErrorState()
protected AbstractEndpoint<S> getEndpoint()
public Request getRequest()
getRequest
in interface Processor<S>
public void setAdapter(Adapter adapter)
adapter
- the new adapterpublic Adapter getAdapter()
protected final void setSocketWrapper(SocketWrapper<S> socketWrapper)
protected final SocketWrapper<S> getSocketWrapper()
public java.util.concurrent.Executor getExecutor()
getExecutor
in interface Processor<S>
public AbstractEndpoint.Handler.SocketState asyncPostProcess()
asyncPostProcess
in interface Processor<S>
public void errorDispatch()
errorDispatch
in interface Processor<S>
public abstract AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> socket) throws java.io.IOException
public abstract AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws java.io.IOException
public abstract AbstractEndpoint.Handler.SocketState asyncDispatch(SocketStatus status)
asyncDispatch
in interface Processor<S>
public abstract AbstractEndpoint.Handler.SocketState upgradeDispatch() throws java.io.IOException
upgradeDispatch
in interface Processor<S>
java.io.IOException
@Deprecated public abstract UpgradeInbound getUpgradeInbound()
getUpgradeInbound
in interface Processor<S>
protected abstract Log getLog()
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.