org.waarp.gateway.ftp.control

Class FtpConstraintLimitHandler

java.lang.Object

org.waarp.common.cpu.WaarpConstraintLimitHandler

org.waarp.gateway.ftp.control.FtpConstraintLimitHandler

All Implemented Interfaces:

Runnable

public class FtpConstraintLimitHandler
extends WaarpConstraintLimitHandler

Constraint Limit (CPU and connection - network and local -) handler.

Field Summary

Fields inherited from class org.waarp.common.cpu.WaarpConstraintLimitHandler

lastAlert, LOWBANDWIDTH_DEFAULT

Constructor Summary

Constructors

Constructor and Description
FtpConstraintLimitHandler(long timeoutcon, boolean useCpuLimit, boolean useJdKCpuLimit, double cpulimit, int channellimit)
FtpConstraintLimitHandler(long timeoutcon, boolean useCpuLimit, boolean useJdKCpuLimit, double cpulimit, int channellimit, double lowcpuLimit, double highcpuLimit, double percentageDecrease, io.netty.handler.traffic.GlobalTrafficShapingHandler handler, long delay, long limitLowBandwidth)
FtpConstraintLimitHandler(long timeoutcon, boolean useJdkCpuLimit, double lowcpuLimit, double highcpuLimit, double percentageDecrease, io.netty.handler.traffic.GlobalTrafficShapingHandler handler, long delay, long limitLowBandwidth)

Method Summary

Modifier and Type	Method and Description
protected int	getNumberLocalChannel()
protected long	getReadLimit() Get the current setting on Read Limit (supposed to be not the value in the handler but in the configuration)
protected long	getWriteLimit() Get the current setting on Write Limit (supposed to be not the value in the handler but in the configuration)

Methods inherited from class org.waarp.common.cpu.WaarpConstraintLimitHandler

checkConstraints, checkConstraintsSleep, getChannelLimit, getCpuLimit, getSleepTime, release, run, setChannelLimit, setCpuLimit, setHandler, setServer

Methods inherited from class java.lang.Object

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

Constructor Detail

FtpConstraintLimitHandler

public FtpConstraintLimitHandler(long timeoutcon,
                                 boolean useJdkCpuLimit,
                                 double lowcpuLimit,
                                 double highcpuLimit,
                                 double percentageDecrease,
                                 io.netty.handler.traffic.GlobalTrafficShapingHandler handler,
                                 long delay,
                                 long limitLowBandwidth)

Parameters:

useJdkCpuLimit - True to use JDK Cpu native or False for JavaSysMon

lowcpuLimit - for proactive cpu limitation (throttling bandwidth) (0<= x < 1 & highcpulimit)

highcpuLimit - for proactive cpu limitation (throttling bandwidth) (0<= x <= 1) 0 meaning no throttle activated

percentageDecrease - for proactive cpu limitation, throttling bandwidth reduction (0 < x < 1) as 0.25 for 25% of reduction

handler - the GlobalTrafficShapingHandler associated (null to have no proactive cpu limitation)

delay - the delay between 2 tests for proactive cpu limitation

limitLowBandwidth - the minimal bandwidth (read or write) to apply when decreasing bandwidth (low limit = 4096)

FtpConstraintLimitHandler

public FtpConstraintLimitHandler(long timeoutcon,
                                 boolean useCpuLimit,
                                 boolean useJdKCpuLimit,
                                 double cpulimit,
                                 int channellimit)

Parameters:

useCpuLimit - True to enable cpuLimit on connection check

useJdKCpuLimit - True to use JDK Cpu native or False for JavaSysMon

cpulimit - high cpu limit (0<= x < 1) to refuse new connections

channellimit - number of connection limit (0<= x)

FtpConstraintLimitHandler

public FtpConstraintLimitHandler(long timeoutcon,
                                 boolean useCpuLimit,
                                 boolean useJdKCpuLimit,
                                 double cpulimit,
                                 int channellimit,
                                 double lowcpuLimit,
                                 double highcpuLimit,
                                 double percentageDecrease,
                                 io.netty.handler.traffic.GlobalTrafficShapingHandler handler,
                                 long delay,
                                 long limitLowBandwidth)

Parameters:

useCpuLimit - True to enable cpuLimit on connection check

useJdKCpuLimit - True to use JDK Cpu native or False for JavaSysMon

cpulimit - high cpu limit (0<= x < 1) to refuse new connections

channellimit - number of connection limit (0<= x)

lowcpuLimit - for proactive cpu limitation (throttling bandwidth) (0<= x < 1 & highcpulimit)

highcpuLimit - for proactive cpu limitation (throttling bandwidth) (0<= x <= 1) 0 meaning no throttle activated

percentageDecrease - for proactive cpu limitation, throttling bandwidth reduction (0 < x < 1) as 0.25 for 25% of reduction

handler - the GlobalTrafficShapingHandler associated (null to have no proactive cpu limitation)

delay - the delay between 2 tests for proactive cpu limitation

limitLowBandwidth - the minimal bandwidth (read or write) to apply when decreasing bandwidth (low limit = 4096)

Method Detail

getNumberLocalChannel

protected int getNumberLocalChannel()

Specified by:

getNumberLocalChannel in class WaarpConstraintLimitHandler

Returns:

the current number of active Local Channel

getReadLimit

protected long getReadLimit()

Description copied from class: WaarpConstraintLimitHandler

Get the current setting on Read Limit (supposed to be not the value in the handler but in the configuration)

Specified by:

getReadLimit in class WaarpConstraintLimitHandler

Returns:

the current setting on Read Limit

getWriteLimit

protected long getWriteLimit()

Description copied from class: WaarpConstraintLimitHandler

Get the current setting on Write Limit (supposed to be not the value in the handler but in the configuration)

Specified by:

getWriteLimit in class WaarpConstraintLimitHandler

Returns:

the current setting on Write Limit