java.lang.Object
net.i2p.router.message.OutboundClientMessageOneShotJob.ReplySelector
All Implemented Interfaces:
MessageSelector
Enclosing class:
OutboundClientMessageOneShotJob
private static class OutboundClientMessageOneShotJob.ReplySelectorextends Object implements MessageSelector
Keep an eye out for any of the delivery status message tokens that have been sent down the various tunnels to deliver this message.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final long
    _expiration
    When the selector stops matching.
    private final long
    _pendingToken
    Token the reply must carry.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReplySelector(long token, long expiration)
    Matches the reply for one pending send.

  • Method Summary

    All Methods
    Modifier and Type
    Method
    Description
    boolean
    continueMatching()
    Returns true if the selector should still keep searching for further matches.
    long
    getExpiration()
    Returns the # of milliseconds since the epoch after which this selector should stop searching for matches.
    boolean
    isMatch(I2NPMessage inMsg)
    Returns true if the received message matches the selector.
    String
    toString()
     

    Methods inherited from class Object

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

  • Field Details

    • _pendingToken

      private final long _pendingToken
      Token the reply must carry.

    • _expiration

      private final long _expiration
      When the selector stops matching.

  • Constructor Details

    • ReplySelector

      public ReplySelector(long token, long expiration)
      Matches the reply for one pending send.
      Parameters:
      token - the token the reply must carry
      expiration - when the selector stops matching

  • Method Details

    • continueMatching

      public boolean continueMatching()
      Description copied from interface: MessageSelector
      Returns true if the selector should still keep searching for further matches. This is called only if isMatch() returns true. If this returns true, isMatch() will not be called again.
      Specified by:
      continueMatching in interface MessageSelector
      Returns:
      true to keep searching for further matches, false to stop searching

    • getExpiration

      public long getExpiration()
      Description copied from interface: MessageSelector
      Returns the # of milliseconds since the epoch after which this selector should stop searching for matches. At some time after expiration, if MessageSelector.continueMatching() has not returned false, the job specified by OutNetMessage.getOnFailedReplyJob() will be run for every OutNetMessage associated with this selector (by OutboundMessageRegistry).
      Specified by:
      getExpiration in interface MessageSelector
      Returns:
      the number of milliseconds since the epoch at which to stop searching

    • isMatch

      public boolean isMatch(I2NPMessage inMsg)
      Description copied from interface: MessageSelector
      Returns true if the received message matches the selector. If this returns true, the job specified by OutNetMessage.getOnReplyJob() will be run for every OutNetMessage associated with this selector (by InNetMessagePool), after calling setMessage() for that ReplyJob.

      WARNING this is called from within OutboundMessageSelector.getOriginalMessages() inside a lock and can lead to deadlocks if the selector does too much in MessageSelector.isMatch(I2NPMessage). Until the lock is removed, take care to keep it simple.

      Specified by:
      isMatch in interface MessageSelector
      Parameters:
      inMsg - the received message to test against this selector
      Returns:
      true if the received message is one this selector was waiting for

    • toString

      public String toString()
      Overrides:
      toString in class Object