Modifier and Type	Class and Description
public class	SelectChannelEndPoint.IdleTask

Modifier and Type	Field and Description
protected Connection	_connection
protected boolean	_dispatched
private Timeout.Task	_idleTask
protected int	_interestOps
protected SelectionKey	_key
protected SelectorManager	_manager
private boolean	_open
protected boolean	_readBlocked
protected boolean	_redispatched
protected SelectorManager.SelectSet	_selectSet
protected boolean	_writable
protected boolean	_writeBlocked

Access	Constructor and Description
public	SelectChannelEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey key)

Method Summary

Modifier and Type	Method and Description
public boolean	blockReadable(long timeoutMs) Overrides org.mortbay.io.nio.ChannelEndPoint.blockReadable. Implements org.mortbay.io.EndPoint.blockReadable.
public boolean	blockWritable(long timeoutMs) Overrides org.mortbay.io.nio.ChannelEndPoint.blockWritable. Implements org.mortbay.io.EndPoint.blockWritable.
public void	cancelIdle()
public void	close() Overrides org.mortbay.io.nio.ChannelEndPoint.close. Implements org.mortbay.io.EndPoint.close. Close any backing stream associated with the buffer
public boolean	dispatch() Implements org.mortbay.io.AsyncEndPoint.dispatch. Dispatch the endpoint to a thread to attend to it.
pack-priv void	doUpdateKey() Synchronize the interestOps with the actual key.
public int	flush(Buffer A buffer to write before flushing this buffer. This buffers getIndex is updated. header, Buffer The buffer to flush. This buffers getIndex is updated. buffer, Buffer A buffer to write after flushing this buffer. This buffers getIndex is updated. trailer) Overrides org.mortbay.io.nio.ChannelEndPoint.flush. Implements org.mortbay.io.EndPoint.flush. Flush the buffer from the current getIndex to it's putIndex using whatever byte sink is backing the buffer.
public int	flush(Buffer The buffer to flush. This buffers getIndex is updated. buffer) Overrides org.mortbay.io.nio.ChannelEndPoint.flush. Implements org.mortbay.io.EndPoint.flush. Flush the buffer from the current getIndex to it's putIndex using whatever byte sink is backing the buffer.
public Connection	getConnection()
public SelectorManager.SelectSet	getSelectSet()
public Timeout.Task	getTimeoutTask()
protected void	idleExpired()
public boolean	isReadyForDispatch() Implements org.mortbay.io.AsyncEndPoint.isReadyForDispatch.
public void	run() Implements java.lang.Runnable.run. Runs this operation.
public void	schedule() Called by selectSet to schedule handling
public void	scheduleIdle()
public void	scheduleWrite()
public void	setWritable(boolean writable)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
protected boolean	undispatch() Called when a dispatched thread is no longer handling the endpoint.
private void	updateKey() Updates selection key.

Inherited from org.mortbay.io.nio.ChannelEndPoint:: fill flush getChannel getLocalAddr getLocalHost getLocalPort getRemoteAddr getRemoteHost getRemotePort getTransport isBlocking isBufferingInput isBufferingOutput isBufferred isOpen

Field Detail

_connection	back to summary
protected Connection _connection

_dispatched	back to summary
protected boolean _dispatched

_idleTask	back to summary
private Timeout.Task _idleTask

_interestOps	back to summary
protected int _interestOps

_key	back to summary
protected SelectionKey _key

_manager	back to summary
protected SelectorManager _manager

_open	back to summary
private boolean _open

_readBlocked	back to summary
protected boolean _readBlocked

_redispatched	back to summary
protected boolean _redispatched

_selectSet	back to summary
protected SelectorManager.SelectSet _selectSet

_writable	back to summary
protected boolean _writable

_writeBlocked	back to summary
protected boolean _writeBlocked

Constructor Detail

SelectChannelEndPoint	back to summary
public SelectChannelEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey key)

Method Detail

blockReadable	back to summary
public boolean blockReadable(long timeoutMs) throws IOException Overrides org.mortbay.io.nio.ChannelEndPoint.blockReadable. Implements org.mortbay.io.EndPoint.blockReadable.

