|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.JobImpl
net.i2p.router.networkdb.kademlia.SearchJob
net.i2p.router.networkdb.kademlia.ExploreJob
class ExploreJob
Search for a particular key iteratively until we either find a value, we run out of peers, or the bucket the key belongs in has sufficient values in it. Well, we're skipping the 'bucket gets filled up' test for now, since it'll never get used (at least for a while).
Nested Class Summary |
---|
Nested classes/interfaces inherited from class net.i2p.router.networkdb.kademlia.SearchJob |
---|
SearchJob.FailedJob |
Field Summary |
---|
Fields inherited from class net.i2p.router.networkdb.kademlia.SearchJob |
---|
_facade, MAX_CLOSEST, PER_FLOODFILL_PEER_TIMEOUT |
Constructor Summary | |
---|---|
ExploreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key)
Create a new search for the routingKey specified |
Method Summary | |
---|---|
protected DatabaseLookupMessage |
buildMessage(long expiration)
We're looking for a router, so lets build the lookup message (no need to tunnel route either, so just have replies sent back to us directly). |
protected DatabaseLookupMessage |
buildMessage(TunnelId replyTunnelId,
RouterInfo replyGateway,
long expiration)
Build the database search message, but unlike the normal searches, we're more explicit in what we /dont/ want. |
protected int |
getBredth()
max # of concurrent searches |
java.lang.String |
getName()
Descriptive name of the task |
protected void |
newPeersFound(int numNewPeers)
We've gotten a search reply that contained the specified number of peers that we didn't know about before. |
Methods inherited from class net.i2p.router.networkdb.kademlia.SearchJob |
---|
add, addDeferred, buildMessage, continueSearch, decrementOutstandingFloodfillSearches, fail, getExpiration, getFacade, getPerPeerTimeoutMs, getPerPeerTimeoutMs, getState, getTimeoutMs, isCongested, onlyQueryFloodfillPeers, replyFound, runJob, searchNext, sendLeaseSearch, sendRouterSearch, sendSearch, timeoutMs, toString, wasAttempted |
Methods inherited from class net.i2p.router.JobImpl |
---|
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public ExploreJob(RouterContext context, KademliaNetworkDatabaseFacade facade, Hash key)
Method Detail |
---|
protected DatabaseLookupMessage buildMessage(TunnelId replyTunnelId, RouterInfo replyGateway, long expiration)
replyTunnelId
- tunnel to receive replies throughreplyGateway
- gateway for the reply tunnelexpiration
- when the search should stopprotected DatabaseLookupMessage buildMessage(long expiration)
buildMessage
in class SearchJob
protected int getBredth()
getBredth
in class SearchJob
protected void newPeersFound(int numNewPeers)
newPeersFound
in class SearchJob
public java.lang.String getName()
Job
getName
in interface Job
getName
in class SearchJob
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |