Changeset a351a29


Ignore:
Timestamp:
Jun 25, 2004 5:12:01 PM (17 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
7ef528b
Parents:
983d258
git-author:
jrandom <jrandom> (06/25/04 17:12:01)
git-committer:
zzz <zzz@…> (06/25/04 17:12:01)
Message:

if it expired waiting on the queue for processing, kill 'er

File:
1 edited

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/message/HandleTunnelMessageJob.java

    r983d258 ra351a29  
    6262    public void runJob() {
    6363        TunnelId id = _message.getTunnelId();
     64
     65        if (_context.clock().now() >= _message.getMessageExpiration().getTime()) {
     66            if (_log.shouldLog(Log.ERROR))
     67                _log.error("Accepted message (" + _message.getUniqueId() + ") expired on the queue for tunnel "
     68                           + id.getTunnelId() + " expiring "
     69                           + (_context.clock().now() - _message.getMessageExpiration().getTime())
     70                           + "ms agp");
     71            _context.messageHistory().messageProcessingError(_message.getUniqueId(),
     72                                                             TunnelMessage.class.getName(),
     73                                                             "tunnel message expired on the queue");
     74            return;
     75        }
     76       
    6477        TunnelInfo info = _context.tunnelManager().getTunnelInfo(id);
    6578       
Note: See TracChangeset for help on using the changeset viewer.