public class DistributedHashTable extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
DistributedHashTable.Operation |
Constructor and Description |
---|
DistributedHashTable(DistributedRouting routing,
StorageRPC storeRCP,
DirectDataRPC directDataRPC) |
Modifier and Type | Method and Description |
---|---|
FutureDHT |
add(Number160 locationKey,
Number160 domainKey,
Collection<Data> dataSet,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean protectDomain,
boolean signMessage,
boolean isManualCleanup,
boolean list,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation) |
static RequestP2PConfiguration |
adjustConfiguration(RequestP2PConfiguration p2pConfiguration,
SortedMap<PeerAddress,DigestInfo> directHitsDigest)
Adjusts the number of minimum requests in the P2P configuration.
|
FutureDHT |
direct(Number160 locationKey,
org.jboss.netty.buffer.ChannelBuffer buffer,
boolean raw,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
FutureCreate<FutureDHT> futureCreate,
boolean cancelOnFinish,
boolean manualCleanup,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation) |
FutureDHT |
get(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
EvaluatingSchemeDHT evaluationScheme,
boolean signMessage,
boolean digest,
boolean returnBloomFilter,
boolean range,
boolean isManualCleanup,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation) |
FutureDHT |
parallelRequests(RequestP2PConfiguration p2pConfiguration,
NavigableSet<PeerAddress> queue,
boolean cancleOnFinish,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation,
boolean manualCleanup,
DistributedHashTable.Operation operation)
Creates RPCs and executes them parallel.
|
FutureDHT |
put(Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMap,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean putIfAbsent,
boolean protectDomain,
boolean signMessage,
boolean isManualCleanup,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation) |
FutureDHT |
remove(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean returnResults,
boolean signMessage,
boolean isManualCleanup,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation) |
public DistributedHashTable(DistributedRouting routing, StorageRPC storeRCP, DirectDataRPC directDataRPC)
public FutureDHT add(Number160 locationKey, Number160 domainKey, Collection<Data> dataSet, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, boolean protectDomain, boolean signMessage, boolean isManualCleanup, boolean list, FutureCreate<FutureDHT> futureCreate, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation)
public FutureDHT direct(Number160 locationKey, org.jboss.netty.buffer.ChannelBuffer buffer, boolean raw, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, FutureCreate<FutureDHT> futureCreate, boolean cancelOnFinish, boolean manualCleanup, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation)
public FutureDHT put(Number160 locationKey, Number160 domainKey, Map<Number160,Data> dataMap, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, boolean putIfAbsent, boolean protectDomain, boolean signMessage, boolean isManualCleanup, FutureCreate<FutureDHT> futureCreate, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation)
public FutureDHT get(Number160 locationKey, Number160 domainKey, Collection<Number160> contentKeys, SimpleBloomFilter<Number160> keyBloomFilter, SimpleBloomFilter<Number160> contentBloomFilter, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, EvaluatingSchemeDHT evaluationScheme, boolean signMessage, boolean digest, boolean returnBloomFilter, boolean range, boolean isManualCleanup, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation)
public FutureDHT remove(Number160 locationKey, Number160 domainKey, Collection<Number160> contentKeys, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, boolean returnResults, boolean signMessage, boolean isManualCleanup, FutureCreate<FutureDHT> futureCreate, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation)
public FutureDHT parallelRequests(RequestP2PConfiguration p2pConfiguration, NavigableSet<PeerAddress> queue, boolean cancleOnFinish, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation, boolean manualCleanup, DistributedHashTable.Operation operation)
p2pConfiguration
- The configuration that specifies e.g. how many parallel
requests there are.queue
- The sorted set that will be queries. The first RPC takes the
first in the queue.futureDHT
- The future object that tracks the progresscancleOnFinish
- Set to true if the operation should be canceled (e.g. file
transfer) if the future has finished.operation
- The operation that creates the requestpublic static RequestP2PConfiguration adjustConfiguration(RequestP2PConfiguration p2pConfiguration, SortedMap<PeerAddress,DigestInfo> directHitsDigest)
p2pConfiguration
- The old P2P configuration with the user specified minimum
resultdirectHitsDigest
- The digest information from the routing processCopyright © 2013. All Rights Reserved.