Class NioDatagramPipelineSink

java.lang.Object

org.jboss.netty.channel.AbstractChannelSink

org.jboss.netty.channel.socket.nio.AbstractNioChannelSink

org.jboss.netty.channel.socket.nio.NioDatagramPipelineSink

All Implemented Interfaces:

ChannelSink

class NioDatagramPipelineSink
extends AbstractNioChannelSink

Receives downstream events from a ChannelPipeline. It contains an array of I/O workers.

Field Summary

Fields

Modifier and Type	Field	Description
private final WorkerPool<NioDatagramWorker>	workerPool

Constructor Summary

Constructors

Constructor	Description
NioDatagramPipelineSink(WorkerPool<NioDatagramWorker> workerPool)	Creates a new NioDatagramPipelineSink with a the number of NioDatagramWorkers specified in workerCount.

Method Summary

Modifier and Type	Method	Description
private static void	bind(NioDatagramChannel channel, ChannelFuture future, InetSocketAddress address)	Will bind the DatagramSocket to the passed-in address.
private static void	close(NioDatagramChannel channel, ChannelFuture future)
private static void	connect(NioDatagramChannel channel, ChannelFuture future, InetSocketAddress remoteAddress)
void	eventSunk(ChannelPipeline pipeline, ChannelEvent e)	Handle downstream event.
(package private) NioDatagramWorker	nextWorker()

Methods inherited from class AbstractNioChannelSink

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

workerPool

private final WorkerPool<NioDatagramWorker> workerPool

Constructor Details

NioDatagramPipelineSink

NioDatagramPipelineSink(WorkerPool<NioDatagramWorker> workerPool)

Creates a new NioDatagramPipelineSink with a the number of NioDatagramWorkers specified in workerCount. The NioDatagramWorkers take care of reading and writing for the NioDatagramChannel.

Parameters:

workerExecutor - the Executor that will run the NioDatagramWorkers for this sink

workerCount - the number of NioDatagramWorkers for this sink

Method Details

eventSunk

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

Handle downstream event.

Parameters:

pipeline - the ChannelPipeline that passes down the downstream event.

e - The downstream event.

Throws:

Exception

close

private static void close(NioDatagramChannel channel,
 ChannelFuture future)

bind

private static void bind(NioDatagramChannel channel,
 ChannelFuture future,
 InetSocketAddress address)

Will bind the DatagramSocket to the passed-in address. Every call bind will spawn a new thread using the that basically in turn

connect

private static void connect(NioDatagramChannel channel,
 ChannelFuture future,
 InetSocketAddress remoteAddress)

nextWorker

NioDatagramWorker nextWorker()