blockReadable

back to summary

public boolean blockReadable(long timeoutMs) throws IOException

Overrides org.mortbay.io.nio.ChannelEndPoint.blockReadable.

Implements org.mortbay.io.EndPoint.blockReadable.

blockWritable	back to summary
public boolean blockWritable(long timeoutMs) throws IOException Overrides org.mortbay.io.nio.ChannelEndPoint.blockWritable. Implements org.mortbay.io.EndPoint.blockWritable.

blockWritable

back to summary

public boolean blockWritable(long timeoutMs) throws IOException

Overrides org.mortbay.io.nio.ChannelEndPoint.blockWritable.

Implements org.mortbay.io.EndPoint.blockWritable.

cancelIdle	back to summary
public void cancelIdle()

close	back to summary
public void close() throws IOException Overrides org.mortbay.io.nio.ChannelEndPoint.close. Implements org.mortbay.io.EndPoint.close. Doc from org.mortbay.io.EndPoint.close. Close any backing stream associated with the buffer

back to summary

public void close() throws IOException

Overrides org.mortbay.io.nio.ChannelEndPoint.close.

Implements org.mortbay.io.EndPoint.close.

Doc from org.mortbay.io.EndPoint.close.

Close any backing stream associated with the buffer

dispatch	back to summary
public boolean dispatch() Implements org.mortbay.io.AsyncEndPoint.dispatch. Doc from org.mortbay.io.AsyncEndPoint.dispatch. Dispatch the endpoint to a thread to attend to it. Returns:boolean True If the dispatched succeeded

dispatch

back to summary

public boolean dispatch()

Implements org.mortbay.io.AsyncEndPoint.dispatch.

Doc from org.mortbay.io.AsyncEndPoint.dispatch.

Dispatch the endpoint to a thread to attend to it.

Returns:boolean: True If the dispatched succeeded

doUpdateKey	back to summary
pack-priv void doUpdateKey() Synchronize the interestOps with the actual key. Call is scheduled by a call to updateKey

flush	back to summary
public int flush(Buffer header, Buffer buffer, Buffer trailer) throws IOException Overrides org.mortbay.io.nio.ChannelEndPoint.flush. Implements org.mortbay.io.EndPoint.flush. Doc from org.mortbay.io.EndPoint.flush. Flush the buffer from the current getIndex to it's putIndex using whatever byte sink is backing the buffer. The getIndex is updated with the number of bytes flushed. Any mark set is cleared. If the entire contents of the buffer are flushed, then an implicit empty() is done. The passed header/trailer buffers are written before/after the contents of this buffer. This may be done either as gather writes, as a poke into this buffer or as several writes. The implementation is free to select the optimal mechanism. Parameters header:Buffer A buffer to write before flushing this buffer. This buffers getIndex is updated. buffer:Buffer The buffer to flush. This buffers getIndex is updated. trailer:Buffer A buffer to write after flushing this buffer. This buffers getIndex is updated. Returns:int the total number of bytes written.

flush

back to summary

public int flush(Buffer header, Buffer buffer, Buffer trailer) throws IOException

Overrides org.mortbay.io.nio.ChannelEndPoint.flush.

Implements org.mortbay.io.EndPoint.flush.

Doc from org.mortbay.io.EndPoint.flush.

Flush the buffer from the current getIndex to it's putIndex using whatever byte sink is backing the buffer. The getIndex is updated with the number of bytes flushed. Any mark set is cleared. If the entire contents of the buffer are flushed, then an implicit empty() is done. The passed header/trailer buffers are written before/after the contents of this buffer. This may be done either as gather writes, as a poke into this buffer or as several writes. The implementation is free to select the optimal mechanism.

Parameters

header:Buffer: A buffer to write before flushing this buffer. This buffers getIndex is updated.
buffer:Buffer: The buffer to flush. This buffers getIndex is updated.
trailer:Buffer: A buffer to write after flushing this buffer. This buffers getIndex is updated.

Returns:int

the total number of bytes written.

