Package | Description |
---|---|
net.tomp2p.futures | |
net.tomp2p.p2p | |
net.tomp2p.p2p.builder | |
net.tomp2p.replication |
Modifier and Type | Method and Description |
---|---|
FutureCreate<FutureDHT> |
FutureDHT.getFutureCreate()
Returns the future object that keeps information about future object, based on this object.
|
Modifier and Type | Method and Description |
---|---|
void |
FutureDHT.repeated(FutureDHT futureDHT)
Called for futures created based on this future.
|
Constructor and Description |
---|
FutureDHT(int min,
EvaluatingSchemeDHT evaluationScheme,
FutureCreate<FutureDHT> futureCreate)
Creates a new DHT future object that keeps track of the status of the DHT operations.
|
Modifier and Type | Method and Description |
---|---|
FutureDHT |
DistributedHashTable.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) |
FutureDHT |
DistributedHashTable.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 |
DistributedHashTable.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 |
DistributedHashTable.parallelRequests(RequestP2PConfiguration p2pConfiguration,
NavigableSet<PeerAddress> queue,
boolean cancleOnFinish,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation,
boolean manualCleanup,
DistributedHashTable.Operation operation)
Creates RPCs and executes them parallel.
|
FutureDHT |
DistributedHashTable.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 |
DistributedHashTable.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) |
Modifier and Type | Method and Description |
---|---|
void |
DistributedHashTable.Operation.response(FutureDHT futureDHT) |
Modifier and Type | Method and Description |
---|---|
FutureDHT |
DistributedHashTable.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) |
FutureDHT |
DistributedHashTable.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 |
DistributedHashTable.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 |
DistributedHashTable.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) |
Modifier and Type | Field and Description |
---|---|
protected static FutureDHT |
DHTBuilder.FUTURE_DHT_SHUTDOWN |
Modifier and Type | Field and Description |
---|---|
protected FutureCreator<FutureDHT> |
DHTBuilder.defaultDirectReplication |
protected FutureCreate<FutureDHT> |
DHTBuilder.futureCreate |
Modifier and Type | Method and Description |
---|---|
FutureDHT |
AddBuilder.start() |
FutureDHT |
GetBuilder.start() |
FutureDHT |
RemoveBuilder.start() |
abstract FutureDHT |
DHTBuilder.start() |
FutureDHT |
SendBuilder.start() |
FutureDHT |
ParallelRequestBuilder.start() |
FutureDHT |
PutBuilder.start() |
Modifier and Type | Method and Description |
---|---|
FutureCreator<FutureDHT> |
DHTBuilder.getDefaultDirectReplication() |
FutureCreate<FutureDHT> |
DHTBuilder.getFutureCreate() |
Modifier and Type | Method and Description |
---|---|
K |
DHTBuilder.setDefaultDirectReplication(FutureCreator<FutureDHT> defaultDirectReplication) |
K |
DHTBuilder.setFutureCreate(FutureCreate<FutureDHT> futureCreate) |
Modifier and Type | Method and Description |
---|---|
protected FutureDHT |
ReplicationExecutor.send(Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMapConverted)
If my peer is responsible, I'll issue a put if absent to make sure all replicas are stored.
|
Copyright © 2013. All Rights Reserved.