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, waitactiongetHttpUpgradeHandler, recycle, setSslSupport, upgradeDispatchprotected 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>IOExceptionpublic abstract AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws IOException
event in interface Processor<S>IOExceptionpublic 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.