Modifier and Type	Class and Description
private static class	SelectorManager.ChangeSelectableChannel
private static interface	SelectorManager.ChangeTask
public class	SelectorManager.SelectSet

Field Summary

Modifier and Type	Field and Description
private static final int	__BUSY_KEY
private static final int	__BUSY_PAUSE
private static final int	__JVMBUG_THRESHHOLD
private static final int	__MAX_SELECTS
private static final int	__MONITOR_PERIOD
private boolean	_delaySelectKeyUpdate
private long	_lowResourcesConnections
private long	_lowResourcesMaxIdleTime
private long	_maxIdleTime
private transient SelectorManager.SelectSet[]	_selectSet
private int	_selectSets
private volatile int	_set

Inherited from org.mortbay.component.AbstractLifeCycle:: _listeners

Constructor Summary

Access	Constructor and Description
public	SelectorManager()

Method Summary

Modifier and Type	Method and Description
protected abstract SocketChannel	acceptChannel(SelectionKey key)
protected void	connectionFailed(SocketChannel channel, Throwable ex, Object attachment)
public abstract boolean	dispatch(Runnable task)
public void	doSelect(int acceptorID)
protected void	doStart() Overrides org.mortbay.component.AbstractLifeCycle.doStart.
protected void	doStop() Overrides org.mortbay.component.AbstractLifeCycle.doStop.
protected abstract void	endPointClosed(SelectChannelEndPoint endpoint)
protected abstract void	endPointOpened(SelectChannelEndPoint endpoint)
public long	Returns: the lowResourcesConnections getLowResourcesConnections()
public long	Returns: the lowResourcesMaxIdleTime getLowResourcesMaxIdleTime()
public long	getMaxIdleTime()
public int	getSelectSets()
public boolean	isDelaySelectKeyUpdate()
protected abstract Connection	newConnection(SocketChannel channel, SelectChannelEndPoint endpoint)
protected abstract SelectChannelEndPoint	newEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey sKey)
public void	register(SocketChannel channel, Object Attached Object att) Register a channel
public void	register(ServerSocketChannel acceptChannel) Register a serverchannel
public void	setDelaySelectKeyUpdate(boolean delaySelectKeyUpdate)
public void	setLowResourcesConnections(long the number of connections lowResourcesConnections) Set the number of connections, which if exceeded places this manager in low resources state.
public void	setLowResourcesMaxIdleTime(long the period in ms that a connection is allowed to be idle when this SelectSet has more connections than `getLowResourcesConnections()` lowResourcesMaxIdleTime)
public void	setMaxIdleTime(long The maximum period in milli seconds that a connection may be idle before it is closed. maxIdleTime)
public void	setSelectSets(int selectSets)

Inherited from org.mortbay.component.AbstractLifeCycle:: addLifeCycleListener isFailed isRunning isStarted isStarting isStopped isStopping removeLifeCycleListener start stop

__BUSY_KEY	back to summary
private static final int __BUSY_KEY

__BUSY_PAUSE	back to summary
private static final int __BUSY_PAUSE

__JVMBUG_THRESHHOLD	back to summary
private static final int __JVMBUG_THRESHHOLD

__MAX_SELECTS	back to summary
private static final int __MAX_SELECTS

__MONITOR_PERIOD	back to summary
private static final int __MONITOR_PERIOD

_delaySelectKeyUpdate	back to summary
private boolean _delaySelectKeyUpdate

_lowResourcesConnections	back to summary
private long _lowResourcesConnections

_lowResourcesMaxIdleTime	back to summary
private long _lowResourcesMaxIdleTime

_maxIdleTime	back to summary
private long _maxIdleTime

_selectSet	back to summary
private transient SelectorManager.SelectSet[] _selectSet

_selectSets	back to summary
private int _selectSets

_set	back to summary
private volatile int _set

Constructor Detail

SelectorManager	back to summary
public SelectorManager()

Method Detail

