Grizzly NIO 5.0.2 · org.glassfish.grizzly.nio.transport.UDPNIOConnection

Modifier and Type	Field and Description
pack-priv Holder<SocketAddress>	localSocketAddressHolder
private static final Logger	LOGGER Hides org.glassfish.grizzly.nio.NIOConnection.LOGGER.
private Map<InetAddress, Set<MembershipKey>>	membershipKeysMap
private final Object	multicastSync
pack-priv Holder<SocketAddress>	peerSocketAddressHolder
private int	readBufferSize
private int	writeBufferSize

Access	Constructor and Description
public	UDPNIOConnection(UDPNIOTransport transport, DatagramChannel channel)

Method Summary

Modifier and Type	Method and Description
public void	block(final InetAddress The multicast address to join group, final NetworkInterface The network interface on which to join the group networkInterface, final InetAddress The source address to block source) Blocks multicast datagrams from the given source address.
public boolean	canWrite() Implements org.glassfish.grizzly.OutputSink.canWrite.
public boolean	canWrite(int length) Implements org.glassfish.grizzly.OutputSink.canWrite. Deprecated
public void	drop(final InetAddress The multicast address to join group, final NetworkInterface The network interface on which to join the group networkInterface) Drops non-source specific membership in a multicast group.
public void	drop(final InetAddress The multicast address to join group, final NetworkInterface The network interface on which to join the group networkInterface, final InetAddress The source address source) Drops membership in a multicast group.
public void	dropAll(final InetAddress The multicast address to join group, final NetworkInterface The network interface on which to join the group networkInterface) Drops all active membership in a multicast group.
protected void	enableInitialOpRead() Overrides org.glassfish.grizzly.nio.NIOConnection.enableInitialOpRead. Enables OP_READ if it has never been enabled before.
public SocketAddress	Returns: the local address of this `Connection`, or `null` if it is unconnected. getLocalAddress() Implements org.glassfish.grizzly.Connection.getLocalAddress. Returns the local address of this `Connection`, or `null` if it is unconnected.
public SocketAddress	Returns: the address of the endpoint this `Connection` is connected to, or `null` if it is unconnected. getPeerAddress() Implements org.glassfish.grizzly.Connection.getPeerAddress. Returns the address of the endpoint this `Connection` is connected to, or `null` if it is unconnected.
public int	getReadBufferSize() Implements org.glassfish.grizzly.Connection.getReadBufferSize. Get the default size of `Buffer`s, which will be allocated for reading data from `Connection`.
public int	getWriteBufferSize() Implements org.glassfish.grizzly.Connection.getWriteBufferSize. Get the default size of `Buffer`s, which will be allocated for writing data to `Connection`.
public boolean	isConnected()
public void	join(final InetAddress The multicast address to join group, final NetworkInterface The network interface on which to join the group networkInterface) Joins a multicast group to begin receiving all datagrams sent to the group.
public void	join(final InetAddress The multicast address to join group, final NetworkInterface The network interface on which to join the group networkInterface, final InetAddress The source address source) Joins a multicast group to begin receiving datagrams sent to the group from a given source address.
public void	notifyCanWrite(final WriteHandler writeHandler) Implements org.glassfish.grizzly.OutputSink.notifyCanWrite. Instructs the `OutputSink` to invoke the provided `WriteHandler` when it is possible to write more bytes (or characters).
public void	notifyCanWrite(WriteHandler handler, int length) Implements org.glassfish.grizzly.OutputSink.notifyCanWrite. Deprecated Instructs the `OutputSink` to invoke the provided `WriteHandler` when it is possible to write `length` bytes (or characters).
protected boolean	notifyReady()
protected final void	onConnect() Method will be called, when the connection gets connected.
protected final void	onRead(Buffer data, int size) Method will be called, when some data was read on the connection
protected final void	onWrite(Buffer data, int size) Method will be called, when some data was written on the connection
protected final void	resetProperties()
pack-priv void	setMonitoringProbes(final ConnectionProbe[] monitoringProbes) Hides org.glassfish.grizzly.nio.NIOConnection.setMonitoringProbes. Set the monitoringProbes array directly.
public void	setReadBufferSize(final int readBufferSize) Implements org.glassfish.grizzly.Connection.setReadBufferSize. Set the default size of `Buffer`s, which will be allocated for reading data from `Connection`.
protected void	setSelectionKey(SelectionKey selectionKey) Overrides org.glassfish.grizzly.nio.NIOConnection.setSelectionKey.
protected void	setSelectorRunner(SelectorRunner selectorRunner) Overrides org.glassfish.grizzly.nio.NIOConnection.setSelectorRunner.
public void	setWriteBufferSize(int writeBufferSize) Implements org.glassfish.grizzly.Connection.setWriteBufferSize. Set the default size of `Buffer`s, which will be allocated for writing data to `Connection`.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
public void	unblock(final InetAddress The multicast address to join group, final NetworkInterface The network interface on which to join the group networkInterface, final InetAddress The source address to block source) Unblocks multicast datagrams from the given source address.

