| Package | Description |
|---|---|
| net.i2p.router.tunnel | Core tunnel management, message processing, and encryption for I2P's anonymous routing system. |
| net.i2p.router.tunnel.pool | Tunnel pool management, creation, and peer selection for I2P's anonymous routing system. |
| Modifier and Type | Method and Description |
|---|---|
boolean | TunnelDispatcher.joinOutbound(PooledTunnelCreatorConfig cfg)We are the outbound gateway - we created this tunnel |
| Constructor and Description |
|---|
OutboundReceiver(RouterContext ctx,
PooledTunnelCreatorConfig cfg)OutboundReceiver. |
| Modifier and Type | Method and Description |
|---|---|
(package private) PooledTunnelCreatorConfig | AliasedTunnelPool.configureNewTunnel() |
(package private) PooledTunnelCreatorConfig | TunnelPool.configureNewTunnel()This only sets the peers and creation/expiration times in the configuration. |
(package private) PooledTunnelCreatorConfig | BuildExecutor.removeFromBuilding(long id)This returns the PTCC up to a minute after it 'expired', thus allowing us to
still use a tunnel if it was accepted, and to update peer stats. |
| Modifier and Type | Method and Description |
|---|---|
List<PooledTunnelCreatorConfig> | TunnelPool.cancelExcessInProgress(int maxAllowed)Cancel excess in-progress tunnel builds to stay within budget. |
List<PooledTunnelCreatorConfig> | AliasedTunnelPool.listPending() |
List<PooledTunnelCreatorConfig> | TunnelPool.listPending()list of tunnelInfo instances of tunnels currently being built |
| Modifier and Type | Method and Description |
|---|---|
(package private) void | TunnelPoolManager.buildComplete(PooledTunnelCreatorConfig cfg)queue a recurring test job if appropriate |
void | BuildExecutor.buildComplete(PooledTunnelCreatorConfig cfg,
BuildExecutor.Result result)Handle a completed tunnel build. |
(package private) void | AliasedTunnelPool.buildComplete(PooledTunnelCreatorConfig cfg,
BuildExecutor.Result result) |
(package private) void | TunnelPool.buildComplete(PooledTunnelCreatorConfig cfg,
BuildExecutor.Result result)Remove from the _inprogress list and call addTunnel() if result is SUCCESS. |
void | BuildExecutor.buildComplete(PooledTunnelCreatorConfig cfg,
BuildExecutor.Result result,
String detail)Handle a completed tunnel build with additional detail. |
(package private) void | BuildExecutor.buildTunnel(PooledTunnelCreatorConfig cfg)Build a tunnel with the given configuration. |
static Long | ExpireJob.getTunnelKey(PooledTunnelCreatorConfig cfg)Get the unique key for this tunnel config. |
static void | ExpireJob.removeFromExpiration(PooledTunnelCreatorConfig cfg)Remove a tunnel from the expiration queue. |
(package private) void | TunnelPoolManager.removeFromExpiration(PooledTunnelCreatorConfig cfg)Remove a tunnel from the expiration queue to prevent memory leak |
static boolean | BuildRequestor.request(RouterContext ctx,
PooledTunnelCreatorConfig cfg,
BuildExecutor exec,
long firstHopTimeout)Initiates a tunnel build request. |
static void | ExpireJob.scheduleExpiration(RouterContext ctx,
PooledTunnelCreatorConfig cfg)Schedule a tunnel for batched expiration. |
static boolean | TestJob.shouldSchedule(RouterContext ctx,
PooledTunnelCreatorConfig cfg)Static method to check if a TestJob should be created and scheduled. |
| Constructor and Description |
|---|
TestJob(RouterContext ctx,
PooledTunnelCreatorConfig cfg,
TunnelPool pool)TestJob. |