Uses of Class
net.tomp2p.peers.PeerAddress

Packages that use PeerAddress
net.tomp2p.connection   
net.tomp2p.futures   
net.tomp2p.message   
net.tomp2p.p2p   
net.tomp2p.p2p.builder   
net.tomp2p.peers   
net.tomp2p.replication   
net.tomp2p.rpc   
net.tomp2p.storage   
net.tomp2p.task   
 

Uses of PeerAddress in net.tomp2p.connection
 

Methods in net.tomp2p.connection that return PeerAddress
 PeerAddress PeerConnection.getDestination()
           
 PeerAddress PeerBean.getServerPeerAddress()
           
 

Methods in net.tomp2p.connection with parameters of type PeerAddress
 org.jboss.netty.channel.ChannelFuture ChannelCreator.close(PeerAddress destination)
          Closes a permanent connection.
 void Scheduler.keepTrack(PeerAddress remotePeer, Number160 taskId, TaskResultListener taskResultListener)
           
 void PeerBean.setServerPeerAddress(PeerAddress serverPeerAddress)
           
 

Constructors in net.tomp2p.connection with parameters of type PeerAddress
PeerConnection(PeerAddress destination, ConnectionReservation connectionReservation, ChannelCreator channelCreator, int idleTCPMillis)
           
ReplyTimeoutHandler(org.jboss.netty.util.Timer timer, long timeoutMillis, PeerAddress remotePeer)
           
 

Uses of PeerAddress in net.tomp2p.futures
 

Methods in net.tomp2p.futures that return PeerAddress
 PeerAddress FutureDiscover.getPeerAddress()
          The peerAddress where we are reachable
 PeerAddress FutureAsyncTask.getRemotePeer()
           
 PeerAddress FutureDiscover.getReporter()
           
 

Methods in net.tomp2p.futures that return types with arguments of type PeerAddress
 Collection<PeerAddress> FutureWrappedBootstrap.getBootstrapTo()
          Returns a list of of peers that were involved in the bootstrapping
 Collection<PeerAddress> FutureBootstrap.getBootstrapTo()
          Returns the Peers we bootstrapped in no particular order.
 NavigableSet<PeerAddress> FutureRouting.getDirectHits()
          The direct hits set contains those peers that reported to have the key (Number160) we were looking for.
 SortedMap<PeerAddress,DigestInfo> FutureRouting.getDirectHitsDigest()
          The direct hits map contains those peers that reported to have the key (Number160) we were looking for including its digest (size of the result set and its xored hashes).
 Set<PeerAddress> FutureTracker.getDirectTrackers()
           
 Set<PeerAddress> FutureTracker.getPeersOnTracker()
           
 NavigableSet<PeerAddress> FutureRouting.getPotentialHits()
          The potential hits set contains those peers that are in the direct hit and that did report to *not* have the key (Number160) we were looking for.
 Set<PeerAddress> FutureTracker.getPotentialTrackers()
           
 Map<PeerAddress,Map<Number160,Data>> FutureDHT.getRawData()
          Returns the raw data from the get operation
 Map<PeerAddress,Map<Number160,Data>> FutureTask.getRawDataMap()
           
 Map<PeerAddress,DigestResult> FutureDHT.getRawDigest()
           
 Map<PeerAddress,org.jboss.netty.buffer.ChannelBuffer> FutureDHT.getRawDirectData1()
          Return raw data from send_dircet (Netty buffer).
 Map<PeerAddress,Object> FutureDHT.getRawDirectData2()
          Return raw data from send_dircet (Object).
 Map<PeerAddress,Collection<Number160>> FutureDHT.getRawKeys()
          Returns the raw keys from the storage or removal operation
 Map<PeerAddress,Collection<Number480>> FutureDHT.getRawKeys480()
           
 Map<PeerAddress,Collection<TrackerData>> FutureTracker.getRawPeersOnTracker()
           
 SortedSet<PeerAddress> FutureRouting.getRoutingPath()
          Returns the peers that have been asked to provide neighbor information.
 

