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:

java.lang.Iterable<FailureRecordingCallback.FailureResponses>, java.util.Map.Entry<InetAddressAndPort,RequestFailureReason>

Enclosing class:

FailureRecordingCallback<T>

public static class FailureRecordingCallback.FailureResponses
extends IntrusiveStack<FailureRecordingCallback.FailureResponses>
implements java.util.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 java.util.Iterator<FailureRecordingCallback.FailureResponses>	iterator(FailureRecordingCallback.FailureResponses head)
static <O> void	push(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<O,FailureRecordingCallback.FailureResponses> headUpdater, O owner, InetAddressAndPort from, RequestFailureReason reason)
static <O> void	pushExclusive(java.util.concurrent.atomic.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 Detail

FailureResponses

public FailureResponses(InetAddressAndPort from,
                        RequestFailureReason reason)

Method Detail

getKey

public InetAddressAndPort getKey()

Specified by:

getKey in interface java.util.Map.Entry<InetAddressAndPort,RequestFailureReason>

getValue

public RequestFailureReason getValue()

Specified by:

getValue in interface java.util.Map.Entry<InetAddressAndPort,RequestFailureReason>

setValue

public RequestFailureReason setValue(RequestFailureReason value)

Specified by:

setValue in interface java.util.Map.Entry<InetAddressAndPort,RequestFailureReason>

push

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

pushExclusive

public static <O> void pushExclusive(java.util.concurrent.atomic.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 java.util.Iterator<FailureRecordingCallback.FailureResponses> iterator(FailureRecordingCallback.FailureResponses head)

failureCount

public static int failureCount(FailureRecordingCallback.FailureResponses head)