server.callbacks
Class AsyncCallback

java.lang.Object
  extended by server.callbacks.AsyncCallback

public class AsyncCallback
extends java.lang.Object


Field Summary
static long SIXTY_SECONDS
           
static int SWEEP_RATE
           
static long TEN_SECONDS
           
static long THIRTY_SECONDS
           
 
Constructor Summary
AsyncCallback(int priority, int num)
          Constructor
 
Method Summary
 void checkForTimeout(long curr, long max)
           
 void doCallback(Callback c)
           
 void doCallback(Callback c, java.lang.Object arg)
           
 void doCallback(CallbackRequest c)
           
 long getMaxCalltime()
           
 int getNumThreads()
           
 void setMaxCalltime(long t)
           
 void start()
           
 void stop()
           
 void waitForCallback(Notifier n)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

TEN_SECONDS

public static final long TEN_SECONDS
See Also:
Constant Field Values

THIRTY_SECONDS

public static final long THIRTY_SECONDS
See Also:
Constant Field Values

SIXTY_SECONDS

public static final long SIXTY_SECONDS
See Also:
Constant Field Values

SWEEP_RATE

public static int SWEEP_RATE
Constructor Detail

AsyncCallback

public AsyncCallback(int priority,
                     int num)
Constructor

Parameters:
priority - - int - Priority of the Callback threads.
num - - int - Number of Callback threads
Method Detail

start

public void start()

stop

public void stop()

doCallback

public void doCallback(Callback c)

doCallback

public void doCallback(Callback c,
                       java.lang.Object arg)

doCallback

public void doCallback(CallbackRequest c)

getNumThreads

public int getNumThreads()

setMaxCalltime

public void setMaxCalltime(long t)

getMaxCalltime

public long getMaxCalltime()

checkForTimeout

public void checkForTimeout(long curr,
                            long max)

waitForCallback

public void waitForCallback(Notifier n)
                     throws java.lang.InterruptedException
Throws:
java.lang.InterruptedException