Methods in net.tomp2p.futures with parameters of type PeerAddress
 void FutureDiscover.done(PeerAddress ourPeerAddress, PeerAddress reporter)
          Gets called if the discovery was a success and an other peer could ping us with TCP and UDP.
 

Method parameters in net.tomp2p.futures with type arguments of type PeerAddress
 void FutureWrappedBootstrap.setBootstrapTo(Collection<PeerAddress> bootstrapTo)
          The addresses we boostrap to.
 void FutureDHT.setDirectData1(Map<PeerAddress,org.jboss.netty.buffer.ChannelBuffer> rawChannels)
          Finish the future and set the keys and data that have send directly using the Netty buffer.
 void FutureDHT.setDirectData2(Map<PeerAddress,Object> rawObjects)
          Finish the future and set the keys and data that have send directly using an object.
 void FutureRouting.setNeighbors(SortedMap<PeerAddress,DigestInfo> directHits, NavigableSet<PeerAddress> potentialHits, SortedSet<PeerAddress> routingPath, boolean isBootstrap, boolean isRoutingToOther)
          Sets the result of the routing process and finishes the future.
 void FutureRouting.setNeighbors(SortedMap<PeerAddress,DigestInfo> directHits, NavigableSet<PeerAddress> potentialHits, SortedSet<PeerAddress> routingPath, boolean isBootstrap, boolean isRoutingToOther)
          Sets the result of the routing process and finishes the future.
 void FutureRouting.setNeighbors(SortedMap<PeerAddress,DigestInfo> directHits, NavigableSet<PeerAddress> potentialHits, SortedSet<PeerAddress> routingPath, boolean isBootstrap, boolean isRoutingToOther)
          Sets the result of the routing process and finishes the future.
 void FutureDHT.setReceivedData(Map<PeerAddress,Map<Number160,Data>> rawData)
          Finish the future and set the keys and data that have been received.
 void FutureDHT.setReceivedDigest(Map<PeerAddress,DigestResult> rawDigest)
          Finishes the future and set the digest information that have been received.
 void FutureDHT.setRemovedKeys(Map<PeerAddress,Collection<Number160>> rawKeys)
          Finish the future and set the keys that have been removed.
 void FutureDHT.setStoredKeys(Number160 locationKey, Number160 domainKey, Map<PeerAddress,Collection<Number160>> rawKeys, Map<PeerAddress,Collection<Number480>> rawKeys480)
          Finish the future and set the keys that have been stored.
 void FutureDHT.setStoredKeys(Number160 locationKey, Number160 domainKey, Map<PeerAddress,Collection<Number160>> rawKeys, Map<PeerAddress,Collection<Number480>> rawKeys480)
          Finish the future and set the keys that have been stored.
 void FutureTracker.setTrackers(Set<PeerAddress> potentialTrackers, Set<PeerAddress> directTrackers, Map<PeerAddress,Collection<TrackerData>> peersOnTracker)
          Set the result of the tracker process.
 void FutureTracker.setTrackers(Set<PeerAddress> potentialTrackers, Set<PeerAddress> directTrackers, Map<PeerAddress,Collection<TrackerData>> peersOnTracker)
          Set the result of the tracker process.
 void FutureTracker.setTrackers(Set<PeerAddress> potentialTrackers, Set<PeerAddress> directTrackers, Map<PeerAddress,Collection<TrackerData>> peersOnTracker)
          Set the result of the tracker process.
 

Constructors in net.tomp2p.futures with parameters of type PeerAddress
FutureAsyncTask(PeerAddress remotePeer)
          Constructor
 

Uses of PeerAddress in net.tomp2p.message
 

