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 final class	OioServerSocketPipelineSink.Boss

Field Summary

Fields

Modifier and Type	Field	Description
private final ThreadNameDeterminer	determiner
(package private) static final InternalLogger	logger
(package private) final Executor	workerExecutor

Constructor Summary

Constructors

Constructor	Description
OioServerSocketPipelineSink(Executor workerExecutor, ThreadNameDeterminer determiner)

Method Summary

Modifier and Type	Method	Description
private void	bind(OioServerSocketChannel channel, ChannelFuture future, 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 AbstractOioChannelSink

execute, isFireExceptionCaughtLater

Methods inherited from class AbstractChannelSink

exceptionCaught

Methods inherited from class Object

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

Field Details

logger

static final InternalLogger logger

workerExecutor

final Executor workerExecutor

determiner

private final ThreadNameDeterminer determiner

Constructor Details

OioServerSocketPipelineSink

OioServerSocketPipelineSink(Executor workerExecutor,
 ThreadNameDeterminer determiner)

Method Details

eventSunk

public void eventSunk(ChannelPipeline pipeline,
 ChannelEvent e)
               throws Exception

Description copied from interface: ChannelSink

Invoked by ChannelPipeline when a downstream ChannelEvent has reached its terminal (the head of the pipeline).

Throws:

Exception

handleServerSocket

private void handleServerSocket(ChannelEvent e)

handleAcceptedSocket

private static void handleAcceptedSocket(ChannelEvent e)

bind

private void bind(OioServerSocketChannel channel,
 ChannelFuture future,
 SocketAddress localAddress)

close

private static void close(OioServerSocketChannel channel,
 ChannelFuture future)