io.aeron.driver

Interface FlowControl

All Known Implementing Classes:

MaxMulticastFlowControl, MinMulticastFlowControl, PreferredMulticastFlowControl, UnicastFlowControl

public interface FlowControl

Strategy for applying flow control to the Sender.

Method Summary

Modifier and Type	Method and Description
void	initialize(int initialTermId, int termBufferLength) Initialize the flow control strategy
long	onIdle(long timeNs, long senderLimit, long senderPosition, boolean isEos) Perform any maintenance needed by the flow control strategy and return current position
long	onStatusMessage(StatusMessageFlyweight flyweight, java.net.InetSocketAddress receiverAddress, long senderLimit, int initialTermId, int positionBitsToShift, long timeNs) Update the sender flow control strategy based on a status message from the receiver.
boolean	shouldLinger(long timeNs) Called from the DriverConductor to check should the NetworkPublication linger or not.

Method Detail

onStatusMessage

long onStatusMessage(StatusMessageFlyweight flyweight,
                     java.net.InetSocketAddress receiverAddress,
                     long senderLimit,
                     int initialTermId,
                     int positionBitsToShift,
                     long timeNs)

Update the sender flow control strategy based on a status message from the receiver.

Parameters:

flyweight - the Status Message contents

receiverAddress - of the receiver.

senderLimit - the current sender position limit.

initialTermId - for the term buffers.

positionBitsToShift - in use for the length of each term buffer.

timeNs - current time (in nanoseconds). System.nanoTime()

Returns:

the new position limit to be employed by the sender.

initialize

void initialize(int initialTermId,
                int termBufferLength)

Initialize the flow control strategy

Parameters:

initialTermId - for the term buffers

termBufferLength - to use as the length of each term buffer

onIdle

long onIdle(long timeNs,
            long senderLimit,
            long senderPosition,
            boolean isEos)

Perform any maintenance needed by the flow control strategy and return current position

Parameters:

timeNs - current time in nanoseconds.

senderLimit - for the current sender position.

senderPosition - for the current

isEos - is this end-of-stream for the sender.

Returns:

the position limit to be employed by the sender.

shouldLinger

boolean shouldLinger(long timeNs)

Called from the DriverConductor to check should the NetworkPublication linger or not.

Parameters:

timeNs - current time in nanoseconds.

Returns:

true to continue to linger or false to not linger