Methods in net.tomp2p.message that return PeerAddress
 PeerAddress MessageID.getNodeAddress()
          The node address of sender or recipient
 PeerAddress Message.getRecipient()
          The ID of the recipient.
 PeerAddress Message.getSender()
          The ID of the sender.
 

Methods in net.tomp2p.message that return types with arguments of type PeerAddress
 Collection<PeerAddress> Message.getNeighbors()
          Returns the stored neighbors
 

Methods in net.tomp2p.message with parameters of type PeerAddress
static Data DataCodec.createData(ByteBuffer[] byteBuffers, int length, int ttl, boolean protectedEntry, boolean fileReference, PeerAddress originator)
           
static Data DataCodec.decodeData(org.jboss.netty.buffer.ChannelBuffer buffer, PeerAddress originator)
           
 Message Message.setRecipient(PeerAddress recipient)
          Set the ID of the recipient.
 Message Message.setSender(PeerAddress sender)
          The ID of the sender.
 

Method parameters in net.tomp2p.message with type arguments of type PeerAddress
 Message Message.setNeighbors(Collection<PeerAddress> neighbors)
           
 Message Message.setNeighbors(Collection<PeerAddress> neighbors, int useAtMostNeighbors)
           
 

Uses of PeerAddress in net.tomp2p.p2p
 

Methods in net.tomp2p.p2p that return PeerAddress
 PeerAddress Peer.getPeerAddress()
           
 PeerAddress IdentityManagement.getPeerAddress()
           
 

Methods in net.tomp2p.p2p with parameters of type PeerAddress
 void Maintenance.addTrackerMaintenance(PeerAddress peerAddress, PeerAddress referrer, Number160 locationKey, Number160 domainKey, TrackerStorage trackerStorage)
           
 FutureResponse DistributedHashTable.Operation.create(ChannelCreator channelCreator, PeerAddress remotePeerAddress)
           
 FutureResponse DistributedTracker.Operation.create(PeerAddress address, boolean primary)
          Creates an RPC.
 PeerConnection Peer.createPeerConnection(PeerAddress destination, int idleTCPMillis)
          Opens a TCP connection and keeps it open.
 void IdentityManagement.peerFail(PeerAddress peerAddress, boolean force)
           
 void IdentityManagement.peerOffline(PeerAddress peerAddress, PeerStatusListener.Reason reason)
           
 void IdentityManagement.peerOnline(PeerAddress peerAddress)
           
 SendDirectBuilder Peer.sendDirect(PeerAddress recipientAddress)
           
 void PeerListener.serverAddressChanged(PeerAddress peerAddress, PeerAddress reporter, boolean tcp)
           
 

