Uses of Interface
net.tomp2p.futures.BaseFuture

Packages that use BaseFuture

net.tomp2p.connection
net.tomp2p.futures
net.tomp2p.p2p
net.tomp2p.p2p.builder
net.tomp2p.replication
net.tomp2p.utils

Uses of BaseFuture in net.tomp2p.connection

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

void	Scheduler.scheduleTimeout(BaseFuture baseFuture, int millis, String reason)

Method parameters in net.tomp2p.connection with type arguments of type BaseFuture

FutureChannel	ChannelCreator.createTCPChannel(ReplyTimeoutHandler timeoutHandler, RequestHandlerTCP<? extends BaseFuture> requestHandler, int connectTimeoutMillis, InetSocketAddress recipient) Creates a TCP channel future.
FutureChannel	ChannelCreator.createUDPChannel(ReplyTimeoutHandler timeoutHandler, RequestHandlerUDP<? extends BaseFuture> requestHandler, boolean broadcast) Creates a UDP channel.
void	SenderNetty.sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator)
void	Sender.sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator) Sent the message via UDP broadcast.
void	SenderNetty.sendTCP(RequestHandlerTCP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator, int idleTCPMillis)
void	Sender.sendTCP(RequestHandlerTCP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator, int idleTCPMillis) Sent the message via TCP.
void	SenderNetty.sendUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator)
void	Sender.sendUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator) Sent the message via UDP.

Uses of BaseFuture in net.tomp2p.futures

Classes in net.tomp2p.futures with type parameters of type BaseFuture

class	BaseFutureAdapter<F extends BaseFuture> The BaseFuture always completes either successfully or failed.
class	BaseFutureImpl<K extends BaseFuture> The base for all BaseFuture implementations.
interface	BaseFutureListener<F extends BaseFuture> Something interested in being notified when the result of an BaseFuture becomes available.
interface	FutureCreate<K extends BaseFuture> DHT and Tracker operations may occur repeatedly.
interface	FutureCreator<K extends BaseFuture> For direct replication, the DHT needs to be created repeatedly.
class	FutureForkJoin<K extends BaseFuture> The key future for recursive loops.
class	FutureLateJoin<K extends BaseFuture> FutureLateJoin is similar to FutureForkJoin.
class	FutureLaterJoin<K extends BaseFuture> FutureLaterJoin is similar to FutureLateJoin.
class	FutureWrappedBootstrap<K extends BaseFuture> The bootstrap will be a wrapped future, because we need to ping a server first, and if this ping is successful, we can bootstrap.
class	FutureWrapper<K extends BaseFuture> Wraps a future into an other future.

Subinterfaces of BaseFuture in net.tomp2p.futures

interface

FutureBootstrap Used for bootstrapping.

Classes in net.tomp2p.futures that implement BaseFuture

class	BaseFutureImpl<K extends BaseFuture> The base for all BaseFuture implementations.
class	FutureAsyncTask A future to keep track of a future task.
class	FutureChannel Keeps track of the creation of a UDP or TCP channel.
class	FutureChannelCreator This future is used for the connection reservation.
class	FutureDHT The future object for the get() and put() operations including routing.
class	FutureDiscover The future that keeps track of network discovery such as discovery if its behind a NAT, the status if UPNP or NAT-PMP could be established, if there is portforwarding.
class	FutureForkJoin<K extends BaseFuture> The key future for recursive loops.
class	FutureLateJoin<K extends BaseFuture> FutureLateJoin is similar to FutureForkJoin.
class	FutureLaterJoin<K extends BaseFuture> FutureLaterJoin is similar to FutureLateJoin.
class	FutureResponse Each response has one request messages.
class	FutureRouting The routing future keeps track of the routing process.
class	FutureTask This future keeps track of one or more tasks send to remote peers.
class	FutureTracker This class holds the object for future results from the tracker get() and add().
class	FutureWrappedBootstrap<K extends BaseFuture> The bootstrap will be a wrapped future, because we need to ping a server first, and if this ping is successful, we can bootstrap.
class	FutureWrapper<K extends BaseFuture> Wraps a future into an other future.

Methods in net.tomp2p.futures that return BaseFuture