Inherited from org.glassfish.grizzly.nio.NIOConnection:: addCloseListener addCloseListener assertOpen attachToSelectorRunner checkEmptyRead close close closeFuture closeGracefully0 closeSilently closeWithReason configureBlocking configureStandalone detachSelectorRunner disableIOEvent doClose enableIOEvent executeInEventThread getAsyncReadQueue getAsyncWriteQueue getAttributes getChannel getCloseReason getId getMaxAsyncWriteQueueSize getMemoryManager getMonitoringConfig getProcessor getProcessorSelector getReadTimeout getSelectionKey getSelectorRunner getTransport getWriteTimeout isBlocking isClosed isOpen isStandalone notifyConnectionError notifyIOEventDisabled notifyIOEventEnabled notifyIOEventReady notifyProbesAccept notifyProbesBind notifyProbesClose notifyProbesConnect notifyProbesError notifyProbesRead notifyProbesWrite obtainProcessor obtainProcessorState preClose read read removeCloseListener removeCloseListener setChannel setMaxAsyncWriteQueueSize setProcessor setProcessorSelector setReadTimeout setWriteTimeout simulateIOEvent terminate terminate0 terminateSilently terminateWithReason write write write write write

localSocketAddressHolder	back to summary
pack-priv Holder<SocketAddress> localSocketAddressHolder

LOGGER	back to summary
private static final Logger LOGGER Hides org.glassfish.grizzly.nio.NIOConnection.LOGGER.

membershipKeysMap	back to summary
private Map<InetAddress, Set<MembershipKey>> membershipKeysMap

multicastSync	back to summary
private final Object multicastSync

peerSocketAddressHolder	back to summary
pack-priv Holder<SocketAddress> peerSocketAddressHolder

readBufferSize	back to summary
private int readBufferSize

writeBufferSize	back to summary
private int writeBufferSize

UDPNIOConnection	back to summary
public UDPNIOConnection(UDPNIOTransport transport, DatagramChannel channel)

Method Detail

block	back to summary
public void block(final InetAddress group, final NetworkInterface networkInterface, final InetAddress source) throws IOException Blocks multicast datagrams from the given source address. If this connection has non-source specific membership in the group on the given interface then this method blocks multicast datagrams from the given source address. If the given source address is already blocked then this method has no effect. Parameters group:InetAddress The multicast address to join networkInterface:NetworkInterface The network interface on which to join the group source:InetAddress The source address to block

block

back to summary

public void block(final InetAddress group, final NetworkInterface networkInterface, final InetAddress source) throws IOException

Blocks multicast datagrams from the given source address. If this connection has non-source specific membership in the group on the given interface then this method blocks multicast datagrams from the given source address. If the given source address is already blocked then this method has no effect.

Parameters