Method parameters in net.tomp2p.p2p with type arguments of type PeerAddress
static RequestP2PConfiguration DistributedHashTable.adjustConfiguration(RequestP2PConfiguration p2pConfiguration, SortedMap<PeerAddress,DigestInfo> directHitsDigest)
          Adjusts the number of minimum requests in the P2P configuration.
 FutureWrapper<FutureRouting> DistributedRouting.bootstrap(Collection<PeerAddress> peerAddresses, int maxNoNewInfo, int maxFailures, int maxSuccess, int parallel, boolean forceTCP, boolean isForceRoutingOnlyToSelf, ChannelCreator cc)
          Bootstraps to the given peerAddresses, i.e.
 Collection<Number480> CumulativeScheme.evaluate1(Number160 locationKey, Number160 domainKey, Map<PeerAddress,Collection<Number160>> rawKeys, Map<PeerAddress,Collection<Number480>> rawKeys480)
           
 Collection<Number480> CumulativeScheme.evaluate1(Number160 locationKey, Number160 domainKey, Map<PeerAddress,Collection<Number160>> rawKeys, Map<PeerAddress,Collection<Number480>> rawKeys480)
           
 Collection<Number480> EvaluatingSchemeDHT.evaluate1(Number160 locationKey, Number160 domainKey, Map<PeerAddress,Collection<Number160>> rawKeys, Map<PeerAddress,Collection<Number480>> rawKeys480)
           
 Collection<Number480> EvaluatingSchemeDHT.evaluate1(Number160 locationKey, Number160 domainKey, Map<PeerAddress,Collection<Number160>> rawKeys, Map<PeerAddress,Collection<Number480>> rawKeys480)
           
 Collection<Number480> VotingSchemeDHT.evaluate1(Number160 locationKey, Number160 domainKey, Map<PeerAddress,Collection<Number160>> rawKeys, Map<PeerAddress,Collection<Number480>> rawKeys480)
           
 Collection<Number480> VotingSchemeDHT.evaluate1(Number160 locationKey, Number160 domainKey, Map<PeerAddress,Collection<Number160>> rawKeys, Map<PeerAddress,Collection<Number480>> rawKeys480)
           
 Map<Number160,Data> CumulativeScheme.evaluate2(Map<PeerAddress,Map<Number160,Data>> rawKeys)
           
 Map<Number160,Data> EvaluatingSchemeDHT.evaluate2(Map<PeerAddress,Map<Number160,Data>> rawData)
           
 Map<Number160,Data> VotingSchemeDHT.evaluate2(Map<PeerAddress,Map<Number160,Data>> rawData)
           
 Object CumulativeScheme.evaluate3(Map<PeerAddress,Object> rawKeys)
           
 Object EvaluatingSchemeDHT.evaluate3(Map<PeerAddress,Object> rawObjects)
           
 Object VotingSchemeDHT.evaluate3(Map<PeerAddress,Object> rawKeys)
           
 org.jboss.netty.buffer.ChannelBuffer CumulativeScheme.evaluate4(Map<PeerAddress,org.jboss.netty.buffer.ChannelBuffer> rawKeys)
           
 org.jboss.netty.buffer.ChannelBuffer EvaluatingSchemeDHT.evaluate4(Map<PeerAddress,org.jboss.netty.buffer.ChannelBuffer> rawChannels)
           
 org.jboss.netty.buffer.ChannelBuffer VotingSchemeDHT.evaluate4(Map<PeerAddress,org.jboss.netty.buffer.ChannelBuffer> rawKeys)
           
 DigestResult CumulativeScheme.evaluate5(Map<PeerAddress,DigestResult> rawDigest)
           
 DigestResult EvaluatingSchemeDHT.evaluate5(Map<PeerAddress,DigestResult> rawDigest)
           
 DigestResult VotingSchemeDHT.evaluate5(Map<PeerAddress,DigestResult> rawDigest)
           
 Collection<TrackerData> EvaluatingSchemeTracker.evaluateSingle(Map<PeerAddress,Collection<TrackerData>> rawData)
           
 Collection<TrackerData> VotingSchemeTracker.evaluateSingle(Map<PeerAddress,Collection<TrackerData>> rawData)
           
 FutureDHT DistributedHashTable.parallelRequests(RequestP2PConfiguration p2pConfiguration, NavigableSet<PeerAddress> queue, boolean cancleOnFinish, FutureChannelCreator futureChannelCreator, ConnectionReservation connectionReservation, boolean manualCleanup, DistributedHashTable.Operation operation)
          Creates RPCs and executes them parallel.
static void Statistics.tooClose(Collection<PeerAddress> collection)
           
 

Constructors in net.tomp2p.p2p with parameters of type PeerAddress
IdentityManagement(PeerAddress self)
           
 

Constructor parameters in net.tomp2p.p2p with type arguments of type PeerAddress
Statistics(List<Map<Number160,PeerAddress>> peerMap, Number160 remotePeer, int maxSize, int bagSize)
           
 

Uses of PeerAddress in net.tomp2p.p2p.builder
 

