From a351a29bf3a0df51bf355b2fe0a061b4d2543002 Mon Sep 17 00:00:00 2001
From: jrandom <jrandom>
Date: Fri, 25 Jun 2004 17:12:01 +0000
Subject: [PATCH] if it expired waiting on the queue for processing, kill 'er

---
 .../i2p/router/message/HandleTunnelMessageJob.java  | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/router/java/src/net/i2p/router/message/HandleTunnelMessageJob.java b/router/java/src/net/i2p/router/message/HandleTunnelMessageJob.java
index a2dec7770..9194219bb 100644
--- a/router/java/src/net/i2p/router/message/HandleTunnelMessageJob.java
+++ b/router/java/src/net/i2p/router/message/HandleTunnelMessageJob.java
@@ -61,6 +61,19 @@ public class HandleTunnelMessageJob extends JobImpl {
     public String getName() { return "Handle Inbound Tunnel Message"; }
     public void runJob() {
         TunnelId id = _message.getTunnelId();
+
+        if (_context.clock().now() >= _message.getMessageExpiration().getTime()) {
+            if (_log.shouldLog(Log.ERROR))
+                _log.error("Accepted message (" + _message.getUniqueId() + ") expired on the queue for tunnel " 
+                           + id.getTunnelId() + " expiring " 
+                           + (_context.clock().now() - _message.getMessageExpiration().getTime())
+                           + "ms agp");
+            _context.messageHistory().messageProcessingError(_message.getUniqueId(), 
+                                                             TunnelMessage.class.getName(), 
+                                                             "tunnel message expired on the queue");
+            return;
+        }
+        
         TunnelInfo info = _context.tunnelManager().getTunnelInfo(id);
 	
         if (info == null) {