class ExpireJob extends JobImpl
| Modifier and Type | Field and Description |
|---|---|
(package private) static int | MAX_UNTESTED_EXTENSIONSMaximum number of times an UNTESTED tunnel's expiry can be extended
to give tests time to complete. |
(package private) static long | UNTESTED_EXTENSION_MSHow long to extend an UNTESTED tunnel's expiry each time. |
| Modifier and Type | Method and Description |
|---|---|
String | getName()Descriptive name of the task |
static Long | getTunnelKey(PooledTunnelCreatorConfig cfg)Get the unique key for this tunnel config. |
static void | removeFromExpiration(PooledTunnelCreatorConfig cfg)Remove a tunnel from the expiration queue. |
void | runJob()Actually perform the task. |
static void | scheduleExpiration(RouterContext ctx,
PooledTunnelCreatorConfig cfg)Schedule a tunnel for batched expiration. |
dropped, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toStringstatic final int MAX_UNTESTED_EXTENSIONS
UNTESTED_EXTENSION_MS.static final long UNTESTED_EXTENSION_MS
public String getName()
Jobpublic static Long getTunnelKey(PooledTunnelCreatorConfig cfg)
public static void removeFromExpiration(PooledTunnelCreatorConfig cfg)
cfg - config to removepublic void runJob()
Jobpublic static void scheduleExpiration(RouterContext ctx, PooledTunnelCreatorConfig cfg)
ctx - the router contextcfg - the tunnel config to expire