From d4a045d7b1cdd97c710cdcd5580d986f569432f5 Mon Sep 17 00:00:00 2001 From: theli Date: Thu, 18 Aug 2005 06:40:26 +0000 Subject: [PATCH] *) Trying to solve "de.anomic.plasma.plasmaSwitchboard.deQueue': null" Bug See: http://www.yacy-forum.de/viewtopic.php?p=7791 git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@555 6c8d7289-2bf4-0310-a012-ef5d649a1542 --- source/de/anomic/plasma/plasmaSwitchboard.java | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/source/de/anomic/plasma/plasmaSwitchboard.java b/source/de/anomic/plasma/plasmaSwitchboard.java index fc613e587..eede8a499 100644 --- a/source/de/anomic/plasma/plasmaSwitchboard.java +++ b/source/de/anomic/plasma/plasmaSwitchboard.java @@ -573,7 +573,7 @@ public final class plasmaSwitchboard extends serverAbstractSwitch implements ser } public boolean deQueue() { - // work off fresh entries from the proxy or from the crawler + // work off fresh entries from the proxy or from the crawler if (onlineCaution()) { log.logDebug("deQueue: online caution, omitting resource stack processing"); return false; @@ -587,19 +587,20 @@ public final class plasmaSwitchboard extends serverAbstractSwitch implements ser // do one processing step log.logDebug("DEQUEUE: sbQueueSize=" + sbQueue.size() + - ", coreStackSize=" + urlPool.noticeURL.stackSize(plasmaCrawlNURL.STACK_TYPE_CORE) + - ", limitStackSize=" + urlPool.noticeURL.stackSize(plasmaCrawlNURL.STACK_TYPE_LIMIT) + - ", overhangStackSize=" + urlPool.noticeURL.stackSize(plasmaCrawlNURL.STACK_TYPE_OVERHANG) + - ", remoteStackSize=" + urlPool.noticeURL.stackSize(plasmaCrawlNURL.STACK_TYPE_REMOTE)); + ", coreStackSize=" + urlPool.noticeURL.stackSize(plasmaCrawlNURL.STACK_TYPE_CORE) + + ", limitStackSize=" + urlPool.noticeURL.stackSize(plasmaCrawlNURL.STACK_TYPE_LIMIT) + + ", overhangStackSize=" + urlPool.noticeURL.stackSize(plasmaCrawlNURL.STACK_TYPE_OVERHANG) + + ", remoteStackSize=" + urlPool.noticeURL.stackSize(plasmaCrawlNURL.STACK_TYPE_REMOTE)); try { nextentry = sbQueue.pop(); + if (nextentry == null) return false; } catch (IOException e) { log.logError("IOError in plasmaSwitchboard.deQueue: " + e.getMessage(), e); return false; } } - processResourceStack(nextentry); - return true; + processResourceStack(nextentry); + return true; } public int cleanupJobSize() {