org.eclipse.jetty.io
Interface AsyncEndPoint

All Superinterfaces:

ConnectedEndPoint, EndPoint

All Known Implementing Classes:

NetworkTrafficSelectChannelEndPoint, SelectChannelEndPoint, SslConnection.SslEndPoint

public interface AsyncEndPoint
extends ConnectedEndPoint

Method Summary

void	asyncDispatch() Dispatch the endpoint to a thread to attend to it.
void	cancelTimeout(Timeout.Task task)
boolean	hasProgressed()
boolean	isCheckForIdle() Get if the endpoint should be checked for idleness
boolean	isWritable()
void	onIdleExpired() Callback when idle.
void	scheduleTimeout(Timeout.Task task, long timeoutMs)
void	scheduleWrite() Schedule a write dispatch.
void	setCheckForIdle(boolean check) Set if the endpoint should be checked for idleness

Methods inherited from interface org.eclipse.jetty.io.ConnectedEndPoint

getConnection, setConnection

Methods inherited from interface org.eclipse.jetty.io.EndPoint

blockReadable, blockWritable, close, fill, flush, flush, flush, getLocalAddr, getLocalHost, getLocalPort, getMaxIdleTime, getRemoteAddr, getRemoteHost, getRemotePort, getTransport, isBlocking, isInputShutdown, isOpen, isOutputShutdown, setMaxIdleTime, shutdownInput, shutdownOutput

Method Detail

asyncDispatch

void asyncDispatch()

Dispatch the endpoint to a thread to attend to it.

scheduleWrite

void scheduleWrite()

Schedule a write dispatch. Set the endpoint to not be writable and schedule a dispatch when it becomes writable.

onIdleExpired

void onIdleExpired()

Callback when idle.

An endpoint is idle if there has been no IO activity for EndPoint.getMaxIdleTime() and isCheckForIdle() is true.

setCheckForIdle

void setCheckForIdle(boolean check)

Set if the endpoint should be checked for idleness

isCheckForIdle

boolean isCheckForIdle()

Get if the endpoint should be checked for idleness

isWritable

boolean isWritable()

hasProgressed

boolean hasProgressed()

Returns:

True if IO has been successfully performed since the last call to hasProgressed()

scheduleTimeout

void scheduleTimeout(Timeout.Task task,
                     long timeoutMs)

cancelTimeout

void cancelTimeout(Timeout.Task task)