group:InetAddress: The multicast address to join
networkInterface:NetworkInterface: The network interface on which to join the group
source:InetAddress: The source address to block

canWrite	back to summary
public boolean canWrite() Implements org.glassfish.grizzly.OutputSink.canWrite. Annotations @Override

canWrite

back to summary

public boolean canWrite()

Implements org.glassfish.grizzly.OutputSink.canWrite.

Annotations

@Override

canWrite	back to summary
public boolean canWrite(int length) Implements org.glassfish.grizzly.OutputSink.canWrite. Deprecated Annotations @Deprecated @Override

canWrite

back to summary

public boolean canWrite(int length)

Implements org.glassfish.grizzly.OutputSink.canWrite.

Deprecated

Annotations

@Deprecated
@Override

drop	back to summary
public void drop(final InetAddress group, final NetworkInterface networkInterface) throws IOException Drops non-source specific membership in a multicast group. If this connection doesn't have non-source specific membership in the group on the given interface to receive datagrams then this method call has no effect. Otherwise this connection drops the group membership. Parameters group:InetAddress The multicast address to join networkInterface:NetworkInterface The network interface on which to join the group

drop

back to summary

public void drop(final InetAddress group, final NetworkInterface networkInterface) throws IOException

Drops non-source specific membership in a multicast group. If this connection doesn't have non-source specific membership in the group on the given interface to receive datagrams then this method call has no effect. Otherwise this connection drops the group membership.

Parameters

group:InetAddress: The multicast address to join
networkInterface:NetworkInterface: The network interface on which to join the group

drop back to summary

drop	back to summary
public void drop(final InetAddress group, final NetworkInterface networkInterface, final InetAddress source) throws IOException Drops membership in a multicast group. If the source parameter is null - this method call is equivalent to `drop(java.net.InetAddress, java.net.NetworkInterface)`. If the source parameter is not null and this connection doesn't have source specific membership in the group on the given interface to receive datagrams then this method call has no effect. Otherwise this connection drops the source specific group membership. Parameters group:InetAddress The multicast address to join networkInterface:NetworkInterface The network interface on which to join the group source:InetAddress The source address

public void drop(final InetAddress group, final NetworkInterface networkInterface, final InetAddress source) throws IOException

Drops membership in a multicast group. If the source parameter is null - this method call is equivalent to drop(java.net.InetAddress, java.net.NetworkInterface). If the source parameter is not null and this connection doesn't have source specific membership in the group on the given interface to receive datagrams then this method call has no effect. Otherwise this connection drops the source specific group membership.

Parameters

group:InetAddress: The multicast address to join
networkInterface:NetworkInterface: The network interface on which to join the group
source:InetAddress: The source address

dropAll	back to summary
public void dropAll(final InetAddress group, final NetworkInterface networkInterface) throws IOException Drops all active membership in a multicast group. If this connection doesn't have any type of membership in the group on the given interface to receive datagrams then this method call has no effect. Otherwise this connection drops all types of the group membership. Parameters group:InetAddress The multicast address to join networkInterface:NetworkInterface The network interface on which to join the group

dropAll

back to summary

public void dropAll(final InetAddress group, final NetworkInterface networkInterface) throws IOException

Drops all active membership in a multicast group. If this connection doesn't have any type of membership in the group on the given interface to receive datagrams then this method call has no effect. Otherwise this connection drops all types of the group membership.

Parameters

group:InetAddress: The multicast address to join
networkInterface:NetworkInterface: The network interface on which to join the group

enableInitialOpRead	back to summary
protected void enableInitialOpRead() throws IOException Overrides org.glassfish.grizzly.nio.NIOConnection.enableInitialOpRead. Doc from org.glassfish.grizzly.nio.NIOConnection.enableInitialOpRead. Enables OP_READ if it has never been enabled before. Annotations @Override

enableInitialOpRead

back to summary

protected void enableInitialOpRead() throws IOException