acceptChannel	back to summary
protected abstract SocketChannel acceptChannel(SelectionKey key) throws IOException

connectionFailed	back to summary
protected void connectionFailed(SocketChannel channel, Throwable ex, Object attachment)

dispatch	back to summary
public abstract boolean dispatch(Runnable task) throws IOException

doSelect	back to summary
public void doSelect(int acceptorID) throws IOException

doStart	back to summary
protected void doStart() throws Exception Overrides org.mortbay.component.AbstractLifeCycle.doStart.

doStop	back to summary
protected void doStop() throws Exception Overrides org.mortbay.component.AbstractLifeCycle.doStop.

endPointClosed	back to summary
protected abstract void endPointClosed(SelectChannelEndPoint endpoint)

endPointOpened	back to summary
protected abstract void endPointOpened(SelectChannelEndPoint endpoint)

getLowResourcesConnections	back to summary
public long getLowResourcesConnections() Returns:long the lowResourcesConnections

getLowResourcesMaxIdleTime	back to summary
public long getLowResourcesMaxIdleTime() Returns:long the lowResourcesMaxIdleTime

getMaxIdleTime	back to summary
public long getMaxIdleTime()

getSelectSets	back to summary
public int getSelectSets()

isDelaySelectKeyUpdate	back to summary
public boolean isDelaySelectKeyUpdate()

newConnection	back to summary
protected abstract Connection newConnection(SocketChannel channel, SelectChannelEndPoint endpoint)

newEndPoint	back to summary
protected abstract SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey sKey) throws IOException

register	back to summary
public void register(SocketChannel channel, Object att) throws IOException Register a channel Parameters att:Object Attached Object

back to summary

public void register(SocketChannel channel, Object att) throws IOException

Parameters

att:Object: Attached Object

register	back to summary
public void register(ServerSocketChannel acceptChannel) throws IOException Register a serverchannel

setDelaySelectKeyUpdate	back to summary
public void setDelaySelectKeyUpdate(boolean delaySelectKeyUpdate)

setLowResourcesConnections back to summary

setLowResourcesConnections	back to summary
public void setLowResourcesConnections(long lowResourcesConnections) Set the number of connections, which if exceeded places this manager in low resources state. This is not an exact measure as the connection count is averaged over the select sets. Parameters lowResourcesConnections:long the number of connections See Also `setLowResourcesMaxIdleTime(long)`

public void setLowResourcesConnections(long lowResourcesConnections)

Set the number of connections, which if exceeded places this manager in low resources state. This is not an exact measure as the connection count is averaged over the select sets.

Parameters

lowResourcesConnections:long: the number of connections

See Also

setLowResourcesMaxIdleTime(long)

setLowResourcesMaxIdleTime	back to summary
public void setLowResourcesMaxIdleTime(long lowResourcesMaxIdleTime) Parameters lowResourcesMaxIdleTime:long the period in ms that a connection is allowed to be idle when this SelectSet has more connections than `getLowResourcesConnections()` See Also `setMaxIdleTime(long)`

setMaxIdleTime	back to summary
public void setMaxIdleTime(long maxIdleTime) Parameters maxIdleTime:long The maximum period in milli seconds that a connection may be idle before it is closed. See Also `setLowResourcesMaxIdleTime(long)`

setSelectSets	back to summary
public void setSelectSets(int selectSets)

org.mortbay.io.nio back to summary

private Class SelectorManager.ChangeSelectableChannel

Class Inheritance

extends Object

java.lang.Object
org.mortbay.io.nio.SelectorManager.ChangeSelectableChannel

Field Summary

Modifier and Type	Field and Description
pack-priv final Object	_attachment
pack-priv final SelectableChannel	_channel

Constructor Summary

Access	Constructor and Description
public	ChangeSelectableChannel(SelectableChannel channel, Object attachment)

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

_attachment	back to summary
pack-priv final Object _attachment

_channel	back to summary
pack-priv final SelectableChannel _channel

