echelon/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

propagate from branch 'i2p.i2p' (head 2ce39645bf3b3b7fc2f083ebcb073f104114e939)

Browse Source 
to branch 'i2p.i2p.zzz.815' (head 4f0279eb4cf13e547a64913443ff7819a43962c0)
This commit is contained in:
zzz
2015-03-27 14:47:49 +00:00
parent f3d573cab0 3a8ce64c84
commit 188bd6db7b
6 changed files with 152 additions and 106 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnel.java
View File

@ -885,13 +885,13 @@ public class I2PTunnel extends EventDispatcherImpl implements Logging {
if (portNum <= 0) if (portNum <= 0)
throw new IllegalArgumentException(getPrefix() + "Bad port " + args[0]); throw new IllegalArgumentException(getPrefix() + "Bad port " + args[0]);
I2PTunnelTask task;
ownDest = !isShared; ownDest = !isShared;
try { try {
String privateKeyFile = null; String privateKeyFile = null;
if (args.length >= 4) if (args.length >= 4)
privateKeyFile = args[3]; privateKeyFile = args[3];
task = new I2PTunnelClient(portNum, args[1], l, ownDest, this, this, privateKeyFile); I2PTunnelClientBase task = new I2PTunnelClient(portNum, args[1], l, ownDest, this, this, privateKeyFile);
task.startRunning();
addtask(task); addtask(task);
notifyEvent("clientTaskId", Integer.valueOf(task.getId())); notifyEvent("clientTaskId", Integer.valueOf(task.getId()));
} catch (IllegalArgumentException iae) { } catch (IllegalArgumentException iae) {
@ -964,10 +964,10 @@ public class I2PTunnel extends EventDispatcherImpl implements Logging {
} }
} }
I2PTunnelTask task;
ownDest = !isShared; ownDest = !isShared;
try { try {
task = new I2PTunnelHTTPClient(clientPort, l, ownDest, proxy, this, this); I2PTunnelClientBase task = new I2PTunnelHTTPClient(clientPort, l, ownDest, proxy, this, this);
task.startRunning();
addtask(task); addtask(task);
notifyEvent("httpclientTaskId", Integer.valueOf(task.getId())); notifyEvent("httpclientTaskId", Integer.valueOf(task.getId()));
} catch (IllegalArgumentException iae) { } catch (IllegalArgumentException iae) {
@ -1033,10 +1033,10 @@ public class I2PTunnel extends EventDispatcherImpl implements Logging {
} }
} }
I2PTunnelTask task;
ownDest = !isShared; ownDest = !isShared;
try { try {
task = new I2PTunnelConnectClient(_port, l, ownDest, proxy, this, this); I2PTunnelClientBase task = new I2PTunnelConnectClient(_port, l, ownDest, proxy, this, this);
task.startRunning();
addtask(task); addtask(task);
} catch (IllegalArgumentException iae) { } catch (IllegalArgumentException iae) {
String msg = "Invalid I2PTunnel configuration to create a CONNECT client connecting to the router at " + host + ':'+ port + String msg = "Invalid I2PTunnel configuration to create a CONNECT client connecting to the router at " + host + ':'+ port +
@ -1095,13 +1095,13 @@ public class I2PTunnel extends EventDispatcherImpl implements Logging {
} }
} }
I2PTunnelTask task;
ownDest = !isShared; ownDest = !isShared;
try { try {
String privateKeyFile = null; String privateKeyFile = null;
if (args.length >= 4) if (args.length >= 4)
privateKeyFile = args[3]; privateKeyFile = args[3];
task = new I2PTunnelIRCClient(_port, args[1], l, ownDest, this, this, privateKeyFile); I2PTunnelClientBase task = new I2PTunnelIRCClient(_port, args[1], l, ownDest, this, this, privateKeyFile);
task.startRunning();
addtask(task); addtask(task);
notifyEvent("ircclientTaskId", Integer.valueOf(task.getId())); notifyEvent("ircclientTaskId", Integer.valueOf(task.getId()));
} catch (IllegalArgumentException iae) { } catch (IllegalArgumentException iae) {
@ -1158,7 +1158,8 @@ public class I2PTunnel extends EventDispatcherImpl implements Logging {
if (args.length == 3) if (args.length == 3)
privateKeyFile = args[2]; privateKeyFile = args[2];
try { try {
I2PTunnelTask task = new I2PSOCKSTunnel(_port, l, ownDest, this, this, privateKeyFile); I2PTunnelClientBase task = new I2PSOCKSTunnel(_port, l, ownDest, this, this, privateKeyFile);
task.startRunning();
addtask(task); addtask(task);
notifyEvent("sockstunnelTaskId", Integer.valueOf(task.getId())); notifyEvent("sockstunnelTaskId", Integer.valueOf(task.getId()));
} catch (IllegalArgumentException iae) { } catch (IllegalArgumentException iae) {
@ -1205,7 +1206,8 @@ public class I2PTunnel extends EventDispatcherImpl implements Logging {
if (args.length == 3) if (args.length == 3)
privateKeyFile = args[2]; privateKeyFile = args[2];
try { try {
I2PTunnelTask task = new I2PSOCKSIRCTunnel(_port, l, ownDest, this, this, privateKeyFile); I2PTunnelClientBase task = new I2PSOCKSIRCTunnel(_port, l, ownDest, this, this, privateKeyFile);
task.startRunning();
addtask(task); addtask(task);
notifyEvent("sockstunnelTaskId", Integer.valueOf(task.getId())); notifyEvent("sockstunnelTaskId", Integer.valueOf(task.getId()));
} catch (IllegalArgumentException iae) { } catch (IllegalArgumentException iae) {
@ -1668,7 +1670,8 @@ public class I2PTunnel extends EventDispatcherImpl implements Logging {
if (!_clientOptions.containsKey("outbound.nickname")) if (!_clientOptions.containsKey("outbound.nickname"))
_clientOptions.setProperty("outbound.nickname", "I2Ping"); _clientOptions.setProperty("outbound.nickname", "I2Ping");
} }
I2PTunnelTask task = new I2Ping(l, ownDest, this, this); I2PTunnelClientBase task = new I2Ping(l, ownDest, this, this);
task.startRunning();
addtask(task); addtask(task);
notifyEvent("pingTaskId", Integer.valueOf(task.getId())); notifyEvent("pingTaskId", Integer.valueOf(task.getId()));
} else { } else {

5
apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelClient.java
View File

@ -44,11 +44,6 @@ public class I2PTunnelClient extends I2PTunnelClientBase {
tunnel, pkf); tunnel, pkf);
_addrs = new ArrayList<I2PSocketAddress>(1); _addrs = new ArrayList<I2PSocketAddress>(1);
if (waitEventValue("openBaseClientResult").equals("error")) {
notifyEvent("openClientResult", "error");
return;
}
dests = new ArrayList<Destination>(1); dests = new ArrayList<Destination>(1);
buildAddresses(destinations); buildAddresses(destinations);

217
apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelClientBase.java
View File

@ -26,6 +26,7 @@ import javax.net.ssl.SSLServerSocketFactory;
import net.i2p.I2PAppContext; import net.i2p.I2PAppContext;
import net.i2p.I2PException; import net.i2p.I2PException;
import net.i2p.client.I2PSession; import net.i2p.client.I2PSession;
import net.i2p.client.I2PSessionException;
import net.i2p.client.streaming.I2PSocket; import net.i2p.client.streaming.I2PSocket;
import net.i2p.client.streaming.I2PSocketManager; import net.i2p.client.streaming.I2PSocketManager;
import net.i2p.client.streaming.I2PSocketManagerFactory; import net.i2p.client.streaming.I2PSocketManagerFactory;
@ -53,6 +54,7 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
protected Destination dest; protected Destination dest;
private int localPort; private int localPort;
private final String _handlerName;
/** /**
* Protected for I2Ping since 0.9.11. Not for use outside package. * Protected for I2Ping since 0.9.11. Not for use outside package.
@ -91,6 +93,7 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
chained = true; chained = true;
sockMgr = sktMgr; sockMgr = sktMgr;
_clientId = clientId; _clientId = clientId;
_handlerName = "chained";
this.localPort = localPort; this.localPort = localPort;
this.l = l; this.l = l;
_ownDest = true; // == ! shared client _ownDest = true; // == ! shared client
@ -101,31 +104,19 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
_context.statManager().createRateStat("i2ptunnel.client.buildRunTime", "How long it takes to run a queued socket into an i2ptunnel runner?", "I2PTunnel", new long[] { 60*1000, 10*60*1000, 60*60*1000 }); _context.statManager().createRateStat("i2ptunnel.client.buildRunTime", "How long it takes to run a queued socket into an i2ptunnel runner?", "I2PTunnel", new long[] { 60*1000, 10*60*1000, 60*60*1000 });
_log = _context.logManager().getLog(getClass()); _log = _context.logManager().getLog(getClass());
Thread t = new I2PAppThread(this, "Client " + tunnel.listenHost + ':' + localPort); synchronized (_executorLock) {
t.start(); if (_executor == null)
open = true; _executor = new CustomThreadPoolExecutor();
synchronized (this) {
while (!listenerReady && open) {
try {
wait();
} catch (InterruptedException e) {
// ignore
}
}
} }
if (open && listenerReady) { startup();
l.log("Client ready, listening on " + tunnel.listenHost + ':' + localPort);
notifyEvent("openBaseClientResult", "ok");
} else {
l.log("Client error for " + tunnel.listenHost + ':' + localPort + ", check logs");
notifyEvent("openBaseClientResult", "error");
}
} }
/** /**
* The main constructor. * The main constructor.
* This may take a LONG time if building and starting a new manager. *
* As of 0.9.20 this is fast, and does NOT connect the manager to the router,
* or open the local socket. You MUST call startRunning() for that.
* *
* @param localPort if 0, use any port, get actual port selected with getLocalPort() * @param localPort if 0, use any port, get actual port selected with getLocalPort()
* @throws IllegalArgumentException if the I2CP configuration is b0rked so * @throws IllegalArgumentException if the I2CP configuration is b0rked so
@ -139,7 +130,9 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
/** /**
* Use this to build a client with a persistent private key. * Use this to build a client with a persistent private key.
* This may take a LONG time if building and starting a new manager. *
* As of 0.9.20 this is fast, and does NOT connect the manager to the router,
* or open the local socket. You MUST call startRunning() for that.
* *
* @param localPort if 0, use any port, get actual port selected with getLocalPort() * @param localPort if 0, use any port, get actual port selected with getLocalPort()
* @param pkf Path to the private key file, or null to generate a transient key * @param pkf Path to the private key file, or null to generate a transient key
@ -155,7 +148,7 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
this.localPort = localPort; this.localPort = localPort;
this.l = l; this.l = l;
_ownDest = ownDest; // == ! shared client _ownDest = ownDest; // == ! shared client
_handlerName = handlerName;
_context = tunnel.getContext(); _context = tunnel.getContext();
_context.statManager().createRateStat("i2ptunnel.client.closeBacklog", "How many pending sockets remain when we close one due to backlog?", "I2PTunnel", new long[] { 60*1000, 10*60*1000, 60*60*1000 }); _context.statManager().createRateStat("i2ptunnel.client.closeBacklog", "How many pending sockets remain when we close one due to backlog?", "I2PTunnel", new long[] { 60*1000, 10*60*1000, 60*60*1000 });
@ -201,33 +194,12 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
} // else delay creating session until createI2PSocket() is called } // else delay creating session until createI2PSocket() is called
Thread t = new I2PAppThread(this);
t.setName("Client " + _clientId);
t.start();
open = true;
synchronized (this) {
while (!listenerReady && open) {
try {
wait();
} catch (InterruptedException e) {
// ignore
}
}
}
if (open && listenerReady) {
if (openNow)
l.log("Client ready, listening on " + tunnel.listenHost + ':' + localPort);
else
l.log("Client ready, listening on " + tunnel.listenHost + ':' + localPort + ", delaying tunnel open until required");
notifyEvent("openBaseClientResult", "ok");
} else {
l.log("Client error for " + tunnel.listenHost + ':' + localPort + ", check logs");
notifyEvent("openBaseClientResult", "error");
}
} }
/** /**
* Create the manager if it doesn't exist, AND connect it to the router and
* build tunnels.
*
* Sets the this.sockMgr field if it is null, or if we want a new one. * Sets the this.sockMgr field if it is null, or if we want a new one.
* This may take a LONG time if building a new manager. * This may take a LONG time if building a new manager.
* *
@ -269,6 +241,7 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
this.sockMgr = getSocketManager(); this.sockMgr = getSocketManager();
} }
} }
connectManager();
} }
/** this is ONLY for shared clients */ /** this is ONLY for shared clients */
@ -277,7 +250,8 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
/** /**
* This is ONLY for shared clients. * This is ONLY for shared clients.
* This may take a LONG time if building a new manager. * As of 0.9.20 this is fast, and does NOT connect the manager to the router.
* Call verifySocketManager() for that.
* *
* @return non-null * @return non-null
* @throws IllegalArgumentException if the I2CP configuration is b0rked so * @throws IllegalArgumentException if the I2CP configuration is b0rked so
@ -289,7 +263,8 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
/** /**
* This is ONLY for shared clients. * This is ONLY for shared clients.
* This may take a LONG time if building a new manager. * As of 0.9.20 this is fast, and does NOT connect the manager to the router.
* Call verifySocketManager() for that.
* *
* @return non-null * @return non-null
* @throws IllegalArgumentException if the I2CP configuration is b0rked so * @throws IllegalArgumentException if the I2CP configuration is b0rked so
@ -301,7 +276,8 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
/** /**
* This is ONLY for shared clients. * This is ONLY for shared clients.
* This may take a LONG time if building a new manager. * As of 0.9.20 this is fast, and does NOT connect the manager to the router.
* Call verifySocketManager() for that.
* *
* @return non-null * @return non-null
* @throws IllegalArgumentException if the I2CP configuration is b0rked so * @throws IllegalArgumentException if the I2CP configuration is b0rked so
@ -347,7 +323,10 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
} }
/** /**
* This may take a LONG time. * For NON-SHARED clients (ownDest = true).
*
* As of 0.9.20 this is fast, and does NOT connect the manager to the router.
* Call verifySocketManager() for that.
* *
* @return non-null * @return non-null
* @throws IllegalArgumentException if the I2CP configuration is b0rked so * @throws IllegalArgumentException if the I2CP configuration is b0rked so
@ -356,8 +335,10 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
protected I2PSocketManager buildSocketManager() { protected I2PSocketManager buildSocketManager() {
return buildSocketManager(getTunnel(), this.privKeyFile, this.l); return buildSocketManager(getTunnel(), this.privKeyFile, this.l);
} }
/** /**
* This may take a LONG time. * As of 0.9.20 this is fast, and does NOT connect the manager to the router.
* Call verifySocketManager() for that.
* *
* @return non-null * @return non-null
* @throws IllegalArgumentException if the I2CP configuration is b0rked so * @throws IllegalArgumentException if the I2CP configuration is b0rked so
@ -371,7 +352,8 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
private static final int MAX_RETRIES = 4; private static final int MAX_RETRIES = 4;
/** /**
* This may take a LONG time. * As of 0.9.20 this is fast, and does NOT connect the manager to the router.
* Call verifySocketManager() for that.
* *
* @param pkf absolute path or null * @param pkf absolute path or null
* @return non-null * @return non-null
@ -383,7 +365,8 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
} }
/** /**
* This may take a LONG time. * As of 0.9.20 this is fast, and does NOT connect the manager to the router.
* Call verifySocketManager() for that.
* *
* @param pkf absolute path or null * @param pkf absolute path or null
* @return non-null * @return non-null
@ -400,36 +383,61 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
try { try {
portNum = Integer.parseInt(tunnel.port); portNum = Integer.parseInt(tunnel.port);
} catch (NumberFormatException nfe) { } catch (NumberFormatException nfe) {
_log.log(Log.CRIT, "Invalid port specified [" + tunnel.port + "], reverting to " + portNum); throw new IllegalArgumentException("Invalid port specified [" + tunnel.port + "]", nfe);
} }
} }
I2PSocketManager sockManager = null; I2PSocketManager sockManager = null;
// FIXME: Can't stop a tunnel from the UI while it's in this loop (no session yet) FileInputStream fis = null;
int retries = 0; try {
while (sockManager == null) {
if (pkf != null) { if (pkf != null) {
// Persistent client dest // Persistent client dest
FileInputStream fis = null; fis = new FileInputStream(pkf);
try { sockManager = I2PSocketManagerFactory.createDisconnectedManager(fis, tunnel.host, portNum, props);
fis = new FileInputStream(pkf);
sockManager = I2PSocketManagerFactory.createManager(fis, tunnel.host, portNum, props);
} catch (IOException ioe) {
if (log != null)
log.log("Error opening key file " + ioe);
_log.error("Error opening key file", ioe);
throw new IllegalArgumentException("Error opening key file " + ioe);
} finally {
if (fis != null)
try { fis.close(); } catch (IOException ioe) {}
}
} else { } else {
sockManager = I2PSocketManagerFactory.createManager(tunnel.host, portNum, props); sockManager = I2PSocketManagerFactory.createDisconnectedManager(null, tunnel.host, portNum, props);
} }
} catch (I2PSessionException ise) {
if (sockManager == null) { throw new IllegalArgumentException("Can't create socket manager", ise);
// try to make this error sensible as it will happen... sadly we can't get to the listenPort, only the listenHost } catch (IOException ioe) {
String msg = "Unable to connect to the router at " + tunnel.host + ':' + portNum + if (log != null)
log.log("Error opening key file " + ioe);
_log.error("Error opening key file", ioe);
throw new IllegalArgumentException("Error opening key file " + ioe);
} finally {
if (fis != null)
try { fis.close(); } catch (IOException ioe) {}
}
sockManager.setName("Client");
if (_log.shouldLog(Log.INFO))
_log.info(tunnel.getClientOptions().getProperty("inbound.nickname") + ": Built a new socket manager [s=" + sockManager.getSession() + "]");
tunnel.addSession(sockManager.getSession());
return sockManager;
}
/**
* Warning, blocks while connecting to router and building tunnels;
* This may take a LONG time.
*
* @throws IllegalArgumentException if the I2CP configuration is b0rked so
* badly that we cant create a socketManager
* @since 0.9.20
*/
private void connectManager() {
// shadows instance _log
Log _log = getTunnel().getContext().logManager().getLog(I2PTunnelClientBase.class);
Logging log = this.l;
int retries = 0;
while (sockMgr.getSession().isClosed()) {
try {
sockMgr.getSession().connect();
} catch (I2PSessionException ise) {
// try to make this error sensible as it will happen...
String portNum = getTunnel().port;
if (portNum == null)
portNum = "7654";
String msg = "Unable to connect to the router at " + getTunnel().host + ':' + portNum +
" and build tunnels for the client"; " and build tunnels for the client";
if (++retries < MAX_RETRIES) { if (++retries < MAX_RETRIES) {
if (log != null) if (log != null)
@ -446,11 +454,6 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
try { Thread.sleep(RETRY_DELAY); } catch (InterruptedException ie) {} try { Thread.sleep(RETRY_DELAY); } catch (InterruptedException ie) {}
} }
} }
sockManager.setName("Client");
if (_log.shouldLog(Log.INFO))
_log.info(tunnel.getClientOptions().getProperty("inbound.nickname") + ": Built a new socket manager [s=" + sockManager.getSession() + "]");
tunnel.addSession(sockManager.getSession());
return sockManager;
} }
public final int getLocalPort() { public final int getLocalPort() {
@ -469,11 +472,65 @@ public abstract class I2PTunnelClientBase extends I2PTunnelTask implements Runna
} }
/** /**
* Actually start working on incoming connections. *Must* be * Actually open the local socket and start working on incoming connections. *Must* be
* called by derived classes after initialization. * called by derived classes after initialization.
* *
* (this wasn't actually true until 0.9.20)
*
* This will be fast if i2cp.delayOpen is true, but could take
* a LONG TIME if it is false, as it connects to the router and builds tunnels.
*
*/ */
public void startRunning() { public void startRunning() {
boolean openNow = !Boolean.parseBoolean(getTunnel().getClientOptions().getProperty("i2cp.delayOpen"));
if (openNow) {
while (sockMgr == null) {
verifySocketManager();
if (sockMgr == null) {
_log.error("Unable to connect to router and build tunnels for " + _handlerName);
// FIXME there is a loop in buildSocketManager(), do we really need another one here?
// no matter, buildSocketManager() now throws an IllegalArgumentException
try { Thread.sleep(10*1000); } catch (InterruptedException ie) {}
}
}
// can't be null unless we limit the loop above
//if (sockMgr == null) {
// l.log("Invalid I2CP configuration");
// throw new IllegalArgumentException("Socket manager could not be created");
//}
l.log("Tunnels ready for client: " + _handlerName);
} // else delay creating session until createI2PSocket() is called
startup();
}
private void startup() {
// prevent JVM exit when running outside the router
boolean isDaemon = getTunnel().getContext().isRouterContext();
Thread t = new I2PAppThread(this, "Client " + _clientId, isDaemon);
t.start();
open = true;
synchronized (this) {
while (!listenerReady && open) {
try {
wait();
} catch (InterruptedException e) {
// ignore
}
}
}
if (open && listenerReady) {
boolean openNow = !Boolean.parseBoolean(getTunnel().getClientOptions().getProperty("i2cp.delayOpen"));
if (openNow)
l.log("Client ready, listening on " + getTunnel().listenHost + ':' + localPort);
else
l.log("Client ready, listening on " + getTunnel().listenHost + ':' + localPort + ", delaying tunnel open until required");
notifyEvent("openBaseClientResult", "ok");
} else {
l.log("Client error for " + getTunnel().listenHost + ':' + localPort + ", check logs");
notifyEvent("openBaseClientResult", "error");
}
synchronized (startLock) { synchronized (startLock) {
startRunning = true; startRunning = true;
startLock.notify(); startLock.notify();

5
apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelConnectClient.java
View File

@ -85,11 +85,6 @@ public class I2PTunnelConnectClient extends I2PTunnelHTTPClientBase implements R
I2PTunnel tunnel) throws IllegalArgumentException { I2PTunnel tunnel) throws IllegalArgumentException {
super(localPort, ownDest, l, notifyThis, "HTTPS Proxy on " + tunnel.listenHost + ':' + localPort, tunnel); super(localPort, ownDest, l, notifyThis, "HTTPS Proxy on " + tunnel.listenHost + ':' + localPort, tunnel);
if (waitEventValue("openBaseClientResult").equals("error")) {
notifyEvent("openConnectClientResult", "error");
return;
}
if (wwwProxy != null) { if (wwwProxy != null) {
StringTokenizer tok = new StringTokenizer(wwwProxy, ", "); StringTokenizer tok = new StringTokenizer(wwwProxy, ", ");
while (tok.hasMoreTokens()) while (tok.hasMoreTokens())

4
apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java
View File

@ -216,10 +216,6 @@ public class I2PTunnelHTTPClient extends I2PTunnelHTTPClientBase implements Runn
_proxyNonce = Long.toString(_context.random().nextLong()); _proxyNonce = Long.toString(_context.random().nextLong());
//proxyList = new ArrayList(); // We won't use outside of i2p //proxyList = new ArrayList(); // We won't use outside of i2p
if(waitEventValue("openBaseClientResult").equals("error")) {
notifyEvent("openHTTPClientResult", "error");
return;
}
if(wwwProxy != null) { if(wwwProxy != null) {
StringTokenizer tok = new StringTokenizer(wwwProxy, ", "); StringTokenizer tok = new StringTokenizer(wwwProxy, ", ");

2
apps/i2ptunnel/java/src/net/i2p/i2ptunnel/TunnelControllerGroup.java
View File

@ -276,7 +276,7 @@ public class TunnelControllerGroup implements ClientApp {
for (int i = 0; i < _controllers.size(); i++) { for (int i = 0; i < _controllers.size(); i++) {
TunnelController controller = _controllers.get(i); TunnelController controller = _controllers.get(i);
if (controller.getStartOnLoad()) if (controller.getStartOnLoad())
controller.startTunnel(); controller.startTunnelBackground();
} }
} finally { } finally {
_controllersLock.readLock().unlock(); _controllersLock.readLock().unlock();