|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of Number160 in net.tomp2p.connection |
|---|
| Methods in net.tomp2p.connection with parameters of type Number160 | |
|---|---|
void |
Scheduler.keepTrack(PeerAddress remotePeer,
Number160 taskId,
TaskResultListener taskResultListener)
|
void |
DispatcherReply.registerIoHandler(Number160 localPeerId,
ReplyHandler ioHandler,
Message.Command... names)
Registers a handler with this dispatcher. |
void |
DispatcherReply.removeIoHandler(Number160 localPeerId)
If we shutdown, we remove the handlers. |
| Constructors in net.tomp2p.connection with parameters of type Number160 | |
|---|---|
ConnectionHandler(ConnectionHandler parent,
Number160 id,
KeyPair keyPair,
PeerMap peerMap)
Attaches a peer to an existing connection and use existing information. |
|
ConnectionHandler(int udpPort,
int tcpPort,
Number160 id,
Bindings bindings,
int p2pID,
ConnectionConfiguration configuration,
File messageLogger,
KeyPair keyPair,
PeerMap peerMap,
org.jboss.netty.util.Timer timer,
int maxMessageSize,
int maintenanceThreads,
int replicationThreads,
int workerThreads)
|
|
| Uses of Number160 in net.tomp2p.examples |
|---|
| Methods in net.tomp2p.examples with parameters of type Number160 | |
|---|---|
static void |
ExamplePutGet.exampleGetBlocking(Peer[] peers,
Number160 nr)
|
static void |
ExamplePutGet.exampleGetNonBlocking(Peer[] peers,
Number160 nr)
|
static void |
ExamplePutGet.examplePutGet(Peer[] peers,
Number160 nr)
|
static void |
ExamplePutGet.examplePutGetConfig(Peer[] peers,
Number160 nr2)
|
| Uses of Number160 in net.tomp2p.futures |
|---|
| Methods in net.tomp2p.futures that return Number160 | |
|---|---|
Number160 |
FutureDHT.getDomainKey()
|
Number160 |
FutureDHT.getLocationKey()
|
| Methods in net.tomp2p.futures that return types with arguments of type Number160 | |
|---|---|
Map<Number160,Data> |
FutureDHT.getDataMap()
Return the data from get() after evaluation. |
Map<Number160,Data> |
FutureAsyncTask.getDataMap()
|
Collection<Number160> |
FutureDHT.getKeys()
Deprecated. |
Set<Number160> |
FutureTracker.getKnownPeers()
|
Map<PeerAddress,Map<Number160,Data>> |
FutureDHT.getRawData()
Returns the raw data from the get operation |
Map<PeerAddress,Map<Number160,Data>> |
FutureTask.getRawDataMap()
|
Map<PeerAddress,Collection<Number160>> |
FutureDHT.getRawKeys()
Returns the raw keys from the storage or removal operation |
| Methods in net.tomp2p.futures with parameters of type Number160 | |
|---|---|
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. |
| Method parameters in net.tomp2p.futures with type arguments of type Number160 | |
|---|---|
void |
FutureAsyncTask.setDataMap(Map<Number160,Data> dataMap)
Finishes the future and notifies listeners. |
void |
FutureDHT.setReceivedData(Map<PeerAddress,Map<Number160,Data>> rawData)
Finish the future and set the keys and data 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. |
| Constructor parameters in net.tomp2p.futures with type arguments of type Number160 | |
|---|---|
FutureTracker(EvaluatingSchemeTracker evaluatingSchemeTracker,
Set<Number160> knownPeers)
Create a future object for retrieving. |
|
| Uses of Number160 in net.tomp2p.message |
|---|
| Methods in net.tomp2p.message that return Number160 | |
|---|---|
Number160 |
Message.getKey()
|
Number160 |
Message.getKeyKey1()
|
Number160 |
Message.getKeyKey2()
|
Number160 |
SHA1Signature.getNumber1()
|
Number160 |
SHA1Signature.getNumber2()
|
| Methods in net.tomp2p.message that return types with arguments of type Number160 | |
|---|---|
SimpleBloomFilter<Number160> |
Message.getBloomFilter1()
|
SimpleBloomFilter<Number160> |
Message.getBloomFilter2()
|
Map<Number160,Data> |
Message.getDataMap()
|
Map<Number160,HashData> |
Message.getHashDataMap()
|
Map<Number160,Number160> |
Message.getKeyMap()
|
Map<Number160,Number160> |
Message.getKeyMap()
|
Collection<Number160> |
Message.getKeys()
|
| Methods in net.tomp2p.message with parameters of type Number160 | |
|---|---|
Message |
Message.setKey(Number160 key3)
|
Message |
Message.setKeyKey(Number160 key1,
Number160 key2)
|
| Method parameters in net.tomp2p.message with type arguments of type Number160 | |
|---|---|
Message |
Message.setDataMap(Map<Number160,Data> dataMap)
|
Message |
Message.setHashDataMap(Map<Number160,HashData> hashDataMap)
|
Message |
Message.setKeyMap(Map<Number160,Number160> keyMap)
|
Message |
Message.setKeyMap(Map<Number160,Number160> keyMap)
|
Message |
Message.setKeys(Collection<Number160> keys)
|
Message |
Message.setTwoBloomFilter(SimpleBloomFilter<Number160> bloomFilter1,
SimpleBloomFilter<Number160> bloomFilter2)
|
Message |
Message.setTwoBloomFilter(SimpleBloomFilter<Number160> bloomFilter1,
SimpleBloomFilter<Number160> bloomFilter2)
|
| Constructors in net.tomp2p.message with parameters of type Number160 | |
|---|---|
SHA1Signature(Number160 number1,
Number160 number2)
|
|
| Uses of Number160 in net.tomp2p.p2p |
|---|
| Methods in net.tomp2p.p2p that return Number160 | |
|---|---|
Number160 |
Peer.getPeerID()
|
Number160 |
IdentityManagement.getSelf()
|
| Methods in net.tomp2p.p2p that return types with arguments of type Number160 | |
|---|---|
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)
|
| Methods in net.tomp2p.p2p with parameters of type Number160 | |
|---|---|
AddBuilder |
Peer.add(Number160 locationKey)
|
FutureDHT |
DistributedHashTable.add(Number160 locationKey,
Number160 domainKey,
Collection<Data> dataSet,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean protectDomain,
boolean signMessage,
boolean isManualCleanup,
boolean list,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
FutureTracker |
DistributedTracker.addToTracker(Number160 locationKey,
Number160 domainKey,
byte[] attachment,
RoutingConfiguration routingConfiguration,
TrackerConfiguration trackerConfiguration,
boolean signMessage,
FutureCreate<BaseFuture> futureCreate,
Set<Number160> knownPeers,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
AddTrackerBuilder |
Peer.addTracker(Number160 locationKey)
|
void |
Maintenance.addTrackerMaintenance(PeerAddress peerAddress,
PeerAddress referrer,
Number160 locationKey,
Number160 domainKey,
TrackerStorage trackerStorage)
|
BroadcastBuilder |
Peer.broadcast(Number160 messageKey)
|
boolean |
IdentityManagement.checkIdentity(Number160 peerId,
PublicKey publicKey)
|
FutureDHT |
DistributedHashTable.direct(Number160 locationKey,
org.jboss.netty.buffer.ChannelBuffer buffer,
boolean raw,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
FutureCreate<FutureDHT> futureCreate,
boolean cancelOnFinish,
boolean manualCleanup,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
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> |
VotingSchemeDHT.evaluate1(Number160 locationKey,
Number160 domainKey,
Map<PeerAddress,Collection<Number160>> rawKeys,
Map<PeerAddress,Collection<Number480>> rawKeys480)
|
GetBuilder |
Peer.get(Number160 locationKey)
|
FutureDHT |
DistributedHashTable.get(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
EvaluatingSchemeDHT evaluationScheme,
boolean signMessage,
boolean digest,
boolean returnBloomFilter,
boolean range,
boolean isManualCleanup,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
FutureTracker |
DistributedTracker.getFromTracker(Number160 locationKey,
Number160 domainKey,
RoutingConfiguration routingConfiguration,
TrackerConfiguration trackerConfiguration,
boolean expectAttachement,
EvaluatingSchemeTracker evaluatingScheme,
boolean signMessage,
boolean useSecondaryTrackers,
Set<Number160> knownPeers,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
GetTrackerBuilder |
Peer.getTracker(Number160 locationKey)
|
ParallelRequestBuilder |
Peer.parallelRequest(Number160 locationKey)
|
PutBuilder |
Peer.put(Number160 locationKey)
|
FutureDHT |
DistributedHashTable.put(Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMap,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean putIfAbsent,
boolean protectDomain,
boolean signMessage,
boolean isManualCleanup,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
void |
BroadcastHandler.receive(Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
boolean isUDP)
|
void |
DefaultBroadcastHandler.receive(Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
boolean isUDP)
|
RemoveBuilder |
Peer.remove(Number160 locationKey)
|
FutureDHT |
DistributedHashTable.remove(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean returnResults,
boolean signMessage,
boolean isManualCleanup,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
FutureRouting |
DistributedRouting.route(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
Message.Type type,
int maxDirectHits,
int maxNoNewInfo,
int maxFailures,
int maxSuccess,
int parallel,
boolean forceTCP,
ChannelCreator cc)
Looks for a route to the given locationKey |
SendBuilder |
Peer.send(Number160 locationKey)
The send method works as follows: |
FutureLateJoin<FutureResponse> |
DistributedTracker.startPeerExchange(Number160 locationKey,
Number160 domainKey,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation,
boolean forceTCP)
|
FutureTask |
DistributedTask.submit(Number160 locationKey,
Map<Number160,Data> dataMap,
Worker worker,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration requestP2PConfiguration,
FutureChannelCreator futureChannelCreator,
boolean signMessage,
boolean isManualCleanup,
ConnectionReservation connectionReservation)
Submit a task to the DHT. |
SubmitBuilder |
Peer.submit(Number160 locationKey,
Worker worker)
|
| Method parameters in net.tomp2p.p2p with type arguments of type Number160 | |
|---|---|
FutureTracker |
DistributedTracker.addToTracker(Number160 locationKey,
Number160 domainKey,
byte[] attachment,
RoutingConfiguration routingConfiguration,
TrackerConfiguration trackerConfiguration,
boolean signMessage,
FutureCreate<BaseFuture> futureCreate,
Set<Number160> knownPeers,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
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> |
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)
|
FutureDHT |
DistributedHashTable.get(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
EvaluatingSchemeDHT evaluationScheme,
boolean signMessage,
boolean digest,
boolean returnBloomFilter,
boolean range,
boolean isManualCleanup,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
FutureDHT |
DistributedHashTable.get(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
EvaluatingSchemeDHT evaluationScheme,
boolean signMessage,
boolean digest,
boolean returnBloomFilter,
boolean range,
boolean isManualCleanup,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
FutureDHT |
DistributedHashTable.get(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
EvaluatingSchemeDHT evaluationScheme,
boolean signMessage,
boolean digest,
boolean returnBloomFilter,
boolean range,
boolean isManualCleanup,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
FutureTracker |
DistributedTracker.getFromTracker(Number160 locationKey,
Number160 domainKey,
RoutingConfiguration routingConfiguration,
TrackerConfiguration trackerConfiguration,
boolean expectAttachement,
EvaluatingSchemeTracker evaluatingScheme,
boolean signMessage,
boolean useSecondaryTrackers,
Set<Number160> knownPeers,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
FutureDHT |
DistributedHashTable.put(Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMap,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean putIfAbsent,
boolean protectDomain,
boolean signMessage,
boolean isManualCleanup,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
void |
BroadcastHandler.receive(Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
boolean isUDP)
|
void |
DefaultBroadcastHandler.receive(Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
boolean isUDP)
|
FutureDHT |
DistributedHashTable.remove(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean returnResults,
boolean signMessage,
boolean isManualCleanup,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
FutureRouting |
DistributedRouting.route(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
Message.Type type,
int maxDirectHits,
int maxNoNewInfo,
int maxFailures,
int maxSuccess,
int parallel,
boolean forceTCP,
ChannelCreator cc)
Looks for a route to the given locationKey |
FutureTask |
DistributedTask.submit(Number160 locationKey,
Map<Number160,Data> dataMap,
Worker worker,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration requestP2PConfiguration,
FutureChannelCreator futureChannelCreator,
boolean signMessage,
boolean isManualCleanup,
ConnectionReservation connectionReservation)
Submit a task to the DHT. |
| Constructors in net.tomp2p.p2p with parameters of type Number160 | |
|---|---|
PeerMaker(Number160 peerId)
|
|
Statistics(List<Map<Number160,PeerAddress>> peerMap,
Number160 remotePeer,
int maxSize,
int bagSize)
|
|
| Constructor parameters in net.tomp2p.p2p with type arguments of type Number160 | |
|---|---|
Statistics(List<Map<Number160,PeerAddress>> peerMap,
Number160 remotePeer,
int maxSize,
int bagSize)
|
|
| Uses of Number160 in net.tomp2p.p2p.builder |
|---|
| Fields in net.tomp2p.p2p.builder declared as Number160 | |
|---|---|
static Number160 |
TrackerBuilder.DEFAULT_DOMAIN
|
static Number160 |
DHTBuilder.DEFAULT_DOMAIN
|
protected Number160 |
TrackerBuilder.domainKey
|
protected Number160 |
DHTBuilder.domainKey
|
protected Number160 |
TrackerBuilder.locationKey
|
protected Number160 |
DHTBuilder.locationKey
|
| Methods in net.tomp2p.p2p.builder that return Number160 | |
|---|---|
Number160 |
GetBuilder.getContentKey()
|
Number160 |
RemoveBuilder.getContentKey()
|
Number160 |
TrackerBuilder.getDomainKey()
|
Number160 |
DHTBuilder.getDomainKey()
|
| Methods in net.tomp2p.p2p.builder that return types with arguments of type Number160 | |
|---|---|
SimpleBloomFilter<Number160> |
AddTrackerBuilder.getBloomFilter()
|
Collection<Number160> |
GetBuilder.getContentKeys()
|
Collection<Number160> |
RemoveBuilder.getContentKeys()
|
Map.Entry<Number160,Data> |
PutBuilder.getData()
|
Map<Number160,Data> |
BroadcastBuilder.getDataMap()
|
Map<Number160,Data> |
SubmitBuilder.getDataMap()
|
Map<Number160,Data> |
PutBuilder.getDataMap()
|
SimpleBloomFilter<Number160> |
GetBuilder.getKeyBloomFilter()
|
Set<Number160> |
GetTrackerBuilder.getKnownPeers()
|
SimpleBloomFilter<Number160> |
GetBuilder.getValueBloomFilter()
|
| Methods in net.tomp2p.p2p.builder with parameters of type Number160 | |
|---|---|
GetBuilder |
GetBuilder.setContentKey(Number160 contentKey)
|
RemoveBuilder |
RemoveBuilder.setContentKey(Number160 contentKey)
|
PutBuilder |
PutBuilder.setData(Number160 key,
Data data)
|
K |
TrackerBuilder.setDomainKey(Number160 domainKey)
|
K |
DHTBuilder.setDomainKey(Number160 domainKey)
|
PutBuilder |
PutBuilder.setKeyObject(Number160 contentKey,
Object object)
|
| Method parameters in net.tomp2p.p2p.builder with type arguments of type Number160 | |
|---|---|
AddTrackerBuilder |
AddTrackerBuilder.setBloomFilter(SimpleBloomFilter<Number160> bloomFilter)
|
GetBuilder |
GetBuilder.setContentKeys(Collection<Number160> contentKeys)
Set the content keys that should be found. |
RemoveBuilder |
RemoveBuilder.setContentKeys(Collection<Number160> contentKeys)
|
BroadcastBuilder |
BroadcastBuilder.setDataMap(Map<Number160,Data> dataMap)
|
SubmitBuilder |
SubmitBuilder.setDataMap(Map<Number160,Data> dataMap)
|
PutBuilder |
PutBuilder.setDataMap(Map<Number160,Data> dataMap)
|
GetBuilder |
GetBuilder.setKeyBloomFilter(SimpleBloomFilter<Number160> keyBloomFilter)
|
GetTrackerBuilder |
GetTrackerBuilder.setKnownPeers(Set<Number160> knownPeers)
|
GetBuilder |
GetBuilder.setValueBloomFilter(SimpleBloomFilter<Number160> valueBloomFilter)
|
| Constructors in net.tomp2p.p2p.builder with parameters of type Number160 | |
|---|---|
AddBuilder(Peer peer,
Number160 locationKey)
|
|
AddTrackerBuilder(Peer peer,
Number160 locationKey)
|
|
BroadcastBuilder(Peer peer,
Number160 messageKey)
|
|
DHTBuilder(Peer peer,
Number160 locationKey)
|
|
GetBuilder(Peer peer,
Number160 locationKey)
|
|
GetTrackerBuilder(Peer peer,
Number160 locationKey)
|
|
ParallelRequestBuilder(Peer peer,
Number160 locationKey)
|
|
PutBuilder(Peer peer,
Number160 locationKey)
|
|
RemoveBuilder(Peer peer,
Number160 locationKey)
|
|
SendBuilder(Peer peer,
Number160 locationKey)
|
|
SubmitBuilder(Peer peer,
Number160 locationKey,
Worker worker)
|
|
TrackerBuilder(Peer peer,
Number160 locationKey)
|
|
| Uses of Number160 in net.tomp2p.peers |
|---|
| Fields in net.tomp2p.peers declared as Number160 | |
|---|---|
static Number160 |
Number160.MAX_VALUE
|
static Number160 |
Number160.ONE
|
static Number160 |
Number160.ZERO
|
| Methods in net.tomp2p.peers that return Number160 | |
|---|---|
static Number160 |
Number160.createHash(int integerValue)
Create a new Number160 from the integer, which fills all the 160bits. |
static Number160 |
Number160.createHash(long longValue)
Create a new Number160 from the long, which fills all the 160bit. |
static Number160 |
Number160.createHash(String string)
Create a new Number160 using SHA1 on the string. |
Number160 |
Number480.getContentKey()
|
Number160 |
Number480.getDomainKey()
|
Number160 |
Number320.getDomainKey()
|
Number160 |
PeerAddress.getID()
The id of the peer. |
Number160 |
Number480.getLocationKey()
|
Number160 |
Number320.getLocationKey()
|
Number160 |
PeerMap.self()
Each node that has a bag has an ID itself to define what is close. |
Number160 |
Number160.shiftLeft(int nr)
Shift left the 160bit number. |
Number160 |
Number160.shiftRight(int nr)
Shift right the 160bit number. |
Number160 |
ShortString.toNumber160()
|
Number160 |
Number160.xor(Number160 key)
Xor operation. |
| Methods in net.tomp2p.peers with parameters of type Number160 | |
|---|---|
Number480 |
Number480.changeDomain(Number160 newDomain)
|
PeerAddress |
PeerAddress.changePeerId(Number160 id2)
|
SortedSet<PeerAddress> |
PeerMap.closePeers(Number160 id,
int atLeast)
Returns close peer from the set to a given key. |
int |
Number160.compareTo(Number160 o)
|
static Comparator<PeerAddress> |
PeerMap.createComparator(Number160 id)
|
Comparator<PeerAddress> |
PeerMap.createPeerComparator(Number160 id)
Creates a comparator that orders to peers according to their distance to the specified id. |
int |
PeerMap.isCloser(Number160 id,
Number160 rn,
Number160 rn2)
Returns -1 if the first key is closer to the key, if the second is closer, then 1 is returned. |
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. |
Number160 |
Number160.xor(Number160 key)
Xor operation. |
| Constructors in net.tomp2p.peers with parameters of type Number160 | |
|---|---|
Number320(Number160 locationKey,
Number160 domainKey)
|
|
Number480(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
|
Number480(Number320 key,
Number160 contentKey)
|
|
PeerAddress(Number160 id)
If you only need to know the id |
|
PeerAddress(Number160 id,
byte[] me,
int offset)
|
|
PeerAddress(Number160 id,
org.jboss.netty.buffer.ChannelBuffer channelBuffer)
|
|
PeerAddress(Number160 id,
InetAddress address)
If you only need to know the id and InetAddress |
|
PeerAddress(Number160 id,
InetAddress address,
int portTCP,
int portUDP)
|
|
PeerAddress(Number160 id,
InetAddress address,
int portTCP,
int portUDP,
boolean firewalledUDP,
boolean firewalledTCP)
Creates a PeerAddress |
|
PeerAddress(Number160 id,
InetAddress address,
int portTCP,
int portUDP,
int options)
|
|
PeerAddress(Number160 id,
InetSocketAddress inetSocketAddress)
|
|
PeerAddress(Number160 id,
PeerAddress parent)
|
|
PeerAddress(Number160 id,
String address,
int portTCP,
int portUDP)
|
|
PeerMap(Number160 self,
int bagSize,
int cacheTimeoutMillis,
int maxNrBeforeExclude,
int[] waitingTimeBetweenNodeMaintenenceSeconds,
int cachSize,
boolean acceptFirstClassOnly)
Deprecated. |
|
PeerMap(Number160 self,
int bagSize,
int cacheTimeoutMillis,
int maxNrBeforeExclude,
int[] waitingTimeBetweenNodeMaintenenceSeconds,
int cachSize,
MapAcceptHandler mapHandler)
Creates the bag for the peers. |
|
ShortString(Number160 number160)
Creates a short string, decodes the byte array from UTF-8 and checks for its length |
|
| Uses of Number160 in net.tomp2p.replication |
|---|
| Methods in net.tomp2p.replication with parameters of type Number160 | |
|---|---|
void |
Replication.checkResponsibility(Number160 locationKey)
|
void |
DefaultStorageReplication.meResponsible(Number160 locationKey)
|
void |
ResponsibilityListener.meResponsible(Number160 locationKey)
|
void |
TrackerStorageReplication.meResponsible(Number160 locationKey)
|
void |
DefaultStorageReplication.otherResponsible(Number160 locationKey,
PeerAddress other)
|
void |
ResponsibilityListener.otherResponsible(Number160 locationKey,
PeerAddress other)
|
void |
TrackerStorageReplication.otherResponsible(Number160 locationKey,
PeerAddress other)
|
void |
Replication.updatePeerMapIfCloser(Number160 locationKey,
Number160 current)
|
| Uses of Number160 in net.tomp2p.rpc |
|---|
| Methods in net.tomp2p.rpc that return Number160 | |
|---|---|
Number160 |
DigestInfo.getContentDigest()
|
Number160 |
HashData.getHash()
|
Number160 |
DigestInfo.getKeyDigest()
|
| Methods in net.tomp2p.rpc that return types with arguments of type Number160 | |
|---|---|
SimpleBloomFilter<Number160> |
DigestResult.getContentBloomFilter()
|
SimpleBloomFilter<Number160> |
DigestInfo.getContentBloomFilter(int bitArraySize,
int expectedElements)
|
Map<Number160,Number160> |
DigestInfo.getDigests()
|
Map<Number160,Number160> |
DigestInfo.getDigests()
|
SimpleBloomFilter<Number160> |
DigestResult.getKeyBloomFilter()
|
SimpleBloomFilter<Number160> |
DigestInfo.getKeyBloomFilter(int bitArraySize,
int expectedElements)
|
Map<Number160,Number160> |
DigestResult.getKeyDigest()
|
Map<Number160,Number160> |
DigestResult.getKeyDigest()
|
| Methods in net.tomp2p.rpc with parameters of type Number160 | |
|---|---|
FutureResponse |
StorageRPC.add(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Data> dataSet,
boolean protectDomain,
boolean signMessage,
boolean list,
ChannelCreator channelCreator,
boolean forceUDP,
SenderCacheStrategy senderCacheStrategy)
Adds data on a remote peer. |
FutureResponse |
TrackerRPC.addToTracker(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
byte[] attachement,
boolean signMessage,
boolean primary,
Set<Number160> knownPeers,
ChannelCreator channelCreator,
boolean forceUDP,
boolean forceTCP)
|
FutureResponse |
TrackerRPC.addToTracker(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
byte[] attachement,
int offset,
int legth,
boolean signMessage,
boolean primary,
Set<Number160> knownPeers,
ChannelCreator channelCreator,
boolean forceUDP,
boolean forceTCP)
|
FutureResponse |
NeighborRPC.closeNeighbors(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
Message.Type type,
ChannelCreator channelCreator,
boolean forceTCP)
Requests close neighbors from the remote peer. |
FutureResponse |
StorageRPC.compareAndPut(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Map<Number160,HashData> hashDataMap,
FutureSuccessEvaluator futureSuccessEvaluator,
boolean protectDomain,
boolean protectEntry,
boolean signMessage,
boolean partialPut,
ChannelCreator channelCreator,
boolean forceUDP)
Compares and puts data on a peer. |
FutureResponse |
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. |
void |
DigestInfo.put(Number160 key,
Number160 content)
Stores a key and the hash of the content for further processing |
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 |
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 |
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. |
| Method parameters in net.tomp2p.rpc with type arguments of type Number160 | |
|---|---|
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 |
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 |
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 |
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 |
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 |
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 |
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. |
void |
DigestResult.setContentBloomFilter(SimpleBloomFilter<Number160> contentBloomFilter)
|
void |
DigestResult.setKeyBloomFilter(SimpleBloomFilter<Number160> keyBloomFilter)
|
void |
DigestResult.setKeyDigest(Map<Number160,Number160> keyDigest)
|
void |
DigestResult.setKeyDigest(Map<Number160,Number160> keyDigest)
|
FutureResponse |
TaskRPC.taskStatus(PeerAddress remotePeer,
ChannelCreator channelCreator,
Collection<Number160> taskIDs,
boolean forceTCP)
|
| Constructors in net.tomp2p.rpc with parameters of type Number160 | |
|---|---|
DigestInfo(Number160 keyDigest,
Number160 contentDigest,
int size)
If a global hash has already been calculated, then this constructor is used to store those. |
|
HashData(Number160 hash,
Data data)
|
|
| Constructor parameters in net.tomp2p.rpc with type arguments of type Number160 | |
|---|---|
DigestResult(Map<Number160,Number160> keyDigest)
|
|
DigestResult(Map<Number160,Number160> keyDigest)
|
|
DigestResult(SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter)
|
|
DigestResult(SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter)
|
|
| Uses of Number160 in net.tomp2p.storage |
|---|
| Methods in net.tomp2p.storage that return Number160 | |
|---|---|
Number160 |
StorageMemory.findPeerIDForResponsibleContent(Number160 locationKey)
|
Number160 |
StorageMemoryReplication.findPeerIDForResponsibleContent(Number160 locationKey)
|
Number160 |
TrackerStorage.findPeerIDForResponsibleContent(Number160 locationKey)
|
Number160 |
ReplicationStorage.findPeerIDForResponsibleContent(Number160 locationKey)
|
Number160 |
StorageDisk.findPeerIDForResponsibleContent(Number160 locationKey)
|
Number160 |
Data.getHash()
|
Number160 |
Data.getPeerId()
|
| Methods in net.tomp2p.storage with parameters of type Number160 | |
|---|---|
Map<Number160,TrackerData> |
TrackerStorage.activePeers(Number160 locationKey,
Number160 domainKey)
|
void |
TrackerStorage.addActive(Number160 locationKey,
Number160 domainKey,
PeerAddress remotePeer,
byte[] attachement,
int offset,
int length)
|
void |
StorageMemory.addTimeout(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
long expiration)
|
void |
Storage.addTimeout(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
long expiration)
|
void |
StorageDisk.addTimeout(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
long expiration)
|
Collection<Number160> |
StorageGeneric.compareAndPut(Number160 locationKey,
Number160 domainKey,
Map<Number160,HashData> hashDataMap,
PublicKey publicKey,
boolean partial,
boolean protectDomain)
Compares and puts the data if the compare matches |
boolean |
StorageMemory.contains(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
boolean |
Storage.contains(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
boolean |
StorageDisk.contains(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
DigestInfo |
StorageGeneric.digest(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys)
|
DigestInfo |
Digest.digest(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys)
Calculates a digest over a specific location and domain. |
DigestInfo |
TrackerStorage.digest(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys)
|
DigestInfo |
StorageGeneric.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter)
|
DigestInfo |
Digest.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter)
Calculates a digest over a specific location and domain. |
DigestInfo |
TrackerStorage.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> bloomFilter1,
SimpleBloomFilter<Number160> bloomFilter2)
|
Collection<Number160> |
StorageMemory.findContentForResponsiblePeerID(Number160 peerID)
|
Collection<Number160> |
StorageMemoryReplication.findContentForResponsiblePeerID(Number160 peerID)
|
Collection<Number160> |
TrackerStorage.findContentForResponsiblePeerID(Number160 peerID)
|
Collection<Number160> |
ReplicationStorage.findContentForResponsiblePeerID(Number160 peerID)
|
Collection<Number160> |
StorageDisk.findContentForResponsiblePeerID(Number160 peerID)
|
Number160 |
StorageMemory.findPeerIDForResponsibleContent(Number160 locationKey)
|
Number160 |
StorageMemoryReplication.findPeerIDForResponsibleContent(Number160 locationKey)
|
Number160 |
TrackerStorage.findPeerIDForResponsibleContent(Number160 locationKey)
|
Number160 |
ReplicationStorage.findPeerIDForResponsibleContent(Number160 locationKey)
|
Number160 |
StorageDisk.findPeerIDForResponsibleContent(Number160 locationKey)
|
Data |
StorageMemory.get(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
Storage.get(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
StorageDisk.get(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
SortedMap<Number480,Data> |
StorageGeneric.get(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
boolean |
StorageMemory.isDomainProtectedByOthers(Number160 locationKey,
Number160 domainKey,
PublicKey publicKey)
|
boolean |
Storage.isDomainProtectedByOthers(Number160 locationKey,
Number160 domainKey,
PublicKey publicKey)
|
boolean |
StorageDisk.isDomainProtectedByOthers(Number160 locationKey,
Number160 domainKey,
PublicKey publicKey)
|
boolean |
TrackerStorage.isSecondaryTracker(Number160 locationKey,
Number160 domainKey)
A peer is a secondary tracker if the peers stores itself on the tracker as well. |
Map<Number160,TrackerData> |
TrackerStorage.meshPeers(Number160 locationKey,
Number160 domainKey)
|
boolean |
TrackerStorage.moveFromSecondaryToMesh(PeerAddress peerAddress,
PeerAddress referrer,
Number160 locationKey,
Number160 domainKey,
PublicKey publicKey)
|
boolean |
StorageMemory.protectDomain(Number160 locationKey,
Number160 domainKey,
PublicKey publicKey)
|
boolean |
Storage.protectDomain(Number160 locationKey,
Number160 domainKey,
PublicKey publicKey)
|
boolean |
StorageDisk.protectDomain(Number160 locationKey,
Number160 domainKey,
PublicKey publicKey)
|
boolean |
StorageMemory.put(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
Data value)
|
boolean |
Storage.put(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
Data value)
|
boolean |
StorageDisk.put(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
Data value)
|
StorageGeneric.PutStatus |
StorageGeneric.put(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
Data newData,
PublicKey publicKey,
boolean putIfAbsent,
boolean domainProtection)
|
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)
|
Data |
StorageMemory.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
Storage.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
StorageDisk.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
SortedMap<Number480,Data> |
StorageGeneric.remove(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey,
PublicKey publicKey)
|
Data |
StorageGeneric.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
PublicKey publicKey)
|
boolean |
TrackerStorage.removeActive(Number160 locationKey,
Number160 domainKey,
Number160 remotePeerId)
|
void |
StorageGeneric.removeDomainProtection(Number160 removeDomain)
|
void |
TrackerStorage.removeReferred(Number160 locationKey,
Number160 domainKey,
Number160 key,
PeerAddress referrer)
|
void |
StorageMemory.removeResponsibility(Number160 locationKey)
|
void |
StorageMemoryReplication.removeResponsibility(Number160 locationKey)
|
void |
TrackerStorage.removeResponsibility(Number160 locationKey)
|
void |
ReplicationStorage.removeResponsibility(Number160 locationKey)
|
void |
StorageDisk.removeResponsibility(Number160 locationKey)
|
void |
StorageMemory.removeTimeout(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
void |
Storage.removeTimeout(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
void |
StorageDisk.removeTimeout(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Collection<Number160> |
TrackerStorage.responsibleDomains(Number160 locationKey)
|
Map<Number160,TrackerData> |
TrackerStorage.secondaryPeers(Number160 locationKey,
Number160 domainKey)
|
int |
TrackerStorage.sizePrimary(Number160 locationKey,
Number160 domainKey)
|
int |
TrackerStorage.sizeSecondary(Number160 locationKey,
Number160 domainKey)
|
Map<Number480,Data> |
StorageMemory.subMap(Number160 locationKey)
|
Map<Number480,Data> |
Storage.subMap(Number160 locationKey)
|
Map<Number480,Data> |
StorageDisk.subMap(Number160 locationKey)
|
SortedMap<Number480,Data> |
StorageMemory.subMap(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
SortedMap<Number480,Data> |
Storage.subMap(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
SortedMap<Number480,Data> |
StorageDisk.subMap(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
boolean |
StorageMemory.updateResponsibilities(Number160 locationKey,
Number160 peerId)
|
boolean |
StorageMemoryReplication.updateResponsibilities(Number160 locationKey,
Number160 peerId)
|
boolean |
TrackerStorage.updateResponsibilities(Number160 locationKey,
Number160 peerId)
|
boolean |
ReplicationStorage.updateResponsibilities(Number160 locationKey,
Number160 peerId)
|
boolean |
StorageDisk.updateResponsibilities(Number160 locationKey,
Number160 peerId)
|
| Method parameters in net.tomp2p.storage with type arguments of type Number160 | |
|---|---|
Collection<Number160> |
StorageGeneric.compareAndPut(Number160 locationKey,
Number160 domainKey,
Map<Number160,HashData> hashDataMap,
PublicKey publicKey,
boolean partial,
boolean protectDomain)
Compares and puts the data if the compare matches |
DigestInfo |
StorageGeneric.digest(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys)
|
DigestInfo |
Digest.digest(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys)
Calculates a digest over a specific location and domain. |
DigestInfo |
TrackerStorage.digest(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys)
|
DigestInfo |
StorageGeneric.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter)
|
DigestInfo |
StorageGeneric.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter)
|
DigestInfo |
Digest.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter)
Calculates a digest over a specific location and domain. |
DigestInfo |
Digest.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter)
Calculates a digest over a specific location and domain. |
DigestInfo |
TrackerStorage.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> bloomFilter1,
SimpleBloomFilter<Number160> bloomFilter2)
|
DigestInfo |
TrackerStorage.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> bloomFilter1,
SimpleBloomFilter<Number160> bloomFilter2)
|
| Constructors in net.tomp2p.storage with parameters of type Number160 | |
|---|---|
Data(byte[] data,
int offset,
int length,
Number160 peerId)
|
|
Data(byte[] data,
Number160 peerId)
|
|
Data(ByteBuffer[] buffer,
int length,
Number160 peerId)
|
|
Data(Object object,
Number160 peerId)
|
|
| Uses of Number160 in net.tomp2p.task |
|---|
| Methods in net.tomp2p.task that return types with arguments of type Number160 | |
|---|---|
Map<Number160,Data> |
Worker.execute(Peer peer,
Number160 taskId,
Map<Number160,Data> inputData)
|
| Methods in net.tomp2p.task with parameters of type Number160 | |
|---|---|
Map<Number160,Data> |
Worker.execute(Peer peer,
Number160 taskId,
Map<Number160,Data> inputData)
|
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)
|
| Method parameters in net.tomp2p.task with type arguments of type Number160 | |
|---|---|
Map<Number160,Data> |
Worker.execute(Peer peer,
Number160 taskId,
Map<Number160,Data> inputData)
|
void |
TaskManager.notifyListeners(Number320 taskKey,
Map<Number160,Data> dataMap)
|
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)
|
void |
TaskResultListener.taskReceived(Number320 taskId,
Map<Number160,Data> dataMap)
|
void |
AsyncTask.taskReceived(Number320 taskKey,
Map<Number160,Data> dataMap)
|
| Uses of Number160 in net.tomp2p.utils |
|---|
| Methods in net.tomp2p.utils that return Number160 | |
|---|---|
static Number160 |
Utils.createRandomNodeID()
|
static Number160 |
Utils.makeSHAHash(byte[] buffer)
|
static Number160 |
Utils.makeSHAHash(byte[] buffer,
int offset,
int length)
|
static Number160 |
Utils.makeSHAHash(ByteBuffer buffer)
|
static Number160 |
Utils.makeSHAHash(File file)
|
static Number160 |
Utils.makeSHAHash(String strInput)
|
| Methods in net.tomp2p.utils that return types with arguments of type Number160 | |
|---|---|
static Collection<Number160> |
Utils.convert(Collection<TrackerData> a)
|
static Collection<Number160> |
Utils.extractContentKeys(Collection<Number480> collection)
|
static Map<Number160,TrackerData> |
Utils.limitRandom(Map<Number160,TrackerData> activePeers,
int trackerSize)
|
| Method parameters in net.tomp2p.utils with type arguments of type Number160 | |
|---|---|
static boolean |
Utils.checkEntryProtection(Map<Number160,Data> dataMap)
|
static Map<Number160,TrackerData> |
Utils.limitRandom(Map<Number160,TrackerData> activePeers,
int trackerSize)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||