net.tomp2p.task
Class TaskManager

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

public class TaskManager
extends Object


Constructor Summary
TaskManager(PeerBean peerBean, ConnectionBean connectionBean, int threads)
           
 
Method Summary
 void addListener(TaskResultListener taskResultListener)
           
 DigestInfo digest()
           
 TaskRPC getTaskRPC()
           
 void init(TaskRPC taskRPC)
           
 void notifyListeners(Number160 taskId, Map<Number160,Data> dataMap)
           
 void removeListener(TaskResultListener taskResultListener)
           
 int submitTask(Number160 taskId, Worker mapper, Map<Number160,Data> data, PeerAddress senderAddress, boolean sign)
           
 TaskStatus taskStatus(Number160 taskId)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TaskManager

public TaskManager(PeerBean peerBean,
                   ConnectionBean connectionBean,
                   int threads)
Method Detail

addListener

public void addListener(TaskResultListener taskResultListener)

removeListener

public void removeListener(TaskResultListener taskResultListener)

notifyListeners

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

init

public void init(TaskRPC taskRPC)

getTaskRPC

public TaskRPC getTaskRPC()

taskStatus

public TaskStatus taskStatus(Number160 taskId)

submitTask

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

digest

public DigestInfo digest()


Copyright © 2012. All Rights Reserved.