io.aeron.driver.ext

Class DebugSendChannelEndpoint

java.lang.Object

io.aeron.driver.media.UdpChannelTransport

io.aeron.driver.media.SendChannelEndpoint

io.aeron.driver.ext.DebugSendChannelEndpoint

All Implemented Interfaces:

java.lang.AutoCloseable

public class DebugSendChannelEndpoint
extends SendChannelEndpoint

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

Method Summary

Modifier and Type	Method and Description
void	onNakMessage(NakFlyweight msg, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress)
void	onRttMeasurement(RttMeasurementFlyweight msg, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress)
void	onStatusMessage(StatusMessageFlyweight msg, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress)
int	send(java.nio.ByteBuffer buffer) Send contents of a ByteBuffer to connected address.

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

addDestination, closeStatusIndicator, decRef, incRef, indicateActive, openChannel, originalUriString, registerForSend, removeDestination, shouldBeClosed, statusIndicatorCounterId, unregisterForSend, validateAllowsManualControl

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

close, isMulticast, isValidFrame, multicastTtl, openDatagramChannel, receive, receiveDatagramChannel, receiveHook, registerForRead, sendError, sendHook, udpChannel

Methods inherited from class java.lang.Object

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

Constructor Detail

DebugSendChannelEndpoint

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

DebugSendChannelEndpoint

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

Method Detail

send

public int send(java.nio.ByteBuffer buffer)

Description copied from class: SendChannelEndpoint

Send contents of a ByteBuffer to connected address. This is used on the sender side for performance over send(ByteBuffer, SocketAddress).

Overrides:

send in class SendChannelEndpoint

Parameters:

buffer - to send

Returns:

number of bytes sent

onStatusMessage

public void onStatusMessage(StatusMessageFlyweight msg,
                            org.agrona.concurrent.UnsafeBuffer buffer,
                            int length,
                            java.net.InetSocketAddress srcAddress)

Overrides:

onStatusMessage in class SendChannelEndpoint

onNakMessage

public void onNakMessage(NakFlyweight msg,
                         org.agrona.concurrent.UnsafeBuffer buffer,
                         int length,
                         java.net.InetSocketAddress srcAddress)

Overrides:

onNakMessage in class SendChannelEndpoint

onRttMeasurement

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

Overrides:

onRttMeasurement in class SendChannelEndpoint