Job
class ExploreJob extends SearchJob
SearchJob.FailedJob
修飾子とタイプ | フィールド | 説明 |
---|---|---|
(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
コンストラクタ | 説明 |
---|---|
ExploreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key) |
Create a new search for the routingKey specified
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
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
|
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.
|
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
クラス内 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 void newPeersFound(int numNewPeers)
newPeersFound
クラス内 SearchJob