diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java index 65d1eca00..1320d858e 100644 --- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java +++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java @@ -227,8 +227,6 @@ public class I2PTunnelHTTPClient extends I2PTunnelHTTPClientBase implements Runn super(localPort, l, sockMgr, tunnel, notifyThis, clientId); _proxyNonce = Long.toString(_context.random().nextLong()); // proxyList = new ArrayList(); - if (tunnel.getClientOptions().getProperty("i2p.streaming.connectDelay") == null) - tunnel.getClientOptions().setProperty("i2p.streaming.connectDelay", "1000"); setName("HTTP Proxy on " + getTunnel().listenHost + ':' + localPort); notifyEvent("openHTTPClientResult", "ok"); @@ -255,8 +253,6 @@ public class I2PTunnelHTTPClient extends I2PTunnelHTTPClientBase implements Runn _proxyList.add(tok.nextToken().trim()); } } - if (tunnel.getClientOptions().getProperty("i2p.streaming.connectDelay") == null) - tunnel.getClientOptions().setProperty("i2p.streaming.connectDelay", "1000"); setName("HTTP Proxy on " + tunnel.listenHost + ':' + localPort); notifyEvent("openHTTPClientResult", "ok"); diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClientBase.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClientBase.java index 744abde1b..0609a0b39 100644 --- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClientBase.java +++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClientBase.java @@ -277,6 +277,10 @@ public abstract class I2PTunnelHTTPClientBase extends I2PTunnelClientBase implem EventDispatcher notifyThis, String handlerName, I2PTunnel tunnel) throws IllegalArgumentException { super(localPort, ownDest, l, notifyThis, handlerName, tunnel); + // force connect delay and bulk profile + Properties opts = tunnel.getClientOptions(); + opts.setProperty("i2p.streaming.connectDelay", "200"); + opts.remove("i2p.streaming.maxWindowSize"); _proxyList = new ArrayList(4); _proxyNonce = new byte[PROXYNONCE_BYTES]; _context.random().nextBytes(_proxyNonce); @@ -293,6 +297,10 @@ public abstract class I2PTunnelHTTPClientBase extends I2PTunnelClientBase implem I2PTunnel tunnel, EventDispatcher notifyThis, long clientId ) throws IllegalArgumentException { super(localPort, l, sktMgr, tunnel, notifyThis, clientId); + // force connect delay and bulk profile + Properties opts = tunnel.getClientOptions(); + opts.setProperty("i2p.streaming.connectDelay", "200"); + opts.remove("i2p.streaming.maxWindowSize"); _proxyList = new ArrayList(4); _proxyNonce = new byte[PROXYNONCE_BYTES]; _context.random().nextBytes(_proxyNonce); diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelIRCClient.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelIRCClient.java index 9007c7a4c..d33980e64 100644 --- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelIRCClient.java +++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelIRCClient.java @@ -62,6 +62,10 @@ public class I2PTunnelIRCClient extends I2PTunnelClientBase { l, notifyThis, "IRC Client on " + tunnel.listenHost + ':' + localPort, tunnel, pkf); + // force connect delay and bulk profile + Properties opts = tunnel.getClientOptions(); + opts.setProperty("i2p.streaming.connectDelay", "200"); + opts.remove("i2p.streaming.maxWindowSize"); _addrs = new ArrayList(4); buildAddresses(destinations); diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/I2PSOCKSTunnel.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/I2PSOCKSTunnel.java index 100891f17..a3ecbbc41 100644 --- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/I2PSOCKSTunnel.java +++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/I2PSOCKSTunnel.java @@ -51,6 +51,10 @@ public class I2PSOCKSTunnel extends I2PTunnelClientBase { */ public I2PSOCKSTunnel(int localPort, Logging l, boolean ownDest, EventDispatcher notifyThis, I2PTunnel tunnel, String pkf) { super(localPort, ownDest, l, notifyThis, "SOCKS Proxy on " + tunnel.listenHost + ':' + localPort, tunnel, pkf); + // force connect delay and bulk profile + Properties opts = tunnel.getClientOptions(); + opts.setProperty("i2p.streaming.connectDelay", "200"); + opts.remove("i2p.streaming.maxWindowSize"); setName("SOCKS Proxy on " + tunnel.listenHost + ':' + localPort); parseOptions(); diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java index aa02b8aad..8571ddc7c 100644 --- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java +++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java @@ -480,7 +480,7 @@ class SOCKS5Server extends SOCKSServer { */ private I2PSocket outproxyConnect(I2PSOCKSTunnel tun, String proxy) throws IOException, I2PException { Properties overrides = new Properties(); - overrides.setProperty("option.i2p.streaming.connectDelay", "1000"); + overrides.setProperty("option.i2p.streaming.connectDelay", "200"); I2PSocketOptions proxyOpts = tun.buildOptions(overrides); Destination dest = _context.namingService().lookup(proxy); if (dest == null) diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/ui/TunnelConfig.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/ui/TunnelConfig.java index 069695a21..7a857797f 100644 --- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/ui/TunnelConfig.java +++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/ui/TunnelConfig.java @@ -930,7 +930,7 @@ public class TunnelConfig { updateTunnelQuantities(config); if (_connectDelay) - config.setProperty("option.i2p.streaming.connectDelay", "1000"); + config.setProperty("option.i2p.streaming.connectDelay", "500"); else config.setProperty("option.i2p.streaming.connectDelay", "0"); if (TunnelController.isClient(_type) && _sharedClient) { diff --git a/apps/i2ptunnel/jsp/editClient.jsi b/apps/i2ptunnel/jsp/editClient.jsi index 797566908..59a410e60 100644 --- a/apps/i2ptunnel/jsp/editClient.jsi +++ b/apps/i2ptunnel/jsp/editClient.jsi @@ -319,7 +319,7 @@ <% - if (!"streamrclient".equals(tunnelType)) { + if ("client".equals(tunnelType)) { %> @@ -340,7 +340,7 @@ <% - } // !streamrclient + } // client if (!editBean.isRouterContext()) { %>