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
Boss implementation which handles accepting of new connections
-
Nested Class Summary
Nested Classes -
Field Summary
Fields inherited from class org.jboss.netty.channel.socket.nio.AbstractNioSelector
logger, selector, startupLatch, thread, wakenUp
-
Constructor Summary
ConstructorsConstructorDescriptionNioServerBoss
(Executor bossExecutor) NioServerBoss
(Executor bossExecutor, ThreadNameDeterminer determiner) -
Method Summary
Modifier and TypeMethodDescription(package private) void
bind
(NioServerSocketChannel channel, ChannelFuture future, SocketAddress localAddress) protected void
(package private) void
close
(NioServerSocketChannel channel, ChannelFuture future) protected Runnable
createRegisterTask
(Channel channel, ChannelFuture future) protected ThreadRenamingRunnable
newThreadRenamingRunnable
(int id, ThreadNameDeterminer determiner) protected void
private static void
registerAcceptedChannel
(NioServerSocketChannel parent, SocketChannel acceptedSocket, Thread currentThread) protected int
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
-
Constructor Details
-
NioServerBoss
NioServerBoss(Executor bossExecutor) -
NioServerBoss
NioServerBoss(Executor bossExecutor, ThreadNameDeterminer determiner)
-
-
Method Details
-
bind
-
close
- Specified by:
close
in classAbstractNioSelector
-
close
-
process
- Specified by:
process
in classAbstractNioSelector
-
registerAcceptedChannel
private static void registerAcceptedChannel(NioServerSocketChannel parent, SocketChannel acceptedSocket, Thread currentThread) -
select
- Overrides:
select
in classAbstractNioSelector
- Throws:
IOException
-
newThreadRenamingRunnable
- Specified by:
newThreadRenamingRunnable
in classAbstractNioSelector
-
createRegisterTask
- Specified by:
createRegisterTask
in classAbstractNioSelector
-