io.aeron.driver.ext

Class DebugReceiveChannelEndpoint

java.lang.Object

io.aeron.driver.media.UdpChannelTransport

io.aeron.driver.media.ReceiveChannelEndpoint

io.aeron.driver.ext.DebugReceiveChannelEndpoint

All Implemented Interfaces:

java.lang.AutoCloseable

public class DebugReceiveChannelEndpoint
extends ReceiveChannelEndpoint

Debug implementation which can introduce loss.

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
DebugReceiveChannelEndpoint(UdpChannel udpChannel, DataPacketDispatcher dispatcher, org.agrona.concurrent.status.AtomicCounter statusIndicator, MediaDriver.Context context)
DebugReceiveChannelEndpoint(UdpChannel udpChannel, DataPacketDispatcher dispatcher, org.agrona.concurrent.status.AtomicCounter statusIndicator, MediaDriver.Context context, LossGenerator dataLossGenerator, LossGenerator controlLossGenerator)

Method Summary

Modifier and Type	Method and Description
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)
int	sendTo(java.nio.ByteBuffer buffer, java.net.InetSocketAddress remoteAddress) Send contents of ByteBuffer to the remote address.

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

addDestination, addPublicationImage, addSubscription, addSubscription, closeMultiRcvDestination, closeStatusIndicator, decRefToStream, decRefToStreamAndSession, destination, destination, explicitControlAddress, hasDestinationControl, hasExplicitControl, incRefToStream, incRefToStreamAndSession, indicateActive, isMulticast, isMulticast, multicastTtl, multicastTtl, openChannel, originalUriString, possibleTtlAsymmetryEncountered, removeCoolDown, removeDestination, removePendingSetup, removePublicationImage, removeSubscription, removeSubscription, send, send, sendNakMessage, sendRttMeasurement, sendRttMeasurement, sendSetupElicitingStatusMessage, sendStatusMessage, shouldBeClosed, shouldElicitSetupMessage, statusIndicatorCounterId, streamCount, udpChannel, udpChannel, 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

DebugReceiveChannelEndpoint

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

DebugReceiveChannelEndpoint

public DebugReceiveChannelEndpoint(UdpChannel udpChannel,
                                   DataPacketDispatcher dispatcher,
                                   org.agrona.concurrent.status.AtomicCounter statusIndicator,
                                   MediaDriver.Context context,
                                   LossGenerator dataLossGenerator,
                                   LossGenerator controlLossGenerator)

Method Detail

sendTo

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

Description copied from class: ReceiveChannelEndpoint

Send contents of ByteBuffer to the remote address.

Overrides:

sendTo in class ReceiveChannelEndpoint

Parameters:

buffer - to send containing the payload.

remoteAddress - to send to send the payload to.

Returns:

number of bytes sent.

onDataPacket

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

Overrides:

onDataPacket in class ReceiveChannelEndpoint

onSetupMessage

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

Overrides:

onSetupMessage in class ReceiveChannelEndpoint

onRttMeasurement

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

Overrides:

onRttMeasurement in class ReceiveChannelEndpoint