public final class DeliveryThread
extends java.lang.Thread
Constructor and Description |
---|
DeliveryThread(TOMLayer tomLayer,
ServiceReplica receiver,
Recoverable recoverer,
ServerViewManager manager)
Creates a new instance of DeliveryThread
|
Modifier and Type | Method and Description |
---|---|
void |
canDeliver() |
void |
deliverLock() |
void |
deliverUnlock() |
void |
delivery(Consensus cons)
Invoked by the TOM layer, to deliver a decide consensus
|
Recoverable |
getRecoverer() |
void |
run()
This is the code for the thread.
|
void |
update(ApplicationState state) |
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public DeliveryThread(TOMLayer tomLayer, ServiceReplica receiver, Recoverable recoverer, ServerViewManager manager)
tomLayer
- TOM layerreceiver
- Object that receives requests from clientsconf
- TOM configurationpublic Recoverable getRecoverer()
public void delivery(Consensus cons)
cons
- Consensus established as being decidedpublic void deliverLock()
public void deliverUnlock()
public void canDeliver()
public void update(ApplicationState state)
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread