public class DistributedRouting extends Object
Constructor and Description |
---|
DistributedRouting(PeerBean peerBean,
NeighborRPC neighbors) |
Modifier and Type | Method and Description |
---|---|
FutureWrapper<FutureRouting> |
bootstrap(Collection<PeerAddress> peerAddresses,
int maxNoNewInfo,
int maxFailures,
int maxSuccess,
int parallel,
boolean forceTCP,
boolean isForceRoutingOnlyToSelf,
ChannelCreator cc)
Bootstraps to the given peerAddresses, i.e.
|
static void |
cancel(boolean cancelOnFinish,
int parallel,
BaseFuture[] futureResponses) |
FutureRouting |
route(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
Message.Type type,
int maxDirectHits,
int maxNoNewInfo,
int maxFailures,
int maxSuccess,
int parallel,
boolean forceTCP,
ChannelCreator cc)
Looks for a route to the given locationKey
|
public DistributedRouting(PeerBean peerBean, NeighborRPC neighbors)
public FutureWrapper<FutureRouting> bootstrap(Collection<PeerAddress> peerAddresses, int maxNoNewInfo, int maxFailures, int maxSuccess, int parallel, boolean forceTCP, boolean isForceRoutingOnlyToSelf, ChannelCreator cc)
peerAddresses
- the node to which bootstrap should be performed tomaxNoNewInfo
- number of nodes asked without new information to stop atmaxFailures
- number of failures to stop atparallel
- number of routing requests performed concurrentlypublic FutureRouting route(Number160 locationKey, Number160 domainKey, Collection<Number160> contentKeys, Message.Type type, int maxDirectHits, int maxNoNewInfo, int maxFailures, int maxSuccess, int parallel, boolean forceTCP, ChannelCreator cc)
locationKey
- the node a route should be found todomainKey
- the domain of the network the current node and locationKey is
incontentKeys
- keys of the content to search for. Only used if you perform a
getmaxDirectHits
- number of direct hits to stop atmaxNoNewInfo
- number of nodes asked without new information to stop atmaxFailures
- number of failures to stop atparallel
- number of routing requests performed concurrentlyisDigest
- Set to true to return a digest of the remote content for close
neighborsforceTCP
- Set to true if routing should use TCP connectionscc
- the channel creatorpublic static void cancel(boolean cancelOnFinish, int parallel, BaseFuture[] futureResponses)
Copyright © 2013. All Rights Reserved.