Methods in net.tomp2p.p2p.builder that return PeerAddress
 PeerAddress DiscoverBuilder.getPeerAddress()
           
 PeerAddress SendDirectBuilder.getPeerAddress()
          Deprecated. 
 PeerAddress PingBuilder.getPeerAddress()
           
 PeerAddress BootstrapBuilder.getPeerAddress()
           
 PeerAddress SendDirectBuilder.getRecipient()
           
 

Methods in net.tomp2p.p2p.builder that return types with arguments of type PeerAddress
 Collection<PeerAddress> BootstrapBuilder.getBootstrapTo()
           
 NavigableSet<PeerAddress> ParallelRequestBuilder.getQueue()
           
 

Methods in net.tomp2p.p2p.builder with parameters of type PeerAddress
 ParallelRequestBuilder ParallelRequestBuilder.add(PeerAddress peerAddress)
           
 DiscoverBuilder DiscoverBuilder.setPeerAddress(PeerAddress peerAddress)
           
 SendDirectBuilder SendDirectBuilder.setPeerAddress(PeerAddress peerAddress)
          Deprecated. 
 PingBuilder PingBuilder.setPeerAddress(PeerAddress peerAddress)
           
 BootstrapBuilder BootstrapBuilder.setPeerAddress(PeerAddress peerAddress)
           
 SendDirectBuilder SendDirectBuilder.setRecipient(PeerAddress recipient)
           
 

Method parameters in net.tomp2p.p2p.builder with type arguments of type PeerAddress
 BootstrapBuilder BootstrapBuilder.setBootstrapTo(Collection<PeerAddress> bootstrapTo)
           
 ParallelRequestBuilder ParallelRequestBuilder.setQueue(NavigableSet<PeerAddress> queue)
           
 

Constructors in net.tomp2p.p2p.builder with parameters of type PeerAddress
SendDirectBuilder(Peer peer, PeerAddress recipientAddress)
           
 

Uses of PeerAddress in net.tomp2p.peers
 

Fields in net.tomp2p.peers declared as PeerAddress
static PeerAddress PeerAddress.EMPTY_IPv4
           
 

Methods in net.tomp2p.peers that return PeerAddress
 PeerAddress PeerAddress.changeAddress(InetAddress address)
           
 PeerAddress PeerAddress.changeFirewalledTCP(boolean status)
           
 PeerAddress PeerAddress.changeFirewalledUDP(boolean status)
           
 PeerAddress PeerAddress.changePeerId(Number160 id2)
           
 PeerAddress PeerAddress.changePorts(int portUDP, int portTCP)
           
 

Methods in net.tomp2p.peers that return types with arguments of type PeerAddress
 SortedSet<PeerAddress> PeerMap.closePeers(Number160 id, int atLeast)
          Returns close peer from the set to a given key.
static Comparator<PeerAddress> PeerMap.createComparator(Number160 id)
           
 Comparator<PeerAddress> PeerMap.createPeerComparator()
           
 Comparator<PeerAddress> PeerMap.createPeerComparator(Number160 id)
          Creates a comparator that orders to peers according to their distance to the specified id.
 List<PeerAddress> PeerMap.getAll()
          Return all addresses from the neighbor list.
 Collection<PeerAddress> PeerMap.peersForMaintenance()
           
 

Methods in net.tomp2p.peers with parameters of type PeerAddress
 boolean MapAcceptHandler.acceptPeer(boolean firstHand, PeerAddress remotePeer)
           
 boolean DefaultMapAcceptHandler.acceptPeer(boolean firstHand, PeerAddress remotePeer)
           
 int PeerAddress.compareTo(PeerAddress nodeAddress)
           
 boolean PeerMap.contains(PeerAddress peerAddress)
           
 int PeerMapStat.getChecked(PeerAddress peerAddress)
           
 long PeerMapStat.getLastSeenOnlineTime(PeerAddress peerAddress)
           
 void PeerMapStat.incChecked(PeerAddress peerAddress)
           
 int PeerMap.isCloser(Number160 id, PeerAddress rn, PeerAddress rn2)
          Returns -1 if the first remote node is closer to the key, if the second is closer, then 1 is returned.
