public class DebugSendChannelEndpoint extends SendChannelEndpoint
bindAddress, connectAddress, endPointAddress, errorLog, invalidPackets, isClosed, multicastTtl, receiveDatagramChannel, selectionKey, sendDatagramChannel, transportPoller, udpChannel
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) |
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. |
addDestination, closeStatusIndicator, decRef, incRef, indicateActive, openChannel, originalUriString, registerForSend, removeDestination, shouldBeClosed, statusIndicatorCounterId, unregisterForSend, validateAllowsManualControl
close, isMulticast, isValidFrame, multicastTtl, openDatagramChannel, receive, receiveDatagramChannel, receiveHook, registerForRead, sendError, sendHook, udpChannel
public DebugSendChannelEndpoint(UdpChannel udpChannel, org.agrona.concurrent.status.AtomicCounter statusIndicator, MediaDriver.Context context)
public DebugSendChannelEndpoint(UdpChannel udpChannel, org.agrona.concurrent.status.AtomicCounter statusIndicator, MediaDriver.Context context, LossGenerator dataLossGenerator, LossGenerator controlLossGenerator)
public int send(java.nio.ByteBuffer buffer)
SendChannelEndpoint
ByteBuffer
to connected address.
This is used on the sender side for performance over send(ByteBuffer, SocketAddress).send
in class SendChannelEndpoint
buffer
- to sendpublic void onStatusMessage(StatusMessageFlyweight msg, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress)
onStatusMessage
in class SendChannelEndpoint
public void onNakMessage(NakFlyweight msg, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress)
onNakMessage
in class SendChannelEndpoint
public void onRttMeasurement(RttMeasurementFlyweight msg, org.agrona.concurrent.UnsafeBuffer buffer, int length, java.net.InetSocketAddress srcAddress)
onRttMeasurement
in class SendChannelEndpoint
Copyright © 2014-2018 Real Logic Ltd. All Rights Reserved.