Package org.apache.cassandra.repair

Class SyncTask

java.lang.Object

com.google.common.util.concurrent.internal.InternalFutureFailureAccess

com.google.common.util.concurrent.AbstractFuture<SyncStat>

org.apache.cassandra.repair.SyncTask

All Implemented Interfaces:

com.google.common.util.concurrent.ListenableFuture<SyncStat>, java.lang.Runnable, java.util.concurrent.Future<SyncStat>

Direct Known Subclasses:

AsymmetricRemoteSyncTask, LocalSyncTask, SymmetricRemoteSyncTask

public abstract class SyncTask
extends com.google.common.util.concurrent.AbstractFuture<SyncStat>
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field	Description
protected RepairJobDesc	desc
protected SyncNodePair	nodePair
protected PreviewKind	previewKind
java.util.List<Range<Token>>	rangesToSync
protected long	startTime
protected SyncStat	stat

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class com.google.common.util.concurrent.AbstractFuture

addListener, afterDone, cancel, get, get, interruptTask, isCancelled, isDone, pendingToString, set, setException, setFuture, toString, tryInternalFastPathGetFailure, wasInterrupted

Methods inherited from class java.lang.Object

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

Field Detail

desc

protected final RepairJobDesc desc

rangesToSync

public final java.util.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 Detail

SyncTask

protected SyncTask(RepairJobDesc desc,
                   InetAddressAndPort primaryEndpoint,
                   InetAddressAndPort peer,
                   java.util.List<Range<Token>> rangesToSync,
                   PreviewKind previewKind)

Method Detail

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 java.lang.Runnable

isLocal

public boolean isLocal()

finished

protected void finished()