Uses of Class
net.tomp2p.connection.ConnectionReservation

Packages that use ConnectionReservation

net.tomp2p.connection
net.tomp2p.p2p
net.tomp2p.utils

Uses of ConnectionReservation in net.tomp2p.connection

Methods in net.tomp2p.connection that return ConnectionReservation

ConnectionReservation

ConnectionBean.getConnectionReservation()

Methods in net.tomp2p.connection with parameters of type ConnectionReservation

void	Scheduler.startMaintainance(PeerMap peerMap, HandshakeRPC handshakeRPC, ConnectionReservation connectionReservation, int max)
void	Scheduler.startTracking(TaskRPC taskRPC, ConnectionReservation connectionReservation)

Constructors in net.tomp2p.connection with parameters of type ConnectionReservation

ConnectionBean(int p2pID, DispatcherReply dispatcherRequest, Sender sender, org.jboss.netty.channel.group.ChannelGroup channelGroup, ConnectionReservation connectionReservation, ConnectionConfiguration configuration, Scheduler scheduler)

PeerConnection(PeerAddress destination, ConnectionReservation connectionReservation, ChannelCreator channelCreator, int idleTCPMillis)

Uses of ConnectionReservation in net.tomp2p.p2p

Methods in net.tomp2p.p2p with parameters of type ConnectionReservation

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 ConnectionReservation in net.tomp2p.utils

Methods in net.tomp2p.utils with parameters of type ConnectionReservation

static void	Utils.addReleaseListener(BaseFuture baseFuture, ConnectionReservation connectionReservation, ChannelCreator cc, int nr)
static void	Utils.addReleaseListenerAll(BaseFuture baseFuture, ConnectionReservation connectionReservation, ChannelCreator channelCreator)