Package org.apache.cassandra.service

Class DatacenterWriteResponseHandler<T>

java.lang.Object

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

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

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

All Implemented Interfaces:

RequestCallback<T>

public class DatacenterWriteResponseHandler<T>
extends WriteResponseHandler<T>

This class blocks for a quorum of responses _in the local datacenter only_ (CL.LOCAL_QUORUM).

Field Summary

Fields inherited from class org.apache.cassandra.service.WriteResponseHandler

logger, responses

Fields inherited from class org.apache.cassandra.service.AbstractWriteResponseHandler

callback, replicaPlan, writeType

Constructor Summary

Constructors

Constructor	Description
DatacenterWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)

Method Summary

Modifier and Type	Method	Description
void	onResponse(Message<T> message)	null message means "response from local write"
protected boolean	waitingFor(InetAddressAndPort from)

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

ackCount

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

blockFor, candidateReplicaCount, consistencyLevel, currentTimeoutNanos, expired, get, getRequestTime, invokeOnFailure, logFailureOrTimeoutToIdealCLDelegate, logResponseToIdealCLDelegate, maybeTryAdditionalReplicas, onFailure, setIdealCLResponseHandler, signal

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

Constructor Details

DatacenterWriteResponseHandler

public DatacenterWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan,
 Runnable callback,
 WriteType writeType,
 Supplier<Mutation> hintOnFailure,
 Dispatcher.RequestTime requestTime)

Method Details

onResponse

public void onResponse(Message<T> message)

Description copied from class: AbstractWriteResponseHandler

null message means "response from local write"

Specified by:

onResponse in interface RequestCallback<T>

Overrides:

onResponse in class WriteResponseHandler<T>

Parameters:

message - response received.

waitingFor

protected boolean waitingFor(InetAddressAndPort from)

Overrides:

waitingFor in class AbstractWriteResponseHandler<T>

Returns:

true if the message counts towards the blockFor() threshold