diff --git a/router/java/src/net/i2p/router/JobQueue.java b/router/java/src/net/i2p/router/JobQueue.java index c7d86c1270dc7bc0a6132f84e7017378aafc811c..b9be0d88b83de794877360e197e266847e0ee2a0 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; }