From 893d1bb45f57b8a8ab2d0b73454a1c1a2260914c Mon Sep 17 00:00:00 2001 From: zzz Date: Wed, 5 Nov 2014 16:59:19 +0000 Subject: [PATCH] Job Queue: Only drop lookup jobs if lagged --- router/java/src/net/i2p/router/JobQueue.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/router/java/src/net/i2p/router/JobQueue.java b/router/java/src/net/i2p/router/JobQueue.java index c7d86c127..b9be0d88b 100644 --- a/router/java/src/net/i2p/router/JobQueue.java +++ b/router/java/src/net/i2p/router/JobQueue.java @@ -286,9 +286,14 @@ public class JobQueue { // we don't really *need* to answer DB lookup messages // This is pretty lame, there's actually a ton of different jobs we // could drop, but is it worth making a list? - if (cls == HandleFloodfillDatabaseLookupMessageJob.class) - return true; - + if (cls == HandleFloodfillDatabaseLookupMessageJob.class) { + JobTiming jt = job.getTiming(); + if (jt != null) { + long lag = _context.clock().now() - jt.getStartAfter(); + if (lag > 2*1000L) + return true; + } + } } return false; }