flush	back to summary
public int flush(Buffer buffer) throws IOException Overrides org.mortbay.io.nio.ChannelEndPoint.flush. Implements org.mortbay.io.EndPoint.flush. Doc from org.mortbay.io.EndPoint.flush. Flush the buffer from the current getIndex to it's putIndex using whatever byte sink is backing the buffer. The getIndex is updated with the number of bytes flushed. Any mark set is cleared. If the entire contents of the buffer are flushed, then an implicit empty() is done. Parameters buffer:Buffer The buffer to flush. This buffers getIndex is updated. Returns:int the number of bytes written

flush

back to summary

public int flush(Buffer buffer) throws IOException

Overrides org.mortbay.io.nio.ChannelEndPoint.flush.

Implements org.mortbay.io.EndPoint.flush.

Doc from org.mortbay.io.EndPoint.flush.

Parameters

buffer:Buffer: The buffer to flush. This buffers getIndex is updated.

Returns:int

the number of bytes written

getConnection	back to summary
public Connection getConnection()

getSelectSet	back to summary
public SelectorManager.SelectSet getSelectSet()

getTimeoutTask	back to summary
public Timeout.Task getTimeoutTask()

idleExpired	back to summary
protected void idleExpired()

isReadyForDispatch	back to summary
public boolean isReadyForDispatch() Implements org.mortbay.io.AsyncEndPoint.isReadyForDispatch. Returns:boolean Doc from org.mortbay.io.AsyncEndPoint.isReadyForDispatch. true if this endpoint can accept a dispatch. False if the endpoint cannot accept a dispatched (eg is suspended or already dispatched)

isReadyForDispatch

back to summary

public boolean isReadyForDispatch()

Implements org.mortbay.io.AsyncEndPoint.isReadyForDispatch.

Returns:boolean

Doc from org.mortbay.io.AsyncEndPoint.isReadyForDispatch.

true if this endpoint can accept a dispatch. False if the endpoint cannot accept a dispatched (eg is suspended or already dispatched)

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation.

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

schedule	back to summary
public void schedule() throws IOException Called by selectSet to schedule handling

scheduleIdle	back to summary
public void scheduleIdle()

scheduleWrite	back to summary
public void scheduleWrite()

setWritable	back to summary
public void setWritable(boolean writable)

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String: a string representation of the object

undispatch	back to summary
protected boolean undispatch() Called when a dispatched thread is no longer handling the endpoint. The selection key operations are updated.

updateKey	back to summary
private void updateKey() Updates selection key. Adds operations types to the selection key as needed. No operations are removed as this is only done during dispatch. This method records the new key and schedules a call to doUpdateKey to do the keyChange

org.mortbay.io.nio back to summary

public Class SelectChannelEndPoint.IdleTask

Class Inheritance

extends Task

java.lang.Object
org.mortbay.thread.Timeout.Task
org.mortbay.io.nio.SelectChannelEndPoint.IdleTask

Constructor Summary

Access	Constructor and Description
public	IdleTask()

Method Summary

Modifier and Type	Method and Description
public void	expired() Overrides org.mortbay.thread.Timeout.Task.expired. Expire task.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from org.mortbay.thread.Timeout.Task:: cancel expire getAge getTimestamp isExpired isScheduled reschedule schedule schedule

Constructor Detail

IdleTask	back to summary
public IdleTask()

Method Detail

expired	back to summary
public void expired() Overrides org.mortbay.thread.Timeout.Task.expired. Doc from org.mortbay.thread.Timeout.Task.expired. Expire task. This method is called when the timeout expires. It is called outside of any synchronization scope and may be delayed.

expired

back to summary

public void expired()

Overrides org.mortbay.thread.Timeout.Task.expired.

Doc from org.mortbay.thread.Timeout.Task.expired.

Expire task. This method is called when the timeout expires. It is called outside of any synchronization scope and may be delayed.

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String: a string representation of the object

public Class SelectChannelEndPoint

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Class SelectChannelEndPoint.IdleTask

Constructor Summary

Method Summary

Constructor Detail

Method Detail