BaseFuture	BaseFuture.addCancellation(Cancellable cancellable) Adds a cancel listener to this future, which is called when cancel is executed.
BaseFuture	BaseFuture.addListener(BaseFutureListener<? extends BaseFuture> listener) Adds a listener which is notified when the state of this future changes.
BaseFuture	BaseFuture.addListener(BaseFutureListener<? extends BaseFuture> listener, boolean last) Adds a listener which is notified when the state of this future changes.
BaseFuture	BaseFuture.await() Wait for the asynchronous operation to end.
BaseFuture	BaseFuture.awaitListeners() Waits until all the listener finished.
BaseFuture	BaseFuture.awaitUninterruptibly() Wait for the asynchronous operation to end without interruption.
BaseFuture	BaseFuture.removeListener(BaseFutureListener<? extends BaseFuture> listener) Removes a listener which is notified when the state of this future changes.
BaseFuture	BaseFuture.setFailed(BaseFuture origin) Sets the failed flat to true and the completed flag to true.
BaseFuture	BaseFuture.setFailed(String reason) Sets the failed flat to true and the completed flag to true.
BaseFuture	BaseFuture.setFailed(String reason, BaseFuture origin) Sets the failed flat to true and the completed flag to true.
BaseFuture	BaseFuture.setFailed(String reason, Throwable t) Sets the failed flat to true and the completed flag to true.
BaseFuture	BaseFuture.setFailed(Throwable t) Sets the failed flat to true and the completed flag to true.

Methods in net.tomp2p.futures with parameters of type BaseFuture

void	FutureTracker.repeated(BaseFuture future) Called if a future is created based on this future.
K	BaseFutureImpl.setFailed(BaseFuture origin)
BaseFuture	BaseFuture.setFailed(BaseFuture origin) Sets the failed flat to true and the completed flag to true.
K	BaseFutureImpl.setFailed(String failed, BaseFuture origin)
BaseFuture	BaseFuture.setFailed(String reason, BaseFuture origin) Sets the failed flat to true and the completed flag to true.

Method parameters in net.tomp2p.futures with type arguments of type BaseFuture

K	BaseFutureImpl.addListener(BaseFutureListener<? extends BaseFuture> listener)
BaseFuture	BaseFuture.addListener(BaseFutureListener<? extends BaseFuture> listener) Adds a listener which is notified when the state of this future changes.
K	BaseFutureImpl.addListener(BaseFutureListener<? extends BaseFuture> listener, boolean last)
BaseFuture	BaseFuture.addListener(BaseFutureListener<? extends BaseFuture> listener, boolean last) Adds a listener which is notified when the state of this future changes.
K	BaseFutureImpl.removeListener(BaseFutureListener<? extends BaseFuture> listener)
BaseFuture	BaseFuture.removeListener(BaseFutureListener<? extends BaseFuture> listener) Removes a listener which is notified when the state of this future changes.

Constructors in net.tomp2p.futures with parameters of type BaseFuture

FutureForkJoin(int nrFinishFuturesSuccess, boolean cancelFuturesOnFinish, K... forks)
Create a future fork join object

FutureForkJoin(K... forks)
Facade if we expect everything to return successfully

Constructor parameters in net.tomp2p.futures with type arguments of type BaseFuture

FutureTracker(FutureCreate<BaseFuture> futureCreate)
Create a future object for storing

Uses of BaseFuture in net.tomp2p.p2p

Methods in net.tomp2p.p2p that return types with arguments of type BaseFuture

Map<BaseFuture,Long>

Peer.getPendingFutures()

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

static void	DistributedRouting.cancel(boolean cancelOnFinish, int parallel, BaseFuture[] futureResponses)
void	Peer.setFutureTimeout(BaseFuture baseFuture, int millis, String reason) Sets a timeout for this future.

Method parameters in net.tomp2p.p2p with type arguments of type BaseFuture

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)

Uses of BaseFuture in net.tomp2p.p2p.builder

Methods in net.tomp2p.p2p.builder that return BaseFuture

BaseFuture

PingBuilder.start()

Methods in net.tomp2p.p2p.builder that return types with arguments of type BaseFuture

FutureCreate<BaseFuture>

AddTrackerBuilder.getFutureCreate()

Method parameters in net.tomp2p.p2p.builder with type arguments of type BaseFuture

AddTrackerBuilder

AddTrackerBuilder.setFutureCreate(FutureCreate<BaseFuture> futureCreate)

Uses of BaseFuture in net.tomp2p.replication

Constructor parameters in net.tomp2p.replication with type arguments of type BaseFuture

DefaultStorageReplication(Peer peer, StorageGeneric storage, StorageRPC storageRPC, Map<BaseFuture,Long> pendingFutures, boolean forceUDP)

TrackerStorageReplication(Peer peer, PeerExchangeRPC peerExchangeRPC, Map<BaseFuture,Long> pendingFutures, TrackerStorage trackerStorage, boolean forceTCP)

Uses of BaseFuture in net.tomp2p.utils

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

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