Package org.apache.cassandra.service.paxos

Class AbstractPaxosRepair

java.lang.Object

org.apache.cassandra.service.paxos.AbstractPaxosRepair

Direct Known Subclasses:

PaxosRepair

public abstract class AbstractPaxosRepair
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	AbstractPaxosRepair.Failure
static interface	AbstractPaxosRepair.Listener
static class	AbstractPaxosRepair.Result
static class	AbstractPaxosRepair.State
static interface	AbstractPaxosRepair.StateUpdater<S,I,T extends Throwable>

Field Summary

Fields

Modifier and Type	Field	Description
static final AbstractPaxosRepair.Result	CANCELLED
static final AbstractPaxosRepair.Result	DONE

Constructor Summary

Constructors

Constructor	Description
AbstractPaxosRepair(DecoratedKey partitionKey, Ballot incompleteBallot)

Method Summary

Modifier and Type	Method	Description
AbstractPaxosRepair	addListener(Consumer<AbstractPaxosRepair.Result> listener)
AbstractPaxosRepair	addListener(AbstractPaxosRepair.Listener listener)	add a listener to this repair, or if the repair has already completed, call the listener with the result
final AbstractPaxosRepair.Result	await()
final void	cancel()
final void	cancelUnexceptionally()
Ballot	incompleteBallot()
boolean	isComplete()
boolean	isStarted()
final DecoratedKey	partitionKey()
AbstractPaxosRepair.State	restart(AbstractPaxosRepair.State state)
abstract AbstractPaxosRepair.State	restart(AbstractPaxosRepair.State state, long waitUntil)
protected void	set(AbstractPaxosRepair.Result result)
final AbstractPaxosRepair	start()
long	startedNanos()
AbstractPaxosRepair.State	state()
protected <S extends AbstractPaxosRepair.State, I, T extends Throwable> void	updateState(S expect, I param, AbstractPaxosRepair.StateUpdater<S,I,T> transform)

Methods inherited from class java.lang.Object

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

Field Details

DONE

public static final AbstractPaxosRepair.Result DONE

CANCELLED

public static final AbstractPaxosRepair.Result CANCELLED

Constructor Details

AbstractPaxosRepair

public AbstractPaxosRepair(DecoratedKey partitionKey,
 Ballot incompleteBallot)

Method Details

state

public AbstractPaxosRepair.State state()

startedNanos

public long startedNanos()

isStarted

public boolean isStarted()

isComplete

public boolean isComplete()

incompleteBallot

public Ballot incompleteBallot()

addListener

public AbstractPaxosRepair addListener(AbstractPaxosRepair.Listener listener)

add a listener to this repair, or if the repair has already completed, call the listener with the result

addListener

public AbstractPaxosRepair addListener(Consumer<AbstractPaxosRepair.Result> listener)

partitionKey

public final DecoratedKey partitionKey()

restart

public AbstractPaxosRepair.State restart(AbstractPaxosRepair.State state)

restart

public abstract AbstractPaxosRepair.State restart(AbstractPaxosRepair.State state,
 long waitUntil)

start

public final AbstractPaxosRepair start()

cancel

public final void cancel()

cancelUnexceptionally

public final void cancelUnexceptionally()

await

public final AbstractPaxosRepair.Result await()
                                       throws InterruptedException

Throws:

InterruptedException

set

protected void set(AbstractPaxosRepair.Result result)

updateState

protected <S extends AbstractPaxosRepair.State,
I,
T extends Throwable>
void updateState(S expect,
 I param,
 AbstractPaxosRepair.StateUpdater<S,I,T> transform)