Tuner.ActivityWindowParam | Javadocs [I2P+]

java.lang.Object

net.i2p.router.Tuner.BaseParam

net.i2p.router.Tuner.ActivityWindowParam

All Implemented Interfaces:: Tuner.TunableParam

Enclosing class:: Tuner

private class Tuner.ActivityWindowParamextends Tuner.BaseParam

Tunes the peer-selection activity-window multiplier to the recency window that peer supply actually warrants.

The window exists to trade recency for pool thickness when, and only when, the router is short of the peers selection would otherwise use. An earlier version drove it from tunnel.buildSuccessRate instead, which was a category error: build success measures outcomes, not supply, and is depressed just as much by unresponsive peers, build timeouts and unreachable destinations as by an over-tight recency window. Keying the window to it closed a positive feedback loop — worse builds widened the window, admitting older peers, which worsened the builds — and did so while ample fast and high-capacity peers sat unused.

The sole gate is now peer supply, shared with TunnelPeerSelector and the pool starvation bypass so all three callers agree. Above TunnelPeerSelector.SCARCE_FAST_PEERS fast peers the multiplier stays at its floor regardless of build success. The one exception is the startup grace period, where a cold profile set makes every peer look stale for want of test history rather than fault.

Value is a multiplier (1-4) applied to the base activity window.

