io.aeron.driver.media

Class MultiRcvDestination

java.lang.Object

io.aeron.driver.media.MultiRcvDestination

All Implemented Interfaces:

java.lang.AutoCloseable

public class MultiRcvDestination
extends java.lang.Object
implements java.lang.AutoCloseable

Constructor Summary

Constructors

Constructor and Description
MultiRcvDestination(org.agrona.concurrent.NanoClock nanoClock, long timeoutNs)

Method Summary

Modifier and Type	Method and Description
int	addDestination(ReceiveDestinationUdpTransport transport)
void	close()
boolean	hasDestination(int transportIndex)
void	removeDestination(int transportIndex)
static int	sendTo(UdpChannelTransport transport, java.nio.ByteBuffer buffer, java.net.InetSocketAddress remoteAddress)
int	sendToAll(ImageConnection[] imageConnections, java.nio.ByteBuffer buffer, int position, int bytesToSend)
ReceiveDestinationUdpTransport	transport(int transportIndex)
int	transport(UdpChannel udpChannel)

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiRcvDestination

public MultiRcvDestination(org.agrona.concurrent.NanoClock nanoClock,
                           long timeoutNs)

Method Detail

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

addDestination

public int addDestination(ReceiveDestinationUdpTransport transport)

removeDestination

public void removeDestination(int transportIndex)

hasDestination

public boolean hasDestination(int transportIndex)

transport

public ReceiveDestinationUdpTransport transport(int transportIndex)

transport

public int transport(UdpChannel udpChannel)

sendToAll

public int sendToAll(ImageConnection[] imageConnections,
                     java.nio.ByteBuffer buffer,
                     int position,
                     int bytesToSend)

sendTo

public static int sendTo(UdpChannelTransport transport,
                         java.nio.ByteBuffer buffer,
                         java.net.InetSocketAddress remoteAddress)