forked from I2P_Developers/i2p.i2p
stop the filter in destroy method
This commit is contained in:
@@ -438,9 +438,6 @@ public class I2PTunnelServer extends I2PTunnelTask implements Runnable {
|
|||||||
if (task != null) {
|
if (task != null) {
|
||||||
task.close(forced);
|
task.close(forced);
|
||||||
}
|
}
|
||||||
StatefulConnectionFilter filter = _filter;
|
|
||||||
if (filter != null)
|
|
||||||
filter.stop();
|
|
||||||
synchronized (lock) {
|
synchronized (lock) {
|
||||||
if (!forced && sockMgr.listSockets().size() != 0) {
|
if (!forced && sockMgr.listSockets().size() != 0) {
|
||||||
l.log("There are still active connections!");
|
l.log("There are still active connections!");
|
||||||
@@ -483,6 +480,9 @@ public class I2PTunnelServer extends I2PTunnelTask implements Runnable {
|
|||||||
public synchronized boolean destroy() {
|
public synchronized boolean destroy() {
|
||||||
close(true);
|
close(true);
|
||||||
sockMgr.destroySocketManager();
|
sockMgr.destroySocketManager();
|
||||||
|
StatefulConnectionFilter filter = _filter;
|
||||||
|
if (filter != null)
|
||||||
|
filter.stop();
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user