Package org.apache.cassandra.repair

Class LocalSyncTask

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.LocalSyncTask

All Implemented Interfaces:

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

public class LocalSyncTask
extends SyncTask
implements StreamEventHandler

LocalSyncTask performs streaming between local(coordinator) node and remote replica.

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
final boolean	requestRanges
final boolean	transferRanges

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
LocalSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort local, InetAddressAndPort remote, List<Range<Token>> diff, TimeUUID pendingRepair, boolean requestRanges, boolean transferRanges, PreviewKind previewKind)

Method Summary

Modifier and Type	Method	Description
void	abort(Throwable reason)
void	handleStreamEvent(StreamEvent event)	Callback for various streaming events.
boolean	isLocal()
void	onFailure(Throwable t)
void	onSuccess(StreamState result)
protected void	startSync()	Starts sending/receiving our list of differences to/from the remote endpoint: creates a callback that will be called out of band once the streams complete.
String	toString()

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

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

Field Details

requestRanges

public final boolean requestRanges

transferRanges

public final boolean transferRanges

Constructor Details

LocalSyncTask

public LocalSyncTask(SharedContext ctx,
 RepairJobDesc desc,
 InetAddressAndPort local,
 InetAddressAndPort remote,
 List<Range<Token>> diff,
 TimeUUID pendingRepair,
 boolean requestRanges,
 boolean transferRanges,
 PreviewKind previewKind)

Method Details

startSync

protected void startSync()

Starts sending/receiving our list of differences to/from the remote endpoint: creates a callback that will be called out of band once the streams complete.

Specified by:

startSync in class SyncTask

isLocal

public boolean isLocal()

Overrides:

isLocal in class SyncTask

handleStreamEvent

public void handleStreamEvent(StreamEvent event)

Description copied from interface: StreamEventHandler

Callback for various streaming events.

Specified by:

handleStreamEvent in interface StreamEventHandler

Parameters:

event - Stream event.

See Also:

• StreamEvent.Type

onSuccess

public void onSuccess(StreamState result)

Specified by:

onSuccess in interface com.google.common.util.concurrent.FutureCallback<StreamState>

onFailure

public void onFailure(Throwable t)

Specified by:

onFailure in interface com.google.common.util.concurrent.FutureCallback<StreamState>

toString

public String toString()

Overrides:

toString in class AbstractFuture<SyncStat>

abort

public void abort(Throwable reason)

Overrides:

abort in class SyncTask