net.tomp2p.connection
Class Scheduler

java.lang.Object
  net.tomp2p.connection.Scheduler

public class Scheduler
extends Object

Constructor Summary

Scheduler(int maintenanceThreads, int replicationThreads)

Method Summary

void	addConnectionQueue(FutureChannel futureChannelCreation, Semaphore semaphore, Runnable runnable)
void	addQueue(FutureRunnable futureRunnable)
ScheduledExecutorService	getScheduledExecutorServiceMaintenance()
ScheduledExecutorService	getScheduledExecutorServiceReplication()
void	keepTrack(PeerAddress remotePeer, Number160 taskId, TaskResultListener taskResultListener)
void	scheduleTimeout(BaseFuture baseFuture, int millis, String reason)
void	shutdown()
void	startDelayedChannelCreator()
void	startMaintainance(PeerMap peerMap, HandshakeRPC handshakeRPC, ConnectionReservation connectionReservation, int max)
void	startTimeout()
void	startTracking(TaskRPC taskRPC, ConnectionReservation connectionReservation)
void	stopKeepTrack(Number320 taskId)

Methods inherited from class java.lang.Object

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

Constructor Detail

Scheduler

public Scheduler(int maintenanceThreads,
                 int replicationThreads)

Method Detail

addQueue

public void addQueue(FutureRunnable futureRunnable)

shutdown

public void shutdown()

startTracking

public void startTracking(TaskRPC taskRPC,
                          ConnectionReservation connectionReservation)

startDelayedChannelCreator

public void startDelayedChannelCreator()

startMaintainance

public void startMaintainance(PeerMap peerMap,
                              HandshakeRPC handshakeRPC,
                              ConnectionReservation connectionReservation,
                              int max)

startTimeout

public void startTimeout()

scheduleTimeout

public void scheduleTimeout(BaseFuture baseFuture,
                            int millis,
                            String reason)

keepTrack

public void keepTrack(PeerAddress remotePeer,
                      Number160 taskId,
                      TaskResultListener taskResultListener)

stopKeepTrack

public void stopKeepTrack(Number320 taskId)

addConnectionQueue

public void addConnectionQueue(FutureChannel futureChannelCreation,
                               Semaphore semaphore,
                               Runnable runnable)

getScheduledExecutorServiceMaintenance

public ScheduledExecutorService getScheduledExecutorServiceMaintenance()

getScheduledExecutorServiceReplication

public ScheduledExecutorService getScheduledExecutorServiceReplication()