io.aeron.driver.ext

Class CubicCongestionControlSupplier

java.lang.Object

io.aeron.driver.ext.CubicCongestionControlSupplier

All Implemented Interfaces:

CongestionControlSupplier

public class CubicCongestionControlSupplier
extends java.lang.Object
implements CongestionControlSupplier

Constructor Summary

Constructors

Constructor and Description
CubicCongestionControlSupplier()

Method Summary

Modifier and Type	Method and Description
CongestionControl	newInstance(long registrationId, UdpChannel udpChannel, int streamId, int sessionId, int termLength, int senderMtuLength, org.agrona.concurrent.NanoClock clock, MediaDriver.Context context, org.agrona.concurrent.status.CountersManager countersManager) Return a new CongestionControl instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

CubicCongestionControlSupplier

public CubicCongestionControlSupplier()

Method Detail

newInstance

public CongestionControl newInstance(long registrationId,
                                     UdpChannel udpChannel,
                                     int streamId,
                                     int sessionId,
                                     int termLength,
                                     int senderMtuLength,
                                     org.agrona.concurrent.NanoClock clock,
                                     MediaDriver.Context context,
                                     org.agrona.concurrent.status.CountersManager countersManager)

Description copied from interface: CongestionControlSupplier

Return a new CongestionControl instance.

Specified by:

newInstance in interface CongestionControlSupplier

Parameters:

registrationId - for the instance.

udpChannel - for the instance.

streamId - for the instance.

sessionId - for the instance.

termLength - for the instance.

senderMtuLength - for the instance.

clock - for the instance.

context - for the instance.

countersManager - for the instance.

Returns:

congestion control instance ready for immediate usage.