Package org.apache.cassandra.service.paxos

Class PaxosState

java.lang.Object

org.apache.cassandra.service.paxos.PaxosState

All Implemented Interfaces:

AutoCloseable, PaxosOperationLock

public class PaxosState
extends Object
implements PaxosOperationLock

We save to memory the result of each operation before persisting to disk, however each operation that performs the update does not return a result to the coordinator until the result is fully persisted.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PaxosState.Key
static class	PaxosState.MaybePromise
static class	PaxosState.Snapshot
static class	PaxosState.UnsafeSnapshot

Field Summary

Fields

Modifier and Type	Field	Description
static final ConcurrentHashMap<PaxosState.Key,PaxosState>	ACTIVE
static final Map<PaxosState.Key,PaxosState.Snapshot>	RECENT

Method Summary

Modifier and Type	Method	Description
Ballot	acceptIfLatest(Commit.Proposal proposal)	Record an acceptance of the proposal if there is no newer promise; otherwise inform the caller of the newer ballot
static PaxosBallotTracker	ballotTracker()
void	close()
void	commit(Commit.Agreed commit)
static void	commitDirect(Commit commit)
PaxosState.Snapshot	currentSnapshot()
static PaxosState	get(DecoratedKey partitionKey, TableMetadata table)
static PaxosState	get(Commit commit)
static boolean	getDisableCoordinatorLocking()
static void	initializeTrackers()
static PrepareResponse	legacyPrepare(Commit toPrepare)
static Boolean	legacyPropose(Commit proposal)
static PaxosOperationLock	lock(DecoratedKey partitionKey, TableMetadata metadata, long deadline, ConsistencyLevel consistencyForConsensus, boolean isWrite)
static void	maybeRebuildUncommittedState()
PaxosState.MaybePromise	promiseIfNewer(Ballot ballot, boolean isWrite)	Record the requested ballot as promised if it is newer than our current promise; otherwise do nothing.
static void	setDisableCoordinatorLocking(boolean disable)
static void	startAutoRepairs()
static PaxosUncommittedTracker	uncommittedTracker()
static PaxosState.Snapshot	unsafeGetIfPresent(DecoratedKey partitionKey, TableMetadata metadata)
static void	unsafeReset()
void	updateStateUnsafe(Function<PaxosState.Snapshot,PaxosState.Snapshot> f)

Methods inherited from class java.lang.Object

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

Field Details

ACTIVE

public static final ConcurrentHashMap<PaxosState.Key,PaxosState> ACTIVE

RECENT

public static final Map<PaxosState.Key,PaxosState.Snapshot> RECENT

Method Details

setDisableCoordinatorLocking

public static void setDisableCoordinatorLocking(boolean disable)

getDisableCoordinatorLocking

public static boolean getDisableCoordinatorLocking()

uncommittedTracker

public static PaxosUncommittedTracker uncommittedTracker()

ballotTracker

public static PaxosBallotTracker ballotTracker()

initializeTrackers

public static void initializeTrackers()

maybeRebuildUncommittedState

public static void maybeRebuildUncommittedState()
                                         throws IOException

Throws:

IOException

startAutoRepairs

public static void startAutoRepairs()

get

public static PaxosState get(Commit commit)

get

public static PaxosState get(DecoratedKey partitionKey,
 TableMetadata table)

lock

public static PaxosOperationLock lock(DecoratedKey partitionKey,
 TableMetadata metadata,
 long deadline,
 ConsistencyLevel consistencyForConsensus,
 boolean isWrite)
                               throws RequestTimeoutException

Throws:

RequestTimeoutException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface PaxosOperationLock

currentSnapshot

public PaxosState.Snapshot currentSnapshot()

updateStateUnsafe

public void updateStateUnsafe(Function<PaxosState.Snapshot,PaxosState.Snapshot> f)

promiseIfNewer

public PaxosState.MaybePromise promiseIfNewer(Ballot ballot,
 boolean isWrite)

Record the requested ballot as promised if it is newer than our current promise; otherwise do nothing.

Returns:

a PromiseResult containing the before and after state for this operation

acceptIfLatest

public Ballot acceptIfLatest(Commit.Proposal proposal)

Record an acceptance of the proposal if there is no newer promise; otherwise inform the caller of the newer ballot

commit

public void commit(Commit.Agreed commit)

commitDirect

public static void commitDirect(Commit commit)

legacyPrepare

public static PrepareResponse legacyPrepare(Commit toPrepare)

legacyPropose

public static Boolean legacyPropose(Commit proposal)

unsafeReset

public static void unsafeReset()

unsafeGetIfPresent

public static PaxosState.Snapshot unsafeGetIfPresent(DecoratedKey partitionKey,
 TableMetadata metadata)