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

fixed server port change

Browse Source 
git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@4826 6c8d7289-2bf4-0310-a012-ef5d649a1542
This commit is contained in:
orbiter 2008-05-19 20:51:09 +00:00
parent 53dfe9fe9a
commit 6aa9bf43f9
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
htroot/SettingsAck_p.java
View File

@ -141,7 +141,7 @@ public class SettingsAck_p {
env.setConfig("port", port);
theServerCore.reconnect();
theServerCore.reconnect(5000);
} catch (SocketException e) {
prop.put("info", "26");
return prop;

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

@ -440,7 +440,7 @@ public final class serverCore extends serverAbstractBusyThread implements server
s.interrupt();
s.close();
}
this.busySessions = null;
this.busySessions.clear();
this.log.logConfig("* terminated");
}
@ -918,11 +918,9 @@ public final class serverCore extends serverAbstractBusyThread implements server
if (currentThread.isInterrupted()) throw new InterruptedException();
if ((currentThread instanceof serverCore.Session) && ((serverCore.Session)currentThread).isStopped()) throw new InterruptedException();
}
public void reconnect() {
this.reconnect(5000);
}
public void reconnect(int delay) {
Thread restart = new Restarter();
Thread restart = new Restarter(delay);
restart.start();
}
@ -930,6 +928,9 @@ public final class serverCore extends serverAbstractBusyThread implements server
public class Restarter extends Thread {
public serverCore theServerCore = null;
public int delay = 5000;
public Restarter(int delay) {
this.delay = delay;
}
public void run() {
// waiting for a while
try {
@ -940,10 +941,10 @@ public final class serverCore extends serverAbstractBusyThread implements server
}
// signaling restart
serverCore.this.forceRestart = true;
forceRestart = true;
// closing socket to notify the thread
serverCore.this.close();
close();
}
}