io.aeron.driver

Class RetransmitHandler

java.lang.Object

io.aeron.driver.RetransmitHandler

public class RetransmitHandler
extends java.lang.Object

Tracking and handling of retransmit request, NAKs, for senders, and receivers.

A max number of retransmits is permitted by Configuration.MAX_RETRANSMITS_DEFAULT. Additional received NAKs will be ignored if this maximum is reached.

Constructor Summary

Constructors

Constructor and Description
RetransmitHandler(org.agrona.concurrent.NanoClock nanoClock, SystemCounters systemCounters, FeedbackDelayGenerator delayGenerator, FeedbackDelayGenerator lingerTimeoutGenerator) Create a retransmit handler.

Method Summary

Modifier and Type	Method and Description
void	onNak(int termId, int termOffset, int length, int termLength, RetransmitSender retransmitSender) Called on reception of a NAK to start retransmits handling.
void	onRetransmitReceived(int termId, int termOffset) Called to indicate a retransmission is received that may obviate the need to send one ourselves.
void	processTimeouts(long nowNs, RetransmitSender retransmitSender) Called to process any outstanding timeouts.

Methods inherited from class java.lang.Object

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

Constructor Detail

RetransmitHandler

public RetransmitHandler(org.agrona.concurrent.NanoClock nanoClock,
                         SystemCounters systemCounters,
                         FeedbackDelayGenerator delayGenerator,
                         FeedbackDelayGenerator lingerTimeoutGenerator)

Create a retransmit handler.

Parameters:

nanoClock - used to determine time

systemCounters - for recording significant events.

delayGenerator - to use for delay determination

lingerTimeoutGenerator - to use for linger timeout

Method Detail

onNak

public void onNak(int termId,
                  int termOffset,
                  int length,
                  int termLength,
                  RetransmitSender retransmitSender)

Called on reception of a NAK to start retransmits handling.

Parameters:

termId - from the NAK and the term id of the buffer to retransmit from

termOffset - from the NAK and the offset of the data to retransmit

length - of the missing data

termLength - of the term buffer.

retransmitSender - to call if an immediate retransmit is required

onRetransmitReceived

public void onRetransmitReceived(int termId,
                                 int termOffset)

Called to indicate a retransmission is received that may obviate the need to send one ourselves.

NOTE: Currently only called from unit tests. Would be used for retransmitting from receivers for NAK suppression

Parameters:

termId - of the data

termOffset - of the data

processTimeouts

public void processTimeouts(long nowNs,
                            RetransmitSender retransmitSender)

Called to process any outstanding timeouts.

Parameters:

nowNs - time in nanoseconds

retransmitSender - to call on retransmissions