Package org.apache.cassandra.service.paxos

Class PaxosCommit<OnDone extends java.util.function.Consumer<? super org.apache.cassandra.service.paxos.PaxosCommit.Status>>

java.lang.Object

org.apache.cassandra.service.FailureRecordingCallback<T>

org.apache.cassandra.service.paxos.PaxosRequestCallback<NoPayload>

org.apache.cassandra.service.paxos.PaxosCommit<OnDone>

All Implemented Interfaces:

RequestCallback<NoPayload>, RequestCallbackWithFailure<NoPayload>

public class PaxosCommit<OnDone extends java.util.function.Consumer<? super org.apache.cassandra.service.paxos.PaxosCommit.Status>>
extends PaxosRequestCallback<NoPayload>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PaxosCommit.RequestHandler

Nested classes/interfaces inherited from class org.apache.cassandra.service.FailureRecordingCallback

FailureRecordingCallback.AsMap, FailureRecordingCallback.FailureResponses

Field Summary

Fields

Modifier and Type	Field	Description
static PaxosCommit.RequestHandler	requestHandler

Constructor Summary

Constructors

Constructor	Description
PaxosCommit(Commit.Agreed commit, boolean allowHints, ConsistencyLevel consistencyForConsensus, ConsistencyLevel consistencyForCommit, org.apache.cassandra.service.paxos.Paxos.Participants participants, OnDone onDone)

Method Summary

Modifier and Type	Method	Description
void	executeOnSelf()	Execute locally and record response
static boolean	getEnableDcLocalCommit()
void	onFailure(InetAddressAndPort from, RequestFailureReason reason)	Record a failure or timeout, and maybe submit a hint to from
void	onResponse(Message<NoPayload> response)	Record a success response
void	onResponse(NoPayload response, InetAddressAndPort from)
static void	setEnableDcLocalCommit(boolean enableDcLocalCommit)

Methods inherited from class org.apache.cassandra.service.paxos.PaxosRequestCallback

executeOnSelf

Methods inherited from class org.apache.cassandra.service.FailureRecordingCallback

failureReasonsAsMap, onFailureWithMutex

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

trackLatencyForSnitch

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

invokeOnFailure

Field Detail

requestHandler

public static final PaxosCommit.RequestHandler requestHandler

Constructor Detail

PaxosCommit

public PaxosCommit(Commit.Agreed commit,
                   boolean allowHints,
                   ConsistencyLevel consistencyForConsensus,
                   ConsistencyLevel consistencyForCommit,
                   org.apache.cassandra.service.paxos.Paxos.Participants participants,
                   OnDone onDone)

Method Detail

getEnableDcLocalCommit

public static boolean getEnableDcLocalCommit()

setEnableDcLocalCommit

public static void setEnableDcLocalCommit(boolean enableDcLocalCommit)

onFailure

public void onFailure(InetAddressAndPort from,
                      RequestFailureReason reason)

Record a failure or timeout, and maybe submit a hint to from

Specified by:

onFailure in interface RequestCallback<OnDone extends java.util.function.Consumer<? super org.apache.cassandra.service.paxos.PaxosCommit.Status>>

Specified by:

onFailure in interface RequestCallbackWithFailure<OnDone extends java.util.function.Consumer<? super org.apache.cassandra.service.paxos.PaxosCommit.Status>>

Overrides:

onFailure in class FailureRecordingCallback<NoPayload>

onResponse

public void onResponse(Message<NoPayload> response)

Record a success response

Specified by:

onResponse in interface RequestCallback<OnDone extends java.util.function.Consumer<? super org.apache.cassandra.service.paxos.PaxosCommit.Status>>

Overrides:

onResponse in class PaxosRequestCallback<NoPayload>

Parameters:

response - response received.

executeOnSelf

public void executeOnSelf()

Execute locally and record response

onResponse

public void onResponse(NoPayload response,
                       InetAddressAndPort from)

Specified by:

onResponse in class PaxosRequestCallback<NoPayload>