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

raise max concurrent tunnel builds

Browse Source
This commit is contained in:
zzz
2014-12-15 14:38:33 +00:00
parent 03df6c2ba0
commit aa6a5e053c
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java
View File

@@ -43,7 +43,7 @@ class BuildExecutor implements Runnable {
private final ConcurrentHashMap<Long, PooledTunnelCreatorConfig> _recentlyBuildingMap; private final ConcurrentHashMap<Long, PooledTunnelCreatorConfig> _recentlyBuildingMap;
private volatile boolean _isRunning; private volatile boolean _isRunning;
private boolean _repoll; private boolean _repoll;
private static final int MAX_CONCURRENT_BUILDS = 10; private static final int MAX_CONCURRENT_BUILDS = 13;
/** accept replies up to a minute after we gave up on them */ /** accept replies up to a minute after we gave up on them */
private static final long GRACE_PERIOD = 60*1000; private static final long GRACE_PERIOD = 60*1000;
@@ -129,8 +129,10 @@ class BuildExecutor implements Runnable {
} }
} }
} }
if (allowed < 2) allowed = 2; // Never choke below 2 builds (but congestion may) if (allowed < 2)
else if (allowed > MAX_CONCURRENT_BUILDS) allowed = MAX_CONCURRENT_BUILDS; // Never go beyond 10, that is uncharted territory (old limit was 5) allowed = 2; // Never choke below 2 builds (but congestion may)
else if (allowed > MAX_CONCURRENT_BUILDS)
allowed = MAX_CONCURRENT_BUILDS;
allowed = _context.getProperty("router.tunnelConcurrentBuilds", allowed); allowed = _context.getProperty("router.tunnelConcurrentBuilds", allowed);
// expire any REALLY old requests // expire any REALLY old requests