Constructor Detail

ChangeSelectableChannel	back to summary
public ChangeSelectableChannel(SelectableChannel channel, Object attachment)

org.mortbay.io.nio back to summary

private Interface SelectorManager.ChangeTask

Method Summary

Modifier and Type	Method and Description
public void	run()

Method Detail

run	back to summary
public void run()

org.mortbay.io.nio back to summary

public Class SelectorManager.SelectSet

Class Inheritance

extends Object

java.lang.Object
org.mortbay.io.nio.SelectorManager.SelectSet

Field Summary

Modifier and Type	Field and Description
private SelectionKey	_busyKey
private int	_busyKeyCount
private transient int	_change
private transient List<E>[]	_changes
private transient Timeout	_idleTimeout
private transient int	_jvmBug
private int	_jvmFix0
private int	_jvmFix1
private int	_jvmFix2
private long	_log
private long	_monitorNext
private long	_monitorStart
private transient int	_nextSet
private int	_paused
private boolean	_pausing
private transient Timeout	_retryTimeout
private volatile boolean	_selecting
private transient Selector	_selector
private int	_selects
private transient int	_setID

Constructor Summary

Access	Constructor and Description
pack-priv	SelectSet(int acceptorID)

Method Summary

Modifier and Type	Method and Description
public void	addChange(Object point)
public void	addChange(SelectableChannel channel, Object att)
public void	cancelIdle(Timeout.Task task)
public void	doSelect() Select and dispatch tasks found from changes and the selector.
public SelectorManager	getManager()
public long	getNow()
pack-priv Selector	getSelector()
public void	scheduleIdle(Timeout.Task task)
public void	scheduleTimeout(Timeout.Task task, long timeout)
pack-priv void	stop()
public void	wakeup()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

_busyKey	back to summary
private SelectionKey _busyKey

_busyKeyCount	back to summary
private int _busyKeyCount

_change	back to summary
private transient int _change

_changes	back to summary
private transient List<E>[] _changes

_idleTimeout	back to summary
private transient Timeout _idleTimeout

_jvmBug	back to summary
private transient int _jvmBug

_jvmFix0	back to summary
private int _jvmFix0

_jvmFix1	back to summary
private int _jvmFix1

_jvmFix2	back to summary
private int _jvmFix2

_log	back to summary
private long _log

_monitorNext	back to summary
private long _monitorNext

_monitorStart	back to summary
private long _monitorStart

_nextSet	back to summary
private transient int _nextSet

_paused	back to summary
private int _paused

_pausing	back to summary
private boolean _pausing

_retryTimeout	back to summary
private transient Timeout _retryTimeout

_selecting	back to summary
private volatile boolean _selecting

_selector	back to summary
private transient Selector _selector

_selects	back to summary
private int _selects

_setID	back to summary
private transient int _setID

Constructor Detail

SelectSet	back to summary
pack-priv SelectSet(int acceptorID) throws Exception

Method Detail

addChange	back to summary
public void addChange(Object point)

addChange	back to summary
public void addChange(SelectableChannel channel, Object att)

cancelIdle	back to summary
public void cancelIdle(Timeout.Task task)

doSelect	back to summary
public void doSelect() throws IOException Select and dispatch tasks found from changes and the selector.

getManager	back to summary
public SelectorManager getManager()

getNow	back to summary
public long getNow()

getSelector	back to summary
pack-priv Selector getSelector()

scheduleIdle	back to summary
public void scheduleIdle(Timeout.Task task)

scheduleTimeout	back to summary
public void scheduleTimeout(Timeout.Task task, long timeout)

stop	back to summary
pack-priv void stop() throws Exception

wakeup	back to summary
public void wakeup()

public abstract Class SelectorManager

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class SelectorManager.ChangeSelectableChannel

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

private Interface SelectorManager.ChangeTask

Method Summary

Method Detail

public Class SelectorManager.SelectSet

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail