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

Class NioClientBoss

java.lang.Object

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

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

All Implemented Interfaces:

java.lang.Runnable, Boss, NioSelector

public final class NioClientBoss
extends AbstractNioSelector
implements Boss

Boss implementation that handles the connection attempts of clients

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	NioClientBoss.RegisterTask

Field Summary

Fields

Modifier and Type	Field	Description
private Timer	timer
private TimerTask	wakeupTask

Fields inherited from class org.jboss.netty.channel.socket.nio.AbstractNioSelector

logger, selector, startupLatch, thread, wakenUp

Constructor Summary

Constructors

Constructor	Description
NioClientBoss(java.util.concurrent.Executor bossExecutor, Timer timer, ThreadNameDeterminer determiner)

Method Summary

Modifier and Type	Method	Description
protected void	close(java.nio.channels.SelectionKey k)
private static void	connect(java.nio.channels.SelectionKey k)
protected java.lang.Runnable	createRegisterTask(Channel channel, ChannelFuture future)
protected ThreadRenamingRunnable	newThreadRenamingRunnable(int id, ThreadNameDeterminer determiner)
protected void	process(java.nio.channels.Selector selector)
private static void	processConnectTimeout(java.util.Set<java.nio.channels.SelectionKey> keys, long currentTimeNanos)
private void	processSelectedKeys(java.util.Set<java.nio.channels.SelectionKey> selectedKeys)

Methods inherited from class org.jboss.netty.channel.socket.nio.AbstractNioSelector

cleanUpCancelledKeys, increaseCancelledKeys, isIoThread, rebuildSelector, register, registerTask, run, select, 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

wakeupTask

private final TimerTask wakeupTask

timer

private final Timer timer

Constructor Detail

NioClientBoss

NioClientBoss(java.util.concurrent.Executor bossExecutor,
              Timer timer,
              ThreadNameDeterminer determiner)

Method Detail

newThreadRenamingRunnable

protected ThreadRenamingRunnable newThreadRenamingRunnable(int id,
                                                           ThreadNameDeterminer determiner)

Specified by:

newThreadRenamingRunnable in class AbstractNioSelector

createRegisterTask

protected java.lang.Runnable createRegisterTask(Channel channel,
                                                ChannelFuture future)

Specified by:

createRegisterTask in class AbstractNioSelector

process

protected void process(java.nio.channels.Selector selector)

Specified by:

process in class AbstractNioSelector

processSelectedKeys

private void processSelectedKeys(java.util.Set<java.nio.channels.SelectionKey> selectedKeys)

processConnectTimeout

private static void processConnectTimeout(java.util.Set<java.nio.channels.SelectionKey> keys,
                                          long currentTimeNanos)

connect

private static void connect(java.nio.channels.SelectionKey k)
                     throws java.io.IOException

Throws:

java.io.IOException

close

protected void close(java.nio.channels.SelectionKey k)

Specified by:

close in class AbstractNioSelector