Fix for WorkQueueFrontier.deleteURIs mishandles deletions from retired

queues (HER-2062)
2026-09-23 14:15:47 +00:00 · 2014-01-15 12:49:41 +00:00
parent 07293fbfb2
commit bc77e82da5
1 changed files with 5 additions and 1 deletions
@@ -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);