Package org.jgroups.util

Class Responses

java.lang.Object

org.jgroups.util.Responses

All Implemented Interfaces:

Iterable<PingData>

public class Responses
extends Object
implements Iterable<PingData>

Manages responses for the discovery protocol. Moved from Discovery into this standalone class. Responses are only added but never removed.

Since:

3.5

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	Responses.PingDataIterator

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	break_on_coord_rsp
protected final CondVar	cond
protected boolean	done
protected int	index
protected final Lock	lock
protected final int	num_expected_rsps
protected PingData[]	ping_rsps

Constructor Summary

Constructors

Constructor	Description
Responses(boolean break_on_coord_rsp)
Responses(int num_expected_rsps, boolean break_on_coord_rsp)
Responses(int num_expected_rsps, boolean break_on_coord_rsp, int initial_capacity)

Method Summary

Modifier and Type	Method	Description
protected Responses	_done()
protected void	add(PingData data)
Responses	add(Responses rsps, Address local_addr)
Responses	addResponse(PingData rsp, boolean overwrite)
Responses	clear()
boolean	containsResponseFrom(Address mbr)
Responses	done()
protected int	find(PingData data)
PingData	findResponseFrom(Address mbr)
boolean	isCoord(Address addr)
boolean	isDone()
boolean	isEmpty()
Iterator<PingData>	iterator()
protected static int	newLength(int length)
protected int[]	numResponses()
String	print()
protected void	resize(int new_size)
int	size()
protected List<PingData>	toList()
String	toString()
boolean	waitFor(long timeout)

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 Details

ping_rsps

protected PingData[] ping_rsps

index

protected int index

lock

protected final Lock lock

cond

protected final CondVar cond

num_expected_rsps

protected final int num_expected_rsps

break_on_coord_rsp

protected final boolean break_on_coord_rsp

done

protected boolean done

Constructor Details

Responses

public Responses(boolean break_on_coord_rsp)

Responses

public Responses(int num_expected_rsps,
 boolean break_on_coord_rsp)

Responses

public Responses(int num_expected_rsps,
 boolean break_on_coord_rsp,
 int initial_capacity)

Method Details

isDone

public boolean isDone()

done

public Responses done()

clear

public Responses clear()

addResponse

public Responses addResponse(PingData rsp,
 boolean overwrite)

add

public Responses add(Responses rsps,
 Address local_addr)

containsResponseFrom

public boolean containsResponseFrom(Address mbr)

isCoord

public boolean isCoord(Address addr)

findResponseFrom

public PingData findResponseFrom(Address mbr)

waitFor

public boolean waitFor(long timeout)

iterator

public Iterator<PingData> iterator()

Specified by:

iterator in interface Iterable<PingData>

size

public int size()

isEmpty

public boolean isEmpty()

toString

public String toString()

Overrides:

toString in class Object

print

public String print()

_done

protected Responses _done()

numResponses

protected int[] numResponses()

toList

protected List<PingData> toList()

resize

protected void resize(int new_size)

add

protected void add(PingData data)

find

protected int find(PingData data)

newLength

protected static int newLength(int length)