diff --git a/router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java b/router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java index aa77ac482..cd0ca2328 100644 --- a/router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java +++ b/router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java @@ -104,7 +104,7 @@ public class TunnelPool { _started = System.currentTimeMillis(); _lastRateUpdate = _started; _lastLifetimeProcessed = 0; - _manager.getExecutor().repoll(); + _manager.tunnelFailed(); if (_settings.isInbound() && !_settings.isExploratory()) { // we just reconnected and didn't require any new tunnel builders. // however, we /do/ want a leaseSet, so build one @@ -452,7 +452,7 @@ public class TunnelPool { if (_settings != null) { if (_log.shouldLog(Log.INFO)) _log.info(toString() + ": Settings updated on the pool: " + settings); - _manager.getExecutor().repoll(); // in case we need more + _manager.tunnelFailed(); // in case we need more } } @@ -508,7 +508,7 @@ public class TunnelPool { remaining = _tunnels.size(); } - _manager.getExecutor().repoll(); + _manager.tunnelFailed(); _lifetimeProcessed += info.getProcessedMessagesCount(); updateRate(); diff --git a/router/java/src/net/i2p/router/tunnel/pool/TunnelPoolManager.java b/router/java/src/net/i2p/router/tunnel/pool/TunnelPoolManager.java index e6a13f91a..24ae68769 100644 --- a/router/java/src/net/i2p/router/tunnel/pool/TunnelPoolManager.java +++ b/router/java/src/net/i2p/router/tunnel/pool/TunnelPoolManager.java @@ -631,6 +631,9 @@ public class TunnelPoolManager implements TunnelManagerFacade { out.add(_outboundExploratory); } + /** + * Poke the build executor to build more tunnels. + */ void tunnelFailed() { _executor.repoll(); } BuildExecutor getExecutor() { return _executor; }