|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Data | |
---|---|
net.tomp2p.futures | |
net.tomp2p.message | |
net.tomp2p.p2p | |
net.tomp2p.p2p.builder | |
net.tomp2p.rpc | |
net.tomp2p.storage | |
net.tomp2p.task | |
net.tomp2p.utils |
Uses of Data in net.tomp2p.futures |
---|
Methods in net.tomp2p.futures that return Data | |
---|---|
Data |
FutureDHT.getData()
|
Methods in net.tomp2p.futures that return types with arguments of type Data | |
---|---|
Map<Number160,Data> |
FutureDHT.getDataMap()
Return the data from get() after evaluation. |
Map<Number160,Data> |
FutureAsyncTask.getDataMap()
|
Map<PeerAddress,Map<Number160,Data>> |
FutureDHT.getRawData()
Returns the raw data from the get operation |
Map<PeerAddress,Map<Number160,Data>> |
FutureTask.getRawDataMap()
|
Method parameters in net.tomp2p.futures with type arguments of type Data | |
---|---|
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. |
Uses of Data in net.tomp2p.message |
---|
Methods in net.tomp2p.message that return Data | |
---|---|
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)
|
Methods in net.tomp2p.message that return types with arguments of type Data | |
---|---|
Map<Number160,Data> |
Message.getDataMap()
|
Map<Number480,Data> |
Message.getDataMap480()
|
Methods in net.tomp2p.message with parameters of type Data | |
---|---|
static int |
DataCodec.encodeData(ProtocolChunked input,
Data data)
|
Method parameters in net.tomp2p.message with type arguments of type Data | |
---|---|
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)
|
Uses of Data in net.tomp2p.p2p |
---|
Methods in net.tomp2p.p2p that return types with arguments of type Data | |
---|---|
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)
|
Method parameters in net.tomp2p.p2p with type arguments of type Data | |
---|---|
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 |
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)
|
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. |
Uses of Data in net.tomp2p.p2p.builder |
---|
Methods in net.tomp2p.p2p.builder that return Data | |
---|---|
Data |
AddBuilder.getData()
|
Methods in net.tomp2p.p2p.builder that return types with arguments of type Data | |
---|---|
Map.Entry<Number160,Data> |
PutBuilder.getData()
|
Map<Number160,Data> |
BroadcastBuilder.getDataMap()
|
Map<Number160,Data> |
SubmitBuilder.getDataMap()
|
Map<Number160,Data> |
PutBuilder.getDataMap()
|
Collection<Data> |
AddBuilder.getDataSet()
|
Methods in net.tomp2p.p2p.builder with parameters of type Data | |
---|---|
AddBuilder |
AddBuilder.setData(Data data)
|
PutBuilder |
PutBuilder.setData(Data data)
|
PutBuilder |
PutBuilder.setData(Number160 key,
Data data)
|
Method parameters in net.tomp2p.p2p.builder with type arguments of type Data | |
---|---|
BroadcastBuilder |
BroadcastBuilder.setDataMap(Map<Number160,Data> dataMap)
|
SubmitBuilder |
SubmitBuilder.setDataMap(Map<Number160,Data> dataMap)
|
PutBuilder |
PutBuilder.setDataMap(Map<Number160,Data> dataMap)
|
AddBuilder |
AddBuilder.setDataSet(Collection<Data> dataSet)
|
Uses of Data in net.tomp2p.rpc |
---|
Methods in net.tomp2p.rpc that return Data | |
---|---|
Data |
HashData.getData()
|
Method parameters in net.tomp2p.rpc with type arguments of type Data | |
---|---|
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. |
Constructors in net.tomp2p.rpc with parameters of type Data | |
---|---|
HashData(Number160 hash,
Data data)
|
Uses of Data in net.tomp2p.storage |
---|
Methods in net.tomp2p.storage that return Data | |
---|---|
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)
|
Methods in net.tomp2p.storage that return types with arguments of type Data | |
---|---|
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)
|
Methods in net.tomp2p.storage with parameters of type Data | |
---|---|
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)
|
Uses of Data in net.tomp2p.task |
---|
Methods in net.tomp2p.task that return types with arguments of type Data | |
---|---|
Map<Number160,Data> |
Worker.execute(Peer peer,
Number160 taskId,
Map<Number160,Data> inputData)
|
Method parameters in net.tomp2p.task with type arguments of type Data | |
---|---|
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 Data in net.tomp2p.utils |
---|
Method parameters in net.tomp2p.utils with type arguments of type Data | |
---|---|
static boolean |
Utils.checkEntryProtection(Map<Number160,Data> dataMap)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |