Package org.jboss.netty.channel.socket.nio

Class AbstractNioSelector

java.lang.Object

org.jboss.netty.channel.socket.nio.AbstractNioSelector

All Implemented Interfaces:

Runnable, NioSelector

Direct Known Subclasses:

AbstractNioWorker, NioClientBoss, NioServerBoss

abstract class AbstractNioSelector
extends Object
implements NioSelector

Field Summary

Fields

Modifier and Type	Field	Description
private int	cancelledKeys
private static final int	CLEANUP_INTERVAL
private final Executor	executor	Executor used to execute Runnables such as channel registration task.
private final int	id
protected static final InternalLogger	logger	Internal Netty logger.
private static final AtomicInteger	nextId
protected Selector	selector	The NIO Selector.
private boolean	shutdown
private final CountDownLatch	shutdownLatch
(package private) final CountDownLatch	startupLatch	Count down to 0 when the I/O thread starts and thread is set to non-null.
private final Queue<Runnable>	taskQueue
protected Thread	thread	If this worker has been started thread will be a reference to the thread used when starting.
protected final AtomicBoolean	wakenUp	Boolean that controls determines if a blocked Selector.select should break out of its selection process.

Constructor Summary

Constructors

Constructor	Description
AbstractNioSelector(Executor executor)
AbstractNioSelector(Executor executor, ThreadNameDeterminer determiner)

Method Summary

Modifier and Type	Method	Description
protected final boolean	cleanUpCancelledKeys()
protected abstract void	close(SelectionKey k)
protected abstract Runnable	createRegisterTask(Channel channel, ChannelFuture future)
protected final void	increaseCancelledKeys()
protected final boolean	isIoThread()
protected abstract ThreadRenamingRunnable	newThreadRenamingRunnable(int id, ThreadNameDeterminer determiner)
private void	openSelector(ThreadNameDeterminer determiner)	Start the AbstractNioWorker and return the Selector that will be used for the AbstractNioChannel's when they get registered
protected abstract void	process(Selector selector)
private void	processTaskQueue()
void	rebuildSelector()	Replaces the current Selector with a new Selector to work around the infamous epoll 100% CPU bug.
void	register(Channel channel, ChannelFuture future)
protected final void	registerTask(Runnable task)
void	run()
protected int	select(Selector selector)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Details

nextId

private static final AtomicInteger nextId

id

private final int id

logger

protected static final InternalLogger logger

Internal Netty logger.

CLEANUP_INTERVAL

private static final int CLEANUP_INTERVAL

See Also:

• Constant Field Values

executor

private final Executor executor

Executor used to execute Runnables such as channel registration task.

thread

protected volatile Thread thread

If this worker has been started thread will be a reference to the thread used when starting. i.e. the current thread when the run method is executed.

startupLatch

final CountDownLatch startupLatch

Count down to 0 when the I/O thread starts and thread is set to non-null.

selector

protected volatile Selector selector

The NIO Selector.

wakenUp

protected final AtomicBoolean wakenUp

Boolean that controls determines if a blocked Selector.select should break out of its selection process. In our case we use a timeone for the select method and the select method will block for that time unless waken up.

taskQueue

private final Queue<Runnable> taskQueue

cancelledKeys

private volatile int cancelledKeys

shutdownLatch

private final CountDownLatch shutdownLatch

shutdown

private volatile boolean shutdown

Constructor Details

AbstractNioSelector

AbstractNioSelector(Executor executor)

AbstractNioSelector

AbstractNioSelector(Executor executor,
 ThreadNameDeterminer determiner)

Method Details

register

public void register(Channel channel,
 ChannelFuture future)

Specified by:

register in interface NioSelector

registerTask

protected final void registerTask(Runnable task)

isIoThread

protected final boolean isIoThread()

rebuildSelector

public void rebuildSelector()

Description copied from interface: NioSelector

Replaces the current Selector with a new Selector to work around the infamous epoll 100% CPU bug.

Specified by:

rebuildSelector in interface NioSelector

run

public void run()

Specified by:

run in interface Runnable

openSelector

private void openSelector(ThreadNameDeterminer determiner)

Start the AbstractNioWorker and return the Selector that will be used for the AbstractNioChannel's when they get registered

processTaskQueue

private void processTaskQueue()

increaseCancelledKeys

protected final void increaseCancelledKeys()

cleanUpCancelledKeys

protected final boolean cleanUpCancelledKeys()
                                      throws IOException

Throws:

IOException

shutdown

public void shutdown()

Specified by:

shutdown in interface NioSelector

process

protected abstract void process(Selector selector)
                         throws IOException

Throws:

IOException

select

protected int select(Selector selector)
              throws IOException

Throws:

IOException

close

protected abstract void close(SelectionKey k)

newThreadRenamingRunnable

protected abstract ThreadRenamingRunnable newThreadRenamingRunnable(int id,
 ThreadNameDeterminer determiner)

createRegisterTask

protected abstract Runnable createRegisterTask(Channel channel,
 ChannelFuture future)