Package | Description |
---|---|
net.tomp2p.futures | |
net.tomp2p.message | |
net.tomp2p.p2p | |
net.tomp2p.p2p.builder | |
net.tomp2p.replication | |
net.tomp2p.rpc | |
net.tomp2p.storage | |
net.tomp2p.task | |
net.tomp2p.utils |
Modifier and Type | Method and Description |
---|---|
Data |
FutureDHT.getData() |
Modifier and Type | Method and Description |
---|---|
Map<Number160,Data> |
FutureAsyncTask.getDataMap() |
Map<Number160,Data> |
FutureDHT.getDataMap()
Return the data from get() after evaluation.
|
Map<PeerAddress,Map<Number160,Data>> |
FutureDHT.getRawData()
Returns the raw data from the get operation.
|
Map<PeerAddress,Map<Number160,Data>> |
FutureTask.getRawDataMap() |
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.
|
Modifier and Type | Method and Description |
---|---|
static Data |
DataCodec.createData(ByteBuffer[] byteBuffers,
int length,
int ttl,
boolean protectedEntry,
boolean fileReference,
PeerAddress originator) |
static Data |
DataCodec.decodeData(org.jboss.netty.buffer.ChannelBuffer buffer,
PeerAddress originator) |
Modifier and Type | Method and Description |
---|---|
Map<Number160,Data> |
Message.getDataMap() |
Map<Number480,Data> |
Message.getDataMap480() |
Modifier and Type | Method and Description |
---|---|
static int |
DataCodec.encodeData(ProtocolChunked input,
Data data) |
Modifier and Type | Method and Description |
---|---|
Message |
Message.replaceDataMap(Map<Number480,Data> dataMap480) |
Message |
Message.setDataMap(Map<Number160,Data> dataMap) |
Message |
Message.setDataMap480(Map<Number480,Data> dataMap480) |
Message |
Message.setDataMapConvert(Map<Number480,Data> dataMap480) |
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 |
---|---|
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) |
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.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 |
DefaultBroadcastHandler.receive(Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
boolean isUDP) |
void |
BroadcastHandler.receive(Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
boolean isUDP) |
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.
|
Modifier and Type | Method and Description |
---|---|
Data |
AddBuilder.getData() |
Modifier and Type | Method and Description |
---|---|
Map.Entry<Number160,Data> |
PutBuilder.getData() |
Map<Number160,Data> |
SubmitBuilder.getDataMap() |
Map<Number160,Data> |
BroadcastBuilder.getDataMap() |
Map<Number160,Data> |
PutBuilder.getDataMap() |
Collection<Data> |
AddBuilder.getDataSet() |
Modifier and Type | Method and Description |
---|---|
AddBuilder |
AddBuilder.setData(Data data) |
PutBuilder |
PutBuilder.setData(Data data) |
PutBuilder |
PutBuilder.setData(Number160 key,
Data data) |
Modifier and Type | Method and Description |
---|---|
SubmitBuilder |
SubmitBuilder.setDataMap(Map<Number160,Data> dataMap) |
BroadcastBuilder |
BroadcastBuilder.setDataMap(Map<Number160,Data> dataMap) |
PutBuilder |
PutBuilder.setDataMap(Map<Number160,Data> dataMap) |
AddBuilder |
AddBuilder.setDataSet(Collection<Data> dataSet) |
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 |
---|---|
Data |
HashData.getData() |
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 |
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 |
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.
|
Constructor and Description |
---|
HashData(Number160 hash,
Data data) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
Data |
StorageGeneric.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
PublicKey publicKey) |
Data |
Data.setDirectReplication() |
Data |
Data.setDirectReplication(boolean directReplication) |
Data |
Data.setFileReference() |
Data |
Data.setFileReference(boolean fileReference) |
Data |
Data.setProtectedEntry() |
Data |
Data.setProtectedEntry(boolean protectedEntry) |
Data |
Data.setPublicKey(PublicKey publicKey) |
Data |
Data.setTTLSeconds(int ttlSeconds) |
Modifier and Type | Method and Description |
---|---|
SortedMap<Number480,Data> |
StorageGeneric.get(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey) |
NavigableMap<Number480,Data> |
StorageMemory.map() |
NavigableMap<Number480,Data> |
Storage.map()
The storage is typically backed by multiple Java collections (HashMap,
TreeMap, etc.).
|
NavigableMap<Number480,Data> |
StorageDisk.map() |
SortedMap<Number480,Data> |
StorageGeneric.remove(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey,
PublicKey publicKey) |
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) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
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 boolean |
Utils.checkEntryProtection(Map<Number160,Data> dataMap) |
Copyright © 2013. All Rights Reserved.