Job
class 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, requeue
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
add, addDeferred, continueSearch, decrementOutstandingFloodfillSearches, fail, getExpiration, getFacade, getPerPeerTimeoutMs, getPerPeerTimeoutMs, getState, getTimeoutMs, onlyQueryFloodfillPeers, replyFound, runJob, searchNext, sendLeaseSearch, sendRouterSearch, sendSearch, timeoutMs, toString, wasAttempted
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