|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.eclipse.jetty.io.nio.ChannelEndPoint org.eclipse.jetty.io.nio.SelectChannelEndPoint
public class SelectChannelEndPoint
An Endpoint that can be scheduled by SelectorManager
.
Field Summary | |
---|---|
static Logger |
LOG
|
Fields inherited from class org.eclipse.jetty.io.nio.ChannelEndPoint |
---|
_channel, _gather2, _local, _maxIdleTime, _remote, _socket |
Constructor Summary | |
---|---|
SelectChannelEndPoint(SocketChannel channel,
SelectorManager.SelectSet selectSet,
SelectionKey key,
int maxIdleTime)
|
Method Summary | |
---|---|
void |
asyncDispatch()
Dispatch the endpoint to a thread to attend to it. |
boolean |
blockReadable(long timeoutMs)
|
boolean |
blockWritable(long timeoutMs)
|
void |
cancelTimeout(Timeout.Task task)
|
void |
checkIdleTimestamp(long now)
|
void |
clearWritable()
|
void |
close()
Close any backing stream associated with the endpoint |
void |
dispatch()
|
int |
fill(Buffer buffer)
Fill the buffer from the current putIndex to it's capacity from whatever byte source is backing the buffer. |
int |
flush(Buffer buffer)
Flush the buffer from the current getIndex to it's putIndex using whatever byte sink is backing the buffer. |
int |
flush(Buffer header,
Buffer buffer,
Buffer trailer)
Flush the buffer from the current getIndex to it's putIndex using whatever byte sink is backing the buffer. |
Connection |
getConnection()
|
long |
getIdleTimestamp()
|
SelectionKey |
getSelectionKey()
|
SelectorManager |
getSelectManager()
|
SelectorManager.SelectSet |
getSelectSet()
|
protected void |
handle()
|
boolean |
hasProgressed()
|
boolean |
isCheckForIdle()
Get if the endpoint should be checked for idleness |
boolean |
isWritable()
|
protected void |
notIdle()
|
void |
onIdleExpired(long idleForMs)
Callback when idle. |
void |
schedule()
Called by selectSet to schedule handling |
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 |
void |
setConnection(Connection connection)
|
void |
setMaxIdleTime(int timeMs)
Don't set the SoTimeout |
String |
toString()
|
protected boolean |
undispatch()
Called when a dispatched thread is no longer handling the endpoint. |
Methods inherited from class org.eclipse.jetty.io.nio.ChannelEndPoint |
---|
flush, gatheringFlush, getChannel, getLocalAddr, getLocalHost, getLocalPort, getMaxIdleTime, getRemoteAddr, getRemoteHost, getRemotePort, getTransport, isBlocking, isInputShutdown, isOpen, isOutputShutdown, shutdownChannelInput, shutdownChannelOutput, shutdownInput, shutdownOutput |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.eclipse.jetty.io.EndPoint |
---|
flush, getLocalAddr, getLocalHost, getLocalPort, getMaxIdleTime, getRemoteAddr, getRemoteHost, getRemotePort, getTransport, isBlocking, isInputShutdown, isOpen, isOutputShutdown, shutdownInput, shutdownOutput |
Field Detail |
---|
public static final Logger LOG
Constructor Detail |
---|
public SelectChannelEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey key, int maxIdleTime) throws IOException
IOException
Method Detail |
---|
public SelectionKey getSelectionKey()
public SelectorManager getSelectManager()
public Connection getConnection()
getConnection
in interface ConnectedEndPoint
public void setConnection(Connection connection)
setConnection
in interface ConnectedEndPoint
public long getIdleTimestamp()
public void schedule()
public void asyncDispatch()
AsyncEndPoint
asyncDispatch
in interface AsyncEndPoint
public void dispatch()
protected boolean undispatch()
public void cancelTimeout(Timeout.Task task)
cancelTimeout
in interface AsyncEndPoint
public void scheduleTimeout(Timeout.Task task, long timeoutMs)
scheduleTimeout
in interface AsyncEndPoint
public void setCheckForIdle(boolean check)
AsyncEndPoint
setCheckForIdle
in interface AsyncEndPoint
public boolean isCheckForIdle()
AsyncEndPoint
isCheckForIdle
in interface AsyncEndPoint
protected void notIdle()
public void checkIdleTimestamp(long now)
public void onIdleExpired(long idleForMs)
AsyncEndPoint
An endpoint is idle if there has been no IO activity for
EndPoint.getMaxIdleTime()
and AsyncEndPoint.isCheckForIdle()
is true.
onIdleExpired
in interface AsyncEndPoint
idleForMs
- TODOpublic int fill(Buffer buffer) throws IOException
EndPoint
fill
in interface EndPoint
fill
in class ChannelEndPoint
int
value indicating the number of bytes
filled or -1 if EOF is reached.
EofException
- If input is shutdown or the endpoint is closed.
IOException
public int flush(Buffer header, Buffer buffer, Buffer trailer) throws IOException
EndPoint
flush
in interface EndPoint
flush
in class ChannelEndPoint
header
- A buffer to write before flushing this buffer. This buffers getIndex is updated.buffer
- The buffer to flush. This buffers getIndex is updated.trailer
- A buffer to write after flushing this buffer. This buffers getIndex is updated.
IOException
public int flush(Buffer buffer) throws IOException
EndPoint
flush
in interface EndPoint
flush
in class ChannelEndPoint
buffer
- The buffer to flush. This buffers getIndex is updated.
EofException
- If the endpoint is closed or output is shutdown.
IOException
public boolean blockReadable(long timeoutMs) throws IOException
blockReadable
in interface EndPoint
blockReadable
in class ChannelEndPoint
IOException
public boolean blockWritable(long timeoutMs) throws IOException
blockWritable
in interface EndPoint
blockWritable
in class ChannelEndPoint
IOException
public void clearWritable()
public void scheduleWrite()
AsyncEndPoint
scheduleWrite
in interface AsyncEndPoint
AsyncEndPoint.scheduleWrite()
public boolean isWritable()
isWritable
in interface AsyncEndPoint
public boolean hasProgressed()
hasProgressed
in interface AsyncEndPoint
AsyncEndPoint.hasProgressed()
protected void handle()
public void close() throws IOException
EndPoint
close
in interface EndPoint
close
in class ChannelEndPoint
IOException
public String toString()
toString
in class Object
public SelectorManager.SelectSet getSelectSet()
public void setMaxIdleTime(int timeMs) throws IOException
setMaxIdleTime
in interface EndPoint
setMaxIdleTime
in class ChannelEndPoint
timeMs
- the max idle time in MS. Timeout <= 0 implies an infinite timeout
IOException
- if the timeout cannot be set.ChannelEndPoint.setMaxIdleTime(int)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |