Modifier and Type | Method and Description |
---|---|
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.
|
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
Number160 |
FutureDHT.getDomainKey() |
Number160 |
FutureDHT.getLocationKey() |
Modifier and Type | Method and Description |
---|---|
Map<Number160,Data> |
FutureAsyncTask.getDataMap() |
Map<Number160,Data> |
FutureDHT.getDataMap()
Return the data from get() after evaluation.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
FutureDHT.setReceivedData(Number160 locationKey,
Number160 domainKey,
Map<PeerAddress,Map<Number160,Data>> rawData)
Finish the future and set the keys and data that have been received.
|
void |
FutureDHT.setReceivedDigest(Number160 locationKey,
Number160 domainKey,
Map<PeerAddress,DigestResult> rawDigest)
Finishes the future and set the digest information that have been received.
|
void |
FutureDHT.setRemovedKeys(Number160 locationKey,
Number160 domainKey,
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.
|
Modifier and Type | Method and Description |
---|---|
void |
FutureAsyncTask.setDataMap(Map<Number160,Data> dataMap)
Finishes the future and notifies listeners.
|
void |
FutureDHT.setReceivedData(Number160 locationKey,
Number160 domainKey,
Map<PeerAddress,Map<Number160,Data>> rawData)
Finish the future and set the keys and data that have been received.
|
void |
FutureDHT.setRemovedKeys(Number160 locationKey,
Number160 domainKey,
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 and Description |
---|
FutureTracker(EvaluatingSchemeTracker evaluatingSchemeTracker,
Set<Number160> knownPeers)
Create a future object for retrieving.
|
Modifier and Type | Method and Description |
---|---|
Number160 |
Message.getKey() |
Number160 |
Message.getKeyKey1() |
Number160 |
Message.getKeyKey2() |
Number160 |
SHA1Signature.getNumber1() |
Number160 |
SHA1Signature.getNumber2() |
Modifier and Type | Method and Description |
---|---|
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() |
Modifier and Type | Method and Description |
---|---|
Message |
Message.setKey(Number160 key3) |
Message |
Message.setKeyKey(Number160 key1,
Number160 key2) |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
SHA1Signature(Number160 number1,
Number160 number2) |
Modifier and Type | Method and Description |
---|---|
Number160 |
Peer.getPeerID() |
Number160 |
IdentityManagement.getSelf() |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
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) |
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.
|
Constructor and Description |
---|
PeerMaker(Number160 peerId) |
Statistics(List<Map<Number160,PeerAddress>> peerMap,
Number160 remotePeer,
int maxSize,
int bagSize) |
Constructor and Description |
---|
Statistics(List<Map<Number160,PeerAddress>> peerMap,
Number160 remotePeer,
int maxSize,
int bagSize) |
Modifier and Type | Field and Description |
---|---|
static Number160 |
DHTBuilder.DEFAULT_DOMAIN |
static Number160 |
TrackerBuilder.DEFAULT_DOMAIN |
protected Number160 |
DHTBuilder.domainKey |
protected Number160 |
TrackerBuilder.domainKey |
protected Number160 |
DHTBuilder.locationKey |
protected Number160 |
TrackerBuilder.locationKey |
Modifier and Type | Method and Description |
---|---|
Number160 |
GetBuilder.getContentKey() |
Number160 |
RemoveBuilder.getContentKey() |
Number160 |
DHTBuilder.getDomainKey() |
Number160 |
TrackerBuilder.getDomainKey() |
Modifier and Type | Method and Description |
---|---|
SimpleBloomFilter<Number160> |
AddTrackerBuilder.getBloomFilter() |
Collection<Number160> |
GetBuilder.getContentKeys() |
Collection<Number160> |
RemoveBuilder.getContentKeys() |
Map.Entry<Number160,Data> |
PutBuilder.getData() |
Map<Number160,Data> |
SubmitBuilder.getDataMap() |
Map<Number160,Data> |
BroadcastBuilder.getDataMap() |
Map<Number160,Data> |
PutBuilder.getDataMap() |
SimpleBloomFilter<Number160> |
GetBuilder.getKeyBloomFilter() |
Set<Number160> |
GetTrackerBuilder.getKnownPeers() |
SimpleBloomFilter<Number160> |
GetBuilder.getValueBloomFilter() |
Modifier and Type | Method and Description |
---|---|
GetBuilder |
GetBuilder.setContentKey(Number160 contentKey) |
RemoveBuilder |
RemoveBuilder.setContentKey(Number160 contentKey) |
PutBuilder |
PutBuilder.setData(Number160 key,
Data data) |
K |
DHTBuilder.setDomainKey(Number160 domainKey) |
K |
TrackerBuilder.setDomainKey(Number160 domainKey) |
PutBuilder |
PutBuilder.setKeyObject(Number160 contentKey,
Object object) |
Modifier and Type | Method and Description |
---|---|
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) |
SubmitBuilder |
SubmitBuilder.setDataMap(Map<Number160,Data> dataMap) |
BroadcastBuilder |
BroadcastBuilder.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) |
Constructor and Description |
---|
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) |
Modifier and Type | Field and Description |
---|---|
static Number160 |
Number160.MAX_VALUE |
static Number160 |
Number160.ONE |
static Number160 |
Number160.ZERO |
Modifier and Type | Method and Description |
---|---|
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 |
Number320.getDomainKey() |
Number160 |
Number480.getDomainKey() |
Number160 |
PeerAddress.getID()
The id of the peer.
|
Number160 |
Number320.getLocationKey() |
Number160 |
Number480.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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Constructor and Description |
---|
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
|
Modifier and Type | Method and Description |
---|---|
void |
ResponsibilityListener.meResponsible(Number160 locationKey)
The responsibilty changed to our peer.
|
void |
ReplicationExecutor.meResponsible(Number160 locationKey) |
void |
TrackerStorageReplication.meResponsible(Number160 locationKey) |
void |
ResponsibilityListener.otherResponsible(Number160 locationKey,
PeerAddress other)
Here an other peer is responsible and we need to transfer data.
|
void |
ReplicationExecutor.otherResponsible(Number160 locationKey,
PeerAddress other) |
void |
TrackerStorageReplication.otherResponsible(Number160 locationKey,
PeerAddress other) |
protected FutureDHT |
ReplicationExecutor.send(Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMapConverted)
If my peer is responsible, I'll issue a put if absent to make sure all replicas are stored.
|
protected void |
ReplicationExecutor.sendDirect(PeerAddress other,
Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMapConverted)
If an other peer is responsible, we send this peer our data, so that the other peer can take care of this.
|
void |
Replication.updateAndNotifyResponsibilities(Number160 locationKey)
Update responsibilities.
|
Modifier and Type | Method and Description |
---|---|
protected FutureDHT |
ReplicationExecutor.send(Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMapConverted)
If my peer is responsible, I'll issue a put if absent to make sure all replicas are stored.
|
protected void |
ReplicationExecutor.sendDirect(PeerAddress other,
Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMapConverted)
If an other peer is responsible, we send this peer our data, so that the other peer can take care of this.
|
Modifier and Type | Method and Description |
---|---|
Number160 |
DigestInfo.getContentDigest() |
Number160 |
HashData.getHash() |
Number160 |
DigestInfo.getKeyDigest() |
Modifier and Type | Method and Description |
---|---|
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() |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
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 and Description |
---|
DigestResult(Map<Number160,Number160> keyDigest) |
DigestResult(Map<Number160,Number160> keyDigest) |
DigestResult(SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter) |
DigestResult(SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter) |
Modifier and Type | Method and Description |
---|---|
Number160 |
TrackerStorage.findPeerIDForResponsibleContent(Number160 locationKey) |
Number160 |
StorageMemory.findPeerIDForResponsibleContent(Number160 locationKey) |
Number160 |
StorageMemoryReplication.findPeerIDForResponsibleContent(Number160 locationKey) |
Number160 |
ReplicationStorage.findPeerIDForResponsibleContent(Number160 locationKey) |
Number160 |
StorageDisk.findPeerIDForResponsibleContent(Number160 locationKey) |
Number160 |
Data.getHash() |
Number160 |
Data.getPeerId() |
Modifier and Type | Method and Description |
---|---|
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 |
TrackerStorage.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 |
StorageGeneric.digest(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys) |
DigestInfo |
TrackerStorage.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> bloomFilter1,
SimpleBloomFilter<Number160> bloomFilter2) |
DigestInfo |
Digest.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter)
Calculates a digest over a specific location and domain.
|
DigestInfo |
StorageGeneric.digest(Number160 locationKey,
Number160 domainKey,
SimpleBloomFilter<Number160> keyBloomFilter,
SimpleBloomFilter<Number160> contentBloomFilter) |
Collection<Number160> |
TrackerStorage.findContentForResponsiblePeerID(Number160 peerID) |
Collection<Number160> |
StorageMemory.findContentForResponsiblePeerID(Number160 peerID) |
Collection<Number160> |
StorageMemoryReplication.findContentForResponsiblePeerID(Number160 peerID) |
Collection<Number160> |
ReplicationStorage.findContentForResponsiblePeerID(Number160 peerID) |
Collection<Number160> |
StorageDisk.findContentForResponsiblePeerID(Number160 peerID) |
Number160 |
TrackerStorage.findPeerIDForResponsibleContent(Number160 locationKey) |
Number160 |
StorageMemory.findPeerIDForResponsibleContent(Number160 locationKey) |
Number160 |
StorageMemoryReplication.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 |
TrackerStorage.removeResponsibility(Number160 locationKey) |
void |
StorageMemory.removeResponsibility(Number160 locationKey) |
void |
StorageMemoryReplication.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 |
TrackerStorage.updateResponsibilities(Number160 locationKey,
Number160 peerId) |
boolean |
StorageMemory.updateResponsibilities(Number160 locationKey,
Number160 peerId) |
boolean |
StorageMemoryReplication.updateResponsibilities(Number160 locationKey,
Number160 peerId) |
boolean |
ReplicationStorage.updateResponsibilities(Number160 locationKey,
Number160 peerId) |
boolean |
StorageDisk.updateResponsibilities(Number160 locationKey,
Number160 peerId) |
Modifier and Type | Method and Description |
---|---|
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 |
TrackerStorage.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 |
StorageGeneric.digest(Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys) |
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) |
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 |
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) |
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
Map<Number160,Data> |
Worker.execute(Peer peer,
Number160 taskId,
Map<Number160,Data> inputData) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
static boolean |
Utils.checkEntryProtection(Map<Number160,Data> dataMap) |
static Map<Number160,TrackerData> |
Utils.limitRandom(Map<Number160,TrackerData> activePeers,
int trackerSize) |
Copyright © 2013. All Rights Reserved.