RequestThrottler (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.tunnel.pool.RequestThrottler

```
public class RequestThrottler
extends Object
```
Throttles incoming tunnel requests earlier than ParticipatingThrottler, with higher limits and more frequent cleanup. Checks various router characteristics and decides whether to throttle, ban, or disconnect routers based on request count, version, bandwidth, and system load.

Field Summary

Fields
Modifier and Type	Field and Description
`static int`	`_highLoadCpuPct` High-load CPU threshold (percent) @since 0.9.70+
`static int`	`_highLoadLagMs` High-load job lag threshold (ms) @since 0.9.70+
`static int`	`_highLoadSysLoadPct` High-load system load threshold (percent, normalized by cores) @since 0.9.70+
`static int`	`_moderateLoadCpuPct` Moderate-load CPU threshold (percent) @since 0.9.70+
`static int`	`_moderateLoadLagMs` Moderate-load job lag threshold (ms) @since 0.9.70+
`static int`	`_moderateLoadSysLoadPct` Moderate-load system load threshold (percent, normalized by cores) @since 0.9.70+
`static int`	`_reqBurst1sThreshold` Burst threshold for 1-second sliding window (requests per second).
`static int`	`_reqLoadWeight` Load weight: how much load inflates effective ratio (0-300%, default 100%).
`static int`	`_reqMaxLimit` Maximum request limit per peer.
`static int`	`_reqMinLimit` Minimum request limit per peer.
`static int`	`_reqPercentLimit` Request limit as percentage of participating tunnel count.
`static int`	`_reqRejectSteepness` Rejection steepness: 100=linear ramp, 200=quadratic.
`static int`	`_reqRejectThreshold` Rejection threshold: start rejecting at count/limit ratio this high (30-100, default 70%).
`static long`	`_sustainedModerateLoadMs` Duration (ms) moderate load must persist before disconnecting low-share peers @since 0.9.70+
`(package private) static boolean`	`DEFAULT_SHOULD_DISCONNECT`
`(package private) static boolean`	`DEFAULT_SHOULD_THROTTLE`
`(package private) static String`	`PROP_SHOULD_DISCONNECT`
`(package private) static String`	`PROP_SHOULD_THROTTLE`

Constructor Summary
Constructors
Constructor and Description
RequestThrottler(RouterContext ctx)
Creates a new RequestThrottler bound to the given router context.

Constructors
Constructor and Description
`RequestThrottler(RouterContext ctx)` Creates a new RequestThrottler bound to the given router context.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`(package private) static long`	`burstBanDurationMs(int offenses)` Ban length for a repeated burst offense: zero for the first `BURST_BAN_OFFENSES` - 1 offenses (throttle-only), then five minutes growing by five minutes per further offense, capped at thirty minutes.
`(package private) static int`	`burstThreshold(int configuredThreshold, int limit)` Effective single-second burst threshold for a peer: the configured floor, raised so peers whose limit permits heavy traffic are not banned for bursts that limit allows (one tenth of the 90-second request limit as a per-second ceiling).
`static int`	`getHighLoadCpuPct()` The high-load CPU threshold percentage.
`static int`	`getHighLoadLagMs()` The high-load job lag threshold in milliseconds.
`static int`	`getHighLoadSysLoadPct()` The high-load system load threshold percentage (normalized by cores).
`static int`	`getModerateLoadCpuPct()` The moderate-load CPU threshold percentage.
`static int`	`getModerateLoadLagMs()` The moderate-load job lag threshold in milliseconds.
`static int`	`getModerateLoadSysLoadPct()` The moderate-load system load threshold percentage (normalized by cores).
`static int`	`getRequestBurst1sThreshold()` The burst threshold for 1-second sliding window.
`static int`	`getRequestLoadWeight()` The load weight (how much load inflates effective ratio, 0-300%).
`static int`	`getRequestMaxLimit()` The maximum request limit per peer.
`static int`	`getRequestMinLimit()` The minimum request limit per peer.
`static int`	`getRequestPctLimit()` The request limit as percentage of participating tunnel count.
`static int`	`getRequestRejectSteepness()` The rejection steepness (100=linear ramp, 200=quadratic).
`static int`	`getRequestRejectThreshold()` The rejection threshold (30-100, default 70%).
`static long`	`getSustainedModerateLoadMs()` The duration (ms) moderate load must persist before disconnecting low-share peers.
`(package private) static float`	`luEnforcementProbability(float loadScore)` Probability of enforcing the LU prev-hop ban at a given load score: zero when idle, linear up to full enforcement at 50% load and beyond, so unloaded routers carry LU traffic while loaded ones shed it.
`static void`	`setHighLoadCpuPct(int val)` The high-load CPU threshold percentage.
`static void`	`setHighLoadLagMs(int val)` The high-load job lag threshold in milliseconds.
`static void`	`setHighLoadSysLoadPct(int val)` The high-load system load threshold percentage.
`static void`	`setModerateLoadCpuPct(int val)` The moderate-load CPU threshold percentage.
`static void`	`setModerateLoadLagMs(int val)` The moderate-load job lag threshold in milliseconds.
`static void`	`setModerateLoadSysLoadPct(int val)` The moderate-load system load threshold percentage.
`static void`	`setRequestBurst1sThreshold(int val)` The burst threshold for 1-second sliding window.
`static void`	`setRequestLoadWeight(int val)` The load weight percentage.
`static void`	`setRequestMaxLimit(int val)` The maximum request limit per peer.
`static void`	`setRequestMinLimit(int val)` The minimum request limit per peer.
`static void`	`setRequestPctLimit(int val)` The request limit as percentage of participating tunnel count.
`static void`	`setRequestRejectSteepness(int val)` The rejection steepness (100=linear, 500=max curve).
`static void`	`setRequestRejectThreshold(int val)` The rejection threshold percentage.
`static void`	`setSustainedModerateLoadMs(long val)` The duration (ms) moderate load must persist before disconnecting low-share peers.
`(package private) boolean`	`shouldThrottle(Hash h)` Checks if the given router's tunnel requests should be throttled.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - _highLoadCpuPct
```
public static volatile int _highLoadCpuPct
```
    High-load CPU threshold (percent) @since 0.9.70+
  - _highLoadLagMs
```
public static volatile int _highLoadLagMs
```
    High-load job lag threshold (ms) @since 0.9.70+
  - _highLoadSysLoadPct
```
public static volatile int _highLoadSysLoadPct
```
    High-load system load threshold (percent, normalized by cores) @since 0.9.70+
  - _moderateLoadCpuPct
```
public static volatile int _moderateLoadCpuPct
```
    Moderate-load CPU threshold (percent) @since 0.9.70+
  - _moderateLoadLagMs
```
public static volatile int _moderateLoadLagMs
```
    Moderate-load job lag threshold (ms) @since 0.9.70+
  - _moderateLoadSysLoadPct
```
public static volatile int _moderateLoadSysLoadPct
```
    Moderate-load system load threshold (percent, normalized by cores) @since 0.9.70+
  - _reqBurst1sThreshold
```
public static volatile int _reqBurst1sThreshold
```
    Burst threshold for 1-second sliding window (requests per second). @since 0.9.70+
  - _reqLoadWeight
```
public static volatile int _reqLoadWeight
```
    Load weight: how much load inflates effective ratio (0-300%, default 100%). @since 0.9.70+
  - _reqMaxLimit
```
public static volatile int _reqMaxLimit
```
    Maximum request limit per peer. @since 0.9.70+
  - _reqMinLimit
```
public static volatile int _reqMinLimit
```
    Minimum request limit per peer. @since 0.9.70+
  - _reqPercentLimit
```
public static volatile int _reqPercentLimit
```
    Request limit as percentage of participating tunnel count. @since 0.9.70+
  - _reqRejectSteepness
```
public static volatile int _reqRejectSteepness
```
    Rejection steepness: 100=linear ramp, 200=quadratic. @since 0.9.70+
  - _reqRejectThreshold
```
public static volatile int _reqRejectThreshold
```
    Rejection threshold: start rejecting at count/limit ratio this high (30-100, default 70%). @since 0.9.70+
  - _sustainedModerateLoadMs
```
public static volatile long _sustainedModerateLoadMs
```
    Duration (ms) moderate load must persist before disconnecting low-share peers @since 0.9.70+
  - DEFAULT_SHOULD_DISCONNECT
```
static final boolean DEFAULT_SHOULD_DISCONNECT
```
    See Also:
    Constant Field Values
  - DEFAULT_SHOULD_THROTTLE
```
static final boolean DEFAULT_SHOULD_THROTTLE
```
    See Also:
    Constant Field Values
  - PROP_SHOULD_DISCONNECT
```
static final String PROP_SHOULD_DISCONNECT
```
    See Also:
    Constant Field Values
  - PROP_SHOULD_THROTTLE
```
static final String PROP_SHOULD_THROTTLE
```
    See Also:
    Constant Field Values
- Constructor Detail
  - RequestThrottler
```
RequestThrottler(RouterContext ctx)
```
    Creates a new RequestThrottler bound to the given router context. Initializes the request counter, burst detector, ban logger, and configures tunable parameters from router properties.
    Parameters:
    ctx - the router context
- Method Detail
  - burstBanDurationMs
```
static long burstBanDurationMs(int offenses)
```
    Ban length for a repeated burst offense: zero for the first BURST_BAN_OFFENSES - 1 offenses (throttle-only), then five minutes growing by five minutes per further offense, capped at thirty minutes.
    Parameters:
    offenses - the consecutive offense count, 1-based
    Returns:
    the ban duration in ms, 0 when only throttling applies
  - burstThreshold
```
static int burstThreshold(int configuredThreshold,
                          int limit)
```
    Effective single-second burst threshold for a peer: the configured floor, raised so peers whose limit permits heavy traffic are not banned for bursts that limit allows (one tenth of the 90-second request limit as a per-second ceiling).
    Parameters:
    configuredThreshold - the i2p.tunnel.requestThrottle.burst1sThreshold value
    limit - the peer's request limit for the current window
    Returns:
    the burst threshold in requests per second
  - getHighLoadCpuPct
```
public static int getHighLoadCpuPct()
```
    The high-load CPU threshold percentage.
    Returns:
    the high-load CPU percentage
  - getHighLoadLagMs
```
public static int getHighLoadLagMs()
```
    The high-load job lag threshold in milliseconds.
    Returns:
    the high-load lag threshold (ms)
  - getHighLoadSysLoadPct
```
public static int getHighLoadSysLoadPct()
```
    The high-load system load threshold percentage (normalized by cores).
    Returns:
    the high-load system load percentage
  - getModerateLoadCpuPct
```
public static int getModerateLoadCpuPct()
```
    The moderate-load CPU threshold percentage.
    Returns:
    the moderate-load CPU percentage
  - getModerateLoadLagMs
```
public static int getModerateLoadLagMs()
```
    The moderate-load job lag threshold in milliseconds.
    Returns:
    the moderate-load lag threshold (ms)
  - getModerateLoadSysLoadPct
```
public static int getModerateLoadSysLoadPct()
```
    The moderate-load system load threshold percentage (normalized by cores).
    Returns:
    the moderate-load system load percentage
  - getRequestBurst1sThreshold
```
public static int getRequestBurst1sThreshold()
```
    The burst threshold for 1-second sliding window.
    Returns:
    the burst threshold (requests per second)
  - getRequestLoadWeight
```
public static int getRequestLoadWeight()
```
    The load weight (how much load inflates effective ratio, 0-300%).
    Returns:
    the load weight percentage
  - getRequestMaxLimit
```
public static int getRequestMaxLimit()
```
    The maximum request limit per peer.
    Returns:
    the maximum limit
  - getRequestMinLimit
```
public static int getRequestMinLimit()
```
    The minimum request limit per peer.
    Returns:
    the minimum limit
  - getRequestPctLimit
```
public static int getRequestPctLimit()
```
    The request limit as percentage of participating tunnel count.
    Returns:
    the percentage limit
  - getRequestRejectSteepness
```
public static int getRequestRejectSteepness()
```
    The rejection steepness (100=linear ramp, 200=quadratic).
    Returns:
    the rejection steepness value
  - getRequestRejectThreshold
```
public static int getRequestRejectThreshold()
```
    The rejection threshold (30-100, default 70%).
    Returns:
    the rejection threshold percentage
  - getSustainedModerateLoadMs
```
public static long getSustainedModerateLoadMs()
```
    The duration (ms) moderate load must persist before disconnecting low-share peers.
    Returns:
    the sustained moderate load duration (ms)
  - luEnforcementProbability
```
static float luEnforcementProbability(float loadScore)
```
    Probability of enforcing the LU prev-hop ban at a given load score: zero when idle, linear up to full enforcement at 50% load and beyond, so unloaded routers carry LU traffic while loaded ones shed it.
    Parameters:
    loadScore - the 0.0-1.0 load score from ParticipatingThrottler.calculateLoadScore(net.i2p.router.RouterContext)
    Returns:
    the enforcement probability, clamped to 0.0-1.0
  - setHighLoadCpuPct
```
public static void setHighLoadCpuPct(int val)
```
    The high-load CPU threshold percentage.
    Parameters:
    val - the CPU percentage (clamped to 50-100)
  - setHighLoadLagMs
```
public static void setHighLoadLagMs(int val)
```
    The high-load job lag threshold in milliseconds.
    Parameters:
    val - the high-load lag threshold (clamped to 200-5000)
  - setHighLoadSysLoadPct
```
public static void setHighLoadSysLoadPct(int val)
```
    The high-load system load threshold percentage.
    Parameters:
    val - the system load percentage (clamped to 50-100)
  - setModerateLoadCpuPct
```
public static void setModerateLoadCpuPct(int val)
```
    The moderate-load CPU threshold percentage.
    Parameters:
    val - the CPU percentage (clamped to 40-100)
  - setModerateLoadLagMs
```
public static void setModerateLoadLagMs(int val)
```
    The moderate-load job lag threshold in milliseconds.
    Parameters:
    val - the moderate-load lag threshold (clamped to 100-3000)
  - setModerateLoadSysLoadPct
```
public static void setModerateLoadSysLoadPct(int val)
```
    The moderate-load system load threshold percentage.
    Parameters:
    val - the system load percentage (clamped to 30-100)
  - setRequestBurst1sThreshold
```
public static void setRequestBurst1sThreshold(int val)
```
    The burst threshold for 1-second sliding window.
    Parameters:
    val - the burst threshold (clamped to 1-100)
  - setRequestLoadWeight
```
public static void setRequestLoadWeight(int val)
```
    The load weight percentage.
    Parameters:
    val - the load weight (clamped to 0-300)
  - setRequestMaxLimit
```
public static void setRequestMaxLimit(int val)
```
    The maximum request limit per peer.
    Parameters:
    val - the maximum limit (clamped to 10-1000)
  - setRequestMinLimit
```
public static void setRequestMinLimit(int val)
```
    The minimum request limit per peer.
    Parameters:
    val - the minimum limit (clamped to 1-100)
  - setRequestPctLimit
```
public static void setRequestPctLimit(int val)
```
    The request limit as percentage of participating tunnel count.
    Parameters:
    val - the percentage limit (clamped to 1-100)
  - setRequestRejectSteepness
```
public static void setRequestRejectSteepness(int val)
```
    The rejection steepness (100=linear, 500=max curve).
    Parameters:
    val - the steepness value (clamped to 100-500)
  - setRequestRejectThreshold
```
public static void setRequestRejectThreshold(int val)
```
    The rejection threshold percentage.
    Parameters:
    val - the rejection threshold (clamped to 30-100)
  - setSustainedModerateLoadMs
```
public static void setSustainedModerateLoadMs(long val)
```
    The duration (ms) moderate load must persist before disconnecting low-share peers.
    Parameters:
    val - the sustained moderate load duration (clamped to 10-300s)
  - shouldThrottle
```
boolean shouldThrottle(Hash h)
```
    Checks if the given router's tunnel requests should be throttled. Increments the request count and evaluates limits, router capabilities, blocking policies, version, and system load to decide throttling.
    Parameters:
    h - the router's hash
    Returns:
    true if the request should be throttled (denied), false otherwise

Class RequestThrottler

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

_highLoadCpuPct

_highLoadLagMs

_highLoadSysLoadPct

_moderateLoadCpuPct

_moderateLoadLagMs

_moderateLoadSysLoadPct

_reqBurst1sThreshold

_reqLoadWeight

_reqMaxLimit

_reqMinLimit

_reqPercentLimit

_reqRejectSteepness

_reqRejectThreshold

_sustainedModerateLoadMs

DEFAULT_SHOULD_DISCONNECT

DEFAULT_SHOULD_THROTTLE

PROP_SHOULD_DISCONNECT

PROP_SHOULD_THROTTLE

Constructor Detail

RequestThrottler

Method Detail

burstBanDurationMs

burstThreshold

getHighLoadCpuPct

getHighLoadLagMs

getHighLoadSysLoadPct

getModerateLoadCpuPct

getModerateLoadLagMs

getModerateLoadSysLoadPct

getRequestBurst1sThreshold

getRequestLoadWeight

getRequestMaxLimit

getRequestMinLimit

getRequestPctLimit

getRequestRejectSteepness

getRequestRejectThreshold

getSustainedModerateLoadMs

luEnforcementProbability

setHighLoadCpuPct

setHighLoadLagMs

setHighLoadSysLoadPct

setModerateLoadCpuPct

setModerateLoadLagMs

setModerateLoadSysLoadPct

setRequestBurst1sThreshold

setRequestLoadWeight

setRequestMaxLimit

setRequestMinLimit

setRequestPctLimit

setRequestRejectSteepness

setRequestRejectThreshold

setSustainedModerateLoadMs

shouldThrottle