net.tomp2p.task
Class TaskManager

java.lang.Object
  net.tomp2p.task.TaskManager

public class TaskManager
extends Object

Constructor Summary

TaskManager(ConnectionBean connectionBean, int threads)

Method Summary

void	addListener(TaskResultListener taskResultListener)
DigestInfo	digest()
TaskRPC	getTaskRPC()
void	init(TaskRPC taskRPC)
void	notifyListeners(Number320 taskKey, Map<Number160,Data> dataMap)
void	removeListener(TaskResultListener taskResultListener)
void	shutdown()
int	submitTask(Peer peer, Number160 taskId, Worker mapper, Map<Number160,Data> data, PeerAddress senderAddress, boolean sign)
TaskStatus	taskStatus(Number320 taskKey)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskManager

public TaskManager(ConnectionBean connectionBean,
                   int threads)

Method Detail

addListener

public void addListener(TaskResultListener taskResultListener)

removeListener

public void removeListener(TaskResultListener taskResultListener)

notifyListeners

public void notifyListeners(Number320 taskKey,
                            Map<Number160,Data> dataMap)

init

public void init(TaskRPC taskRPC)

getTaskRPC

public TaskRPC getTaskRPC()

taskStatus

public TaskStatus taskStatus(Number320 taskKey)

submitTask

public int submitTask(Peer peer,
                      Number160 taskId,
                      Worker mapper,
                      Map<Number160,Data> data,
                      PeerAddress senderAddress,
                      boolean sign)

digest

public DigestInfo digest()

shutdown

public void shutdown()