org.jgroups.util

Class Responses

java.lang.Object

org.jgroups.util.Responses

All Implemented Interfaces:

java.lang.Iterable<PingData>, Condition

public class Responses
extends java.lang.Object
implements java.lang.Iterable<PingData>, Condition

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

Since:

3.5

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	Responses.PingDataIterator

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	break_on_coord_rsp
protected CondVar	cond
protected boolean	done
protected int	index
protected java.util.concurrent.locks.Lock	lock
protected int	num_expected_rsps
protected PingData[]	ping_rsps

Constructor Summary

Constructors

Constructor and 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 and Description
protected Responses	_done()
protected void	add(PingData data)
void	addResponse(PingData rsp, boolean overwrite)
Responses	clear()
boolean	containsResponseFrom(Address mbr)
Responses	done()
protected int	find(PingData data)
PingData	findResponseFrom(Address mbr)
java.util.List<PingData>	get(long timeout) Deprecated.
boolean	isDone()
boolean	isEmpty()
boolean	isMet() Return true if the condition is met and false otherwise
java.util.Iterator<PingData>	iterator()
protected static int	newLength(int length)
protected int[]	numResponses()
java.lang.String	print()
protected void	resize(int new_size)
int	size()
protected java.util.List<PingData>	toList()
java.lang.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 Detail

ping_rsps

protected PingData[] ping_rsps

index

protected int index

lock

protected final java.util.concurrent.locks.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 Detail

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 Detail

isMet

public boolean isMet()

Description copied from interface: Condition

Return true if the condition is met and false otherwise

Specified by:

isMet in interface Condition

isDone

public boolean isDone()

done

public Responses done()

clear

public Responses clear()

addResponse

public void addResponse(PingData rsp,
                        boolean overwrite)

containsResponseFrom

public boolean containsResponseFrom(Address mbr)

findResponseFrom

public PingData findResponseFrom(Address mbr)

get

@Deprecated
public java.util.List<PingData> get(long timeout)
                                         throws java.lang.InterruptedException

Deprecated.

Throws:

java.lang.InterruptedException

waitFor

public boolean waitFor(long timeout)

iterator

public java.util.Iterator<PingData> iterator()

Specified by:

iterator in interface java.lang.Iterable<PingData>

size

public int size()

isEmpty

public boolean isEmpty()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

print

public java.lang.String print()

_done

protected Responses _done()

numResponses

protected int[] numResponses()

toList

protected java.util.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)