public final class DeliveryThread
extends java.lang.Thread
Constructor and Description |
---|
DeliveryThread(TOMLayer tomLayer,
ServiceReplica receiver,
Recoverable recoverer,
ServerViewController controller)
Creates a new instance of DeliveryThread
|
Modifier and Type | Method and Description |
---|---|
void |
canDeliver() |
void |
deliverLock() |
void |
deliverUnlock() |
protected void |
deliverUnordered(TOMMessage request,
int regency) |
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, clone, 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, ServerViewController controller)
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
protected void deliverUnordered(TOMMessage request, int regency)