Package | Description |
---|---|
net.tomp2p.p2p | |
net.tomp2p.p2p.builder | |
net.tomp2p.rpc | |
net.tomp2p.task |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
SubmitBuilder(Peer peer,
Number160 locationKey,
Worker worker) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
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) |
Copyright © 2013. All Rights Reserved.