Package org.apache.cassandra.repair

Class AsymmetricRemoteSyncTask

java.lang.Object

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

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

org.apache.cassandra.repair.SyncTask

org.apache.cassandra.repair.AsymmetricRemoteSyncTask

All Implemented Interfaces:

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

public class AsymmetricRemoteSyncTask
extends SyncTask
implements CompletableRemoteSyncTask

AsymmetricRemoteSyncTask sends SyncRequest to target node to repair(stream) data with other target replica. When AsymmetricRemoteSyncTask receives SyncComplete from the target, task completes.

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 inherited from class org.apache.cassandra.repair.SyncTask

ctx, desc, nodePair, previewKind, rangesToSync, startTime, stat

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

CANCELLED, UNCANCELLABLE, UNSET

Constructor Summary

Constructors

Constructor	Description
AsymmetricRemoteSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort to, InetAddressAndPort from, List<Range<Token>> differences, PreviewKind previewKind)

Method Summary

Modifier and Type	Method	Description
void	startSync()
void	syncComplete(boolean success, List<SessionSummary> summaries)
String	toString()

Methods inherited from class org.apache.cassandra.repair.SyncTask

abort, finished, isLocal, nodePair, run

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, 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

Constructor Details

AsymmetricRemoteSyncTask

public AsymmetricRemoteSyncTask(SharedContext ctx,
 RepairJobDesc desc,
 InetAddressAndPort to,
 InetAddressAndPort from,
 List<Range<Token>> differences,
 PreviewKind previewKind)

Method Details

startSync

public void startSync()

Specified by:

startSync in class SyncTask

syncComplete

public void syncComplete(boolean success,
 List<SessionSummary> summaries)

Specified by:

syncComplete in interface CompletableRemoteSyncTask

toString

public String toString()

Overrides:

toString in class AbstractFuture<SyncStat>