Package org.jboss.netty.channel.socket.nio

Class NioDatagramChannel

java.lang.Object

org.jboss.netty.channel.AbstractChannel

org.jboss.netty.channel.socket.nio.AbstractNioChannel<DatagramChannel>

org.jboss.netty.channel.socket.nio.NioDatagramChannel

All Implemented Interfaces:

Comparable<Channel>, Channel, DatagramChannel

public class NioDatagramChannel
extends AbstractNioChannel<DatagramChannel>
implements DatagramChannel

Provides an NIO based DatagramChannel.

Nested Class Summary

Nested classes/interfaces inherited from class org.jboss.netty.channel.socket.nio.AbstractNioChannel

AbstractNioChannel.WriteRequestQueue

Field Summary

Fields

Modifier and Type	Field	Description
private final NioDatagramChannelConfig	config	The DatagramChannelConfig.
private Map<InetAddress,List<MembershipKey>>	memberships

Fields inherited from class org.jboss.netty.channel.socket.nio.AbstractNioChannel

channel, currentWriteBuffer, currentWriteEvent, highWaterMarkCounter, inWriteNowLoop, remoteAddress, worker, writeBufferQueue, writeBufferSize, writeLock, writeSuspended, writeTask, writeTaskInTaskQueue

Fields inherited from interface org.jboss.netty.channel.Channel

OP_NONE, OP_READ, OP_READ_WRITE, OP_WRITE

Constructor Summary

Constructors

Constructor	Description
NioDatagramChannel(ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink, NioDatagramWorker worker, InternetProtocolFamily family)

Method Summary

Modifier and Type	Method	Description
ChannelFuture	block(InetAddress multicastAddress, InetAddress sourceToBlock)	Block the given sourceToBlock address for the given multicastAddress
ChannelFuture	block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock)	Block the given sourceToBlock address for the given multicastAddress on the given networkInterface
NioDatagramChannelConfig	getConfig()	Returns the configuration of this channel.
(package private) DatagramChannel	getDatagramChannel()
(package private) InetSocketAddress	getLocalSocketAddress()
(package private) InetSocketAddress	getRemoteSocketAddress()
NioDatagramWorker	getWorker()	Return the AbstractNioWorker that handle the IO of the AbstractNioChannel
boolean	isBound()	Returns true if and only if this channel is bound to a local address.
boolean	isConnected()	Returns true if and only if this channel is connected to a remote address.
ChannelFuture	joinGroup(InetAddress multicastAddress)	Joins a multicast group.
ChannelFuture	joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)	Joins the specified multicast group at the specified interface using the specified source.
ChannelFuture	joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)	Joins the specified multicast group at the specified interface.
ChannelFuture	leaveGroup(InetAddress multicastAddress)	Leaves a multicast group.
ChannelFuture	leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)	Leave the specified multicast group at the specified interface using the specified source.
ChannelFuture	leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)	Leaves a multicast group on a specified local interface.
private static DatagramChannel	openNonBlockingChannel(InternetProtocolFamily family)
protected boolean	setClosed()	Marks this channel as closed.
ChannelFuture	write(Object message, SocketAddress remoteAddress)	Sends a message to this channel asynchronously.

Methods inherited from class org.jboss.netty.channel.socket.nio.AbstractNioChannel

getInternalInterestOps, getLocalAddress, getRemoteAddress, setInternalInterestOps

Methods inherited from class org.jboss.netty.channel.AbstractChannel

bind, close, compareTo, connect, disconnect, equals, getAttachment, getCloseFuture, getFactory, getId, getInterestOps, getParent, getPipeline, getSucceededFuture, getUnsupportedOperationFuture, getUserDefinedWritability, hashCode, isOpen, isReadable, isWritable, setAttachment, setInterestOps, setReadable, setUnwritable, setUserDefinedWritability, setWritable, toString, unbind, write

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.jboss.netty.channel.Channel

bind, close, connect, disconnect, getAttachment, getCloseFuture, getFactory, getId, getInterestOps, getParent, getPipeline, getUserDefinedWritability, isOpen, isReadable, isWritable, setAttachment, setInterestOps, setReadable, setUserDefinedWritability, unbind, write

Methods inherited from interface java.lang.Comparable

compareTo

Methods inherited from interface org.jboss.netty.channel.socket.DatagramChannel

getLocalAddress, getRemoteAddress

Field Details

config

private final NioDatagramChannelConfig config

