Package net.i2p.router.networkdb
Class HandleDatabaseLookupMessageJob
java.lang.Object
net.i2p.router.JobImpl
net.i2p.router.networkdb.HandleDatabaseLookupMessageJob
- All Implemented Interfaces:
Job
- Direct Known Subclasses:
HandleFloodfillDatabaseLookupMessageJob
public class HandleDatabaseLookupMessageJob extends JobImpl
Handle a lookup for a key received from a remote peer. Needs to be implemented
to send back replies, etc
Unused directly - see kademlia/ for extension
-
Field Summary
Fields Modifier and Type Field Description static booleanDEFAULT_PUBLISH_UNREACHABLEstatic longEXPIRE_DELAYIf a routerInfo structure isn't this recent, don't send it out.static StringPROP_PUBLISH_UNREACHABLE -
Constructor Summary
Constructors Constructor Description HandleDatabaseLookupMessageJob(RouterContext ctx, DatabaseLookupMessage receivedMessage, RouterIdentity from, Hash fromHash) -
Method Summary
Modifier and Type Method Description protected booleananswerAllQueries()voiddropped()the router is extremely overloaded, so this job has been dropped.StringgetName()Descriptive name of the taskvoidrunJob()Actually perform the task.protected voidsendClosest(Hash key, Set<Hash> routerHashes, Hash toPeer, TunnelId replyTunnel)protected voidsendMessage(I2NPMessage message, Hash toPeer, TunnelId replyTunnel)Methods inherited from class net.i2p.router.JobImpl
getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue, toString
-
Field Details
-
EXPIRE_DELAY
public static final long EXPIRE_DELAYIf a routerInfo structure isn't this recent, don't send it out. Equal to KNDF.ROUTER_INFO_EXPIRATION_FLOODFILL.- See Also:
- Constant Field Values
-
PROP_PUBLISH_UNREACHABLE
- See Also:
- Constant Field Values
-
DEFAULT_PUBLISH_UNREACHABLE
public static final boolean DEFAULT_PUBLISH_UNREACHABLE- See Also:
- Constant Field Values
-
-
Constructor Details
-
HandleDatabaseLookupMessageJob
public HandleDatabaseLookupMessageJob(RouterContext ctx, DatabaseLookupMessage receivedMessage, RouterIdentity from, Hash fromHash)
-
-
Method Details
-
answerAllQueries
protected boolean answerAllQueries() -
runJob
public void runJob()Description copied from interface:JobActually perform the task. This call blocks until the Job is complete. -
sendClosest
-
sendMessage
-
getName
Description copied from interface:JobDescriptive name of the task -
dropped
public void dropped()Description copied from interface:Jobthe router is extremely overloaded, so this job has been dropped. if for some reason the job *must* do some cleanup / requeueing of other tasks, it should do so here.
-