|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use FutureChannelCreator | |
---|---|
net.tomp2p.connection | |
net.tomp2p.p2p | |
net.tomp2p.p2p.builder |
Uses of FutureChannelCreator in net.tomp2p.connection |
---|
Methods in net.tomp2p.connection that return FutureChannelCreator | |
---|---|
FutureChannelCreator |
ConnectionReservation.reserve(int permits)
Reserves connections. |
FutureChannelCreator |
ConnectionReservation.reserve(int permits,
boolean keepAliveAndReuse)
Reserves connections. |
FutureChannelCreator |
ConnectionReservation.reserve(int permits,
boolean keepAliveAndReuse,
String name)
Reserves connections. |
FutureChannelCreator |
ConnectionReservation.reserve(int permits,
String name)
Reserves connections. |
Uses of FutureChannelCreator in net.tomp2p.p2p |
---|
Methods in net.tomp2p.p2p that return FutureChannelCreator | |
---|---|
FutureChannelCreator |
Peer.reserve(RoutingConfiguration routingConfiguration,
RequestP2PConfiguration requestP2PConfiguration,
String name)
Reserves a connection for a routing and DHT operation. |
Methods in net.tomp2p.p2p with parameters of type FutureChannelCreator | |
---|---|
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)
|
FutureTracker |
DistributedTracker.addToTracker(Number160 locationKey,
Number160 domainKey,
byte[] attachment,
RoutingConfiguration routingConfiguration,
TrackerConfiguration trackerConfiguration,
boolean signMessage,
FutureCreate<BaseFuture> futureCreate,
Set<Number160> knownPeers,
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)
|
FutureTracker |
DistributedTracker.getFromTracker(Number160 locationKey,
Number160 domainKey,
RoutingConfiguration routingConfiguration,
TrackerConfiguration trackerConfiguration,
boolean expectAttachement,
EvaluatingSchemeTracker evaluatingScheme,
boolean signMessage,
boolean useSecondaryTrackers,
Set<Number160> knownPeers,
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)
|
FutureLateJoin<FutureResponse> |
DistributedTracker.startPeerExchange(Number160 locationKey,
Number160 domainKey,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation,
boolean forceTCP)
|
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. |
Uses of FutureChannelCreator in net.tomp2p.p2p.builder |
---|
Fields in net.tomp2p.p2p.builder declared as FutureChannelCreator | |
---|---|
protected FutureChannelCreator |
TrackerBuilder.futureChannelCreator
|
protected FutureChannelCreator |
DHTBuilder.futureChannelCreator
|
Methods in net.tomp2p.p2p.builder that return FutureChannelCreator | |
---|---|
FutureChannelCreator |
SendDirectBuilder.getFutureChannelCreator()
|
FutureChannelCreator |
TrackerBuilder.getFutureChannelCreator()
|
FutureChannelCreator |
DHTBuilder.getFutureChannelCreator()
|
FutureChannelCreator |
SubmitBuilder.getFutureChannelCreator()
|
Methods in net.tomp2p.p2p.builder with parameters of type FutureChannelCreator | |
---|---|
SendDirectBuilder |
SendDirectBuilder.setFutureChannelCreator(FutureChannelCreator futureChannelCreator)
|
K |
TrackerBuilder.setFutureChannelCreator(FutureChannelCreator futureChannelCreator)
|
K |
DHTBuilder.setFutureChannelCreator(FutureChannelCreator futureChannelCreator)
|
SubmitBuilder |
SubmitBuilder.setFutureChannelCreator(FutureChannelCreator futureChannelCreator)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |