public class SelectChannelEndPoint extends ChannelEndPoint implements SelectorManager.SelectableEndPoint
SelectorManager.| Constructor and Description |
|---|
SelectChannelEndPoint(SocketChannel channel,
SelectorManager.ManagedSelector selector,
SelectionKey key,
Scheduler scheduler,
long idleTimeout) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close any backing stream associated with the endpoint
|
boolean |
isOpen()
This abstract method should be called to check if idle timeouts
should still be checked.
|
protected boolean |
needsFill() |
protected void |
onIncompleteFlush() |
void |
onOpen()
Callback method invoked when this
EndPoint is opened. |
void |
onSelected()
Callback method invoked when a read or write events has been detected by the
SelectorManager.ManagedSelector
for this endpoint. |
String |
toString() |
fill, flush, getChannel, getSocket, getTransport, isInputShutdown, isOutputShutdown, shutdownInput, shutdownOutputfillInterested, getConnection, getCreatedTimeStamp, getFillInterest, getLocalAddress, getRemoteAddress, getWriteFlusher, onClose, onIdleExpired, setConnection, writecheckIdleTimeout, getIdleTimeout, getIdleTimestamp, notIdle, setIdleTimeoutclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitfill, fillInterested, flush, getConnection, getCreatedTimeStamp, getIdleTimeout, getLocalAddress, getRemoteAddress, getTransport, isInputShutdown, isOutputShutdown, onClose, setConnection, setIdleTimeout, shutdownOutput, writepublic static final Logger LOG
public SelectChannelEndPoint(SocketChannel channel, SelectorManager.ManagedSelector selector, SelectionKey key, Scheduler scheduler, long idleTimeout)
protected boolean needsFill()
needsFill in class ChannelEndPointprotected void onIncompleteFlush()
onIncompleteFlush in class ChannelEndPointpublic void onSelected()
SelectorManager.SelectableEndPointCallback method invoked when a read or write events has been detected by the SelectorManager.ManagedSelector
for this endpoint.
onSelected in interface SelectorManager.SelectableEndPointpublic void close()
EndPointclose in interface Closeableclose in interface AutoCloseableclose in interface EndPointclose in class ChannelEndPointpublic boolean isOpen()
IdleTimeoutisOpen in interface EndPointisOpen in class ChannelEndPointpublic void onOpen()
EndPointCallback method invoked when this EndPoint is opened.
onOpen in interface EndPointonOpen in class AbstractEndPointEndPoint.onClose()public String toString()
toString in class AbstractEndPointCopyright © 1995-2015 Webtide. All Rights Reserved.