From e569a84dc0b6fb9e25ff12398c9142e31473de93 Mon Sep 17 00:00:00 2001 From: theli Date: Wed, 24 Aug 2005 09:34:04 +0000 Subject: [PATCH] *) Using the same configuration settings for all indexing threads on server Startup See: http://www.yacy-forum.de/viewtopic.php?p=8349 git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@584 6c8d7289-2bf4-0310-a012-ef5d649a1542 --- htroot/Performance_p.java | 1 - source/de/anomic/plasma/plasmaSwitchboard.java | 8 ++++++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/htroot/Performance_p.java b/htroot/Performance_p.java index 075863d01..3b821311a 100644 --- a/htroot/Performance_p.java +++ b/htroot/Performance_p.java @@ -50,7 +50,6 @@ import java.io.File; import org.apache.commons.pool.impl.GenericObjectPool; import de.anomic.http.httpHeader; -import de.anomic.http.httpd; import de.anomic.plasma.plasmaSwitchboard; import de.anomic.server.serverCore; import de.anomic.server.serverObjects; diff --git a/source/de/anomic/plasma/plasmaSwitchboard.java b/source/de/anomic/plasma/plasmaSwitchboard.java index 92382bd52..d8e9d9b83 100644 --- a/source/de/anomic/plasma/plasmaSwitchboard.java +++ b/source/de/anomic/plasma/plasmaSwitchboard.java @@ -356,14 +356,18 @@ public final class plasmaSwitchboard extends serverAbstractSwitch implements ser if (indexing_cluster < 1) indexing_cluster = 1; deployThread("90_cleanup", "Cleanup", "simple cleaning process for monitoring information", null, new serverInstantThread(this, "cleanupJob", "cleanupJobSize"), 10000); // all 5 Minutes + serverInstantThread indexingThread = null; deployThread("80_indexing", "Parsing/Indexing", "thread that performes document parsing and indexing", "/IndexCreateIndexingQueue_p.html", - new serverInstantThread(this, "deQueue", "queueSize"), 10000); + indexingThread = new serverInstantThread(this, "deQueue", "queueSize"), 10000); for (int i = 1; i < indexing_cluster; i++) { setConfig((i + 80) + "_indexing_idlesleep", getConfig("80_indexing_idlesleep", "")); setConfig((i + 80) + "_indexing_busysleep", getConfig("80_indexing_busysleep", "")); deployThread((i + 80) + "_indexing", "Parsing/Indexing (cluster job)", "thread that performes document parsing and indexing", null, - new serverInstantThread(this, "deQueue", "queueSize"), 10000 + (i * 1000)); + new serverInstantThread(this, "deQueue", "queueSize"), 10000 + (i * 1000), + Long.parseLong(getConfig("80_indexing_idlesleep" , "5000")), + Long.parseLong(getConfig("80_indexing_busysleep" , "0")), + Long.parseLong(getConfig("80_indexing_memprereq" , "1000000"))); } deployThread("70_cachemanager", "Proxy Cache Enqueue", "job takes new proxy files from RAM stack, stores them, and hands over to the Indexing Stack", null, new serverInstantThread(this, "htEntryStoreJob", "htEntrySize"), 10000);