io.aeron.driver.media

Class ReceiveChannelEndpoint

java.lang.Object

io.aeron.driver.media.UdpChannelTransport

io.aeron.driver.media.ReceiveChannelEndpoint

All Implemented Interfaces:

java.lang.AutoCloseable

Direct Known Subclasses:

DebugReceiveChannelEndpoint

public class ReceiveChannelEndpoint
extends UdpChannelTransport

Aggregator of multiple subscriptions onto a single transport channel for receiving of data and setup frames plus sending status and NAK frames.

Field Summary

Fields inherited from class io.aeron.driver.media.UdpChannelTransport

bindAddress, connectAddress, endPointAddress, errorLog, invalidPackets, isClosed, multicastTtl, receiveDatagramChannel, selectionKey, sendDatagramChannel, transportPoller, udpChannel

Constructor Summary

Constructors

Constructor and Description
ReceiveChannelEndpoint(UdpChannel udpChannel, DataPacketDispatcher dispatcher, org.agrona.concurrent.status.AtomicCounter statusIndicator, MediaDriver.Context context)

Method Summary

Modifier and Type	Method and Description
int	addDestination(ReceiveDestinationUdpTransport transport)
void	addPublicationImage(PublicationImage image)
void	addSubscription(int streamId)
void	addSubscription(int streamId, int sessionId)
void	closeMultiRcvDestination()
void	closeStatusIndicator()
int	decRefToStream(int streamId)
long	decRefToStreamAndSession(int streamId, int sessionId)
ReceiveDestinationUdpTransport	destination(int transportIndex)
int	destination(UdpChannel udpChannel)
java.net.InetSocketAddress	explicitControlAddress()
boolean	hasDestinationControl()
boolean	hasExplicitControl()
int	incRefToStream(int streamId)
long	incRefToStreamAndSession(int streamId, int sessionId)
void	indicateActive()
boolean	isMulticast() Is transport representing a multicast media or unicast
boolean	isMulticast(int transportIndex)
int	multicastTtl() Get the multicast TTL value for sending datagrams on the channel.
int	multicastTtl(int transportIndex)
int	onDataPacket(DataHeaderFlyweight header, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress, int transportIndex)
void	onRttMeasurement(RttMeasurementFlyweight header, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress, int transportIndex)
void	onSetupMessage(SetupFlyweight header, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress, int transportIndex)
void	openChannel(DriverConductorProxy conductorProxy)
java.lang.String	originalUriString()
void	possibleTtlAsymmetryEncountered()
void	removeCoolDown(int sessionId, int streamId)
void	removeDestination(int transportIndex)
void	removePendingSetup(int sessionId, int streamId)
void	removePublicationImage(PublicationImage publicationImage)
void	removeSubscription(int streamId)
void	removeSubscription(int streamId, int sessionId)
protected void	send(java.nio.ByteBuffer buffer, int bytesToSend, ImageConnection[] imageConnections)
protected void	send(java.nio.ByteBuffer buffer, int bytesToSend, int transportIndex, java.net.InetSocketAddress remoteAddress)
void	sendNakMessage(ImageConnection[] controlAddresses, int sessionId, int streamId, int termId, int termOffset, int length)
void	sendRttMeasurement(ImageConnection[] controlAddresses, int sessionId, int streamId, long echoTimestampNs, long receptionDelta, boolean isReply)
void	sendRttMeasurement(int transportIndex, java.net.InetSocketAddress controlAddress, int sessionId, int streamId, long echoTimestampNs, long receptionDelta, boolean isReply)
void	sendSetupElicitingStatusMessage(int transportIndex, java.net.InetSocketAddress controlAddress, int sessionId, int streamId)
void	sendStatusMessage(ImageConnection[] controlAddresses, int sessionId, int streamId, int termId, int termOffset, int window, short flags)
int	sendTo(java.nio.ByteBuffer buffer, java.net.InetSocketAddress remoteAddress) Send contents of ByteBuffer to the remote address.
boolean	shouldBeClosed()
boolean	shouldElicitSetupMessage()
int	statusIndicatorCounterId()
int	streamCount()
UdpChannel	udpChannel() Return underlying UdpChannel
UdpChannel	udpChannel(int transportIndex)
void	validateAllowsDestinationControl()

Methods inherited from class io.aeron.driver.media.UdpChannelTransport

close, isValidFrame, openDatagramChannel, receive, receiveDatagramChannel, receiveHook, registerForRead, sendError, sendHook

Methods inherited from class java.lang.Object

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

Constructor Detail

ReceiveChannelEndpoint

public ReceiveChannelEndpoint(UdpChannel udpChannel,
                              DataPacketDispatcher dispatcher,
                              org.agrona.concurrent.status.AtomicCounter statusIndicator,
                              MediaDriver.Context context)

Method Detail

sendTo

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

Send contents of ByteBuffer to the remote address.

Parameters:

buffer - to send containing the payload.

remoteAddress - to send to send the payload to.

Returns:

number of bytes sent.

originalUriString

