groupmgmt.impl
Class SinglePhaseDisseminator.ConnectionChangeQueue

java.lang.Object
  java.lang.Thread
      groupmgmt.impl.SinglePhaseDisseminator.ConnectionChangeQueue

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

SinglePhaseDisseminator

private class SinglePhaseDisseminator.ConnectionChangeQueue

extends java.lang.Thread

Private inner class to maintain a queue of connection changes to be processed.

Field Summary

private java.util.Vector	arriveQueue
private java.util.Vector	departQueue
private java.lang.Object	lock
private boolean	running

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

private

SinglePhaseDisseminator.ConnectionChangeQueue()

Method Summary

void	enqueue(Member sender, Member[] arriving, Member[] departing)
void	enqueue(SPChange[] arriving, SPChange[] departing)
void	finish()
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

arriveQueue

private java.util.Vector arriveQueue

departQueue

private java.util.Vector departQueue

running

private boolean running

lock

private java.lang.Object lock

Constructor Detail

SinglePhaseDisseminator.ConnectionChangeQueue

private SinglePhaseDisseminator.ConnectionChangeQueue()

Method Detail

run

public void run()

enqueue

public void enqueue(Member sender,
                    Member[] arriving,
                    Member[] departing)

enqueue

public void enqueue(SPChange[] arriving,
                    SPChange[] departing)

finish

public void finish()