Package | Description |
---|---|
net.tomp2p.connection | |
net.tomp2p.futures | |
net.tomp2p.p2p | |
net.tomp2p.p2p.builder | |
net.tomp2p.replication | |
net.tomp2p.utils |
Modifier and Type | Method and Description |
---|---|
void |
Scheduler.scheduleTimeout(BaseFuture baseFuture,
int millis,
String reason) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Class and Description |
---|---|
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.
|
Modifier and Type | Interface and Description |
---|---|
interface |
FutureBootstrap
Used for bootstrapping.
|
Modifier and Type | Class and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
FutureTracker.repeated(BaseFuture future)
Called if a future is created based on this future.
|
BaseFuture |
BaseFuture.setFailed(BaseFuture origin)
Sets the failed flat to true and the completed flag to true.
|
K |
BaseFutureImpl.setFailed(BaseFuture origin) |
BaseFuture |
BaseFuture.setFailed(String reason,
BaseFuture origin)
Sets the failed flat to true and the completed flag to true.
|
K |
BaseFutureImpl.setFailed(String failed,
BaseFuture origin) |
Modifier and Type | Method and Description |
---|---|
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) |
BaseFuture |
BaseFuture.addListener(BaseFutureListener<? extends BaseFuture> listener,
boolean last)
Adds a listener which is notified when the state of this future changes.
|
K |
BaseFutureImpl.addListener(BaseFutureListener<? extends BaseFuture> listener,
boolean last) |
BaseFuture |
BaseFuture.removeListener(BaseFutureListener<? extends BaseFuture> listener)
Removes a listener which is notified when the state of this future
changes.
|
K |
BaseFutureImpl.removeListener(BaseFutureListener<? extends BaseFuture> listener) |
Constructor and Description |
---|
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 and Description |
---|
FutureTracker(FutureCreate<BaseFuture> futureCreate)
Create a future object for storing
|
Modifier and Type | Method and Description |
---|---|
Map<BaseFuture,Long> |
Peer.getPendingFutures() |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
BaseFuture |
PingBuilder.start() |
Modifier and Type | Method and Description |
---|---|
FutureCreate<BaseFuture> |
AddTrackerBuilder.getFutureCreate() |
Modifier and Type | Method and Description |
---|---|
AddTrackerBuilder |
AddTrackerBuilder.setFutureCreate(FutureCreate<BaseFuture> futureCreate) |
Constructor and Description |
---|
TrackerStorageReplication(Peer peer,
PeerExchangeRPC peerExchangeRPC,
Map<BaseFuture,Long> pendingFutures,
TrackerStorage trackerStorage,
boolean forceTCP) |
Modifier and Type | Method and Description |
---|---|
static void |
Utils.addReleaseListener(BaseFuture baseFuture,
ConnectionReservation connectionReservation,
ChannelCreator cc,
int nr) |
static void |
Utils.addReleaseListenerAll(BaseFuture baseFuture,
ConnectionReservation connectionReservation,
ChannelCreator channelCreator) |
Copyright © 2013. All Rights Reserved.