Method Details

• getLifetimeAgreedTo

  public long getLifetimeAgreedTo()

  Total tunnels the peer has agreed to participate in.

  Returns:

  the count since the last decay, applied every 8 hours by decayLifetimeCounters(long)

• getLifetimeRejected

  public long getLifetimeRejected()

  Total tunnels the peer has refused to participate in (does not include timeouts).

  Returns:

  the count since the last decay, applied every 8 hours by decayLifetimeCounters(long)

• getLifetimeTimedOut

  public long getLifetimeTimedOut()

  Total tunnel builds to this peer that timed out without a response.

  Returns:

  the count since the last decay, applied every 8 hours by decayLifetimeCounters(long)

• getLifetimeFailed

  public long getLifetimeFailed()

  Total tunnels the peer has agreed to participate in that were later marked as failed prematurely.

  Returns:

  the count since the last decay, applied every 8 hours by decayLifetimeCounters(long)

• getLastAgreedTo

  public long getLastAgreedTo()

  When the peer last agreed to participate in a tunnel.

  Returns:

  milliseconds since the epoch, or 0 if the peer has never agreed

• getLastRejectedCritical

  public long getLastRejectedCritical()

  When the peer last refused to participate in a tunnel with level of critical.

  Returns:

  milliseconds since the epoch, or 0 if the peer has never rejected at this severity

• getLastRejectedBandwidth

  public long getLastRejectedBandwidth()

  When the peer last refused to participate in a tunnel complaining of bandwidth overload.

  Returns:

  milliseconds since the epoch, or 0 if the peer has never rejected at this severity

• getLastRejectedTransient

  public long getLastRejectedTransient()

  When the peer last refused to participate in a tunnel complaining of transient overload.

  Returns:

  milliseconds since the epoch, or 0 if the peer has never rejected at this severity

• getLastRejectedProbabalistic

  public long getLastRejectedProbabalistic()

  When the peer last refused to participate in a tunnel probabalistically.

  Returns:

  milliseconds since the epoch, or 0 if the peer has never rejected at this severity

• getLastTimedOut

  public long getLastTimedOut()

  When the peer last timed out without responding to a tunnel request.

  Returns:

  milliseconds since the epoch, or 0 if the peer has never timed out

• getLastFailed

  public long getLastFailed()

  When the last tunnel the peer participated in failed.

  Returns:

  milliseconds since the epoch, or 0 if no participating tunnel has failed

• getLastTestedSuccessfully

  public long getLastTestedSuccessfully()

  When the peer last passed a tunnel test.

  Returns:

  milliseconds since the epoch, or 0 if the peer has never passed a tunnel test

• incrementTestSucceeded

  public void incrementTestSucceeded()

  Record that a tunnel test through this peer succeeded. This indicates the peer is actively participating in working tunnels.

• getAcceptanceRatio

  public double getAcceptanceRatio()

  Calculate the ratio of accepted to total tunnel requests. Only explicit rejections are counted; timeouts are tracked separately via getLifetimeTimedOut() and the time-windowed getRejectionRate() RateStat.

  Returns:

  ratio (0.0 to 1.0), or 1.0 if no data available

• incrementProcessed

  public void incrementProcessed(int processedSuccessfully, int failedProcessing)

  Processed message counter; legacy method, no longer tracked.

  Parameters:

  processedSuccessfully - the number of successfully processed messages, ignored

  failedProcessing - the number of messages that failed to process, ignored

• incrementAgreedTo

  public void incrementAgreedTo()

  Count a tunnel participation agreement and record its time.

• incrementRejected

  public void incrementRejected(int severity)

  Count a tunnel rejection at the given severity and record its time.

  Parameters:

  severity - how much the peer doesnt want to participate in the tunnel (large == more severe)

• incrementTimedOut

  public void incrementTimedOut()

  Count a tunnel build timeout (peer did not respond in time). Timeouts are tracked separately from rejections because a peer that is slow to respond is different from a peer that actively refuses. Timeouts do NOT count toward getLifetimeRejected() and therefore do not affect getAcceptanceRatio().

• incrementFailed

  public void incrementFailed(int pct)

  Define this rate as the probability it really failed.

  Parameters:

  pct - = probability * 100

• getRejectionRate

  public RateStat getRejectionRate()

  Rejection rate statistics for this peer.

  Returns:

  the rejection rate

• getFailedRate

  public RateStat getFailedRate()

  Failure rate statistics for this peer.

  Returns:

  the failed rate

• decayLifetimeCounters

  public void decayLifetimeCounters(long now)

  Apply the lifetime-counter decay if its interval has elapsed.

  Deliberately does not coalesce the RateStats. Those are folded by coalesceStats() on the caller's own cadence, and folding them again here would advance their windows twice as often as the statistic's consumers expect. A caller that only wants the decay — the tier reorganise walking every candidate — can call this cheaply: one volatile read and one comparison, with real work only on the pass that actually crosses the interval.

  Must be called with the write lock held when called from the reorganise, so the tier membership being read and the counters being decayed are consistent.

  Parameters:

  now - current time in ms

• coalesceStats

  public void coalesceStats()

  Coalesce the rate statistics and periodically decay lifetime counters.

  Lifetime counters (_lifetimeAgreedTo, _lifetimeRejected, _lifetimeTimedOut, _lifetimeFailed) are decayed at 75% per 8 hours (matching DBHistory). This prevents unbounded growth across restarts and ensures stale history does not permanently block peers from tiers. Recency is handled by the RateStats (10-minute and 1-hour windows) and by selection gates.

• decayCounter

  private void decayCounter(AtomicLong counter, String name)

  Apply decay to a counter. 3/4 per 8 h = ~1% after 128 hours.

  Parameters:

  counter - the lifetime counter to scale down, left alone when already zero

  name - the counter's name, for the debug log

• store

  public void store(OutputStream out) throws IOException

  Write the tunnel history to the stream, including comments.

  Parameters:

  out - the stream to write the properties-formatted history to

  Throws:

  IOException - if the stream rejects a write

• store

  public void store(OutputStream out, boolean addComments) throws IOException

  Write the data from the profile to the stream.

  Parameters:

  out - the stream to write the properties-formatted history to

  addComments - add comment lines to the output

  Throws:

  IOException - if the stream rejects a write

• addDate

  private static void addDate(StringBuilder buf, boolean addComments, String name, long val, String description)

  Appends the date line to the history file.

  Parameters:

  buf - where the line is appended

  addComments - true to write the line as a comment

  name - the statistic name

  val - the statistic value, used as the date

  description - the text shown before the date

• add

  private static void add(StringBuilder buf, boolean addComments, String name, long val, String description)

  Appends one statistic to the history file.

  Parameters:

  buf - where the line is appended

  addComments - true to write the line as a comment

  name - the statistic name

  val - the statistic value

  description - the text shown with the value

• load

  public void load(Properties props)

  Restore the tunnel history fields from the given properties.

  Parameters:

  props - the persisted properties previously written by store(OutputStream, boolean)

• getLong

  private static final long getLong(Properties props, String key)

  Reads a long property with a default of zero.

  Parameters:

  props - the properties read

  key - the property name

  Returns:

  the value, zero if unparseable