Marown/yacy_search_server
1
0
Fork 0
mirror of https://github.com/yacy/yacy_search_server.git synced 2024-09-19 00:01:41 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@507 6c8d7289-2bf4-0310-a012-ef5d649a1542

Browse Source
This commit is contained in:
theli 2005-08-09 09:07:19 +00:00
parent 60eaf3dcde
commit b32e7c516c
3 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/de/anomic/http/httpc.java
View File

@ -210,7 +210,12 @@ public final class httpc {
} }
// initialize it // initialize it
newHttpc.init(server,port,timeout,ssl,remoteProxyHost, remoteProxyPort); try {
newHttpc.init(server,port,timeout,ssl,remoteProxyHost, remoteProxyPort);
} catch (IOException e) {
try{ httpc.theHttpcPool.returnObject(newHttpc); } catch (Exception e1) {}
throw e;
}
return newHttpc; return newHttpc;
} }

2
source/de/anomic/plasma/plasmaCrawlWorker.java
View File

@ -414,6 +414,8 @@ public final class plasmaCrawlWorker extends Thread {
log.logWarning("Read timeout while receiving content from '" + url.toString() + log.logWarning("Read timeout while receiving content from '" + url.toString() +
"'. Retrying request."); "'. Retrying request.");
retryCrawling = true; retryCrawling = true;
} else if (errorMsg.indexOf("Connection refused") >= 0) {
log.logError("CRAWLER LOADER ERROR2 with URL=" + url.toString() + ": Connection refused");
} }
if (retryCrawling) { if (retryCrawling) {

5
source/de/anomic/server/serverCore.java
View File

@ -518,7 +518,10 @@ public final class serverCore extends serverAbstractThread implements serverThre
// trying to gracefull stop all still running sessions ... // trying to gracefull stop all still running sessions ...
serverCore.this.log.logInfo("Signaling shutdown to " + threadCount + " remaining session threads ..."); serverCore.this.log.logInfo("Signaling shutdown to " + threadCount + " remaining session threads ...");
for ( int currentThreadIdx = 0; currentThreadIdx < threadCount; currentThreadIdx++ ) { for ( int currentThreadIdx = 0; currentThreadIdx < threadCount; currentThreadIdx++ ) {
((Session)threadList[currentThreadIdx]).setStopped(true); Thread currentThread = threadList[currentThreadIdx];
if (currentThread.isAlive()) {
((Session)currentThread).setStopped(true);
}
} }
// waiting a frew ms for the session objects to continue processing // waiting a frew ms for the session objects to continue processing