From bc77e82da582877e7b0907b6ef112b7c0713ba39 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kristinn=20Sigur=C3=B0sson?= Date: Wed, 15 Jan 2014 12:49:41 +0000 Subject: [PATCH] Fix for WorkQueueFrontier.deleteURIs mishandles deletions from retired queues (HER-2062) --- .../org/archive/crawler/frontier/WorkQueueFrontier.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/engine/src/main/java/org/archive/crawler/frontier/WorkQueueFrontier.java b/engine/src/main/java/org/archive/crawler/frontier/WorkQueueFrontier.java index 7b50727a..2757f7bf 100644 --- a/engine/src/main/java/org/archive/crawler/frontier/WorkQueueFrontier.java +++ b/engine/src/main/java/org/archive/crawler/frontier/WorkQueueFrontier.java @@ -1075,8 +1075,12 @@ implements Closeable, if (queuePat.matcher(qname).matches()) { WorkQueue wq = getQueueFor(qname); wq.unpeek(null); - count += wq.deleteMatching(this, uriRegex); + long delCount = wq.deleteMatching(this, uriRegex); + if (!wq.isRetired()) { + count += delCount; + } wq.makeDirty(); + } } decrementQueuedCount(count);