public abstract class AbstractProcessor<S> extends Object implements ActionHook, Processor<S>
Modifier and Type | Field and Description |
---|---|
protected Adapter |
adapter |
protected AsyncStateMachine<S> |
asyncStateMachine |
protected AbstractEndpoint<S> |
endpoint |
protected char[] |
hostNameC |
protected Request |
request |
protected Response |
response |
protected static StringManager |
sm |
protected SocketWrapper<S> |
socketWrapper |
protected UserDataHelper |
userDataHelper |
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.
|
AsyncStateMachine<S> |
getAsyncStateMachine() |
protected AbstractEndpoint<S> |
getEndpoint() |
protected ErrorState |
getErrorState() |
Executor |
getExecutor() |
protected abstract Log |
getLog() |
int |
getMaxCookieCount() |
Request |
getRequest()
The request associated with this processor.
|
protected SocketWrapper<S> |
getSocketWrapper() |
abstract UpgradeInbound |
getUpgradeInbound()
Deprecated.
Will be removed in Tomcat 8.0.x.
|
boolean |
isAsync() |
abstract boolean |
isComet() |
abstract boolean |
isUpgrade() |
protected void |
parseHost(MessageBytes valueMB) |
protected void |
populateHost()
Called when a host header is not present in the request (e.g.
|
protected void |
populatePort()
Called when a host header is not present or is empty in the request (e.g.
|
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,
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.
|
void |
setMaxCookieCount(int maxCookieCount) |
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 char[] hostNameC
protected Adapter adapter
protected AsyncStateMachine<S> asyncStateMachine
protected AbstractEndpoint<S> endpoint
protected Request request
protected Response response
protected SocketWrapper<S> socketWrapper
protected final UserDataHelper userDataHelper
protected AbstractProcessor()
public AbstractProcessor(AbstractEndpoint<S> endpoint)
protected void setErrorState(ErrorState errorState, Throwable t)
errorState
- The error status detailst
- The error which occurredprotected 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)
socketWrapper
- The socket wrapperprotected final SocketWrapper<S> getSocketWrapper()
public 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>
protected void parseHost(MessageBytes valueMB)
protected void populateHost()
The default implementation is a NO-OP.
protected void populatePort()
The default implementation is a NO-OP.
public abstract AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> socket) throws IOException
process
in interface Processor<S>
IOException
public abstract AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws IOException
event
in interface Processor<S>
IOException
public abstract AbstractEndpoint.Handler.SocketState asyncDispatch(SocketStatus status)
asyncDispatch
in interface Processor<S>
public abstract AbstractEndpoint.Handler.SocketState upgradeDispatch() throws IOException
upgradeDispatch
in interface Processor<S>
IOException
- An IO error occurredpublic int getMaxCookieCount()
public void setMaxCookieCount(int maxCookieCount)
@Deprecated public abstract UpgradeInbound getUpgradeInbound()
getUpgradeInbound
in interface Processor<S>
protected abstract Log getLog()
public final AsyncStateMachine<S> getAsyncStateMachine()
getAsyncStateMachine
in interface Processor<S>
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.