Overrides org.glassfish.grizzly.nio.NIOConnection.enableInitialOpRead.

Doc from org.glassfish.grizzly.nio.NIOConnection.enableInitialOpRead.

Enables OP_READ if it has never been enabled before.

Annotations

@Override

getLocalAddress back to summary

getLocalAddress	back to summary
public SocketAddress getLocalAddress() Implements org.glassfish.grizzly.Connection.getLocalAddress. Returns the local address of this `Connection`, or `null` if it is unconnected. Returns:SocketAddress the local address of this `Connection`, or `null` if it is unconnected. Annotations @Override

public SocketAddress getLocalAddress()

Implements org.glassfish.grizzly.Connection.getLocalAddress.

Returns the local address of this Connection, or null if it is unconnected.

Returns:SocketAddress

the local address of this Connection, or null if it is unconnected.

Annotations

@Override

getPeerAddress back to summary

getPeerAddress	back to summary
public SocketAddress getPeerAddress() Implements org.glassfish.grizzly.Connection.getPeerAddress. Returns the address of the endpoint this `Connection` is connected to, or `null` if it is unconnected. Returns:SocketAddress the address of the endpoint this `Connection` is connected to, or `null` if it is unconnected. Annotations @Override

public SocketAddress getPeerAddress()

Implements org.glassfish.grizzly.Connection.getPeerAddress.

Returns the address of the endpoint this Connection is connected to, or null if it is unconnected.

Returns:SocketAddress

the address of the endpoint this Connection is connected to, or null if it is unconnected.

Annotations

@Override

getReadBufferSize back to summary

getReadBufferSize	back to summary
public int getReadBufferSize() Implements org.glassfish.grizzly.Connection.getReadBufferSize. Doc from org.glassfish.grizzly.Connection.getReadBufferSize. Get the default size of `Buffer`s, which will be allocated for reading data from `Connection`. The value less or equal to zero will be ignored. Annotations @Override

public int getReadBufferSize()

Implements org.glassfish.grizzly.Connection.getReadBufferSize.

Doc from org.glassfish.grizzly.Connection.getReadBufferSize.

Get the default size of Buffers, which will be allocated for reading data from Connection. The value less or equal to zero will be ignored.

Annotations

@Override

getWriteBufferSize back to summary

getWriteBufferSize	back to summary
public int getWriteBufferSize() Implements org.glassfish.grizzly.Connection.getWriteBufferSize. Doc from org.glassfish.grizzly.Connection.getWriteBufferSize. Get the default size of `Buffer`s, which will be allocated for writing data to `Connection`. Annotations @Override

public int getWriteBufferSize()

Implements org.glassfish.grizzly.Connection.getWriteBufferSize.

Doc from org.glassfish.grizzly.Connection.getWriteBufferSize.

Get the default size of Buffers, which will be allocated for writing data to Connection.

Annotations

@Override

isConnected	back to summary
public boolean isConnected()

join	back to summary
public void join(final InetAddress group, final NetworkInterface networkInterface) throws IOException Joins a multicast group to begin receiving all datagrams sent to the group. If this connection is currently a member of the group on the given interface to receive all datagrams then this method call has no effect. Otherwise this connection joins the requested group and channel's membership in not source-specific. A multicast connection may join several multicast groups, including the same group on more than one interface. An implementation may impose a limit on the number of groups that may be joined at the same time. Parameters group:InetAddress The multicast address to join networkInterface:NetworkInterface The network interface on which to join the group

join

back to summary

public void join(final InetAddress group, final NetworkInterface networkInterface) throws IOException

Joins a multicast group to begin receiving all datagrams sent to the group. If this connection is currently a member of the group on the given interface to receive all datagrams then this method call has no effect. Otherwise this connection joins the requested group and channel's membership in not source-specific. A multicast connection may join several multicast groups, including the same group on more than one interface. An implementation may impose a limit on the number of groups that may be joined at the same time.