static int PeerMap.isKadCloser(Number160 id, PeerAddress rn, PeerAddress rn2)
          Returns -1 if the first remote node is closer to the key, if the secondBITS is closer, then 1 is returned.
 boolean PeerMap.isPeerRemovedTemporarly(PeerAddress remotePeer)
          Checks if this peer has been removed.
 long PeerMapStat.online(PeerAddress peerAddress)
           
 void PeerStatusListener.peerFail(PeerAddress peerAddress, boolean force)
          Called if the peer does not send answer in time.
 boolean PeerMap.peerFound(PeerAddress remotePeer, PeerAddress referrer)
          Adds a neighbor to the neighbor list.
 void PeerMapChangeListener.peerInserted(PeerAddress peerAddress)
          This method is called if a peer is added to the map
 boolean PeerMap.peerOffline(PeerAddress remotePeer, boolean force)
          Remove a peer from the list.
 void PeerStatusListener.peerOffline(PeerAddress peerAddress, PeerStatusListener.Reason reason)
          Called if the peer does not send multiple answer in time.
 void PeerStatusListener.peerOnline(PeerAddress peerAddress)
          Called if the peer is online and we verified it.
 void PeerMapChangeListener.peerRemoved(PeerAddress peerAddress)
          This method is called if a peer is removed from the map
 void PeerMapChangeListener.peerUpdated(PeerAddress peerAddress)
          This method is called if a peer is updated.
 void PeerMapStat.removeStat(PeerAddress peerAddress)
           
 void PeerMapStat.setSeenOnlineTime(PeerAddress peerAddress)
           
 boolean PeerMap.updateExistingPeerAddress(PeerAddress peerAddress)
          Checks if a peer already existis in this map and if it does, it will update the entry becaues the peer address (e.g.
 

Constructors in net.tomp2p.peers with parameters of type PeerAddress
PeerAddress(Number160 id, PeerAddress parent)
           
 

Uses of PeerAddress in net.tomp2p.replication
 

Methods in net.tomp2p.replication with parameters of type PeerAddress
 void DefaultStorageReplication.otherResponsible(Number160 locationKey, PeerAddress other)
           
 void ResponsibilityListener.otherResponsible(Number160 locationKey, PeerAddress other)
           
 void TrackerStorageReplication.otherResponsible(Number160 locationKey, PeerAddress other)
           
 void Replication.peerInserted(PeerAddress peerAddress)
           
 void Replication.peerRemoved(PeerAddress peerAddress)
           
 void Replication.peerUpdated(PeerAddress peerAddress)
           
 

Constructors in net.tomp2p.replication with parameters of type PeerAddress
Replication(ReplicationStorage replicationStorage, PeerAddress selfAddress, PeerMap peerMap)
           
 

Uses of PeerAddress in net.tomp2p.rpc
 

Methods in net.tomp2p.rpc that return PeerAddress
 PeerAddress StorageRPC.getPeerAddress()
           
 PeerAddress TrackerRPC.getPeerAddress()
           
 PeerAddress CacheKey.getRemotePeer()
           
 

Methods in net.tomp2p.rpc with parameters of type PeerAddress
 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.
 Message ReplyHandler.createMessage(PeerAddress recipient, Message.Command name, Message.Type type)
           
 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)
           
 RequestHandlerTCP<FutureResponse> HandshakeRPC.pingTCP(PeerAddress remotePeer)
           
 FutureResponse HandshakeRPC.pingTCP(PeerAddress remotePeer, ChannelCreator channelCreator)
           
 FutureResponse HandshakeRPC.pingTCPDiscover(PeerAddress remotePeer, ChannelCreator channelCreator)
           
 FutureResponse HandshakeRPC.pingTCPProbe(PeerAddress remotePeer, ChannelCreator channelCreator)
           
 RequestHandlerUDP<FutureResponse> HandshakeRPC.pingUDP(PeerAddress remotePeer)
           
 FutureResponse HandshakeRPC.pingUDP(PeerAddress remotePeer, ChannelCreator channelCreator)
           
 FutureResponse HandshakeRPC.pingUDPDiscover(PeerAddress remotePeer, ChannelCreator channelCreator)
           
 FutureResponse HandshakeRPC.pingUDPProbe(PeerAddress remotePeer, ChannelCreator channelCreator)
           
 RequestHandlerTCP<FutureResponse> DirectDataRPC.prepareSend(PeerAddress remotePeer, org.jboss.netty.buffer.ChannelBuffer buffer, boolean raw)
          Prepares for sending to a remote peer.
 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 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.
 org.jboss.netty.buffer.ChannelBuffer RawDataReply.reply(PeerAddress sender, org.jboss.netty.buffer.ChannelBuffer requestBuffer)
          Replies to a direct message from a peer.
 Object ObjectDataReply.reply(PeerAddress sender, Object request)
           
 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)
           
 

