Package org.jboss.netty.channel.socket.oio

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

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 by ChannelPipeline when a downstream ChannelEvent 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 by ChannelPipeline when a downstream ChannelEvent 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)