| 
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| 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)
 | 
  | 
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||