Constructors in net.tomp2p.rpc with parameters of type PeerAddress
CacheKey(PeerAddress remotePeer, Message.Type type, boolean signMessage)
           
 

Uses of PeerAddress in net.tomp2p.storage
 

Methods in net.tomp2p.storage that return PeerAddress
 PeerAddress TrackerData.getPeerAddress()
           
 PeerAddress TrackerData.getReferrer()
           
 

Methods in net.tomp2p.storage with parameters of type PeerAddress
 void TrackerStorage.addActive(Number160 locationKey, Number160 domainKey, PeerAddress remotePeer, byte[] attachement, int offset, int length)
           
 boolean TrackerStorage.moveFromSecondaryToMesh(PeerAddress peerAddress, PeerAddress referrer, Number160 locationKey, Number160 domainKey, PublicKey publicKey)
           
 void TrackerStorage.peerFail(PeerAddress peerAddress, boolean force)
           
 void TrackerStorage.peerOffline(PeerAddress peerAddress, PeerStatusListener.Reason reason)
           
 void TrackerStorage.peerOnline(PeerAddress peerAddress)
           
 boolean TrackerStorage.put(Number160 locationKey, Number160 domainKey, PeerAddress peerAddress, PublicKey publicKey, byte[] attachement)
           
 boolean TrackerStorage.put(Number160 locationKey, Number160 domainKey, PeerAddress peerAddress, PublicKey publicKey, byte[] attachement, int offset, int length)
           
 boolean TrackerStorage.putReferred(Number160 locationKey, Number160 domainKey, PeerAddress peerAddress, PeerAddress referrer, byte[] attachement, int offset, int length, TrackerStorage.ReferrerType type)
           
 void TrackerStorage.removeReferred(Number160 locationKey, Number160 domainKey, Number160 key, PeerAddress referrer)
           
 

Constructors in net.tomp2p.storage with parameters of type PeerAddress
TrackerData(PeerAddress peerAddress, PeerAddress referrer, byte[] attachement, int offset, int length)
           
TrackerData(PeerAddress peerAddress, PeerAddress referrer, byte[] attachement, int offset, int length, boolean couldProvideMoreData)
           
 

Uses of PeerAddress in net.tomp2p.task
 

Methods in net.tomp2p.task with parameters of type PeerAddress
 FutureAsyncTask AsyncTask.submit(PeerAddress remotePeer, ChannelCreator channelCreator, Number160 taskId, Map<Number160,Data> dataMap, Worker mapper, boolean forceUDP, boolean sign)
           
 int TaskManager.submitTask(Peer peer, Number160 taskId, Worker mapper, Map<Number160,Data> data, PeerAddress senderAddress, boolean sign)
           
 



Copyright © 2013. All Rights Reserved.