Package org.apache.cassandra.repair

Class SyncTask

java.lang.Object

org.apache.cassandra.utils.concurrent.AbstractFuture<V>

org.apache.cassandra.utils.concurrent.AsyncFuture<SyncStat>

org.apache.cassandra.repair.SyncTask

All Implemented Interfaces:

com.google.common.util.concurrent.ListenableFuture<SyncStat>, io.netty.util.concurrent.Future<SyncStat>, Runnable, Future<SyncStat>, Awaitable, Future<SyncStat>

Direct Known Subclasses:

AsymmetricRemoteSyncTask, LocalSyncTask, SymmetricRemoteSyncTask

public abstract class SyncTask
extends AsyncFuture<SyncStat>
implements Runnable

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.utils.concurrent.Awaitable

Awaitable.AbstractAwaitable, Awaitable.AsyncAwaitable, Awaitable.Defaults, Awaitable.SyncAwaitable

Field Summary

Fields

Modifier and Type	Field	Description
protected final SharedContext	ctx
protected final RepairJobDesc	desc
protected final SyncNodePair	nodePair
protected final PreviewKind	previewKind
final List<Range<Token>>	rangesToSync
protected long	startTime
protected final SyncStat	stat

Fields inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture

CANCELLED, UNCANCELLABLE, UNSET

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort primaryEndpoint, InetAddressAndPort peer, List<Range<Token>> rangesToSync, PreviewKind previewKind)

Method Summary

Modifier and Type	Method	Description
void	abort(Throwable reason)
protected void	finished()
boolean	isLocal()
SyncNodePair	nodePair()
final void	run()	Compares trees, and triggers repairs for any ranges that mismatch.
protected abstract void	startSync()

Methods inherited from class org.apache.cassandra.utils.concurrent.AsyncFuture

await, awaitUntil, flatMap, map

Methods inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture

addCallback, addCallback, addCallback, addCallback, addCallback, addCallback, addListener, addListener, addListener, addListeners, await, awaitThrowUncheckedOnInterrupt, awaitThrowUncheckedOnInterrupt, awaitUninterruptibly, awaitUninterruptibly, awaitUntilThrowUncheckedOnInterrupt, awaitUntilUninterruptibly, cancel, cause, description, flatMap, get, get, getNow, getWhenDone, isCancellable, isCancelled, isDone, isSuccess, isUncancellable, map, map, notifyExecutor, removeListener, removeListeners, setUncancellable, setUncancellableExclusive, toString, tryFailure, trySuccess

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.utils.concurrent.Future

await, awaitUninterruptibly, flatMap, rethrowIfFailed, sync, syncThrowUncheckedOnInterrupt, syncUninterruptibly

Field Details

ctx

protected final SharedContext ctx

desc

protected final RepairJobDesc desc

rangesToSync

public final List<Range<Token>> rangesToSync

previewKind

protected final PreviewKind previewKind

nodePair

protected final SyncNodePair nodePair

startTime

protected volatile long startTime

stat

protected final SyncStat stat

Constructor Details

SyncTask

protected SyncTask(SharedContext ctx,
 RepairJobDesc desc,
 InetAddressAndPort primaryEndpoint,
 InetAddressAndPort peer,
 List<Range<Token>> rangesToSync,
 PreviewKind previewKind)

Method Details

startSync

protected abstract void startSync()

nodePair

public SyncNodePair nodePair()

run

public final void run()

Compares trees, and triggers repairs for any ranges that mismatch.

Specified by:

run in interface Runnable

isLocal

public boolean isLocal()

finished

protected void finished()

abort

public void abort(Throwable reason)