public class FutureTracker extends BaseFutureImpl<FutureTracker> implements FutureCleanup
BaseFuture.FutureType
completed, lock, reason, type
Constructor and Description |
---|
FutureTracker() |
FutureTracker(EvaluatingSchemeTracker evaluatingSchemeTracker,
Set<Number160> knownPeers)
Create a future object for retrieving.
|
FutureTracker(FutureCreate<BaseFuture> futureCreate)
Create a future object for storing
|
Modifier and Type | Method and Description |
---|---|
void |
addCleanup(Cancellable cancellable)
Call to add cleanup classes for the future e.g.
|
Set<PeerAddress> |
getDirectTrackers() |
Set<Number160> |
getKnownPeers() |
Set<PeerAddress> |
getPeersOnTracker() |
Set<PeerAddress> |
getPotentialTrackers() |
Map<PeerAddress,Collection<TrackerData>> |
getRawPeersOnTracker() |
Collection<TrackerData> |
getTrackers()
Evaluates the data from the trackers.
|
void |
repeated(BaseFuture future)
Called if a future is created based on this future.
|
void |
setTrackers(Set<PeerAddress> potentialTrackers,
Set<PeerAddress> directTrackers,
Map<PeerAddress,Collection<TrackerData>> peersOnTracker)
Set the result of the tracker process.
|
void |
shutdown() |
addCancellation, addListener, addListener, await, await, awaitListeners, awaitUninterruptibly, awaitUninterruptibly, cancel, getFailedReason, getType, isCompleted, isFailed, isSuccess, notifyListerenrs, removeListener, self, setCompletedAndNotify, setFailed, setFailed, setFailed, setFailed, setFailed
public FutureTracker()
public FutureTracker(FutureCreate<BaseFuture> futureCreate)
futureCreate
- Keeps track of futures that are based on this futurepublic FutureTracker(EvaluatingSchemeTracker evaluatingSchemeTracker, Set<Number160> knownPeers)
evaluatingSchemeTracker
- Since we receive results from multiple peers, we need to
summarize themknownPeers
- A set of know peers that we don't want in the result set.public void repeated(BaseFuture future)
future
- The newly created futurepublic void setTrackers(Set<PeerAddress> potentialTrackers, Set<PeerAddress> directTrackers, Map<PeerAddress,Collection<TrackerData>> peersOnTracker)
potentialTrackers
- The trackers that are close to the key, also containing the
direct trackers.directTrackers
- Those peers that are close and reported to have the key.peersOnTracker
- The data from the trackers.public Set<PeerAddress> getPotentialTrackers()
public Set<PeerAddress> getDirectTrackers()
public Map<PeerAddress,Collection<TrackerData>> getRawPeersOnTracker()
public Set<PeerAddress> getPeersOnTracker()
public Set<Number160> getKnownPeers()
public Collection<TrackerData> getTrackers()
getRawPeersOnTracker()
.public void addCleanup(Cancellable cancellable)
FutureCleanup
addCleanup
in interface FutureCleanup
cancellable
- The cleanup classespublic void shutdown()
Copyright © 2013. All Rights Reserved.