org.eclipse.jetty.server

Class HttpChannelState

java.lang.Object

org.eclipse.jetty.server.HttpChannelState

All Implemented Interfaces:

AsyncContext

public class HttpChannelState
extends Object
implements AsyncContext

Implementation of AsyncContext interface that holds the state of request-response cycle.

STATE	ACTION
	handling()	startAsync()	unhandle()	dispatch()	complete()	completed()
IDLE:	DISPATCHED				COMPLETECALLED??
DISPATCHED:		ASYNCSTARTED	COMPLETING
ASYNCSTARTED:			ASYNCWAIT	REDISPATCHING	COMPLETECALLED
REDISPATCHING:			REDISPATCHED
ASYNCWAIT:				REDISPATCH	COMPLETECALLED
REDISPATCH:	REDISPATCHED
REDISPATCHED:		ASYNCSTARTED	COMPLETING
COMPLETECALLED:	COMPLETING		COMPLETING
COMPLETING:	COMPLETING					COMPLETED
COMPLETED:

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	HttpChannelState.AsyncEventState
class	HttpChannelState.AsyncTimeout
static class	HttpChannelState.State

Field Summary

Fields inherited from interface javax.servlet.AsyncContext

ASYNC_CONTEXT_PATH, ASYNC_PATH_INFO, ASYNC_QUERY_STRING, ASYNC_REQUEST_URI, ASYNC_SERVLET_PATH

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HttpChannelState(HttpChannel<?> channel)

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(AsyncListener listener)
void	addListener(AsyncListener listener, ServletRequest request, ServletResponse response)
void	cancel()
protected void	cancelTimeout()
void	complete()
protected void	completed()
<T extends AsyncListener> T	createListener(Class<T> clazz)
void	dispatch()
void	dispatch(ServletContext context, String path)
void	dispatch(String path)
protected void	error(Throwable th)
protected void	expired()
HttpChannelState.AsyncEventState	getAsyncEventState()
Object	getAttribute(String name)
Request	getBaseRequest()
ContextHandler	getContextHandler()
ServletRequest	getRequest()
ServletResponse	getResponse()
ServletResponse	getServletResponse()
HttpChannelState.State	getState()
String	getStatusString()
long	getTimeout()
protected boolean	handling()
boolean	hasOriginalRequestAndResponse()
boolean	isAsync()
boolean	isDispatched()
boolean	isInitial()
boolean	isSuspended()
protected void	recycle()
void	removeAttribute(String name)
protected void	scheduleDispatch()
protected void	scheduleTimeout()
void	setAttribute(String name, Object attribute)
void	setTimeout(long ms)
void	start(Runnable run)
void	startAsync()
void	startAsync(ServletContext context, ServletRequest request, ServletResponse response)
String	toString()
protected boolean	unhandle() Signal that the HttpConnection has finished handling the request.

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpChannelState

protected HttpChannelState(HttpChannel<?> channel)

Method Detail

getState

public HttpChannelState.State getState()

addListener

public void addListener(AsyncListener listener)

Specified by:

addListener in interface AsyncContext

addListener

public void addListener(AsyncListener listener,
               ServletRequest request,
               ServletResponse response)

Specified by:

addListener in interface AsyncContext

setTimeout

public void setTimeout(long ms)

Specified by:

setTimeout in interface AsyncContext

getTimeout

public long getTimeout()

Specified by:

getTimeout in interface AsyncContext

getAsyncEventState

public HttpChannelState.AsyncEventState getAsyncEventState()

toString

public String toString()

Overrides:

toString in class Object

getStatusString

public String getStatusString()

handling

protected boolean handling()

Returns:

true if the handling of the request should proceed

startAsync

public void startAsync()

startAsync

public void startAsync(ServletContext context,
              ServletRequest request,
              ServletResponse response)

error

protected void error(Throwable th)

unhandle

protected boolean unhandle()

Signal that the HttpConnection has finished handling the request. For blocking connectors, this call may block if the request has been suspended (startAsync called).

Returns:

true if handling is complete, false if the request should be handled again (eg because of a resume that happened before unhandle was called)

dispatch

public void dispatch()

Specified by:

dispatch in interface AsyncContext

isDispatched

public boolean isDispatched()

See Also:

Continuation#isDispatched()

expired

protected void expired()

complete

public void complete()

Specified by:

complete in interface AsyncContext

createListener

public <T extends AsyncListener> T createListener(Class<T> clazz)
                                       throws ServletException

Specified by:

createListener in interface AsyncContext

Throws:

ServletException

completed

protected void completed()

recycle

protected void recycle()

cancel

public void cancel()

scheduleDispatch

protected void scheduleDispatch()

scheduleTimeout

protected void scheduleTimeout()

cancelTimeout

protected void cancelTimeout()

isInitial

public boolean isInitial()

isSuspended

public boolean isSuspended()

isAsync

public boolean isAsync()

dispatch

public void dispatch(ServletContext context,
            String path)

Specified by:

dispatch in interface AsyncContext

dispatch

public void dispatch(String path)

Specified by:

dispatch in interface AsyncContext

getBaseRequest

public Request getBaseRequest()

getRequest

public ServletRequest getRequest()

Specified by:

getRequest in interface AsyncContext

getResponse

public ServletResponse getResponse()

Specified by:

getResponse in interface AsyncContext

start

public void start(Runnable run)

Specified by:

start in interface AsyncContext

hasOriginalRequestAndResponse

public boolean hasOriginalRequestAndResponse()

Specified by:

hasOriginalRequestAndResponse in interface AsyncContext

getContextHandler

public ContextHandler getContextHandler()

getServletResponse

public ServletResponse getServletResponse()

See Also:

Continuation.getServletResponse()

getAttribute

public Object getAttribute(String name)

See Also:

Continuation.getAttribute(java.lang.String)

removeAttribute

public void removeAttribute(String name)

See Also:

Continuation.removeAttribute(java.lang.String)

setAttribute

public void setAttribute(String name,
                Object attribute)

See Also:

Continuation.setAttribute(java.lang.String, java.lang.Object)