Package org.jgroups.util

Class AckCollector

java.lang.Object

org.jgroups.util.AckCollector

public class AckCollector
extends Object

Collects acks from a number of nodes, waits for all acks. Can also be time bounded

Field Summary

Fields

Modifier and Type	Field	Description
protected final Promise<Boolean>	all_acks_received
protected final List<Address>	missing_acks	List of members from whom we haven't received an ACK yet

Constructor Summary

Constructors

Constructor	Description
AckCollector()
AckCollector(Collection<Address> members)
AckCollector(Address... members)

Method Summary

Modifier and Type	Method	Description
void	ack(Collection<Address> members)
void	ack(Address member)
void	ack(Address... members)
protected void	addAll(Collection<Address> members)
protected void	addAll(Collection<Address> members, Collection<Address> exclude)
protected void	addAll(Collection<Address> members, Address... exclude)
protected void	addAll(Address... members)
void	destroy()
int	expectedAcks()
String	printMissing()
void	reset(Collection<Address> members)
AckCollector	reset(Collection<Address> expected_acks, Collection<Address> exclude)
AckCollector	reset(Collection<Address> expected_acks, Address... exclude)
boolean	retainAll(Collection<Address> members)
int	size()
void	suspect(Collection<Address> members)
void	suspect(Address member)
void	suspect(Address... members)
String	toString()
boolean	waitForAllAcks()
boolean	waitForAllAcks(long timeout)

Methods inherited from class java.lang.Object

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

Field Details

missing_acks

protected final List<Address> missing_acks

List of members from whom we haven't received an ACK yet

all_acks_received

protected final Promise<Boolean> all_acks_received

Constructor Details

AckCollector

public AckCollector()

AckCollector

public AckCollector(Collection<Address> members)

AckCollector

public AckCollector(Address... members)

Method Details

reset

public void reset(Collection<Address> members)

reset

public AckCollector reset(Collection<Address> expected_acks,
 Collection<Address> exclude)

reset

public AckCollector reset(Collection<Address> expected_acks,
 Address... exclude)

destroy

public void destroy()

size

public int size()

expectedAcks

public int expectedAcks()

ack

public void ack(Address member)

ack

public void ack(Address... members)

ack

public void ack(Collection<Address> members)

suspect

public void suspect(Address member)

suspect

public void suspect(Address... members)

suspect

public void suspect(Collection<Address> members)

retainAll

public boolean retainAll(Collection<Address> members)

waitForAllAcks

public boolean waitForAllAcks()

waitForAllAcks

public boolean waitForAllAcks(long timeout)
                       throws TimeoutException

Throws:

TimeoutException

toString

public String toString()

Overrides:

toString in class Object

printMissing

public String printMissing()

addAll

protected void addAll(Address... members)

addAll

protected void addAll(Collection<Address> members)

addAll

protected void addAll(Collection<Address> members,
 Collection<Address> exclude)

addAll

protected void addAll(Collection<Address> members,
 Address... exclude)