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

Class NioServerBoss

java.lang.Object

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

org.jboss.netty.channel.socket.nio.NioServerBoss

All Implemented Interfaces:

Runnable, Boss, NioSelector

public final class NioServerBoss
extends AbstractNioSelector
implements Boss

Boss implementation which handles accepting of new connections

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	NioServerBoss.RegisterTask

Field Summary

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

logger, selector, startupLatch, thread, wakenUp

Constructor Summary

Constructors

Constructor	Description
NioServerBoss(Executor bossExecutor)
NioServerBoss(Executor bossExecutor, ThreadNameDeterminer determiner)

Method Summary

Modifier and Type	Method	Description
(package private) void	bind(NioServerSocketChannel channel, ChannelFuture future, SocketAddress localAddress)
protected void	close(SelectionKey k)
(package private) void	close(NioServerSocketChannel channel, ChannelFuture future)
protected Runnable	createRegisterTask(Channel channel, ChannelFuture future)
protected ThreadRenamingRunnable	newThreadRenamingRunnable(int id, ThreadNameDeterminer determiner)
protected void	process(Selector selector)
private static void	registerAcceptedChannel(NioServerSocketChannel parent, SocketChannel acceptedSocket, Thread currentThread)
protected int	select(Selector selector)

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

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

Constructor Details

NioServerBoss

NioServerBoss(Executor bossExecutor)

NioServerBoss

NioServerBoss(Executor bossExecutor,
 ThreadNameDeterminer determiner)

Method Details

bind

void bind(NioServerSocketChannel channel,
 ChannelFuture future,
 SocketAddress localAddress)

close

protected void close(SelectionKey k)

Specified by:

close in class AbstractNioSelector

close

void close(NioServerSocketChannel channel,
 ChannelFuture future)

process

protected void process(Selector selector)

Specified by:

process in class AbstractNioSelector

registerAcceptedChannel

private static void registerAcceptedChannel(NioServerSocketChannel parent,
 SocketChannel acceptedSocket,
 Thread currentThread)

select

protected int select(Selector selector)
              throws IOException

Overrides:

select in class AbstractNioSelector

Throws:

IOException

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