infoservice.agreement.paxos.integration
Class PaxosAdapter.AgreementStarterThread

java.lang.Object
  java.lang.Thread
      infoservice.agreement.paxos.integration.PaxosAdapter.AgreementStarterThread

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

PaxosAdapter

 class PaxosAdapter.AgreementStarterThread
extends java.lang.Thread

The AgreementStarterThread looks from time to time if the next agreement has to be startet. If so, it starts the passive phase of the protocol

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

private boolean

m_canceled

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

PaxosAdapter.AgreementStarterThread()

Method Summary

void	cancel() Used to cancel this thread.
void	run()
private boolean	timeForAgreement() Checks if the current time is acceptable to start a the passive phase for the new agreement

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Detail

m_canceled

private boolean m_canceled

Constructor Detail

PaxosAdapter.AgreementStarterThread

PaxosAdapter.AgreementStarterThread()

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

cancel

public void cancel()

Used to cancel this thread. This is only needed for the manual start by an operator which has to be disabled when in production

timeForAgreement

private boolean timeForAgreement()

Checks if the current time is acceptable to start a the passive phase for the new agreement

Returns:

true if a new agreement can be startet, falso otherwise