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
All Methods Static Methods Instance Methods Concrete Methods 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
-
-
-
-
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 classAbstractNioSelector
-
createRegisterTask
protected java.lang.Runnable createRegisterTask(Channel channel, ChannelFuture future)
- Specified by:
createRegisterTask
in classAbstractNioSelector
-
process
protected void process(java.nio.channels.Selector selector)
- Specified by:
process
in classAbstractNioSelector
-
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 classAbstractNioSelector
-
-