Uses of Class
net.tomp2p.futures.FutureResponse

Packages that use FutureResponse

net.tomp2p.connection
net.tomp2p.futures
net.tomp2p.p2p
net.tomp2p.p2p.builder
net.tomp2p.rpc

Uses of FutureResponse in net.tomp2p.connection

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

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 FutureResponse in net.tomp2p.futures

Methods in net.tomp2p.futures that return FutureResponse

FutureResponse

FutureResponse.setFailed(String reason)

Methods in net.tomp2p.futures that return types with arguments of type FutureResponse

FutureForkJoin<FutureResponse>

FutureDHT.getFutureRequests() Returns back those futures that are still running.

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

void	FutureDHT.addRequests(FutureResponse futureResponse) Adds all requests that have been created for the DHT operations.

Uses of FutureResponse in net.tomp2p.p2p

Methods in net.tomp2p.p2p that return FutureResponse

FutureResponse	DistributedHashTable.Operation.create(ChannelCreator channelCreator, PeerAddress remotePeerAddress)
FutureResponse	DistributedTracker.Operation.create(PeerAddress address, boolean primary) Creates an RPC.

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

FutureLateJoin<FutureResponse>

DistributedTracker.startPeerExchange(Number160 locationKey, Number160 domainKey, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation, boolean forceTCP)

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

void	DistributedHashTable.Operation.interMediateResponse(FutureResponse futureResponse)

Uses of FutureResponse in net.tomp2p.p2p.builder

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

FutureResponse	PingBuilder.ping(InetSocketAddress address) Pings a peer.
FutureResponse	PingBuilder.ping(InetSocketAddress address, boolean isUDP) Pings a peer.
FutureResponse	SendDirectBuilder.start()

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

FutureCreator<FutureLateJoin<FutureResponse>>

AddTrackerBuilder.getDefaultPEX()

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

AddTrackerBuilder

AddTrackerBuilder.setDefaultPEX(FutureCreator<FutureLateJoin<FutureResponse>> defaultPEX)

Uses of FutureResponse in net.tomp2p.rpc

Classes in net.tomp2p.rpc with type parameters of type FutureResponse

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.

Methods in net.tomp2p.rpc that return FutureResponse

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)

Methods in net.tomp2p.rpc that return types with arguments of type FutureResponse

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.

Methods in net.tomp2p.rpc with parameters of type FutureResponse

static boolean	TrackerRPC.isPrimary(FutureResponse response)
static boolean	TrackerRPC.isSecondary(FutureResponse response)

Method parameters in net.tomp2p.rpc with type arguments of type FutureResponse

FutureResponse

SenderCacheStrategy.putIfAbsent(CacheKey cacheKey, RequestHandlerTCP<FutureResponse> request, ChannelCreator channelCreator)