org.waarp.openr66.protocol.networkhandler

Class R66ConstraintLimitHandler

java.lang.Object

org.waarp.common.cpu.WaarpConstraintLimitHandler

org.waarp.openr66.protocol.networkhandler.R66ConstraintLimitHandler

All Implemented Interfaces:

Runnable

public class R66ConstraintLimitHandler
extends WaarpConstraintLimitHandler

R66 Constraint Limit Handler

Constraint Limit (CPU and connection - network and local -) handler, only for server side (requested or requester).

Field Summary

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

lastAlert, LOWBANDWIDTH_DEFAULT

Constructor Summary

Constructors

Constructor and Description
R66ConstraintLimitHandler()
R66ConstraintLimitHandler(boolean useCpuLimit, boolean useJdKCpuLimit, double cpulimit, int channellimit)
R66ConstraintLimitHandler(boolean useCpuLimit, boolean useJdKCpuLimit, double cpulimit, int channellimit, double lowcpuLimit, double highcpuLimit, double percentageDecrease, io.netty.handler.traffic.GlobalTrafficShapingHandler handler, long delay, long limitLowBandwidth)
R66ConstraintLimitHandler(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

R66ConstraintLimitHandler

public R66ConstraintLimitHandler()

R66ConstraintLimitHandler

public R66ConstraintLimitHandler(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)

R66ConstraintLimitHandler

public R66ConstraintLimitHandler(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)

R66ConstraintLimitHandler

public R66ConstraintLimitHandler(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