Package org.apache.cassandra.service.paxos.cleanup

Class PaxosFinishPrepareCleanup

java.lang.Object

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

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

org.apache.cassandra.service.paxos.cleanup.PaxosFinishPrepareCleanup

All Implemented Interfaces:

com.google.common.util.concurrent.ListenableFuture<Void>, io.netty.util.concurrent.Future<Void>, Future<Void>, RequestCallback<Void>, RequestCallbackWithFailure<Void>, Awaitable, Future<Void>

public class PaxosFinishPrepareCleanup
extends AsyncFuture<Void>
implements RequestCallbackWithFailure<Void>

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
static final IVerbHandler<PaxosCleanupHistory>	verbHandler

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

CANCELLED, UNCANCELLABLE, UNSET

Method Summary

Modifier and Type	Method	Description
static IVerbHandler<PaxosCleanupHistory>	createVerbHandler(SharedContext ctx)
static PaxosFinishPrepareCleanup	finish(SharedContext ctx, Collection<InetAddressAndPort> endpoints, PaxosCleanupHistory result)
void	onFailure(InetAddressAndPort from, RequestFailureReason reason)	Called when there is an exception on the remote node or timeout happens
void	onResponse(Message<Void> msg)

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

Methods inherited from interface org.apache.cassandra.net.RequestCallback

trackLatencyForSnitch

Methods inherited from interface org.apache.cassandra.net.RequestCallbackWithFailure

invokeOnFailure

Field Details

verbHandler

public static final IVerbHandler<PaxosCleanupHistory> verbHandler

Method Details

finish

public static PaxosFinishPrepareCleanup finish(SharedContext ctx,
 Collection<InetAddressAndPort> endpoints,
 PaxosCleanupHistory result)

onFailure

public void onFailure(InetAddressAndPort from,
 RequestFailureReason reason)

Description copied from interface: RequestCallbackWithFailure

Called when there is an exception on the remote node or timeout happens

Specified by:

onFailure in interface RequestCallback<Void>

Specified by:

onFailure in interface RequestCallbackWithFailure<Void>

onResponse

public void onResponse(Message<Void> msg)

Specified by:

onResponse in interface RequestCallback<Void>

Parameters:

msg - response received.

createVerbHandler

public static IVerbHandler<PaxosCleanupHistory> createVerbHandler(SharedContext ctx)