Package de.hybris.platform.servicelayer.web.session.persister

Class LinearDrainingAdaptiveAlgorithm

java.lang.Object

de.hybris.platform.servicelayer.web.session.persister.LinearDrainingAdaptiveAlgorithm

All Implemented Interfaces:

DrainingAdaptiveAlgorithm

public class LinearDrainingAdaptiveAlgorithm
extends java.lang.Object
implements DrainingAdaptiveAlgorithm

Linear implementation of the DrainingAdaptiveAlgorithm. Uses two percentage values for calculate the linear equation spring.session.save.async.maxratio.adaptive.algorithm - tells what should be the value when queue size is 100% spring.session.save.async.threshold.adaptive.algorithm - defines the threshold when algorithm should be applied, the value for the threshold is equal to spring.session.save.async.max.items.

Constructor Summary

Constructors

Constructor	Description
LinearDrainingAdaptiveAlgorithm()

Method Summary

Modifier and Type	Method	Description
protected int	computeDrainSizeLineary(long currentSize, long threshold)
int	getDrainSize(long currentSize)	Calculates drain size for current queue size value.
void	init()
void	setTenant(Tenant tenant)
protected boolean	shouldAdapt(long currentSize, long threshold)

Methods inherited from class java.lang.Object

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

Constructor Detail

LinearDrainingAdaptiveAlgorithm

public LinearDrainingAdaptiveAlgorithm()

Method Detail

init

@PostConstruct
public void init()

getDrainSize

public int getDrainSize(long currentSize)

Description copied from interface: DrainingAdaptiveAlgorithm

Calculates drain size for current queue size value.

Specified by:

getDrainSize in interface DrainingAdaptiveAlgorithm

computeDrainSizeLineary

protected int computeDrainSizeLineary(long currentSize,
                                      long threshold)

shouldAdapt

protected boolean shouldAdapt(long currentSize,
                              long threshold)

setTenant

public void setTenant(Tenant tenant)