Uses of Class
net.tomp2p.futures.FutureChannelCreator

Packages that use FutureChannelCreator
net.tomp2p.connection   
net.tomp2p.p2p   
 

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(ConfigurationBaseDHT configurationBaseDHT)
          Reserves a connection for a routing and DHT operation.
 FutureChannelCreator Peer.reserve(ConfigurationBaseDHT configurationBaseDHT, String name)
          Reserves a connection for a routing and DHT operation.
 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 Peer.add(Number160 locationKey, Collection<Data> dataCollection, ConfigurationStore config, FutureChannelCreator channelCreator)
           
 FutureDHT Peer.add(Number160 locationKey, Data data, ConfigurationStore config, FutureChannelCreator channelCreator)
           
 FutureDHT DistributedHashTable.add(Number160 locationKey, Number160 domainKey, Collection<Data> dataSet, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, boolean protectDomain, boolean signMessage, boolean isAutomaticCleanup, 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 Peer.digest(Number160 locationKey, ConfigurationGet config, FutureChannelCreator channelCreator)
           
 FutureDHT Peer.digest(Number160 locationKey, Set<Number160> keyCollection, ConfigurationGet config, FutureChannelCreator channelCreator)
           
 FutureDHT Peer.digestAll(Number160 locationKey, ConfigurationGet config, FutureChannelCreator channelCreator)
           
 FutureDHT DistributedHashTable.direct(Number160 locationKey, org.jboss.netty.buffer.ChannelBuffer buffer, boolean raw, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, FutureCreate<FutureDHT> futureCreate, boolean cancelOnFinish, boolean isAutomaticCleanup, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation)
           
 FutureDHT Peer.get(Number160 locationKey, ConfigurationGet config, FutureChannelCreator channelCreator)
           
 FutureDHT DistributedHashTable.get(Number160 locationKey, Number160 domainKey, Set<Number160> contentKeys, PublicKey publicKey, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, EvaluatingSchemeDHT evaluationScheme, boolean signMessage, boolean digest, boolean isAutomaticCleanup, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation)
           
 FutureDHT Peer.get(Number160 locationKey, Set<Number160> keyCollection, ConfigurationGet config, FutureChannelCreator channelCreator)
           
 FutureDHT Peer.getAll(Number160 locationKey, ConfigurationGet config, FutureChannelCreator channelCreator)
           
 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 Peer.parallelRequests(Number160 locationKey, ConfigurationBaseDHT config, FutureChannelCreator channelCreator, boolean cancleOnFinish, NavigableSet<PeerAddress> queue, DistributedHashTable.Operation operation)
           
 FutureDHT DistributedHashTable.parallelRequests(RequestP2PConfiguration p2pConfiguration, NavigableSet<PeerAddress> queue, boolean cancleOnFinish, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation, boolean isAutomaticCleanup, DistributedHashTable.Operation operation)
          Creates RPCs and executes them parallel.
 FutureDHT Peer.put(Number160 locationKey, Data data, ConfigurationStore config, FutureChannelCreator channelCreator)
           
 FutureDHT Peer.put(Number160 locationKey, Map<Number160,Data> dataMap, ConfigurationStore config, FutureChannelCreator channelCreator)
          Stores values in the DHT.
 FutureDHT DistributedHashTable.put(Number160 locationKey, Number160 domainKey, Map<Number160,Data> dataMap, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, boolean putIfAbsent, boolean protectDomain, boolean signMessage, boolean isAutomaticCleanup, FutureCreate<FutureDHT> futureCreate, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation)
           
 FutureDHT Peer.remove(Number160 locationKey, ConfigurationRemove config, FutureChannelCreator channelCreator)
           
 FutureDHT DistributedHashTable.remove(Number160 locationKey, Number160 domainKey, Set<Number160> contentKeys, RoutingConfiguration routingConfiguration, RequestP2PConfiguration p2pConfiguration, boolean returnResults, boolean signMessage, boolean isAutomaticCleanup, FutureCreate<FutureDHT> futureCreate, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation)
           
 FutureDHT Peer.remove(Number160 locationKey, Set<Number160> keyCollection, ConfigurationRemove config, FutureChannelCreator channelCreator)
           
 FutureDHT Peer.removeAll(Number160 locationKey, ConfigurationRemove config, FutureChannelCreator channelCreator)
           
 FutureDHT Peer.send(Number160 locationKey, org.jboss.netty.buffer.ChannelBuffer buffer, ConfigurationDirect config, FutureChannelCreator channelCreator)
           
 FutureDHT Peer.send(Number160 locationKey, Object object, ConfigurationDirect config, FutureChannelCreator channelCreator)
           
 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, TaskConfiguration taskConfiguration, FutureChannelCreator futureChannelCreator, boolean signMessage, boolean isAutomaticCleanup, ConnectionReservation connectionReservation)
          Submit a task to the DHT.
 



Copyright © 2012. All Rights Reserved.