Class ManagedSelector

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.io.ManagedSelector

All Implemented Interfaces:

Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle

public class ManagedSelector
extends ContainerLifeCycle
implements Dumpable

ManagedSelector wraps a Selector simplifying non-blocking operations on channels.

ManagedSelector runs the select loop, which waits on Selector.select() until events happen for registered channels. When events happen, it notifies the EndPoint associated with the channel.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	ManagedSelector.Accept
(package private) class	ManagedSelector.Acceptor
private class	ManagedSelector.CloseConnections
(package private) class	ManagedSelector.Connect
private final class	ManagedSelector.CreateEndPoint
private class	ManagedSelector.DestroyEndPoint
private static class	ManagedSelector.DumpKeys
static interface	ManagedSelector.Selectable	A ManagedSelector.Selectable is an EndPoint that wish to be notified of non-blocking events by the ManagedSelector.
private class	ManagedSelector.SelectorProducer
static interface	ManagedSelector.SelectorUpdate	A selector update to be done when the selector has been woken.
private class	ManagedSelector.Start
private class	ManagedSelector.StopSelector

Nested classes/interfaces inherited from class AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface LifeCycle

LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field	Description
private final int	_id
private final SampleStatistic	_keyStats
private boolean	_selecting
private Selector	_selector
private final SelectorManager	_selectorManager
private final AtomicBoolean	_started
private final ExecutionStrategy	_strategy
private Deque<ManagedSelector.SelectorUpdate>	_updateable
private Deque<ManagedSelector.SelectorUpdate>	_updates
private static final boolean	FORCE_SELECT_NOW
private static final Logger	LOG

Fields inherited from class AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface Dumpable

KEY

Constructor Summary

Constructors

Constructor	Description
ManagedSelector(SelectorManager selectorManager, int id)

Method Summary

Modifier and Type	Method	Description
private void	createEndPoint(SelectableChannel channel, SelectionKey selectionKey)
(package private) void	destroyEndPoint(EndPoint endPoint)
protected void	doStart()	Starts the managed lifecycle beans in the order they were added.
protected void	doStop()	Stops the managed lifecycle beans in the reverse order they were added.
void	dump(Appendable out, String indent)	Dump this object (and children) into an Appendable using the provided indent after any new lines.
protected void	endPointClosed(EndPoint endPoint)
protected void	endPointOpened(EndPoint endPoint)
private void	execute(Runnable task)
private int	getActionSize()
double	getAverageSelectedKeys()
double	getMaxSelectedKeys()
long	getSelectCount()
Selector	getSelector()
int	getTotalKeys()
protected void	handleSelectFailure(Selector selector, Throwable failure)
protected int	nioSelect(Selector selector, boolean now)
protected void	onSelectFailed(Throwable cause)
private void	processConnect(SelectionKey key, ManagedSelector.Connect connect)
void	resetStats()
(package private) static int	safeInterestOps(SelectionKey selectionKey)
(package private) static int	safeReadyOps(SelectionKey selectionKey)
protected int	select(Selector selector)
int	size()
void	submit(ManagedSelector.SelectorUpdate update)	Submit an ManagedSelector.SelectorUpdate to be acted on between calls to Selector.select()
private void	submit(ManagedSelector.SelectorUpdate update, boolean lazy)
String	toString()
private void	wakeup()

Methods inherited from class ContainerLifeCycle

addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dump, dumpBeans, dumpObject, dumpObjects, dumpStdErr, dumpThis, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeans

Methods inherited from class AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface Dumpable

dump, dumpSelf

Methods inherited from interface Dumpable.DumpableContainer

isDumpable

Field Details

LOG

private static final Logger LOG

FORCE_SELECT_NOW

private static final boolean FORCE_SELECT_NOW

_started

private final AtomicBoolean _started

_selecting

private boolean _selecting

_selectorManager

private final SelectorManager _selectorManager

_id

private final int _id

_strategy

private final ExecutionStrategy _strategy

_selector

private Selector _selector

_updates

private Deque<ManagedSelector.SelectorUpdate> _updates

_updateable

private Deque<ManagedSelector.SelectorUpdate> _updateable

_keyStats

private final SampleStatistic _keyStats

Constructor Details

ManagedSelector

public ManagedSelector(SelectorManager selectorManager,
 int id)

Method Details

getSelector

public Selector getSelector()

doStart

protected void doStart()
                throws Exception

Description copied from class: ContainerLifeCycle

Starts the managed lifecycle beans in the order they were added.

Overrides:

doStart in class ContainerLifeCycle

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Description copied from class: ContainerLifeCycle

Stops the managed lifecycle beans in the reverse order they were added.

Overrides:

doStop in class ContainerLifeCycle

Throws:

Exception

getTotalKeys

@ManagedAttribute(value="Total number of keys",
                  readonly=true)
public int getTotalKeys()

getAverageSelectedKeys

@ManagedAttribute(value="Average number of selected keys",
                  readonly=true)
public double getAverageSelectedKeys()

getMaxSelectedKeys

@ManagedAttribute(value="Maximum number of selected keys",
                  readonly=true)
public double getMaxSelectedKeys()

getSelectCount

@ManagedAttribute(value="Total number of select() calls",
                  readonly=true)
public long getSelectCount()

resetStats

@ManagedOperation(value="Resets the statistics",
                  impact="ACTION")
public void resetStats()

nioSelect

protected int nioSelect(Selector selector,
 boolean now)
                 throws IOException

Throws:

IOException

select

protected int select(Selector selector)
              throws IOException

Throws:

IOException

handleSelectFailure

protected void handleSelectFailure(Selector selector,
 Throwable failure)
                            throws IOException

Throws:

IOException

onSelectFailed

protected void onSelectFailed(Throwable cause)

size

public int size()

submit

public void submit(ManagedSelector.SelectorUpdate update)

Submit an ManagedSelector.SelectorUpdate to be acted on between calls to Selector.select()

Parameters:

update - The selector update to apply at next wakeup

submit

private void submit(ManagedSelector.SelectorUpdate update,
 boolean lazy)

wakeup

private void wakeup()

execute

private void execute(Runnable task)

processConnect

private void processConnect(SelectionKey key,
 ManagedSelector.Connect connect)

endPointOpened

protected void endPointOpened(EndPoint endPoint)

endPointClosed

protected void endPointClosed(EndPoint endPoint)

createEndPoint

private void createEndPoint(SelectableChannel channel,
 SelectionKey selectionKey)
                     throws IOException

Throws:

IOException

destroyEndPoint

void destroyEndPoint(EndPoint endPoint)

getActionSize

private int getActionSize()

safeReadyOps

static int safeReadyOps(SelectionKey selectionKey)

safeInterestOps

static int safeInterestOps(SelectionKey selectionKey)

dump

public void dump(Appendable out,
 String indent)
          throws IOException

Description copied from interface: Dumpable

Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.

Specified by:

dump in interface Dumpable

Overrides:

dump in class ContainerLifeCycle

Parameters:

out - The appendable to dump to

indent - The indent to apply after any new lines.

Throws:

IOException - if unable to write to Appendable

toString

public String toString()

Overrides:

toString in class AbstractLifeCycle