Parameters

group:InetAddress: The multicast address to join
networkInterface:NetworkInterface: The network interface on which to join the group

join	back to summary
public void join(final InetAddress group, final NetworkInterface networkInterface, final InetAddress source) throws IOException Joins a multicast group to begin receiving datagrams sent to the group from a given source address. If this connection is currently a member of the group on the given interface to receive datagrams from the given source address then this method call has no effect. Otherwise this connection joins the group and depending on the source parameter value (whether it's not null or null value) the connection's membership is or is not source-specific. Membership is cumulative and this method may be invoked again with the same group and interface to allow receiving datagrams sent by other source addresses to the group. Parameters group:InetAddress The multicast address to join networkInterface:NetworkInterface The network interface on which to join the group source:InetAddress The source address

join

back to summary

public void join(final InetAddress group, final NetworkInterface networkInterface, final InetAddress source) throws IOException

Joins a multicast group to begin receiving datagrams sent to the group from a given source address. If this connection is currently a member of the group on the given interface to receive datagrams from the given source address then this method call has no effect. Otherwise this connection joins the group and depending on the source parameter value (whether it's not null or null value) the connection's membership is or is not source-specific. Membership is cumulative and this method may be invoked again with the same group and interface to allow receiving datagrams sent by other source addresses to the group.

Parameters

group:InetAddress: The multicast address to join
networkInterface:NetworkInterface: The network interface on which to join the group
source:InetAddress: The source address

notifyCanWrite back to summary

notifyCanWrite	back to summary
public void notifyCanWrite(final WriteHandler writeHandler) Implements org.glassfish.grizzly.OutputSink.notifyCanWrite. Doc from org.glassfish.grizzly.OutputSink.notifyCanWrite. Instructs the `OutputSink` to invoke the provided `WriteHandler` when it is possible to write more bytes (or characters). Note that once the `WriteHandler` has been notified, it will not be considered for notification again at a later point in time. Annotations @Override

public void notifyCanWrite(final WriteHandler writeHandler)

Implements org.glassfish.grizzly.OutputSink.notifyCanWrite.

Doc from org.glassfish.grizzly.OutputSink.notifyCanWrite.

Instructs the OutputSink to invoke the provided WriteHandler when it is possible to write more bytes (or characters). Note that once the WriteHandler has been notified, it will not be considered for notification again at a later point in time.

Annotations

@Override

notifyCanWrite back to summary

notifyCanWrite	back to summary
public void notifyCanWrite(WriteHandler handler, int length) Implements org.glassfish.grizzly.OutputSink.notifyCanWrite. Doc from org.glassfish.grizzly.OutputSink.notifyCanWrite. Deprecated Instructs the `OutputSink` to invoke the provided `WriteHandler` when it is possible to write `length` bytes (or characters). Note that once the `WriteHandler` has been notified, it will not be considered for notification again at a later point in time. Annotations @Deprecated @Override

public void notifyCanWrite(WriteHandler handler, int length)

Implements org.glassfish.grizzly.OutputSink.notifyCanWrite.

Doc from org.glassfish.grizzly.OutputSink.notifyCanWrite.

Deprecated

Instructs the OutputSink to invoke the provided WriteHandler when it is possible to write length bytes (or characters). Note that once the WriteHandler has been notified, it will not be considered for notification again at a later point in time.

Annotations

@Deprecated
@Override

notifyReady	back to summary
protected boolean notifyReady()

onConnect	back to summary
protected final void onConnect() throws IOException Method will be called, when the connection gets connected.

onRead	back to summary
protected final void onRead(Buffer data, int size) Method will be called, when some data was read on the connection

onWrite	back to summary
protected final void onWrite(Buffer data, int size) Method will be called, when some data was written on the connection

resetProperties	back to summary
protected final void resetProperties()

setMonitoringProbes	back to summary
pack-priv void setMonitoringProbes(final ConnectionProbe[] monitoringProbes) Hides org.glassfish.grizzly.nio.NIOConnection.setMonitoringProbes. Set the monitoringProbes array directly.

setMonitoringProbes

back to summary

pack-priv void setMonitoringProbes(final ConnectionProbe[] monitoringProbes)

Hides org.glassfish.grizzly.nio.NIOConnection.setMonitoringProbes.

Set the monitoringProbes array directly.

setReadBufferSize back to summary

setReadBufferSize	back to summary
public void setReadBufferSize(final int readBufferSize) Implements org.glassfish.grizzly.Connection.setReadBufferSize. Doc from org.glassfish.grizzly.Connection.setReadBufferSize. Set the default size of `Buffer`s, which will be allocated for reading data from `Connection`. The value less or equal to zero will be ignored. Annotations @Override

public void setReadBufferSize(final int readBufferSize)

Implements org.glassfish.grizzly.Connection.setReadBufferSize.

Doc from org.glassfish.grizzly.Connection.setReadBufferSize.

Set the default size of Buffers, which will be allocated for reading data from Connection. The value less or equal to zero will be ignored.

Annotations

@Override

setSelectionKey	back to summary
protected void setSelectionKey(SelectionKey selectionKey) Overrides org.glassfish.grizzly.nio.NIOConnection.setSelectionKey. Annotations @Override

setSelectionKey

back to summary

protected void setSelectionKey(SelectionKey selectionKey)

Overrides org.glassfish.grizzly.nio.NIOConnection.setSelectionKey.

Annotations

@Override

setSelectorRunner	back to summary
protected void setSelectorRunner(SelectorRunner selectorRunner) Overrides org.glassfish.grizzly.nio.NIOConnection.setSelectorRunner. Annotations @Override

setSelectorRunner

back to summary

protected void setSelectorRunner(SelectorRunner selectorRunner)

Overrides org.glassfish.grizzly.nio.NIOConnection.setSelectorRunner.

Annotations

@Override

setWriteBufferSize back to summary

setWriteBufferSize	back to summary
public void setWriteBufferSize(int writeBufferSize) Implements org.glassfish.grizzly.Connection.setWriteBufferSize. Doc from org.glassfish.grizzly.Connection.setWriteBufferSize. Set the default size of `Buffer`s, which will be allocated for writing data to `Connection`. Annotations @Override

public void setWriteBufferSize(int writeBufferSize)

Implements org.glassfish.grizzly.Connection.setWriteBufferSize.

Doc from org.glassfish.grizzly.Connection.setWriteBufferSize.

Set the default size of Buffers, which will be allocated for writing data to Connection.

Annotations

@Override

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Annotations @Override

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Annotations

@Override

unblock back to summary

unblock	back to summary
public void unblock(final InetAddress group, final NetworkInterface networkInterface, final InetAddress source) throws IOException Unblocks multicast datagrams from the given source address. If this connection has non-source specific membership in the group on the given interface and specified source address was previously blocked using `block(java.net.InetAddress, java.net.NetworkInterface, java.net.InetAddress)` method then this method unblocks multicast datagrams from the given source address. If the given source address wasn't blocked then this method has no effect. Parameters group:InetAddress The multicast address to join networkInterface:NetworkInterface The network interface on which to join the group source:InetAddress The source address to block

public void unblock(final InetAddress group, final NetworkInterface networkInterface, final InetAddress source) throws IOException

Unblocks multicast datagrams from the given source address. If this connection has non-source specific membership in the group on the given interface and specified source address was previously blocked using block(java.net.InetAddress, java.net.NetworkInterface, java.net.InetAddress) method then this method unblocks multicast datagrams from the given source address. If the given source address wasn't blocked then this method has no effect.

Parameters

group:InetAddress: The multicast address to join
networkInterface:NetworkInterface: The network interface on which to join the group
source:InetAddress: The source address to block

public Class UDPNIOConnection

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail