Package org.apache.cassandra.repair

Class ValidationTask

java.lang.Object

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

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

org.apache.cassandra.repair.ValidationTask

All Implemented Interfaces:

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

public class ValidationTask
extends AsyncFuture<TreeResponse>
implements Runnable

ValidationTask sends ValidationRequest to a replica. When a replica sends back message, 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.utils.concurrent.AbstractFuture

CANCELLED, UNCANCELLABLE, UNSET

Constructor Summary

Constructors

Constructor	Description
ValidationTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort endpoint, long nowInSec, PreviewKind previewKind)

Method Summary

Modifier and Type	Method	Description
void	abort(Throwable reason)	Release any trees already received by this task, and place it a state where any trees received subsequently will be properly discarded.
boolean	isActive()
void	run()	Send ValidationRequest to replica
void	treesReceived(MerkleTrees trees)	Receive MerkleTrees from replica node.

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

Constructor Details

ValidationTask

public ValidationTask(SharedContext ctx,
 RepairJobDesc desc,
 InetAddressAndPort endpoint,
 long nowInSec,
 PreviewKind previewKind)

Method Details

run

public void run()

Send ValidationRequest to replica

Specified by:

run in interface Runnable

treesReceived

public void treesReceived(MerkleTrees trees)

Receive MerkleTrees from replica node.

Parameters:

trees - MerkleTrees that is sent from replica. Null if validation failed on replica node.

abort

public void abort(Throwable reason)

Release any trees already received by this task, and place it a state where any trees received subsequently will be properly discarded.

isActive

public boolean isActive()