Package org.apache.cassandra.service.paxos.v1

Class PrepareCallback

java.lang.Object

org.apache.cassandra.service.paxos.v1.AbstractPaxosCallback<PrepareResponse>

org.apache.cassandra.service.paxos.v1.PrepareCallback

All Implemented Interfaces:

RequestCallback<PrepareResponse>

public class PrepareCallback
extends AbstractPaxosCallback<PrepareResponse>

Field Summary

Fields

Modifier and Type	Field	Description
Commit	mostRecentCommit
Commit	mostRecentInProgressCommit
boolean	promised

Fields inherited from class org.apache.cassandra.service.paxos.v1.AbstractPaxosCallback

latch, targets

Constructor Summary

Constructors

Constructor	Description
PrepareCallback(DecoratedKey key, TableMetadata metadata, int targets, ConsistencyLevel consistency, Dispatcher.RequestTime requestTime)

Method Summary

Modifier and Type	Method	Description
void	onResponse(Message<PrepareResponse> message)
java.lang.Iterable<InetAddressAndPort>	replicasMissingMostRecentCommit(TableMetadata metadata)

Methods inherited from class org.apache.cassandra.service.paxos.v1.AbstractPaxosCallback

await, getResponseCount, invokeOnFailure, onFailure

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

Field Detail

promised

public boolean promised

mostRecentCommit

public Commit mostRecentCommit

mostRecentInProgressCommit

public Commit mostRecentInProgressCommit

Constructor Detail

PrepareCallback

public PrepareCallback(DecoratedKey key,
                       TableMetadata metadata,
                       int targets,
                       ConsistencyLevel consistency,
                       Dispatcher.RequestTime requestTime)

Method Detail

onResponse

public void onResponse(Message<PrepareResponse> message)

Parameters:

message - response received.

replicasMissingMostRecentCommit

public java.lang.Iterable<InetAddressAndPort> replicasMissingMostRecentCommit(TableMetadata metadata)