Class OioServerSocketPipelineSink
- java.lang.Object
-
- org.jboss.netty.channel.AbstractChannelSink
-
- org.jboss.netty.channel.socket.oio.AbstractOioChannelSink
-
- org.jboss.netty.channel.socket.oio.OioServerSocketPipelineSink
-
- All Implemented Interfaces:
ChannelSink
class OioServerSocketPipelineSink extends AbstractOioChannelSink
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
OioServerSocketPipelineSink.Boss
-
Field Summary
Fields Modifier and Type Field Description private ThreadNameDeterminer
determiner
(package private) static InternalLogger
logger
(package private) java.util.concurrent.Executor
workerExecutor
-
Constructor Summary
Constructors Constructor Description OioServerSocketPipelineSink(java.util.concurrent.Executor workerExecutor, ThreadNameDeterminer determiner)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
bind(OioServerSocketChannel channel, ChannelFuture future, java.net.SocketAddress localAddress)
private static void
close(OioServerSocketChannel channel, ChannelFuture future)
void
eventSunk(ChannelPipeline pipeline, ChannelEvent e)
Invoked byChannelPipeline
when a downstreamChannelEvent
has reached its terminal (the head of the pipeline).private static void
handleAcceptedSocket(ChannelEvent e)
private void
handleServerSocket(ChannelEvent e)
-
Methods inherited from class org.jboss.netty.channel.socket.oio.AbstractOioChannelSink
execute, isFireExceptionCaughtLater
-
Methods inherited from class org.jboss.netty.channel.AbstractChannelSink
exceptionCaught
-
-
-
-
Field Detail
-
logger
static final InternalLogger logger
-
workerExecutor
final java.util.concurrent.Executor workerExecutor
-
determiner
private final ThreadNameDeterminer determiner
-
-
Constructor Detail
-
OioServerSocketPipelineSink
OioServerSocketPipelineSink(java.util.concurrent.Executor workerExecutor, ThreadNameDeterminer determiner)
-
-
Method Detail
-
eventSunk
public void eventSunk(ChannelPipeline pipeline, ChannelEvent e) throws java.lang.Exception
Description copied from interface:ChannelSink
Invoked byChannelPipeline
when a downstreamChannelEvent
has reached its terminal (the head of the pipeline).- Throws:
java.lang.Exception
-
handleServerSocket
private void handleServerSocket(ChannelEvent e)
-
handleAcceptedSocket
private static void handleAcceptedSocket(ChannelEvent e)
-
bind
private void bind(OioServerSocketChannel channel, ChannelFuture future, java.net.SocketAddress localAddress)
-
close
private static void close(OioServerSocketChannel channel, ChannelFuture future)
-
-