Tuner.StreamingReceiveWorkersParam

java.lang.Object

net.i2p.router.Tuner.BaseParam

net.i2p.router.Tuner.StreamingReceiveWorkersParam

All Implemented Interfaces:: Tuner.TunableParam

Enclosing class:: Tuner

private class Tuner.StreamingReceiveWorkersParamextends Tuner.BaseParam

Tunes inbound packet receive worker shards (i2p.streaming.receiveWorkerThreads). Grows the per-destination dispatch pool while producers are blocked on a full receive shard queue (throughput: a slow connection no longer stalls the session notifier, more connections are processed in parallel), and reclaims threads when the shard queue stays near-empty (latency: only as many threads as the traffic needs). Refuses to shrink while the path is lossy so retransmission traffic keeps its dispatch capacity (reliability). Live dispatchers are resized immediately via I2PSocketManagerFull.resizeReceiveWorkers. Primary signal: stream.receiveBacklogged. Cross-refs: stream.receiveQueueDepth, stream.rtxRatio, jobQueue.jobLag.

Field Summary
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
StreamingReceiveWorkersParam()
Creates the parameter that tunes the streaming receive worker threads.
Method Summary
All Methods
Modifier and Type
Method
Description
protected void
applyValue(int value)
Apply the tunable value to the worker default and every live dispatcher.
protected int
computeTarget(double observed)
Target tunable value computed from the observed stat.
protected double
getObservedStat(RouterContext ctx)
Read the observed stat (receiveBacklogged avg per period).
protected int
getRuntimeValue()
Current live worker default; falls back to the core-derived count.
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

Constructor Details
- StreamingReceiveWorkersParam
  StreamingReceiveWorkersParam()
  Creates the parameter that tunes the streaming receive worker threads.
Method Details
- applyValue
  protected void applyValue(int value)
  Apply the tunable value to the worker default and every live dispatcher.
  Specified by:
  applyValue in class Tuner.BaseParam
  Parameters:
  value - the tunable value to apply to router configuration
- getRuntimeValue
  protected int getRuntimeValue()
  Current live worker default; falls back to the core-derived count.
  Specified by:
  getRuntimeValue in class Tuner.BaseParam
  Returns:
  current runtime value read from router config
- getObservedStat
  protected double getObservedStat(RouterContext ctx)
  Read the observed stat (receiveBacklogged avg per period). Returns NaN only when there is no inbound packet traffic at all, so a healthy router with light traffic still reaches the reclaim decision: with no backlog events but live queue-depth observations, the cycle runs with observed == 0, letting computeTarget shrink a pool that has stopped blocking.
  Specified by:
  getObservedStat in class Tuner.BaseParam
  Parameters:
  ctx - router context, never null
  Returns:
  observed stat value for autotuning
- computeTarget
  protected int computeTarget(double observed)
  Description copied from class: Tuner.BaseParam
  Target tunable value computed from the observed stat.
  Specified by:
  computeTarget in class Tuner.BaseParam
  Parameters:
  observed - current stat value
  Returns:
  target tunable value

Field Summary

Fields inherited from class Tuner.BaseParam

Constructor Summary

Method Summary

Methods inherited from class Tuner.BaseParam

Methods inherited from class Object

Constructor Details

StreamingReceiveWorkersParam

Method Details

applyValue

getRuntimeValue

getObservedStat

computeTarget