Package | Description |
---|---|
net.tomp2p.connection | |
net.tomp2p.futures | |
net.tomp2p.p2p | |
net.tomp2p.p2p.builder | |
net.tomp2p.rpc |
Modifier and Type | Method and Description |
---|---|
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 | Method and Description |
---|---|
FutureResponse |
FutureResponse.setFailed(String reason) |
Modifier and Type | Method and Description |
---|---|
FutureForkJoin<FutureResponse> |
FutureDHT.getFutureRequests()
Returns back those futures that are still running.
|
Modifier and Type | Method and Description |
---|---|
void |
FutureDHT.addRequests(FutureResponse futureResponse)
Adds all requests that have been created for the DHT operations.
|
Modifier and Type | Method and Description |
---|---|
FutureResponse |
DistributedHashTable.Operation.create(ChannelCreator channelCreator,
PeerAddress remotePeerAddress) |
FutureResponse |
DistributedTracker.Operation.create(PeerAddress address,
boolean primary)
Creates an RPC.
|
Modifier and Type | Method and Description |
---|---|
FutureLateJoin<FutureResponse> |
DistributedTracker.startPeerExchange(Number160 locationKey,
Number160 domainKey,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation,
boolean forceTCP) |
Modifier and Type | Method and Description |
---|---|
void |
DistributedHashTable.Operation.interMediateResponse(FutureResponse futureResponse) |
Modifier and Type | Method and Description |
---|---|
FutureResponse |
PingBuilder.ping(InetSocketAddress address)
Pings a peer.
|
FutureResponse |
PingBuilder.ping(InetSocketAddress address,
boolean isUDP)
Pings a peer.
|
FutureResponse |
SendDirectBuilder.start() |
Modifier and Type | Method and Description |
---|---|
FutureCreator<FutureLateJoin<FutureResponse>> |
AddTrackerBuilder.getDefaultPEX() |
Modifier and Type | Method and Description |
---|---|
AddTrackerBuilder |
AddTrackerBuilder.setDefaultPEX(FutureCreator<FutureLateJoin<FutureResponse>> defaultPEX) |
Modifier and Type | Class and Description |
---|---|
class |
RequestHandlerTCP<K extends FutureResponse>
Is able to send TCP messages (as a request) and processes incoming replies.
|
class |
RequestHandlerUDP<K extends FutureResponse>
Is able to send UDP messages (as a request) and processes incoming replies.
|
Modifier and Type | Method and Description |
---|---|
FutureResponse |
StorageRPC.add(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Data> dataSet,
boolean protectDomain,
boolean signMessage,
boolean list,
ChannelCreator channelCreator,
boolean forceUDP,
SenderCacheStrategy senderCacheStrategy)
Adds data on a remote peer.
|
FutureResponse |
TrackerRPC.addToTracker(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
byte[] attachement,
boolean signMessage,
boolean primary,
Set<Number160> knownPeers,
ChannelCreator channelCreator,
boolean forceUDP,
boolean forceTCP) |
FutureResponse |
TrackerRPC.addToTracker(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
byte[] attachement,
int offset,
int legth,
boolean signMessage,
boolean primary,
Set<Number160> knownPeers,
ChannelCreator channelCreator,
boolean forceUDP,
boolean forceTCP) |
FutureResponse |
NeighborRPC.closeNeighbors(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
Message.Type type,
ChannelCreator channelCreator,
boolean forceTCP)
Requests close neighbors from the remote peer.
|
FutureResponse |
StorageRPC.compareAndPut(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Map<Number160,HashData> hashDataMap,
FutureSuccessEvaluator futureSuccessEvaluator,
boolean protectDomain,
boolean protectEntry,
boolean signMessage,
boolean partialPut,
ChannelCreator channelCreator,
boolean forceUDP)
Compares and puts data on a peer.
|
FutureResponse |
HandshakeRPC.fireTCP(PeerAddress remotePeer,
ChannelCreator channelCreator) |
FutureResponse |
HandshakeRPC.fireUDP(PeerAddress remotePeer,
ChannelCreator channelCreator) |
FutureResponse |
StorageRPC.get(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter,
boolean signMessage,
boolean digest,
boolean returnBloomFilter,
boolean range,
ChannelCreator channelCreator,
boolean forceUDP)
Get the data from a remote peer.
|
FutureResponse |
TrackerRPC.getFromTracker(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
boolean expectAttachement,
boolean signMessage,
Set<Number160> knownPeers,
ChannelCreator channelCreator) |
FutureResponse |
TrackerRPC.getFromTracker(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
boolean expectAttachement,
boolean signMessage,
Set<Number160> knownPeers,
ChannelCreator channelCreator,
boolean forceUDP,
boolean forceTCP) |
FutureResponse |
PeerExchangeRPC.peerExchange(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
boolean isReplication,
ChannelCreator channelCreator,
boolean forceTCP)
Peer exchange (PEX) information about other peers from the swarm, to not
ask the primary trackers too often.
|
FutureResponse |
HandshakeRPC.pingBroadcastUDP(PeerAddress remotePeer,
ChannelCreator channelCreator) |
FutureResponse |
HandshakeRPC.pingTCP(PeerAddress remotePeer,
ChannelCreator channelCreator) |
FutureResponse |
HandshakeRPC.pingTCPDiscover(PeerAddress remotePeer,
ChannelCreator channelCreator) |
FutureResponse |
HandshakeRPC.pingTCPProbe(PeerAddress remotePeer,
ChannelCreator channelCreator) |
FutureResponse |
HandshakeRPC.pingUDP(PeerAddress remotePeer,
ChannelCreator channelCreator) |
FutureResponse |
HandshakeRPC.pingUDPDiscover(PeerAddress remotePeer,
ChannelCreator channelCreator) |
FutureResponse |
HandshakeRPC.pingUDPProbe(PeerAddress remotePeer,
ChannelCreator channelCreator) |
FutureResponse |
StorageRPC.put(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMap,
boolean protectDomain,
boolean protectEntry,
boolean signMessage,
ChannelCreator channelCreator,
boolean forceUDP,
SenderCacheStrategy senderCacheStrategy)
Stores data on a remote peer.
|
FutureResponse |
SenderCacheStrategy.putIfAbsent(CacheKey cacheKey,
RequestHandlerTCP<FutureResponse> request,
ChannelCreator channelCreator) |
FutureResponse |
StorageRPC.putIfAbsent(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMap,
boolean protectDomain,
boolean protectEntry,
boolean signMessage,
ChannelCreator channelCreator,
boolean forceUDP,
SenderCacheStrategy senderCacheStrategy)
Stores data on a remote peer.
|
FutureResponse |
QuitRPC.quit(PeerAddress remotePeer,
ChannelCreator channelCreator,
boolean forceTCP)
Sends a message that indicates this peer is about to quit.
|
FutureResponse |
StorageRPC.remove(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
boolean sendBackResults,
boolean signMessage,
ChannelCreator channelCreator,
boolean forceUDP)
Removes data from a peer.
|
FutureResponse |
DirectDataRPC.send(PeerAddress remotePeer,
org.jboss.netty.buffer.ChannelBuffer buffer,
boolean raw,
ChannelCreator channelCreator,
boolean forceUDP) |
FutureResponse |
DirectDataRPC.send(PeerAddress remotePeer,
org.jboss.netty.buffer.ChannelBuffer buffer,
boolean raw,
ChannelCreator channelCreator,
int idleTCPMillis,
boolean forceUDP)
Send data directly to a peer.
|
FutureResponse |
BroadcastRPC.send(PeerAddress remotePeer,
Number160 messageKey,
Map<Number160,Data> dataMap,
ChannelCreator channelCreator,
int idleTCPMillis,
boolean forceUDP) |
FutureResponse |
BroadcastRPC.send(PeerAddress remotePeer,
Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
ChannelCreator channelCreator,
int idleTCPMillis,
boolean forceUDP) |
FutureResponse |
TaskRPC.sendResult(PeerAddress remotePeer,
ChannelCreator channelCreator,
Number160 taskID,
Map<Number160,Data> dataMap,
KeyPair keyPair,
boolean forceUDP,
boolean sign) |
FutureResponse |
TaskRPC.sendTask(PeerAddress remotePeer,
ChannelCreator channelCreator,
Number160 taskID,
Map<Number160,Data> dataMap,
Worker mapper,
KeyPair keyPair,
boolean forceUDP,
boolean sign)
Sends a task to a remote peer.
|
FutureResponse |
TaskRPC.taskStatus(PeerAddress remotePeer,
ChannelCreator channelCreator,
Collection<Number160> taskIDs,
boolean forceTCP) |
Modifier and Type | Method and Description |
---|---|
RequestHandlerTCP<FutureResponse> |
HandshakeRPC.pingTCP(PeerAddress remotePeer) |
RequestHandlerUDP<FutureResponse> |
HandshakeRPC.pingUDP(PeerAddress remotePeer) |
RequestHandlerTCP<FutureResponse> |
DirectDataRPC.prepareSend(PeerAddress remotePeer,
org.jboss.netty.buffer.ChannelBuffer buffer,
boolean raw)
Prepares for sending to a remote peer.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
TrackerRPC.isPrimary(FutureResponse response) |
static boolean |
TrackerRPC.isSecondary(FutureResponse response) |
Modifier and Type | Method and Description |
---|---|
FutureResponse |
SenderCacheStrategy.putIfAbsent(CacheKey cacheKey,
RequestHandlerTCP<FutureResponse> request,
ChannelCreator channelCreator) |
Copyright © 2013. All Rights Reserved.