public java.lang.String originalUriString()

statusIndicatorCounterId

public int statusIndicatorCounterId()

indicateActive

public void indicateActive()

closeStatusIndicator

public void closeStatusIndicator()

closeMultiRcvDestination

public void closeMultiRcvDestination()

openChannel

public void openChannel(DriverConductorProxy conductorProxy)

possibleTtlAsymmetryEncountered

public void possibleTtlAsymmetryEncountered()

incRefToStream

public int incRefToStream(int streamId)

decRefToStream

public int decRefToStream(int streamId)

incRefToStreamAndSession

public long incRefToStreamAndSession(int streamId,
                                     int sessionId)

decRefToStreamAndSession

public long decRefToStreamAndSession(int streamId,
                                     int sessionId)

streamCount

public int streamCount()

shouldBeClosed

public boolean shouldBeClosed()

hasExplicitControl

public boolean hasExplicitControl()

explicitControlAddress

public java.net.InetSocketAddress explicitControlAddress()

hasDestinationControl

public boolean hasDestinationControl()

validateAllowsDestinationControl

public void validateAllowsDestinationControl()

isMulticast

public boolean isMulticast()

Description copied from class: UdpChannelTransport

Is transport representing a multicast media or unicast

Overrides:

isMulticast in class UdpChannelTransport

Returns:

if transport is multicast media

isMulticast

public boolean isMulticast(int transportIndex)

udpChannel

public UdpChannel udpChannel()

Description copied from class: UdpChannelTransport

Return underlying UdpChannel

Overrides:

udpChannel in class UdpChannelTransport

Returns:

underlying channel

udpChannel

public UdpChannel udpChannel(int transportIndex)

multicastTtl

public int multicastTtl()

Description copied from class: UdpChannelTransport

Get the multicast TTL value for sending datagrams on the channel.

Overrides:

multicastTtl in class UdpChannelTransport

Returns:

the multicast TTL value for sending datagrams on the channel.

multicastTtl

public int multicastTtl(int transportIndex)

addDestination

public int addDestination(ReceiveDestinationUdpTransport transport)

removeDestination

public void removeDestination(int transportIndex)

destination

public int destination(UdpChannel udpChannel)

destination

public ReceiveDestinationUdpTransport destination(int transportIndex)

onDataPacket

public int onDataPacket(DataHeaderFlyweight header,
                        org.agrona.concurrent.UnsafeBuffer buffer,
                        int length,
                        java.net.InetSocketAddress srcAddress,
                        int transportIndex)

onSetupMessage

public void onSetupMessage(SetupFlyweight header,
                           org.agrona.concurrent.UnsafeBuffer buffer,
                           int length,
                           java.net.InetSocketAddress srcAddress,
                           int transportIndex)

onRttMeasurement

public void onRttMeasurement(RttMeasurementFlyweight header,
                             org.agrona.concurrent.UnsafeBuffer buffer,
                             int length,
                             java.net.InetSocketAddress srcAddress,
                             int transportIndex)

sendSetupElicitingStatusMessage

public void sendSetupElicitingStatusMessage(int transportIndex,
                                            java.net.InetSocketAddress controlAddress,
                                            int sessionId,
                                            int streamId)

sendRttMeasurement

public void sendRttMeasurement(int transportIndex,
                               java.net.InetSocketAddress controlAddress,
                               int sessionId,
                               int streamId,
                               long echoTimestampNs,
                               long receptionDelta,
                               boolean isReply)

sendStatusMessage

public void sendStatusMessage(ImageConnection[] controlAddresses,
                              int sessionId,
                              int streamId,
                              int termId,
                              int termOffset,
                              int window,
                              short flags)

sendNakMessage

public void sendNakMessage(ImageConnection[] controlAddresses,
                           int sessionId,
                           int streamId,
                           int termId,
                           int termOffset,
                           int length)

sendRttMeasurement

public void sendRttMeasurement(ImageConnection[] controlAddresses,
                               int sessionId,
                               int streamId,
                               long echoTimestampNs,
                               long receptionDelta,
                               boolean isReply)

removePendingSetup

public void removePendingSetup(int sessionId,
                               int streamId)

removePublicationImage

public void removePublicationImage(PublicationImage publicationImage)

addSubscription

public void addSubscription(int streamId)

addSubscription

public void addSubscription(int streamId,
                            int sessionId)

removeSubscription

public void removeSubscription(int streamId)

removeSubscription

public void removeSubscription(int streamId,
                               int sessionId)

addPublicationImage

public void addPublicationImage(PublicationImage image)

removeCoolDown

public void removeCoolDown(int sessionId,
                           int streamId)

shouldElicitSetupMessage

public boolean shouldElicitSetupMessage()

send

protected void send(java.nio.ByteBuffer buffer,
                    int bytesToSend,
                    ImageConnection[] imageConnections)

send

protected void send(java.nio.ByteBuffer buffer,
                    int bytesToSend,
                    int transportIndex,
                    java.net.InetSocketAddress remoteAddress)