edu.dmi
Class GenericMessageBroadcaster

java.lang.Object
  |
  +--edu.dmi.GenericMessageBroadcaster
Direct Known Subclasses:
UpdateBroadcaster

public class GenericMessageBroadcaster
extends java.lang.Object


Inner Class Summary
(package private)  class GenericMessageBroadcaster.ControlThread
           
 
Field Summary
private  java.lang.Thread fControl
           
private  long fMaxProcesstime
           
private  int fNumInvokers
           
private  int fPriority
           
private  java.util.Vector invokerPool
           
private  java.util.Vector invokerPoolB
           
private  java.lang.Object invokerPoolBLock
           
private  java.lang.Object invokerPoolLock
           
(package private)  java.util.Vector listeners
           
(package private)  java.lang.Object listenersLock
           
static long SIXTY_SECONDS
           
static int SWEEP_RATE
           
static long TEN_SECONDS
           
static long THIRTY_SECONDS
           
(package private)  java.lang.Object vGenericMessageLock
           
private  java.util.Vector vGenericMessages
           
 
Constructor Summary
GenericMessageBroadcaster(int priority, int num)
           
 
Method Summary
 void addListener(java.lang.Object l)
           
 void broadcastGenericMessage(GenericMessage gm)
           
(package private)  void checkForTimeout(long curr, long max)
           
 java.lang.Object getFirstListener()
           
 java.util.Enumeration getListeners()
           
 long getMaxProcesstime()
           
 int getNumberOfListeners()
           
 int getNumThreads()
           
 void removeListener(java.lang.Object l)
           
 void setMaxProcesstime(long t)
           
 void start()
           
 void stop()
           
 void waitForBroadcast(Invoker n)
           
 
Methods inherited from class java.lang.Object
, clone, equals, finalize, getClass, hashCode, notify, notifyAll, registerNatives, toString, wait, wait, wait
 

Field Detail

fNumInvokers

private int fNumInvokers

fPriority

private int fPriority

invokerPool

private java.util.Vector invokerPool

invokerPoolB

private java.util.Vector invokerPoolB

invokerPoolLock

private java.lang.Object invokerPoolLock

invokerPoolBLock

private java.lang.Object invokerPoolBLock

fMaxProcesstime

private long fMaxProcesstime

fControl

private java.lang.Thread fControl

vGenericMessages

private java.util.Vector vGenericMessages

TEN_SECONDS

public static final long TEN_SECONDS

THIRTY_SECONDS

public static final long THIRTY_SECONDS

SIXTY_SECONDS

public static final long SIXTY_SECONDS

SWEEP_RATE

public static int SWEEP_RATE

vGenericMessageLock

java.lang.Object vGenericMessageLock

listeners

java.util.Vector listeners

listenersLock

java.lang.Object listenersLock
Constructor Detail

GenericMessageBroadcaster

public GenericMessageBroadcaster(int priority,
                                 int num)
Method Detail

start

public void start()

stop

public void stop()

broadcastGenericMessage

public void broadcastGenericMessage(GenericMessage gm)
Parameters:
GenericMessage -  

waitForBroadcast

public void waitForBroadcast(Invoker n)
                      throws java.lang.InterruptedException

addListener

public void addListener(java.lang.Object l)

removeListener

public void removeListener(java.lang.Object l)

getListeners

public java.util.Enumeration getListeners()

getNumberOfListeners

public int getNumberOfListeners()

getFirstListener

public java.lang.Object getFirstListener()

getNumThreads

public int getNumThreads()

setMaxProcesstime

public void setMaxProcesstime(long t)

getMaxProcesstime

public long getMaxProcesstime()

checkForTimeout

void checkForTimeout(long curr,
                     long max)