com.gigaspaces.internal.cluster.node.impl.groups.sync

Class BacklogAdjustedThrottleController

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.groups.sync.BacklogAdjustedThrottleController

All Implemented Interfaces:

IReplicationThrottleController

public class BacklogAdjustedThrottleController
extends Object
implements IReplicationThrottleController

This will throttle operations according to the backlog size and active state. When a channel is inactive, each thread will be throttled according to maxTPWhenInactive When a channel is active, each thread will be throttled in a manner that will continuously decrease the backlog size.

Since:

8.0

Author:

eitany

Constructor Summary

Constructors

Constructor and Description
BacklogAdjustedThrottleController(int maxTPWhenInactive, int minTPWhenActive, int threshold, int sampleRate, int finalStageLength, String groupName, String sourceMemberName, String targetMemberName, boolean throttleWhenInactive)

Method Summary

Modifier and Type	Method and Description
void	suggestThroughPut(int throughPut)
boolean	throttle(long backlogSize, int contextSize, boolean channelActive)

Methods inherited from class java.lang.Object

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

Constructor Detail

BacklogAdjustedThrottleController

public BacklogAdjustedThrottleController(int maxTPWhenInactive,
                                         int minTPWhenActive,
                                         int threshold,
                                         int sampleRate,
                                         int finalStageLength,
                                         String groupName,
                                         String sourceMemberName,
                                         String targetMemberName,
                                         boolean throttleWhenInactive)

Method Detail

throttle

public boolean throttle(long backlogSize,
                        int contextSize,
                        boolean channelActive)

Specified by:

throttle in interface IReplicationThrottleController

suggestThroughPut

public void suggestThroughPut(int throughPut)

Specified by:

suggestThroughPut in interface IReplicationThrottleController