net.tomp2p.p2p
Class DistributedTask

java.lang.Object
  net.tomp2p.p2p.DistributedTask

public class DistributedTask
extends Object

Constructor Summary

DistributedTask(DistributedRouting routing, AsyncTask asyncTask)

Method Summary

FutureTask

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DistributedTask

public DistributedTask(DistributedRouting routing,
                       AsyncTask asyncTask)

Method Detail

submit

public FutureTask 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. The node that is close to the locationKey will get the task. The routing process returns a list of close peers with the current load. The peer with the lowest load will get the task.

Parameters:

locationKey -

dataMap -

routingConfiguration -

taskConfiguration -

futureChannelCreator -

signMessage -

isAutomaticCleanup -

connectionReservation -

Returns: