Package org.apache.cassandra.service

Class FailureRecordingCallback.FailureResponses

java.lang.Object

org.apache.cassandra.utils.concurrent.IntrusiveStack<FailureRecordingCallback.FailureResponses>

org.apache.cassandra.service.FailureRecordingCallback.FailureResponses

All Implemented Interfaces:

Iterable<FailureRecordingCallback.FailureResponses>, Map.Entry<InetAddressAndPort,RequestFailureReason>

Enclosing class:

FailureRecordingCallback<T>

public static class FailureRecordingCallback.FailureResponses
extends IntrusiveStack<FailureRecordingCallback.FailureResponses>
implements Map.Entry<InetAddressAndPort,RequestFailureReason>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.utils.concurrent.IntrusiveStack

IntrusiveStack.Setter<O,T>

Constructor Summary

Constructors

Constructor	Description
FailureResponses(InetAddressAndPort from, RequestFailureReason reason)

Method Summary

Modifier and Type	Method	Description
static int	failureCount(FailureRecordingCallback.FailureResponses head)
InetAddressAndPort	getKey()
RequestFailureReason	getValue()
static Iterator<FailureRecordingCallback.FailureResponses>	iterator(FailureRecordingCallback.FailureResponses head)
static <O> void	push(AtomicReferenceFieldUpdater<O,FailureRecordingCallback.FailureResponses> headUpdater, O owner, InetAddressAndPort from, RequestFailureReason reason)
static <O> void	pushExclusive(AtomicReferenceFieldUpdater<O,FailureRecordingCallback.FailureResponses> headUpdater, O owner, InetAddressAndPort from, RequestFailureReason reason)
static FailureRecordingCallback.FailureResponses	pushExclusive(FailureRecordingCallback.FailureResponses head, InetAddressAndPort from, RequestFailureReason reason)
RequestFailureReason	setValue(RequestFailureReason value)
static int	size(FailureRecordingCallback.FailureResponses head)

Methods inherited from class org.apache.cassandra.utils.concurrent.IntrusiveStack

accumulate, forEach, forEach, iterable, iterable, iterator, iterator, push, push, push, push, pushExclusive, pushExclusive, pushExclusive, reverse, reverse, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

spliterator

Methods inherited from interface java.util.Map.Entry

equals, hashCode

Constructor Details

FailureResponses

public FailureResponses(InetAddressAndPort from,
 RequestFailureReason reason)

Method Details

getKey

public InetAddressAndPort getKey()

Specified by:

getKey in interface Map.Entry<InetAddressAndPort,RequestFailureReason>

getValue

public RequestFailureReason getValue()

Specified by:

getValue in interface Map.Entry<InetAddressAndPort,RequestFailureReason>

setValue

public RequestFailureReason setValue(RequestFailureReason value)

Specified by:

setValue in interface Map.Entry<InetAddressAndPort,RequestFailureReason>

push

public static <O> void push(AtomicReferenceFieldUpdater<O,FailureRecordingCallback.FailureResponses> headUpdater,
 O owner,
 InetAddressAndPort from,
 RequestFailureReason reason)

pushExclusive

public static <O> void pushExclusive(AtomicReferenceFieldUpdater<O,FailureRecordingCallback.FailureResponses> headUpdater,
 O owner,
 InetAddressAndPort from,
 RequestFailureReason reason)

pushExclusive

public static FailureRecordingCallback.FailureResponses pushExclusive(FailureRecordingCallback.FailureResponses head,
 InetAddressAndPort from,
 RequestFailureReason reason)

size

public static int size(FailureRecordingCallback.FailureResponses head)

iterator

public static Iterator<FailureRecordingCallback.FailureResponses> iterator(FailureRecordingCallback.FailureResponses head)

failureCount

public static int failureCount(FailureRecordingCallback.FailureResponses head)