io.aeron.driver

Class DefaultCongestionControlSupplier

java.lang.Object

io.aeron.driver.DefaultCongestionControlSupplier

All Implemented Interfaces:

CongestionControlSupplier

public class DefaultCongestionControlSupplier
extends java.lang.Object
implements CongestionControlSupplier

Constructor Summary

Constructors

Constructor and Description
DefaultCongestionControlSupplier()

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

DefaultCongestionControlSupplier

public DefaultCongestionControlSupplier()

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.