io.aeron.driver

Class CongestionControlUtil

java.lang.Object

io.aeron.driver.CongestionControlUtil

public class CongestionControlUtil
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
CongestionControlUtil()

Method Summary

Modifier and Type	Method and Description
static long	packOutcome(int receiverWindowLength, boolean forceStatusMessage)
static long	positionThreshold(long position)
static int	receiverWindowLength(long outcome)
static boolean	shouldForceStatusMessage(long outcome)

Methods inherited from class java.lang.Object

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

Constructor Detail

CongestionControlUtil

public CongestionControlUtil()

Method Detail

packOutcome

public static long packOutcome(int receiverWindowLength,
                               boolean forceStatusMessage)

receiverWindowLength

public static int receiverWindowLength(long outcome)

shouldForceStatusMessage

public static boolean shouldForceStatusMessage(long outcome)

positionThreshold

public static long positionThreshold(long position)