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:

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 final class	NioClientBoss.RegisterTask

Field Summary

Fields

Modifier and Type	Field	Description
private final Timer	timer
private final TimerTask	wakeupTask

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

logger, selector, startupLatch, thread, wakenUp

Constructor Summary

Constructors

Constructor	Description
NioClientBoss(Executor bossExecutor, Timer timer, ThreadNameDeterminer determiner)

Method Summary

Modifier and Type	Method	Description
protected void	close(SelectionKey k)
private static void	connect(SelectionKey k)
protected Runnable	createRegisterTask(Channel channel, ChannelFuture future)
protected ThreadRenamingRunnable	newThreadRenamingRunnable(int id, ThreadNameDeterminer determiner)
protected void	process(Selector selector)
private static void	processConnectTimeout(Set<SelectionKey> keys, long currentTimeNanos)
private void	processSelectedKeys(Set<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 Details

wakeupTask

private final TimerTask wakeupTask

timer

private final Timer timer

Constructor Details

NioClientBoss

NioClientBoss(Executor bossExecutor,
 Timer timer,
 ThreadNameDeterminer determiner)

Method Details

newThreadRenamingRunnable

protected ThreadRenamingRunnable newThreadRenamingRunnable(int id,
 ThreadNameDeterminer determiner)

Specified by:

newThreadRenamingRunnable in class AbstractNioSelector

createRegisterTask

protected Runnable createRegisterTask(Channel channel,
 ChannelFuture future)

Specified by:

createRegisterTask in class AbstractNioSelector

process

protected void process(Selector selector)

Specified by:

process in class AbstractNioSelector

processSelectedKeys

private void processSelectedKeys(Set<SelectionKey> selectedKeys)

processConnectTimeout

private static void processConnectTimeout(Set<SelectionKey> keys,
 long currentTimeNanos)

connect

private static void connect(SelectionKey k)
                     throws IOException

Throws:

IOException

close

protected void close(SelectionKey k)

Specified by:

close in class AbstractNioSelector