The DatagramChannelConfig.

memberships

private Map<InetAddress,List<MembershipKey>> memberships

Constructor Details

NioDatagramChannel

NioDatagramChannel(ChannelFactory factory,
 ChannelPipeline pipeline,
 ChannelSink sink,
 NioDatagramWorker worker,
 InternetProtocolFamily family)

Method Details

openNonBlockingChannel

private static DatagramChannel openNonBlockingChannel(InternetProtocolFamily family)

getWorker

public NioDatagramWorker getWorker()

Description copied from class: AbstractNioChannel

Return the AbstractNioWorker that handle the IO of the AbstractNioChannel

Overrides:

getWorker in class AbstractNioChannel<DatagramChannel>

Returns:

worker

isBound

public boolean isBound()

Description copied from interface: Channel

Returns true if and only if this channel is bound to a local address.

Specified by:

isBound in interface Channel

isConnected

public boolean isConnected()

Description copied from interface: Channel

Returns true if and only if this channel is connected to a remote address.

Specified by:

isConnected in interface Channel

setClosed

protected boolean setClosed()

Description copied from class: AbstractChannel

Marks this channel as closed. This method is intended to be called by an internal component - please do not call it unless you know what you are doing.

Overrides:

setClosed in class AbstractNioChannel<DatagramChannel>

Returns:

true if and only if this channel was not marked as closed yet

getConfig

public NioDatagramChannelConfig getConfig()

Description copied from interface: Channel

Returns the configuration of this channel.

Specified by:

getConfig in interface Channel

Specified by:

getConfig in interface DatagramChannel

Specified by:

getConfig in class AbstractNioChannel<DatagramChannel>

getDatagramChannel

DatagramChannel getDatagramChannel()

joinGroup

public ChannelFuture joinGroup(InetAddress multicastAddress)

Description copied from interface: DatagramChannel

Joins a multicast group.

Specified by:

joinGroup in interface DatagramChannel

joinGroup

public ChannelFuture joinGroup(InetSocketAddress multicastAddress,
 NetworkInterface networkInterface)

Description copied from interface: DatagramChannel

Joins the specified multicast group at the specified interface.

Specified by:

joinGroup in interface DatagramChannel

joinGroup

public ChannelFuture joinGroup(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress source)

Joins the specified multicast group at the specified interface using the specified source.

leaveGroup

public ChannelFuture leaveGroup(InetAddress multicastAddress)

Description copied from interface: DatagramChannel

Leaves a multicast group.

Specified by:

leaveGroup in interface DatagramChannel

leaveGroup

public ChannelFuture leaveGroup(InetSocketAddress multicastAddress,
 NetworkInterface networkInterface)

Description copied from interface: DatagramChannel

Leaves a multicast group on a specified local interface.

Specified by:

leaveGroup in interface DatagramChannel

leaveGroup

public ChannelFuture leaveGroup(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress source)

Leave the specified multicast group at the specified interface using the specified source.

block

public ChannelFuture block(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress sourceToBlock)

Block the given sourceToBlock address for the given multicastAddress on the given networkInterface

block

public ChannelFuture block(InetAddress multicastAddress,
 InetAddress sourceToBlock)

Block the given sourceToBlock address for the given multicastAddress

getLocalSocketAddress

InetSocketAddress getLocalSocketAddress()
                                 throws Exception

Specified by:

getLocalSocketAddress in class AbstractNioChannel<DatagramChannel>

Throws:

Exception

getRemoteSocketAddress

InetSocketAddress getRemoteSocketAddress()
                                  throws Exception

Specified by:

getRemoteSocketAddress in class AbstractNioChannel<DatagramChannel>

Throws:

Exception

write

public ChannelFuture write(Object message,
 SocketAddress remoteAddress)

Description copied from interface: Channel

Sends a message to this channel asynchronously. It has an additional parameter that allows a user to specify where to send the specified message instead of this channel's current remote address. If this channel was created by a connectionless transport (e.g. DatagramChannel) and is not connected yet, you must specify non-null address. Otherwise, the write request will fail with NotYetConnectedException and an 'exceptionCaught' event will be triggered.

Specified by:

write in interface Channel

Overrides:

write in class AbstractChannel

Parameters:

message - the message to write

remoteAddress - where to send the specified message. This method is identical to Channel.write(Object) if null is specified here.

Returns:

the ChannelFuture which will be notified when the write request succeeds or fails