public class RepublishLeaseSetJob extends JobImpl
| Modifier and Type | Field and Description |
|---|---|
static long | REPUBLISH_LEASESET_TIMEOUT_DEFAULTDefault timeout for LeaseSet publication to floodfills. |
static int | RETRY_DELAY_DEFAULTDefault base delay before retrying a failed publish. |
static int | RETRY_MAX_DELAY_DEFAULTMaximum backoff delay for publish retries. |
| Constructor and Description |
|---|
RepublishLeaseSetJob(RouterContext ctx,
KademliaNetworkDatabaseFacade facade,
Hash destHash)Creates a new job to republish a LeaseSet for the given destination. |
| Modifier and Type | Method and Description |
|---|---|
(package private) Hash | getDestHash()The destination hash this job publishes for. |
String | getName()Human-readable name for the job queue. |
String | getTunnelName(Destination d)Look up the tunnel nickname for a destination. |
long | lastPublished()Timestamp of the last successful publication. |
boolean | registerSelf()Attempt to register this job with the facade. |
(package private) void | requeueRepublish()Requeue republish |
void | runJob()Actually perform the task. |
dropped, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toStringpublic static final long REPUBLISH_LEASESET_TIMEOUT_DEFAULT
public static final int RETRY_DELAY_DEFAULT
public static final int RETRY_MAX_DELAY_DEFAULT
public RepublishLeaseSetJob(RouterContext ctx, KademliaNetworkDatabaseFacade facade, Hash destHash)
ctx - the router contextfacade - the network database facadedestHash - the destination hash to republishHash getDestHash()
public String getName()
public String getTunnelName(Destination d)
d - the destinationpublic long lastPublished()
public boolean registerSelf()
void requeueRepublish()
public void runJob()
Job