Modifier and Type	Class and Description
public class	SelectorManager.SelectSet

Modifier and Type	Field and Description
private long	_lowResourcesConnections
private long	_lowResourcesMaxIdleTime
private long	_maxIdleTime
private transient SelectorManager.SelectSet[]	_selectSet
private int	_selectSets
private volatile int	_set

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()
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	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

_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)

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()

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

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

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 transient int	_change
private transient List<Object>[]	_changes
private transient Timeout	_idleTimeout
private transient int	_jvmBug
private transient int	_nextSet
private transient boolean	_selecting
private transient Selector	_selector
private transient int	_setID
private transient Timeout	_timeout

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(SocketChannel channel, Object att)
public void	cancelIdle(Timeout.Task task)
public void	cancelTimeout(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 timeoutMs)
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

_change	back to summary
private transient int _change

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

_idleTimeout	back to summary
private transient Timeout _idleTimeout

_jvmBug	back to summary
private transient int _jvmBug

_nextSet	back to summary
private transient int _nextSet

_selecting	back to summary
private transient boolean _selecting

_selector	back to summary
private transient Selector _selector

_setID	back to summary
private transient int _setID

_timeout	back to summary
private transient Timeout _timeout

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(SocketChannel channel, Object att)

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

cancelTimeout	back to summary
public void cancelTimeout(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 timeoutMs)

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

public Class SelectorManager.SelectSet

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail