java.lang.Object
net.i2p.router.transport.udp.EstablishmentManager.Establisher
All Implemented Interfaces:
Runnable
Enclosing class:
EstablishmentManager
private class EstablishmentManager.Establisherextends Object implements Runnable
Driving thread, processing up to one step for an inbound peer and up to one step for an outbound peer. This is prodded whenever any peer's state changes as well.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private long
    _lastFailsafe
    When the failsafe pass last ran.
    private long
    _lastPrinted
    When the establishment state was last printed.
    private static final long
    FAILSAFE_INTERVAL
    Interval between failsafe passes.
    private static final long
    PRINT_INTERVAL
    Interval between establishment state prints.

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    private
    Establisher()
    Runs one SSU handshake.

  • Method Summary

    Modifier and Type
    Method
    Description
    private void
    doFailsafe(long now)
    Perform failsafe cleanup of stale establishment states.
    private void
    doPass()
    Prints the active establishment counts if the interval passed.
    void
    run()
     

    Methods inherited from class Object

    clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • _lastFailsafe

      private long _lastFailsafe
      When the failsafe pass last ran.

    • FAILSAFE_INTERVAL

      private static final long FAILSAFE_INTERVAL
      Interval between failsafe passes.
      See Also:

    • _lastPrinted

      private long _lastPrinted
      When the establishment state was last printed.

  • Constructor Details

    • Establisher

      private Establisher()
      Runs one SSU handshake.

  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • doPass

      private void doPass()
      Prints the active establishment counts if the interval passed.

    • doFailsafe

      private void doFailsafe(long now)
      Perform failsafe cleanup of stale establishment states.
      Parameters:
      now - the current time