java.lang.Object
net.i2p.router.JobImpl
net.i2p.router.peermanager.PeerTestJob.PeerReplyTimeoutJob
All Implemented Interfaces:
Job
Enclosing class:
PeerTestJob
private class PeerTestJob.PeerReplyTimeoutJobextends JobImpl
Called when the peer's response times out.

  • Field Details

    • _peer

      private final RouterInfo _peer
      The peer whose test timed out.

    • _replyTunnel

      private final TunnelInfo _replyTunnel
      The tunnel the reply was expected on.

    • _sendTunnel

      private final TunnelInfo _sendTunnel
      The tunnel the test was sent on.

    • _selector

      private final PeerTestJob.ReplySelector _selector
      The selector to remove from the job queue.

  • Constructor Details

    • PeerReplyTimeoutJob

      public PeerReplyTimeoutJob(RouterContext context, RouterInfo peer, TunnelInfo replyTunnel, TunnelInfo sendTunnel, PeerTestJob.ReplySelector sel)
      Schedules timeout handling when no reply arrived in time.
      Parameters:
      context - the router context
      peer - the peer whose test timed out
      replyTunnel - the tunnel the reply was expected on
      sendTunnel - the tunnel the test was sent on
      sel - the selector to remove from the job queue

  • Method Details

    • getName

      public String getName()
      Name of this job.
      Returns:
      the name this job is listed under in the job queue and the logs, "Timeout Peer Test"

    • getShouldFailPeer

      private boolean getShouldFailPeer()
      Whether a test timeout should fail the peer.
      Returns:
      true, always

    • runJob

      public void runJob()
      Run the timeout handling job.