|
||||||||||
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 |