class ExploreJob extends SearchJob
SearchJob.FailedJob
Modifier and Type | Field and 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 and Description |
---|
ExploreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key)
Create a new search for the routingKey specified
|
Modifier and Type | Method and 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.
|
add, addDeferred, continueSearch, decrementOutstandingFloodfillSearches, fail, getExpiration, getFacade, getPerPeerTimeoutMs, getPerPeerTimeoutMs, getState, getTimeoutMs, onlyQueryFloodfillPeers, replyFound, runJob, searchNext, sendLeaseSearch, sendRouterSearch, sendSearch, timeoutMs, toString, wasAttempted
dropped, getAddedBy, getContext, getJobId, getMadeReadyOn, getTiming, madeReady, requeue
static 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 SearchJob
replyTunnelId
- 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