Package | Description |
---|---|
net.tomp2p.p2p | |
net.tomp2p.p2p.builder |
Modifier and Type | Method and Description |
---|---|
static RequestP2PConfiguration |
DistributedHashTable.adjustConfiguration(RequestP2PConfiguration p2pConfiguration,
SortedMap<PeerAddress,DigestInfo> directHitsDigest)
Adjusts the number of minimum requests in the P2P configuration.
|
RequestP2PConfiguration |
RequestP2PConfiguration.adjustMinimumResult(int minimumResultsLow) |
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) |
static RequestP2PConfiguration |
DistributedHashTable.adjustConfiguration(RequestP2PConfiguration p2pConfiguration,
SortedMap<PeerAddress,DigestInfo> directHitsDigest)
Adjusts the number of minimum requests in the P2P configuration.
|
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) |
FutureChannelCreator |
Peer.reserve(RoutingConfiguration routingConfiguration,
RequestP2PConfiguration requestP2PConfiguration,
String name)
Reserves a connection for a routing and DHT operation.
|
FutureTask |
DistributedTask.submit(Number160 locationKey,
Map<Number160,Data> dataMap,
Worker worker,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration requestP2PConfiguration,
FutureChannelCreator futureChannelCreator,
boolean signMessage,
boolean isManualCleanup,
ConnectionReservation connectionReservation)
Submit a task to the DHT.
|
Modifier and Type | Field and Description |
---|---|
protected RequestP2PConfiguration |
DHTBuilder.requestP2PConfiguration |
Modifier and Type | Method and Description |
---|---|
RequestP2PConfiguration |
SubmitBuilder.getRequestP2PConfiguration() |
RequestP2PConfiguration |
BootstrapBuilder.getRequestP2PConfiguration() |
RequestP2PConfiguration |
DHTBuilder.getRequestP2PConfiguration() |
Modifier and Type | Method and Description |
---|---|
SubmitBuilder |
SubmitBuilder.setRequestP2PConfiguration(RequestP2PConfiguration requestP2PConfiguration) |
BootstrapBuilder |
BootstrapBuilder.setRequestP2PConfiguration(RequestP2PConfiguration requestP2PConfiguration) |
K |
DHTBuilder.setRequestP2PConfiguration(RequestP2PConfiguration requestP2PConfiguration) |
Copyright © 2013. All Rights Reserved.