org.infinispan.remoting.transport.jgroups

Class Responses

java.lang.Object

org.infinispan.remoting.transport.jgroups.Responses

All Implemented Interfaces:

Iterable<org.jgroups.util.Rsp<Response>>

@ThreadSafe
public class Responses
extends Object
implements Iterable<org.jgroups.util.Rsp<Response>>

Pre-allocated holder for multiple responses. Until the response is received, or node is marked as suspected/unreachable the value is null. This class is safe against concurrent access by multiple threads.

Field Summary

Fields

Modifier and Type	Field and Description
static Responses	EMPTY

Constructor Summary

Constructors

Constructor and Description
Responses(Collection<org.jgroups.Address> addresses)
Responses(org.jgroups.util.RspList<Response> results) Constructs new instance using existing RspList.

Method Summary

Modifier and Type	Method and Description
void	addResponse(org.jgroups.util.Rsp rsp)
boolean	isMissingResponses()
boolean	isTimedOut()
Iterator<org.jgroups.util.Rsp<Response>>	iterator()
void	setTimedOut()
int	size()
static Responses	suspected(Collection<org.jgroups.Address> dests) Constructs a new instance with responses from all recipients marked as suspected.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

EMPTY

public static final Responses EMPTY

Constructor Detail

Responses

public Responses(Collection<org.jgroups.Address> addresses)

Responses

public Responses(org.jgroups.util.RspList<Response> results)

Constructs new instance using existing RspList. If the response was not received and the node was neither marked as suspected nor unreachable the response in this instance will be null.

Parameters:

results - Received responses.

Method Detail

suspected

public static Responses suspected(Collection<org.jgroups.Address> dests)

Constructs a new instance with responses from all recipients marked as suspected.

Parameters:

dests - Collection of recipients.

Returns:

addResponse

public void addResponse(org.jgroups.util.Rsp rsp)

isMissingResponses

public boolean isMissingResponses()

size

public int size()

iterator

public Iterator<org.jgroups.util.Rsp<Response>> iterator()

Specified by:

iterator in interface Iterable<org.jgroups.util.Rsp<Response>>

toString

public String toString()

Overrides:

toString in class Object

setTimedOut

public void setTimedOut()

isTimedOut

public boolean isTimedOut()