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
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
abort()
protected void
finished()
boolean
isLocal()
SyncNodePair
nodePair()
void
run()
Compares trees, and triggers repairs for any ranges that mismatch.protected abstract void
startSync()
-
-
-
Field Detail
-
desc
protected final RepairJobDesc desc
-
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 interfacejava.lang.Runnable
-
isLocal
public boolean isLocal()
-
finished
protected void finished()
-
abort
public void abort()
-
-