Uses of Class
net.tomp2p.futures.FutureResponse

Packages that use FutureResponse
net.tomp2p.connection   
net.tomp2p.futures   
net.tomp2p.p2p   
net.tomp2p.rpc   
 

Uses of FutureResponse in net.tomp2p.connection
 

Methods in net.tomp2p.connection with parameters of type FutureResponse
 void Sender.sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator)
          Sent the message via UDP broadcast.
 void SenderNetty.sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator)
           
 void Sender.sendTCP(RequestHandlerTCP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator, int idleTCPMillis)
          Sent the message via TCP.
 void SenderNetty.sendTCP(RequestHandlerTCP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator, int idleTCPMillis)
           
 void Sender.sendUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator)
          Sent the message via UDP.
 void SenderNetty.sendUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator)
           
 

Uses of FutureResponse in net.tomp2p.futures
 

Subclasses of FutureResponse in net.tomp2p.futures
 class FutureData
          FutureData is used as the future object for direct DHT operations.
 

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.
 FutureResponse Peer.ping(InetSocketAddress address)
          Pings a peer.
 FutureResponse Peer.ping(InetSocketAddress address, boolean isUDP)
          Pings a peer.
 

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.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, ChannelCreator channelCreator, boolean forceUDP)
          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, PublicKey protectedDomains, boolean signMessage, boolean digest, boolean returnBloomFilter, 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)
          Stores data on a remote peer.
 FutureResponse StorageRPC.putIfAbsent(PeerAddress remotePeer, Number160 locationKey, Number160 domainKey, Map<Number160,Data> dataMap, boolean protectDomain, boolean protectEntry, boolean signMessage, ChannelCreator channelCreator, boolean forceUDP)
          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 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)
           
 

Methods in net.tomp2p.rpc with parameters of type FutureResponse
static boolean TrackerRPC.isPrimary(FutureResponse response)
           
static boolean TrackerRPC.isSecondary(FutureResponse response)
           
 



Copyright © 2012. All Rights Reserved.