Jobclass ExploreJob extends SearchJob
SearchJob.FailedJob| Modifier and Type | Field | Description |
|---|---|---|
(package private) static int |
MAX_CLOSEST |
only send the closest "dont tell me about" refs...
|
(package private) static int |
PER_FLOODFILL_PEER_TIMEOUT |
Override to make this shorter, since we don't sort out the
unresponsive ff peers like we do in FloodOnlySearchJob
|
_facade, _log, MIN_TIMEOUT| Constructor | Description |
|---|---|
ExploreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key) |
Create a new search for the routingKey specified
|
| Modifier and Type | Method | Description |
|---|---|---|
protected I2NPMessage |
buildMessage(TunnelId replyTunnelId,
Hash replyGateway,
long expiration,
RouterInfo peer) |
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
|
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.
|
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeueclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitadd, addDeferred, continueSearch, decrementOutstandingFloodfillSearches, fail, getExpiration, getFacade, getPerPeerTimeoutMs, getPerPeerTimeoutMs, getState, getTimeoutMs, onlyQueryFloodfillPeers, replyFound, runJob, searchNext, sendLeaseSearch, sendRouterSearch, sendSearch, timeoutMs, toString, wasAttemptedstatic final int MAX_CLOSEST
static final int PER_FLOODFILL_PEER_TIMEOUT
public ExploreJob(RouterContext context, KademliaNetworkDatabaseFacade facade, Hash key)
protected I2NPMessage buildMessage(TunnelId replyTunnelId, Hash replyGateway, long expiration, RouterInfo peer)
buildMessage in class SearchJobreplyTunnelId - tunnel to receive replies through, or our router hash if replyGateway is nullreplyGateway - gateway for the reply tunnel, if null, we are sending direct, do not encryptexpiration - when the search should stoppeer - the peer to send it toprotected int getBredth()
protected void newPeersFound(int numNewPeers)
newPeersFound in class SearchJob