|
|||||||||||
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
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 | |
protected class |
SearchJob.FailedJob
Called when a particular peer failed to respond before the timeout was reached, or if the peer could not be contacted at all. |
Field Summary | |
protected KademliaNetworkDatabaseFacade |
_facade
|
(package private) static int |
MAX_CLOSEST
only send the 10 closest "dont tell me about" refs |
Constructor Summary | |
ExploreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key)
Create a new search for the routingKey specified |
Method Summary | |
void |
addDeferred(Job onFind,
Job onFail,
long expiration,
boolean isLease)
|
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 void |
continueSearch()
Send a series of searches to the next available peers as selected by the routing table, but making sure no more than SEARCH_BREDTH are outstanding at any time |
protected void |
fail()
Search totally failed |
protected int |
getBredth()
max # of concurrent searches |
protected long |
getExpiration()
|
protected KademliaNetworkDatabaseFacade |
getFacade()
|
java.lang.String |
getName()
Descriptive name of the task |
protected SearchState |
getState()
|
protected long |
getTimeoutMs()
|
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. |
(package private) void |
replyFound(DatabaseSearchReplyMessage message,
Hash peer)
|
void |
runJob()
Actually perform the task. |
protected void |
searchNext()
Send the next search, or stop if its completed |
protected void |
sendLeaseSearch(RouterInfo router)
we're (probably) searching for a LeaseSet, so to be (overly) cautious, we're sending the request out through a tunnel w/ reply back through another tunnel. |
protected void |
sendRouterSearch(RouterInfo router)
we're searching for a router, so we can just send direct |
protected void |
sendSearch(RouterInfo router)
Send a search to the given peer |
java.lang.String |
toString()
|
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 |
Field Detail |
protected KademliaNetworkDatabaseFacade _facade
static final int MAX_CLOSEST
Constructor Detail |
public ExploreJob(RouterContext context, KademliaNetworkDatabaseFacade facade, Hash key)
Method Detail |
protected DatabaseLookupMessage buildMessage(TunnelId replyTunnelId, RouterInfo replyGateway, long expiration)
buildMessage
in class SearchJob
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
public void runJob()
Job
protected SearchState getState()
protected KademliaNetworkDatabaseFacade getFacade()
protected long getExpiration()
protected long getTimeoutMs()
protected void searchNext()
protected void continueSearch()
protected void sendSearch(RouterInfo router)
protected void sendLeaseSearch(RouterInfo router)
protected void sendRouterSearch(RouterInfo router)
void replyFound(DatabaseSearchReplyMessage message, Hash peer)
protected void fail()
public void addDeferred(Job onFind, Job onFail, long expiration, boolean isLease)
public java.lang.String toString()
toString
in class JobImpl
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |