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

Class NioClientBoss

java.lang.Object

org.jboss.netty.channel.socket.nio.NioClientBoss

All Implemented Interfaces:

Runnable, Boss, NioSelector

public final class NioClientBoss
extends Object
implements Boss

Boss implementation that handles the connection attempts of clients

Field Summary

Fields

Modifier and Type	Field	Description
protected static InternalLogger	logger	Internal Netty logger.
protected Selector	selector	The NIO Selector.
protected Thread	thread	If this worker has been started thread will be a reference to the thread used when starting.
protected AtomicBoolean	wakenUp	Boolean that controls determines if a blocked Selector.select should break out of its selection process.

Method Summary

Modifier and Type	Method	Description
protected boolean	cleanUpCancelledKeys()
protected void	close(SelectionKey k)
protected Runnable	createRegisterTask(Channel channel, ChannelFuture future)
protected void	increaseCancelledKeys()
protected boolean	isIoThread()
protected ThreadRenamingRunnable	newThreadRenamingRunnable(int id, ThreadNameDeterminer determiner)
protected void	process(Selector selector)
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 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

Methods inherited from interface org.jboss.netty.channel.socket.nio.NioSelector

rebuildSelector, register, shutdown

Methods inherited from interface java.lang.Runnable

run

Field Detail

logger

protected static final InternalLogger logger

Internal Netty logger.

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.

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.

Method Detail

newThreadRenamingRunnable

protected ThreadRenamingRunnable newThreadRenamingRunnable(int id,
                                                           ThreadNameDeterminer determiner)

createRegisterTask

protected Runnable createRegisterTask(Channel channel,
                                      ChannelFuture future)

process

protected void process(Selector selector)

close

protected void close(SelectionKey k)

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

increaseCancelledKeys

protected final void increaseCancelledKeys()

cleanUpCancelledKeys

protected final boolean cleanUpCancelledKeys()
                                      throws IOException

Throws:

IOException

shutdown

public void shutdown()

Specified by:

shutdown in interface NioSelector

select

protected int select(Selector selector)
              throws IOException

Throws:

IOException