Field Summary
Fields
Modifier and Type
Field
Description
private int
_healthyCycles
Consecutive cycles observed with ample peer supply, counting toward Tuner.HEALTHY_CYCLES_TO_TIGHTEN.
Fields inherited from class Tuner.BaseParam
_autotune, _autoTuning, _cpuDriven, _ctx, _defaultMax, _defaultMin, _defaultStep, _defaultValue, _description, _effMax, _factoryDefault, _firstTick, _health, _historyCount, _initialValue, _log, _max, _min, _name, _override, _propPrefix, _statHistory, _statName, _step, _subsystem, _valueHistory, sharedAutotune
Modifier and Type
Field
Description
protected final Tuner.AutotuneConfig
_autotune
Autotune profile for this tunable parameter.
protected boolean
_autoTuning
Whether autotuning is active for this parameter.
protected boolean
_cpuDriven
Whether this param's value is being driven by CPU load rather than its own stat.
protected final RouterContext
_ctx
Router context.
protected final int
_defaultMax
Default maximum value from code or config.
protected final int
_defaultMin
Default minimum value from code or config.
protected final int
_defaultStep
Default step/increment size for adjustments.
protected int
_defaultValue
Factory default: value before any tuning.
protected final String
_description
Human-readable label for display in the Tuner UI.
protected int
_effMax
Effective ceiling = min(_max, memory-derived bound); never exceeds _max.
protected final int
_factoryDefault
Code-level default captured at construction time.
protected boolean
_firstTick
True until first Tuner.BaseParam.update() call — applies persisted value from autotune.config.
protected Tuner.SystemHealth
_health
Health score and subsystem for autotune decisions.
protected int
_historyCount
Number of valid entries in _valueHistory / _statHistory.
protected final int
_initialValue
Last known value (from persistence or runtime default).
protected final Log
_log
Class logger.
protected int
_max
Current maximum value (may differ from default after tuning).
protected int
_min
Current minimum value (may differ from default after tuning).
protected final String
_name
Internal config property key (e.g.
protected int
_override
User-set override value, or Integer.MIN_VALUE if unset.
protected final String
_propPrefix
Config key prefix for property lookups.
protected final double[]
_statHistory
Rolling window of recent stat values for trend analysis.
protected final String
_statName
Router stat name for observed value feedback.
protected int
_step
Current step/increment size (may differ from default).
protected final String
_subsystem
Subsystem identifier this parameter belongs to.
protected final int[]
_valueHistory
Rolling window of recent tunable values for trend analysis.
(package private) static Tuner.AutotuneConfig
sharedAutotune
Shared instance — set once in Tuner constructor, used by all BaseParams.
Constructor Summary
Constructors
Constructor
Description
ActivityWindowParam()
Creates the parameter that multiplies the peer selection activity window.
Method Summary
All Methods
Modifier and Type
Method
Description
protected void
applyValue(int value)
Apply the tunable value to the router configuration.
protected int
computeTarget(double observed)
Compute the target multiplier from peer supply, ignoring the observed build success rate.
protected double
getObservedStat(RouterContext ctx)
Observed stat, retained for the base-class contract and the console cross-reference only.
protected int
getRuntimeValue()
Current runtime value read from the router configuration.
Methods inherited from class Tuner.BaseParam
clamp, decisionReason, getAdditionalEventCount, getAdditionalEventCountHourly, getAdditionalStat, getAdditionalStat5Min, getAdditionalStatHourly, getAdditionalStatLong, getBuildSuccessRate, getCoDelDropEventCount, getCurrentValue, getDefaultMax, getDefaultMin, getDefaultStep, getDefaultValue, getDescription, getHeavyTransitThreshold, getMax, getMessageReceiverUtilization, getMin, getName, getObservedRTT, getPacketHandlerUtilization, getPumperUtilization, getReaderUtilization, getSendFinisherUtilization, getShareBps, getStatHistory, getStatPeriodStamp, getStep, getStreamingLossRate, getSubsystem, getSustainedHeavyTransitThreshold, getValueHistory, getWriterUtilization, isAutoTuning, persistValue, reclaimIfIdle, recordHistory, refreshDefault, refreshRanges, setHealth, setOverride, signalIsFresh, snapshot, update
Modifier and Type
Method
Description
protected static int
clamp(int current, int target, int step)
Move from current toward target, but at most one step per cycle.
protected String
decisionReason()
Why the current target was chosen, for the change line.
protected double
getAdditionalEventCount(RouterContext ctx, String statName)
Fetch the event count for an additional stat using the 60s period.
protected double
getAdditionalEventCountHourly(RouterContext ctx, String statName)
Fetch the event count for an additional stat using the 1-hour period.
protected double
getAdditionalStat(RouterContext ctx, String statName)
Fetch an additional stat value for cross-reference decisions.
protected double
getAdditionalStat5Min(RouterContext ctx, String statName)
Fetch an additional stat value using the 5-minute average.
protected double
getAdditionalStatHourly(RouterContext ctx, String statName)
Fetch an additional stat value using the 1-hour average.
protected double
getAdditionalStatLong(RouterContext ctx, String statName)
Fetch an additional stat value using the 10-minute average.
protected double
getBuildSuccessRate(RouterContext ctx)
Compute actual tunnel build success rate from event counts.
protected double
getCoDelDropEventCount(RouterContext ctx, String prefix)
Fetch the total CoDel drop event count across all priority levels.
int
getCurrentValue()
The value in effect right now.
protected int
getDefaultMax(RouterContext ctx)
Effective default max — override for bandwidth-scaled params.
protected int
getDefaultMin(RouterContext ctx)
Effective default min — override for bandwidth-scaled params.
protected int
getDefaultStep(RouterContext ctx)
Effective default step — override for bandwidth-scaled params.
int
getDefaultValue()
Default value.
String
getDescription()
Param description.
protected static int
getHeavyTransitThreshold(RouterContext ctx)
Transit bandwidth threshold for "heavy" — 80% of configured share bandwidth.
int
getMax()
Maximum value.
protected double
getMessageReceiverUtilization(RouterContext ctx)
UDP message receiver pool utilization (0.0-1.0).
int
getMin()
Minimum value.
String
getName()
Param name.
protected double
getObservedRTT(RouterContext ctx, String primaryStat)
Fetch observed RTT, falling back to udp.sendConfirmTime when the primary stat has no events (lightly loaded router).
protected double
getPacketHandlerUtilization(RouterContext ctx)
UDP packet handler pool utilization (0.0-1.0).
protected double
getPumperUtilization(RouterContext ctx)
Tunnel pumper pool utilization (0.0-1.0).
protected double
getReaderUtilization(RouterContext ctx)
NTCP reader pool utilization (0.0-1.0).
protected double
getSendFinisherUtilization(RouterContext ctx)
NTCP send finisher pool utilization (0.0-1.0).
protected static int
getShareBps(RouterContext ctx)
Current share bandwidth in bytes per second.
double[]
getStatHistory()
Rolling window of recent stat values.
protected double
getStatPeriodStamp(RouterContext ctx, String statName)
When the window behind a stat's event count last completed, in ms, or NaN when it cannot be determined.
int
getStep()
Step size.
protected double
getStreamingLossRate(RouterContext ctx)
Recent streaming retransmission rate for this tuning cycle.
String
getSubsystem()
Subsystem name.
protected static int
getSustainedHeavyTransitThreshold(RouterContext ctx)
Transit bandwidth threshold for "sustained heavy" — 50% of configured share.
int[]
getValueHistory()
Rolling window of recent tunable values.
protected double
getWriterUtilization(RouterContext ctx)
NTCP writer pool utilization (0.0-1.0).
boolean
isAutoTuning()
Whether auto-tuning is enabled.
protected void
persistValue(RouterContext ctx, int value)
Persist a tuned value to autotune.config.
protected static int
reclaimIfIdle(double utilization, int current, int min, double idleThreshold)
Reclaim parked threads from a thread pool that is massively under-utilized.
protected void
recordHistory(double observed)
Record history.
void
refreshDefault(RouterContext ctx)
Re-read the default value from autotune.config for live updates.
void
refreshRanges(RouterContext ctx)
Re-read min/max/step from autotune.config — live update, no restart.
(package private) void
setHealth(Tuner.SystemHealth health)
The current system health score for this update cycle.
void
setOverride(int value)
A manual override value.
(package private) static boolean
signalIsFresh(double periodStamp, double lastStamp)
Whether a signal reading is from a window that closed since the stored stamp.
Tuner.ParamSnapshot
snapshot()
Capture snapshot of current tunable state for display.
void
update()
Main tuning loop for this param.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- _healthyCycles
  private int _healthyCycles
  Consecutive cycles observed with ample peer supply, counting toward Tuner.HEALTHY_CYCLES_TO_TIGHTEN. Reset whenever supply is scarce or the router is in its startup grace period, so relief is withdrawn only after sustained evidence that it is no longer needed.
Constructor Details
- ActivityWindowParam
  ActivityWindowParam()
  Creates the parameter that multiplies the peer selection activity window.
Method Details
- applyValue
  protected void applyValue(int value)
  Description copied from class: Tuner.BaseParam
  Apply the tunable value to the router configuration.
  Specified by:
  applyValue in class Tuner.BaseParam
  Parameters:
  value - the tunable value to apply to router configuration
- getRuntimeValue
  protected int getRuntimeValue()
  Description copied from class: Tuner.BaseParam
  Current runtime value read from the router configuration.
  Specified by:
  getRuntimeValue in class Tuner.BaseParam
  Returns:
  current runtime value read from router config
- getObservedStat
  protected double getObservedStat(RouterContext ctx)
  Observed stat, retained for the base-class contract and the console cross-reference only. This param no longer gates on it: build success is an outcome, not a measure of peer supply, so widening the recency window in response to it fed back on itself. See the class javadoc.
  Specified by:
  getObservedStat in class Tuner.BaseParam
  Parameters:
  ctx - router context, never null
  Returns:
  the current build success rate, or NaN when unavailable
- computeTarget
  protected int computeTarget(double observed)
  Compute the target multiplier from peer supply, ignoring the observed build success rate. Ample fast peers pin the window at its floor no matter how degraded builds look. Scarcity, or the startup grace period, is the only thing that widens it.
  Specified by:
  computeTarget in class Tuner.BaseParam
  Parameters:
  observed - build success rate; carried for the base-class contract and deliberately not consulted
  Returns:
  the multiplier to apply

Field Summary

Fields inherited from class Tuner.BaseParam

Constructor Summary

Method Summary

Methods inherited from class Tuner.BaseParam

Methods inherited from class Object

Field Details

_healthyCycles

Constructor Details

ActivityWindowParam

Method Details

applyValue

getRuntimeValue

getObservedStat

computeTarget