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

Class PaxosCleanupComplete

java.lang.Object

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

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

org.apache.cassandra.service.paxos.cleanup.PaxosCleanupComplete

All Implemented Interfaces:

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

public class PaxosCleanupComplete
extends AsyncFuture<Void>
implements RequestCallbackWithFailure<Void>, Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PaxosCleanupComplete.Request

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 IVersionedSerializer<PaxosCleanupComplete.Request>	serializer
static final IVerbHandler<PaxosCleanupComplete.Request>	verbHandler

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

CANCELLED, UNCANCELLABLE, UNSET

Method Summary

Modifier and Type	Method	Description
static IVerbHandler<PaxosCleanupComplete.Request>	createVerbHandler(SharedContext ctx)
void	onFailure(InetAddressAndPort from, RequestFailureReason reason)	Called when there is an exception on the remote node or timeout happens
void	onResponse(Message<Void> msg)
void	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, 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

serializer

public static final IVersionedSerializer<PaxosCleanupComplete.Request> serializer

verbHandler

public static final IVerbHandler<PaxosCleanupComplete.Request> verbHandler

Method Details

run

public void run()

Specified by:

run in interface Runnable

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<PaxosCleanupComplete.Request> createVerbHandler(SharedContext ctx)