org.eclipse.jetty.io

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, 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 and Description
(package private) class	ManagedSelector.Accept
(package private) class	ManagedSelector.Acceptor
private class	ManagedSelector.CloseConnections
(package private) class	ManagedSelector.Connect
private 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.StopSelector

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field and Description
private int	_id
private boolean	_selecting
private java.nio.channels.Selector	_selector
private SelectorManager	_selectorManager
private java.util.concurrent.atomic.AtomicBoolean	_started
private ExecutionStrategy	_strategy
private java.util.Deque<ManagedSelector.SelectorUpdate>	_updateable
private java.util.Deque<ManagedSelector.SelectorUpdate>	_updates
private static Logger	LOG

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOP_ON_FAILURE, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor and Description
ManagedSelector(SelectorManager selectorManager, int id)

Method Summary

Modifier and Type	Method and Description
private static void	closeNoExceptions(java.io.Closeable closeable)
private void	createEndPoint(java.nio.channels.SelectableChannel channel, java.nio.channels.SelectionKey selectionKey)
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(java.lang.Appendable out, java.lang.String indent)
private void	execute(java.lang.Runnable task)
private int	getActionSize()
java.nio.channels.Selector	getSelector()
private void	processConnect(java.nio.channels.SelectionKey key, ManagedSelector.Connect connect)
int	size()
void	submit(ManagedSelector.SelectorUpdate update) Submit an ManagedSelector.SelectorUpdate to be acted on between calls to Selector.select()
java.lang.String	toString()

Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle

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

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump

Methods inherited from interface org.eclipse.jetty.util.component.LifeCycle

start, stop

Field Detail

LOG

private static final Logger LOG

_started

private final java.util.concurrent.atomic.AtomicBoolean _started

_selecting

private boolean _selecting

_selectorManager

private final SelectorManager _selectorManager

_id

private final int _id

_strategy

private final ExecutionStrategy _strategy

_selector

private java.nio.channels.Selector _selector

_updates

private java.util.Deque<ManagedSelector.SelectorUpdate> _updates

_updateable

private java.util.Deque<ManagedSelector.SelectorUpdate> _updateable

Constructor Detail

ManagedSelector

public ManagedSelector(SelectorManager selectorManager,
                       int id)

Method Detail

getSelector

public java.nio.channels.Selector getSelector()

doStart

protected void doStart()
                throws java.lang.Exception

Description copied from class: ContainerLifeCycle

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

Overrides:

doStart in class ContainerLifeCycle

Throws:

java.lang.Exception

size

public int size()

doStop

protected void doStop()
               throws java.lang.Exception

Description copied from class: ContainerLifeCycle

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

Overrides:

doStop in class ContainerLifeCycle

Throws:

java.lang.Exception

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

execute

private void execute(java.lang.Runnable task)

processConnect

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

closeNoExceptions

private static void closeNoExceptions(java.io.Closeable closeable)

createEndPoint

private void createEndPoint(java.nio.channels.SelectableChannel channel,
                            java.nio.channels.SelectionKey selectionKey)
                     throws java.io.IOException

Throws:

java.io.IOException

destroyEndPoint

public void destroyEndPoint(EndPoint endPoint)

getActionSize

private int getActionSize()

dump

public void dump(java.lang.Appendable out,
                 java.lang.String indent)
          throws java.io.IOException

Specified by:

dump in interface Dumpable

Overrides:

dump in class ContainerLifeCycle

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object