Class PaxosCleanupComplete
- java.lang.Object
-
- org.apache.cassandra.utils.concurrent.AbstractFuture<V>
-
- org.apache.cassandra.utils.concurrent.AsyncFuture<java.lang.Void>
-
- org.apache.cassandra.service.paxos.cleanup.PaxosCleanupComplete
-
- All Implemented Interfaces:
com.google.common.util.concurrent.ListenableFuture<java.lang.Void>,io.netty.util.concurrent.Future<java.lang.Void>,java.lang.Runnable,java.util.concurrent.Future<java.lang.Void>,RequestCallback<java.lang.Void>,RequestCallbackWithFailure<java.lang.Void>,Awaitable,Future<java.lang.Void>
public class PaxosCleanupComplete extends AsyncFuture<java.lang.Void> implements RequestCallbackWithFailure<java.lang.Void>, java.lang.Runnable
-
-
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 IVersionedSerializer<org.apache.cassandra.service.paxos.cleanup.PaxosCleanupComplete.Request>serializerstatic IVerbHandler<org.apache.cassandra.service.paxos.cleanup.PaxosCleanupComplete.Request>verbHandler-
Fields inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture
CANCELLED, UNCANCELLABLE, UNSET
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidonFailure(InetAddressAndPort from, RequestFailureReason reason)Called when there is an exception on the remote node or timeout happensvoidonResponse(Message<java.lang.Void> msg)voidrun()-
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 Detail
-
serializer
public static final IVersionedSerializer<org.apache.cassandra.service.paxos.cleanup.PaxosCleanupComplete.Request> serializer
-
verbHandler
public static final IVerbHandler<org.apache.cassandra.service.paxos.cleanup.PaxosCleanupComplete.Request> verbHandler
-
-
Method Detail
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable
-
onFailure
public void onFailure(InetAddressAndPort from, RequestFailureReason reason)
Description copied from interface:RequestCallbackWithFailureCalled when there is an exception on the remote node or timeout happens- Specified by:
onFailurein interfaceRequestCallback<java.lang.Void>- Specified by:
onFailurein interfaceRequestCallbackWithFailure<java.lang.Void>
-
onResponse
public void onResponse(Message<java.lang.Void> msg)
- Specified by:
onResponsein interfaceRequestCallback<java.lang.Void>- Parameters:
msg- response received.
-
-