Field Detail

• running

  protected volatile boolean running

• sink

  protected Sink sink

• thread

  protected final Thread thread

Constructor Detail

• Pinger

  public Pinger(I2PAppContext ctx,
                int fromPort)

  Parameters:

  fromPort - the I2CP from port

Method Detail

• run

  public void run()

  Main run loop that periodically sends subscribe messages. Runs until stop() is called.

  Specified by:

  run in interface Runnable

• setSink

  public void setSink(Sink sink)

  Sets the destination sink for ping messages.

  Specified by:

  setSink in interface Source

  Parameters:

  sink - the sink to receive ping messages

• start

  public void start()

  Starts the pinger thread to send periodic subscribe messages.

  Specified by:

  start in interface Source

• stop

  public void stop()

  Stops the pinger thread and sends an unsubscribe message.